- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for create_stream (0.14 sec)
-
tensorflow/c/experimental/stream_executor/stream_executor_test.cc
int64_t total = 0; executor->DeviceMemoryUsage(&free, &total); ASSERT_EQ(free, 45); ASSERT_EQ(total, 7); } TEST_F(StreamExecutorTest, CreateStream) { static bool stream_created = false; static bool stream_deleted = false; se_.create_stream = [](const SP_Device* const device, SP_Stream* stream, TF_Status* const status) -> void { *stream = new SP_Stream_st(14);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon May 20 19:54:04 UTC 2024 - 26.5K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor.cc
TF_VALIDATE_NOT_NULL(SP_StreamExecutor, se, unified_memory_deallocate); } TF_VALIDATE_NOT_NULL(SP_StreamExecutor, se, device_memory_usage); TF_VALIDATE_NOT_NULL(SP_StreamExecutor, se, create_stream); TF_VALIDATE_NOT_NULL(SP_StreamExecutor, se, destroy_stream); TF_VALIDATE_NOT_NULL(SP_StreamExecutor, se, create_stream_dependency); TF_VALIDATE_NOT_NULL(SP_StreamExecutor, se, get_stream_status);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 14 07:39:19 UTC 2024 - 27.1K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor.h
/*** STREAM CALLBACKS ***/ // Creates SP_Stream. This call should also allocate stream // resources on the underlying platform and initializes its // internals. void (*create_stream)(const SP_Device* device, SP_Stream* stream, TF_Status* status); // Destroys SP_Stream and deallocates any underlying resources.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 24 08:40:35 UTC 2022 - 21.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper_test.go
return } defer conn.Close() if resp.StatusCode != http.StatusSwitchingProtocols { t.Fatalf("expected http 101 switching protocols, got %d", resp.StatusCode) } stream, err := conn.CreateStream(http.Header{}) if err != nil { t.Fatalf("error creating client stream: %s", err) } n, err := stream.Write([]byte("hello")) if err != nil { t.Fatalf("error writing to stream: %s", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 32.7K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_device.cc
// pool to avoid potential lifetime issues. TF_ASSIGN_OR_RETURN( stream_, backend->stream_executors()[device_ordinal_]->CreateStream()); TF_RETURN_IF_ERROR(EnsureStreamOkLocked(backend, "stream", &stream_, &need_new_device_context)); (*global_compute_streams_)[device_ordinal_] = stream_; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon May 20 21:05:42 UTC 2024 - 24.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go
randomSize := 1024 * 1024 randomData := make([]byte, randomSize) _, err = rand.Read(randomData) require.NoError(t, err) var actual []byte go func() { clientStream, err := spdyClient.CreateStream(http.Header{}) require.NoError(t, err) _, err = io.Copy(clientStream, bytes.NewReader(randomData)) require.NoError(t, err) clientStream.Close() //nolint:errcheck }() select {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 02:21:50 UTC 2024 - 22.7K bytes - Viewed (0)