Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for stateless (0.28 sec)

  1. 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)
  2. tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc

        return n;
      };
      std::vector<char> out;
      std::unique_ptr<NowSecondsEnv> env(new NowSecondsEnv);
      // Create a cache with max staleness of 2 seconds, and verify that it works as
      // expected.
      tf_gcs_filesystem::RamFileBlockCache cache1(
          8, 16, 2 /* max staleness */, fetcher,
          [&env]() { return env->NowSeconds(); });
      // Execute the first read to load the block.
    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)
  3. tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.h

              uint64_t block_size, size_t max_bytes, uint64_t max_staleness,
              uint64_t stat_cache_max_age, size_t stat_cache_max_entries);
    } GCSFile;
    
    // This function is used to initialize a filesystem without the need of setting
    // manually environement variables.
    void InitTest(TF_Filesystem* filesystem, bool compose, uint64_t block_size,
                  size_t max_bytes, uint64_t max_staleness,
    C
    - Registered: Tue Apr 30 12:39:09 GMT 2024
    - Last Modified: Mon Aug 31 04:37:41 GMT 2020
    - 5.2K bytes
    - Viewed (0)
  4. RELEASE.md

        *   `RandomBinomial` broadcasts and appends the sample shape to the left
            rather than the right.
        *   Added `tf.random.stateless_binomial`, `tf.random.stateless_gamma`,
            `tf.random.stateless_poisson`
        *   `tf.random.stateless_uniform` now supports unbounded sampling of `int`
            types.
    *   Math and Linear Algebra:
        *   Add `tf.linalg.LinearOperatorTridiag`.
    Plain Text
    - Registered: Tue Apr 30 12:39:09 GMT 2024
    - Last Modified: Mon Apr 29 19:17:57 GMT 2024
    - 727.7K bytes
    - Viewed (8)
  5. tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.h

          BlockFetcher;
    
      RamFileBlockCache(size_t block_size, size_t max_bytes, uint64_t max_staleness,
                        BlockFetcher block_fetcher,
                        std::function<uint64_t()> timer_seconds = TF_NowSeconds)
          : block_size_(block_size),
            max_bytes_(max_bytes),
            max_staleness_(max_staleness),
            block_fetcher_(block_fetcher),
            timer_seconds_(timer_seconds),
    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)
  6. tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc

        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);
    
      file_block_cache = std::make_unique<RamFileBlockCache>(
    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)
Back to top