- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 247 for blocks (0.21 sec)
-
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.h
}; /// \brief The block map type for the file block cache. /// /// The block map is an ordered map from Key to Block. typedef std::map<Key, std::shared_ptr<Block>> BlockMap; /// Prune the cache by removing files with expired blocks. void Prune() ABSL_LOCKS_EXCLUDED(mu_); bool BlockNotStale(const std::shared_ptr<Block>& block) ABSL_EXCLUSIVE_LOCKS_REQUIRED(mu_);
C - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Mon Aug 31 04:46:34 GMT 2020 - 10.6K bytes - Viewed (0) -
build-logic/documentation/src/test/groovy/gradlebuild/docs/dsl/docbook/ClassDocRendererTest.groovy
''') ClassDoc classDoc = classDoc('Class', content: content) BlockDoc block1 = blockDoc('block1', id: 'block1', description: 'block1 description', comment: 'block1 comment', type: 'org.gradle.Type') BlockDoc block2 = blockDoc('block2', id: 'block2', description: 'block2 description', comment: 'block2 comment', type: 'org.gradle.Type', multivalued: true) _ * classDoc.classProperties >> []
Groovy - Registered: Wed Apr 17 11:36:08 GMT 2024 - Last Modified: Wed Dec 09 08:14:05 GMT 2020 - 40.8K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
EXPECT_FALSE(second_block); EXPECT_EQ(out.size(), file_size - block_size); } TEST(RamFileBlockCacheTest, Inconsistent) { // Tests the detection of interrupted reads leading to partially filled blocks // where we expected complete blocks. const size_t block_size = 16; // This fetcher returns OK but only fills in one byte for any offset.
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Fri Oct 15 03:16:57 GMT 2021 - 23.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
} final ReentrantLock lock = this.lock; lock.lock(); boolean satisfied = false; try { return satisfied = guard.isSatisfied(); } finally { if (!satisfied) { lock.unlock(); } } } /** * Enters this monitor if the guard is satisfied. Blocks at most the given time acquiring the * lock, but does not wait for the guard to be satisfied.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Dec 04 18:22:01 GMT 2023 - 38.6K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirExpressionInfoProvider.kt
is KtStringTemplateEntry -> parent.expression == child // Catch blocks are used if the parent-try uses the catch block is KtCatchClause -> doesParentUseChild(parent.parent, parent) // Finally blocks are never used is KtFinallySection -> false !is KtExpression ->
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Mon Feb 12 20:38:23 GMT 2024 - 17.6K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.cc
case FetchState::CREATED: block->state = FetchState::FETCHING; block->mu.Unlock(); // Release the lock while making the API call. block->data.clear(); block->data.resize(block_size_, 0); int64_t bytes_transferred; bytes_transferred = block_fetcher_(key.first, key.second, block_size_, block->data.data(), status);
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Thu Jul 16 01:39:09 GMT 2020 - 11.1K bytes - Viewed (0) -
internal/dsync/drwmutex.go
return dm.lockBlocking(ctx, cancel, id, source, isReadLock, opts) } // RLock holds a read lock on dm. // // If one or more read locks are already in use, it will grant another lock. // Otherwise the calling go routine blocks until the mutex is available. func (dm *DRWMutex) RLock(id, source string) { isReadLock := true dm.lockBlocking(context.Background(), nil, id, source, isReadLock, Options{ Timeout: drwMutexInfinite,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
common-protos/k8s.io/api/certificates/v1/generated.proto
// // Validation requirements: // 1. certificate must contain one or more PEM blocks. // 2. All PEM blocks must have the "CERTIFICATE" label, contain no headers, and the encoded data // must be a BER-encoded ASN.1 Certificate structure as described in section 4 of RFC5280. // 3. Non-PEM content may appear before or after the "CERTIFICATE" PEM blocks and is unvalidated,
Plain Text - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 11.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
import java.net.SocketTimeoutException import java.util.ArrayDeque import java.util.concurrent.locks.Condition import java.util.concurrent.locks.ReentrantLock import okhttp3.Headers import okhttp3.internal.EMPTY_HEADERS import okhttp3.internal.assertNotHeld import okhttp3.internal.connection.Locks.withLock import okhttp3.internal.http2.flowcontrol.WindowCounter import okhttp3.internal.toHeaderList
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
src/archive/tar/reader.go
return paxHdrs, nil } // readHeader reads the next block header and assumes that the underlying reader // is already aligned to a block boundary. It returns the raw block of the // header in case further processing is required. // // The err will be set to io.EOF only when one of the following occurs: // - Exactly 0 bytes are read and EOF is hit. // - Exactly 1 block of zeros is read and EOF is hit.
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0)