- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for frush (0.21 sec)
-
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem_test.cc
ASSERT_TF_OK(status_); tf_writable_file::Flush(file, status_); ASSERT_TF_OK(status_); ASSERT_TRUE( CompareWithServer(filepath, 0, 4, &gcs_file->gcs_client, status_)); tf_writable_file::Append(file, content + 4, 4, status_); ASSERT_TF_OK(status_); length = tf_writable_file::Tell(file, status_); ASSERT_EQ(length, 8); ASSERT_TF_OK(status_); tf_writable_file::Flush(file, status_); ASSERT_TF_OK(status_);
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Mon Aug 31 12:04:23 GMT 2020 - 24.9K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/posix/posix_filesystem.cc
} static void Sync(const TF_WritableFile* file, TF_Status* status) { // For historical reasons, this does the same as `Flush` at the moment. // TODO(b/144055243): This should use `fsync`/`sync`. Flush(file, status); } static void Close(const TF_WritableFile* file, TF_Status* status) { auto posix_file = static_cast<PosixFile*>(file->plugin_file); if (fclose(posix_file->handle) != 0)
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Sun Mar 24 20:08:23 GMT 2024 - 15.8K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/modular_filesystem.cc
} Status ModularWritableFile::Flush() { if (ops_->flush == nullptr) return OkStatus(); UniquePtrTo_TF_Status plugin_status(TF_NewStatus(), TF_DeleteStatus); ops_->flush(file_.get(), plugin_status.get()); return StatusFromTF_Status(plugin_status.get()); } Status ModularWritableFile::Sync() { if (ops_->sync == nullptr) return Flush();
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/experimental/filesystem/modular_filesystem_test.cc
const std::string test_data("asdf"); status = new_file->Append(test_data); if (!status.ok()) GTEST_SKIP() << "Append() not supported: " << status; status = new_file->Flush(); if (!status.ok()) GTEST_SKIP() << "Flush() not supported: " << status; status = new_file->Close(); if (!status.ok()) GTEST_SKIP() << "Close() not supported: " << status; std::unique_ptr<ReadOnlyMemoryRegion> region;
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/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
std::vector<char> out; TF_EXPECT_OK(ReadCache(&cache, "", block_size / 2, block_size / 2, &out)); EXPECT_EQ(out.size(), block_size / 2); EXPECT_EQ(1, num_requests); } TEST(RamFileBlockCacheTest, Flush) { int calls = 0; auto fetcher = [&calls](const string& filename, size_t offset, size_t n, char* buffer, TF_Status* status) -> int64_t { calls++; memset(buffer, 'x', n);
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
// be used within RemoveFile_Locked after `it` is deleted. RemoveFile_Locked(std::string(it->first.first)); } } } 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) {
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/c_api_test.cc
// Import it in a fresh graph. TF_DeleteGraph(graph); graph = TF_NewGraph(); TF_ImportGraphDefOptions* opts = TF_NewImportGraphDefOptions(); TF_GraphImportGraphDef(graph, graph_def, opts, s); ASSERT_EQ(TF_OK, TF_GetCode(s)) << TF_Message(s); TF_Operation* scalar = TF_GraphOperationByName(graph, "scalar"); // Import it in a fresh graph with an unused input mapping.
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 03:35:10 GMT 2024 - 96.9K bytes - Viewed (3) -
tensorflow/c/env.cc
auto* cc_file = reinterpret_cast<::tensorflow::WritableFile*>(handle); TF_SetStatus(status, TF_OK, ""); ::tensorflow::Set_TF_Status_from_Status(status, cc_file->Flush()); } void TF_AppendWritableFile(TF_WritableFileHandle* handle, const char* data, size_t length, TF_Status* status) { auto* cc_file = reinterpret_cast<::tensorflow::WritableFile*>(handle);
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Aug 11 01:20:50 GMT 2021 - 7K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/gcs_filesystem.cc
return position == -1 ? -1 : position + (gcs_file->offset == -1 ? 0 : gcs_file->offset); } void Flush(const TF_WritableFile* file, TF_Status* status) { auto gcs_file = static_cast<GCSFile*>(file->plugin_file); if (gcs_file->sync_need) { TF_VLog(3, "Flush started: gs://%s/%s", gcs_file->bucket.c_str(), gcs_file->object.c_str()); if (!gcs_file->outfile) {
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)