Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for create_stream (0.16 sec)

  1. tensorflow/c/experimental/stream_executor/stream_executor_test_util.cc

      se->host_memory_allocate = HostMemoryAllocate;
      se->host_memory_deallocate = HostMemoryDeallocate;
      se->get_allocator_stats = GetAllocatorStats;
      se->device_memory_usage = DeviceMemoryUsage;
      se->create_stream = CreateStream;
      se->destroy_stream = DestroyStream;
      se->create_stream_dependency = CreateStreamDependency;
      se->get_stream_status = GetStreamStatus;
      se->create_event = CreateEvent;
      se->destroy_event = DestroyEvent;
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Mar 21 20:09:00 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  2. tensorflow/c/experimental/stream_executor/stream_executor_internal.h

        parent()->DeallocateStream(this);
        Destroy();
      }
    
      absl::Status Create() {
        tensorflow::TF_StatusPtr c_status(TF_NewStatus());
        stream_executor_->create_stream(device_, &stream_handle_, c_status.get());
        absl::Status s = tensorflow::StatusFromTF_Status(c_status.get());
        return s;
      }
    
      void Destroy() {
        if (stream_handle_ != nullptr) {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Fri Jun 14 07:39:19 UTC 2024
    - 8K bytes
    - Viewed (0)
  3. tensorflow/compiler/jit/xla_host_send_recv_device_context_test.cc

          stream_executor::PlatformManager::PlatformWithName("CUDA").value();
      stream_executor::StreamExecutor* executor =
          platform->ExecutorForDevice(0).value();
      TF_ASSERT_OK_AND_ASSIGN(auto stream, executor->CreateStream());
    
      se::DeviceMemoryBase gpu_dst{device_tensor.data(), 4 * sizeof(float)};
      xla::Shape shape;
      TF_ASSERT_OK(TensorShapeToXLAShape(DT_FLOAT, TensorShape({2, 2}), &shape));
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Fri May 17 22:46:36 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection.go

    			delete(c.streams, stream.Identifier())
    		}
    	}
    	c.streamLock.Unlock()
    }
    
    // CreateStream creates a new stream with the specified headers and registers
    // it with the connection.
    func (c *connection) CreateStream(headers http.Header) (httpstream.Stream, error) {
    	stream, err := c.conn.CreateStream(headers, nil, false)
    	if err != nil {
    		return nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 01 15:04:07 UTC 2021
    - 6.7K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/connection_test.go

    	}
    
    	spdyConn, err := NewClientConnection(conn)
    	if err != nil {
    		t.Fatalf("client: error creating spdy connection: %v", err)
    	}
    
    	if _, err := spdyConn.CreateStream(http.Header{}); err != nil {
    		t.Fatalf("client: error creating stream: %v", err)
    	}
    
    	spdyConn.Close()
    	raw := spdyConn.(*connection).conn
    	if err := raw.Wait(15 * time.Second); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 01 11:58:57 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apimachinery/pkg/util/httpstream/httpstream.go

    }
    
    // Connection represents an upgraded HTTP connection.
    type Connection interface {
    	// CreateStream creates a new Stream with the supplied headers.
    	CreateStream(headers http.Header) (Stream, error)
    	// Close resets all streams and closes the connection.
    	Close() error
    	// CloseChan returns a channel that is closed when the underlying connection is closed.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:33:38 UTC 2023
    - 6.4K bytes
    - Viewed (0)
Back to top