- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for reads (0.15 sec)
-
tensorflow/c/experimental/filesystem/plugins/windows/windows_filesystem.cc
// SECTION 3. Implementation for `TF_ReadOnlyMemoryRegion` // ---------------------------------------------------------------------------- namespace tf_read_only_memory_region { // TODO(b/139060984): Implement later } // namespace tf_read_only_memory_region // SECTION 4. Implementation for `TF_Filesystem`, the actual filesystem // ----------------------------------------------------------------------------
C++ - Registered: Tue Apr 09 12:39:09 GMT 2024 - Last Modified: Fri May 27 20:21:15 GMT 2022 - 2.6K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/posix/posix_filesystem.cc
ops->read_only_memory_region_ops = static_cast<TF_ReadOnlyMemoryRegionOps*>( plugin_memory_allocate(TF_READ_ONLY_MEMORY_REGION_OPS_SIZE)); ops->read_only_memory_region_ops->cleanup = tf_read_only_memory_region::Cleanup; ops->read_only_memory_region_ops->data = tf_read_only_memory_region::Data; ops->read_only_memory_region_ops->length = tf_read_only_memory_region::Length;
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/eager/parallel_device/parallel_device_lib_test.cc
} std::unique_ptr<TFE_Op, decltype(&TFE_DeleteOp)> read_op( TFE_NewOp(context.get(), "ReadVariableOp", status.get()), TFE_DeleteOp); ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get()); TFE_OpSetAttrType(read_op.get(), "dtype", TF_FLOAT); parallel_device.Execute(context.get(), handle_inputs, "ReadVariableOp", TFE_OpGetAttrs(read_op.get()),
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Jul 08 23:47:35 GMT 2021 - 15.3K bytes - Viewed (0) -
tensorflow/c/eager/c_api_cluster_test.cc
TFE_ExecutorWaitForAllPendingNodes(executor, status); ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); TFE_DeleteExecutor(executor); TF_DeleteStatus(status); } // Read the value of variable `var` and save it into `out_value`. void ReadVariable(TFE_Context* ctx, TFE_TensorHandle* var, TFE_TensorHandle** out_value) { TF_Status* status = TF_NewStatus();
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri Apr 14 10:03:59 GMT 2023 - 19.3K 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/eager/c_api_remote_function_test.cc
/*remote_func_outputs=*/true); } TEST(CAPI, RemoteExecuteSilentCopiesLocalAsyncFuncOrdering) { // A remote input may be not ready when we start running a function. Test that // the function execution should wait until the remote input is ready. TestRemoteExecuteSilentCopiesFunc(/*async=*/true, /*remote=*/false, /*heavy_load_on_streaming_rpc=*/true); }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri Dec 11 22:56:03 GMT 2020 - 3.6K bytes - Viewed (0) -
tensorflow/c/eager/custom_device_test.cc
executed = false; num_retvals = 0; TFE_Execute(op.get(), nullptr, &num_retvals, status.get()); ASSERT_TRUE(TF_GetCode(status.get()) == TF_OK) << TF_Message(status.get()); ASSERT_TRUE(executed); // Read the variable's value. op.reset(TFE_NewOp(context.get(), "ReadVariableOp", status.get())); TFE_OpAddInput(op.get(), var_handle, status.get()); TFE_OpSetDevice(op.get(), name, status.get());
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Aug 27 23:39:24 GMT 2020 - 18.4K bytes - Viewed (0) -
tensorflow/c/eager/c_api_distributed_test.cc
string VariableAddFunctionWithGraphError() { string signature = VariableAddFunctionSignature(); // Replace the node 'read0' with 'read0_maybe_with_graph_error', so that the // error injecting pass can identify and introduce graph pass errors. signature = std::regex_replace(signature, std::regex("read0"), "read0_maybe_with_graph_error"); tensorflow::FunctionDef def;
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Feb 15 09:49:45 GMT 2024 - 23.5K bytes - Viewed (0) -
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/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)