- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 52 for block_size (0.27 sec)
-
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
} TF_SetStatus(status, TF_OK, ""); return bytes_transferred; }; for (size_t block_size = 2; block_size <= 4; block_size++) { // Make a cache of N-byte block size (1 block) and verify that reads of // varying offsets and lengths return correct data. tf_gcs_filesystem::RamFileBlockCache cache(block_size, block_size, 0, fetcher);
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) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.cc
size_t start = block_size_ * (offset / block_size_); size_t finish = block_size_ * ((offset + n) / block_size_); if (finish < offset + n) { finish += block_size_; } size_t total_bytes_transferred = 0; // Now iterate through the blocks, reading them one at a time. for (size_t pos = start; pos < finish; pos += block_size_) { Key key = std::make_pair(filename, pos);
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/gcs_filesystem.h
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. std::unique_ptr<ExpiringLRUCache<GcsFileStat>> stat_cache; GCSFile(google::cloud::storage::Client&& gcs_client); // This constructor is used for testing purpose only.
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) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.h
TF_Status* status)> 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),
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) -
internal/config/cache/cache.go
"github.com/tinylib/msgp/msgp" ) // Cache related keys const ( Enable = "enable" Endpoint = "endpoint" BlockSize = "block_size" EnvEnable = "MINIO_CACHE_ENABLE" EnvEndpoint = "MINIO_CACHE_ENDPOINT" EnvBlockSize = "MINIO_CACHE_BLOCK_SIZE" ) // DefaultKVS - default KV config for cache settings var DefaultKVS = config.KVS{ config.KV{ Key: Enable, Value: "off", },
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.6K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc
uint64_t value; block_size = kDefaultBlockSize; size_t max_bytes = kDefaultMaxCacheSize; uint64_t max_staleness = kDefaultMaxStaleness; // Apply the overrides for the block size (MB), max bytes (MB), and max // staleness (seconds) if provided. const char* block_size_env = std::getenv(kBlockSize); if (block_size_env && absl::SimpleAtoi(block_size_env, &value)) { block_size = value * 1024 * 1024;
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) -
cmd/erasure-heal_test.go
badDisks, badStaleDisks int blocksize, size int64 algorithm BitrotAlgorithm shouldFail bool }{ {dataBlocks: 2, disks: 4, offDisks: 1, badDisks: 0, badStaleDisks: 0, blocksize: int64(blockSizeV2), size: oneMiByte, algorithm: SHA256, shouldFail: false}, // 0
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 7.9K bytes - Viewed (0) -
cmd/erasure-decode_test.go
{dataBlocks: 6, onDisks: 12, offDisks: 0, blocksize: int64(oneMiByte), data: oneMiByte, offset: oneMiByte, length: 0, algorithm: BLAKE2b512, shouldFail: false, shouldFailQuorum: false}, // 4
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 21.1K bytes - Viewed (1) -
cmd/erasure_test.go
type erasureTestSetup struct { dataBlocks int parityBlocks int blockSize int64 diskPaths []string disks []StorageAPI } // Returns an initialized setup for erasure tests. func newErasureTestSetup(tb testing.TB, dataBlocks int, parityBlocks int, blockSize int64) (*erasureTestSetup, error) { diskPaths := make([]string, dataBlocks+parityBlocks)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Jul 25 19:37:26 GMT 2022 - 4.8K bytes - Viewed (0) -
src/archive/tar/writer_test.go
testReadFrom{fileOps{ int64(1e10 - blockSize), strings.Repeat("\x00", blockSize-100) + strings.Repeat("0123456789", 10), int64(1e10 - blockSize), strings.Repeat("\x00", blockSize-100) + strings.Repeat("0123456789", 10), int64(1e10 - blockSize), strings.Repeat("\x00", blockSize-100) + strings.Repeat("0123456789", 10), int64(1e10 - blockSize),
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Tue Feb 27 16:39:23 GMT 2024 - 38.7K bytes - Viewed (0)