Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for RamFileBlockCache (0.3 sec)

  1. tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.cc

        }
      }
    }
    
    void RamFileBlockCache::Flush() {
      absl::MutexLock lock(&mu_);
      block_map_.clear();
      lru_list_.clear();
      lra_list_.clear();
      cache_size_ = 0;
    }
    
    void RamFileBlockCache::RemoveFile(const std::string& filename) {
      absl::MutexLock lock(&mu_);
      RemoveFile_Locked(filename);
    }
    
    void RamFileBlockCache::RemoveFile_Locked(const std::string& filename) {
    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

        // Do nothing.
        TF_SetStatus(status, TF_OK, "");
        return 0;
      };
      tf_gcs_filesystem::RamFileBlockCache cache1(0, 0, 0, fetcher);
      tf_gcs_filesystem::RamFileBlockCache cache2(16, 0, 0, fetcher);
      tf_gcs_filesystem::RamFileBlockCache cache3(0, 32, 0, fetcher);
      tf_gcs_filesystem::RamFileBlockCache cache4(16, 32, 0, fetcher);
    
      EXPECT_FALSE(cache1.IsCacheEnabled());
      EXPECT_FALSE(cache2.IsCacheEnabled());
    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/ram_file_block_cache.h

    namespace tf_gcs_filesystem {
    
    /// \brief An LRU block cache of file contents, keyed by {filename, offset}.
    ///
    /// This class should be shared by read-only random access files on a remote
    /// filesystem (e.g. GCS).
    class RamFileBlockCache {
     public:
      /// The callback executed when a block is not found in the cache, and needs to
      /// be fetched from the backing filesystem. This callback is provided when the
    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)
  4. tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.h

      int64_t generation_number;
    } GcsFileStat;
    
    typedef struct GCSFile {
      google::cloud::storage::Client gcs_client;  // owned
      bool compose;
      absl::Mutex block_cache_lock;
      std::shared_ptr<RamFileBlockCache> file_block_cache
          ABSL_GUARDED_BY(block_cache_lock);
      uint64_t block_size;  // Reads smaller than block_size will trigger a read
                            // of block_size.
    C
    - Registered: Tue Apr 23 12:39:09 GMT 2024
    - Last Modified: Mon Aug 31 04:37:41 GMT 2020
    - 5.2K bytes
    - Viewed (0)
  5. tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc

        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>(
          block_size, max_bytes, max_staleness,
          [this](const std::string& filename, size_t offset, size_t buffer_size,
                 char* buffer, TF_Status* status) {
    C++
    - Registered: Tue Apr 23 12:39:09 GMT 2024
    - Last Modified: Wed Aug 23 06:55:53 GMT 2023
    - 46.9K bytes
    - Viewed (0)
Back to top