- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for Read (0.17 sec)
-
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc
TF_SetStatus(status, TF_UNKNOWN, "Could not get content-length header"); return -1; } // `TF_OUT_OF_RANGE` isn't considered as an error. So we clear it here. TF_SetStatus(status, TF_OK, ""); TF_VLog(1, "Successful read of %s @ %u of size: %u", path.c_str(), offset, read); stream.read(buffer, read); read = stream.gcount(); if (read < buffer_size) {
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/eager/c_api_experimental_reader.cc
int64_t TFE_MonitoringCounterReader::Read(const LabelType&... labels) { return counter->Read(labels...); } TFE_MonitoringCounterReader* TFE_MonitoringNewCounterReader(const char* name) { auto* result = new TFE_MonitoringCounterReader(name); return result; } int64_t TFE_MonitoringReadCounter0(TFE_MonitoringCounterReader* cell_reader) { int64_t result = cell_reader->Read(); return result; }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Apr 20 03:14:47 GMT 2023 - 1.4K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
std::vector<char> out; // First read. EXPECT_TRUE(cache.ValidateAndUpdateFileSignature(filename, 123)); TF_EXPECT_OK(ReadCache(&cache, filename, 0, 16, &out)); EXPECT_EQ(calls, 1); // Second read. Hit cache. EXPECT_TRUE(cache.ValidateAndUpdateFileSignature(filename, 123)); TF_EXPECT_OK(ReadCache(&cache, filename, 0, 16, &out)); EXPECT_EQ(calls, 1); // Third read. File signatures are different.
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/posix/copy_file_portable.cc
size_t chunk = size - offset; if (chunk > kPosixCopyFileBufferSize) chunk = kPosixCopyFileBufferSize; rc = read(src_fd, buffer.get(), chunk); if (rc < 0) return -1; int total_write = 0; int total_read = rc; while (total_write < total_read && rc > 0) { rc = write(dst_fd, buffer.get() + total_write, chunk - total_write); if (rc < 0) return -1; total_write += rc;
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Fri Nov 22 21:23:55 GMT 2019 - 1.9K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/expiring_lru_cache_test.cc
tf_gcs_filesystem::ExpiringLRUCache<int> cache2(2, 4); num_compute_calls = 0; value = -1; // Read our first value cache2.LookupOrCompute("a", &value, compute_func, &status); TF_EXPECT_OK(status.status); EXPECT_EQ(value, 0); EXPECT_EQ(num_compute_calls, 1); // Re-read, exepct no additional function compute_func calls. cache2.LookupOrCompute("a", &value, compute_func, &status);
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Jul 09 19:31:22 GMT 2020 - 7.1K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/modular_filesystem.cc
} Status ModularRandomAccessFile::Read(uint64 offset, size_t n, StringPiece* result, char* scratch) const { if (ops_->read == nullptr) return errors::Unimplemented( tensorflow::strings::StrCat("Read() not implemented for ", filename_)); UniquePtrTo_TF_Status plugin_status(TF_NewStatus(), TF_DeleteStatus); int64_t read =
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Sep 06 19:12:29 GMT 2023 - 23.1K bytes - Viewed (0) -
tensorflow/c/c_api_function_test.cc
// Get attr AttrValue read_attr; GetAttr("test_attr_name", &read_attr); ASSERT_EQ(attr.DebugString(), read_attr.DebugString()); // Retrieve the same attr after save/restore Reincarnate(); AttrValue read_attr2; GetAttr("test_attr_name", &read_attr2); ASSERT_EQ(attr.DebugString(), read_attr2.DebugString()); } TEST_F(CApiFunctionTest, Description) {
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Jul 20 22:08:54 GMT 2023 - 63.6K bytes - Viewed (6) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.cc
} int64_t RamFileBlockCache::Read(const std::string& filename, size_t offset, size_t n, char* buffer, TF_Status* status) { if (n == 0) { TF_SetStatus(status, TF_OK, ""); return 0; } if (!IsCacheEnabled() || (n > max_bytes_)) { // The cache is effectively disabled, so we pass the read through to the // fetcher without breaking it up into blocks.
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/modular_filesystem_test.cc
std::unique_ptr<RandomAccessFile> read_file; status = env_->NewRandomAccessFile(filepath, &read_file); if (!status.ok()) GTEST_SKIP() << "NewRandomAccessFile() not supported: " << status; char scratch[64 /* must be bigger than test_data */] = {0}; StringPiece result; // read at least 1 byte more than test_data status = read_file->Read(0, test_data.size() + 1, &result, scratch);
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri May 27 20:25:58 GMT 2022 - 71K bytes - Viewed (0) -
tensorflow/c/eager/c_api_test.cc
ASSERT_TRUE(std::find(device_names.begin(), device_names.end(), remote_device) != device_names.end()); } // Create a variable using `ctx_0`. // Read the variable using `ctx_1`. This read should succeed. // 1. Create a variable on `remote_device`, using `ctx_0`. TFE_TensorHandle* handle_0 = CreateVariable(ctx_0, 1.2, remote_device, /*variable_name=*/"var2");
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Aug 03 20:50:20 GMT 2023 - 94.6K bytes - Viewed (1)