- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for Start (0.14 sec)
-
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.cc
} // Calculate the block-aligned start and end of the read. size_t start = block_size_ * (offset / block_size_); size_t finish = block_size_ * ((offset + n) / block_size_); if (finish < offset + n) { finish += block_size_; } size_t total_bytes_transferred = 0; // Now iterate through the blocks, reading them one at a time. for (size_t pos = start; pos < finish; pos += block_size_) {
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/eager/c_api_remote_test_util.h
// If heavy_load_on_streaming_rpc is true, send some rpc requests before the one // which creates a remote input, to simulate a scenario that the remote input // is not ready when we start running an op or a function. void TestRemoteExecuteSilentCopies(bool async, bool remote, bool func, bool heavy_load_on_streaming_rpc,
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri Dec 11 22:56:03 GMT 2020 - 1.4K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental_test.cc
ASSERT_TRUE( factory->NewServer(server_def, ServerFactory::Options(), &w0).ok()); ASSERT_TRUE(w0->Start().ok()); server_def.set_task_index(1); std::unique_ptr<tensorflow::ServerInterface> w1; ASSERT_TRUE( factory->NewServer(server_def, ServerFactory::Options(), &w1).ok()); ASSERT_TRUE(w1->Start().ok()); TF_Status* status = TF_NewStatus(); TFE_ContextOptions* opts = TFE_NewContextOptions();
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Aug 03 03:14:26 GMT 2023 - 31.5K bytes - Viewed (1) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
// one second of wall time), it should remove "a" and leave "b" alone. uint64 start = Env::Default()->NowSeconds(); do { Env::Default()->SleepForMicroseconds(100000); } while (cache.CacheSize() == 24 && Env::Default()->NowSeconds() - start < 3); // There should be one block left in the cache, and it should be the first // block of "b". EXPECT_EQ(cache.CacheSize(), 8);
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) -
ci/official/bisect.sh
# export TF_ANY_MODE=test set -euxo pipefail cd "$(dirname "$0")/../../" # tensorflow/ export TFCI="$(echo $TFCI | sed 's/,nightly_upload/,public_cache,disk_cache/')" git bisect start "$TF_BISECT_BAD" "$TF_BISECT_GOOD"
Shell Script - Registered: Tue May 07 12:40:20 GMT 2024 - Last Modified: Thu Feb 01 03:21:19 GMT 2024 - 1.8K bytes - Viewed (0) -
tensorflow/c/eager/c_api_test.cc
.ok()); ASSERT_TRUE(worker_server1->Start().ok()); server_def_0.set_task_index(2); std::unique_ptr<tensorflow::GrpcServer> worker_server2; ASSERT_TRUE(tensorflow::GrpcServer::Create( server_def_0, tensorflow::Env::Default(), &worker_server2) .ok()); ASSERT_TRUE(worker_server2->Start().ok()); TFE_Context* ctx_0 = CreateContext(serialized_server_def_0,
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) -
ci/official/utilities/code_check_changed_files.bats
# See the License for the specific language governing permissions and # limitations under the License. # ============================================================================== setup_file() { bazel version # Start the bazel server # Fixes "fatal: detected dubious ownership in repository" for Docker. git config --system --add safe.directory '*' git config --system protocol.file.allow always
Plain Text - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Jan 10 19:39:41 GMT 2024 - 4K bytes - Viewed (0) -
tensorflow/c/eager/c_api_unified_experimental_test.cc
TF_DeleteExecutionContext(ctx); } TEST_P(UnifiedCAPI, TestBasicGraph) { std::unique_ptr<TF_Status, decltype(&TF_DeleteStatus)> status( TF_NewStatus(), TF_DeleteStatus); // Start a new function / execution context. string fn_name = "double"; TF_ExecutionContext* graph_ctx = TF_CreateFunction(fn_name.c_str(), status.get());
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Fri May 19 21:44:52 GMT 2023 - 39.1K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_remote_test.cc
.ok()); ASSERT_TRUE(worker_server1->Start().ok()); server_def.set_task_index(2); std::unique_ptr<tensorflow::GrpcServer> worker_server2; ASSERT_TRUE(tensorflow::GrpcServer::Create( server_def, tensorflow::Env::Default(), &worker_server2) .ok()); ASSERT_TRUE(worker_server2->Start().ok()); TFE_ContextSetServerDef(context.get(), 0, serialized.data(),
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Apr 27 22:09:57 GMT 2023 - 6.7K 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,
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)