Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for isInterrupted (0.16 sec)

  1. 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)
  2. 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)
Back to top