- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for stream_handle_ (0.29 sec)
-
tensorflow/c/experimental/stream_executor/stream_executor_internal.h
return s; } void Destroy() { if (stream_handle_ != nullptr) { stream_executor_->destroy_stream(device_, stream_handle_); stream_handle_ = nullptr; } } absl::Status RefreshStatus() override { tensorflow::TF_StatusPtr c_status(TF_NewStatus()); stream_executor_->get_stream_status(device_, stream_handle_, c_status.get());
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 14 07:39:19 UTC 2024 - 8K bytes - Viewed (0) -
tensorflow/c/experimental/stream_executor/stream_executor.cc
uint64 size) override { OwnedTFStatus c_status(TF_NewStatus()); SP_Stream stream_handle = static_cast<CStream*>(stream)->Handle(); SP_DeviceMemoryBase device_mem = DeviceMemoryBaseToC(location); stream_executor_->mem_zero(&device_, stream_handle, &device_mem, size, c_status.get()); return StatusFromTF_Status(c_status.get()); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jun 14 07:39:19 UTC 2024 - 27.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonOutputConsumer.java
import org.gradle.api.logging.Logger; import org.gradle.api.logging.Logging; import org.gradle.process.internal.StreamsHandler; import java.io.InputStream; import java.io.PrintWriter; import java.io.StringWriter; import java.util.Scanner; import java.util.concurrent.Executor; public class DaemonOutputConsumer implements StreamsHandler { private final static Logger LOGGER = Logging.getLogger(DaemonOutputConsumer.class);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 2.7K bytes - Viewed (0) -
internal/grid/grid_test.go
} } // We fake a local and remote server. remoteHost := remote.HostName() // 1: Echo register := func(manager *Manager) { errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{ Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr { for in := range request { b := append([]byte{}, payload...) b = append(b, in...)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
internal/grid/handlers.go
// Buffers sent on out can not be referenced once sent. StreamHandlerFn func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr // StreamHandler handles fully bidirectional streams, // There is flow control in both directions. StreamHandler struct { // Handle an incoming request. Initial payload is sent. // Additional input packets (if any) are streamed to request.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.1K bytes - Viewed (0) -
internal/grid/benchmark_test.go
const responses = 10 // Create n managers. for _, remote := range grid.Managers { // Register a single handler which echos the payload. errFatal(remote.RegisterStreamingHandler(handlerTest, StreamHandler{ // Send 10x response. Handle: func(ctx context.Context, payload []byte, _ <-chan []byte, out chan<- []byte) *RemoteErr { for i := 0; i < responses; i++ { toSend := GetByteBuffer()[:0]
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.7K bytes - Viewed (0) -
internal/grid/muxserver.go
LastPing: time.Now().Unix(), BaseFlags: c.baseFlags, } go func() { // TODO: Handle }() return &m } func newMuxStream(ctx context.Context, msg message, c *Connection, handler StreamHandler) *muxServer { var cancel context.CancelFunc ctx = setCaller(ctx, c.remote) if len(handler.Subroute) > 0 { ctx = setSubroute(ctx, handler.Subroute) } if msg.DeadlineMS > 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
internal/grid/manager.go
return nil } */ // RegisterStreamingHandler will register a stateless handler that serves // two-way streaming requests. func (m *Manager) RegisterStreamingHandler(id HandlerID, h StreamHandler) error { if !id.valid() { return ErrUnknownHandler } if debugPrint { fmt.Println("RegisterStreamingHandler: subroute:", h.Subroute) } if h.Subroute == "" {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 17:40:33 UTC 2024 - 9.8K bytes - Viewed (0) -
samples/bookinfo/src/productpage/productpage.py
logging.basicConfig(stream=sys.stdout, level=logging.INFO) requests_log = logging.getLogger("requests.packages.urllib3") requests_log.setLevel(logging.INFO) requests_log.propagate = True app.logger.addHandler(logging.StreamHandler(sys.stdout)) app.logger.setLevel(logging.INFO) # Set the secret key to some random bytes. Keep this really secret! app.secret_key = b'_5#y2L"F4Q8z\n\xec]/'
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 14:35:54 UTC 2024 - 14.6K bytes - Viewed (0) -
cmd/storage-rest-server.go
logger.FatalIf(storageStatVolRPC.Register(gm, server.StatVolHandler, endpoint.Path), "unable to register handler") logger.FatalIf(gm.RegisterStreamingHandler(grid.HandlerWalkDir, grid.StreamHandler{ Subroute: endpoint.Path, Handle: server.WalkDirHandler, OutCapacity: 1, }), "unable to register handler") createStorage := func(endpoint Endpoint) bool {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 44.8K bytes - Viewed (0)