- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for isInterrupted (0.16 sec)
-
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc
read); stream.read(buffer, read); read = stream.gcount(); if (read < buffer_size) { // Check stat cache to see if we encountered an interrupted read. tf_gcs_filesystem::GcsFileStat stat; if (gcs_file->stat_cache->Lookup(path, &stat)) { if (offset + read < stat.base.length) { TF_SetStatus(status, TF_INTERNAL,
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
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)