- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for max_staleness_ (0.18 sec)
-
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.cc
absl::MutexLock l(&block->mu); if (block->state != FetchState::FINISHED) { return true; // No need to check for staleness. } if (max_staleness_ == 0) return true; // Not enforcing staleness. return timer_seconds_() - block->timestamp <= max_staleness_; } std::shared_ptr<RamFileBlockCache::Block> RamFileBlockCache::Lookup( const Key& key) { absl::MutexLock lock(&mu_);
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) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.h
: block_size_(block_size), max_bytes_(max_bytes), max_staleness_(max_staleness), block_fetcher_(block_fetcher), timer_seconds_(timer_seconds), pruning_thread_(nullptr, [](TF_Thread* thread) { TF_JoinThread(thread); }) { if (max_staleness_ > 0) { TF_ThreadOptions thread_options; TF_DefaultThreadOptions(&thread_options);
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) -
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc
if (max_bytes_env && absl::SimpleAtoi(max_bytes_env, &value)) { max_bytes = static_cast<size_t>(value * 1024 * 1024); } const char* max_staleness_env = std::getenv(kMaxStaleness); if (max_staleness_env && absl::SimpleAtoi(max_staleness_env, &value)) { max_staleness = value; } TF_VLog(1, "GCS cache max size = %u ; block size = %u ; max staleness = %u", max_bytes, block_size, max_staleness);
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Aug 23 06:55:53 GMT 2023 - 46.9K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
TF_EXPECT_OK(ReadCache(&cache, "", block_size, 1, &out)); // Element at 0 was evicted again. calls.push_back(0); TF_EXPECT_OK(ReadCache(&cache, "", 0, 1, &out)); } TEST(RamFileBlockCacheTest, MaxStaleness) { int calls = 0; auto fetcher = [&calls](const string& filename, size_t offset, size_t n, char* buffer, TF_Status* status) -> int64_t { calls++; memset(buffer, 'x', n);
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)