- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for stream_handle_ (0.62 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) -
platforms/core-runtime/process-services/src/main/java/org/gradle/process/internal/StreamsHandler.java
* limitations under the License. */ package org.gradle.process.internal; import org.gradle.internal.concurrent.Stoppable; import java.util.concurrent.Executor; public interface StreamsHandler extends Stoppable { /** * Collects whatever state is required the given process. Should not start work. */ void connectStreams(Process process, String processName, Executor executor); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:10:02 UTC 2023 - 1.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/StreamHandler.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 945 bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/ExecHandleRunner.java
private final Executor executor; private Process process; private boolean aborted; private final StreamsHandler streamsHandler; private volatile BuildOperationRef associatedBuildOperation; public ExecHandleRunner( DefaultExecHandle execHandle, StreamsHandler streamsHandler, ProcessLauncher processLauncher, Executor executor, BuildOperationRef associatedBuildOperation ) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 4.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/process-services/src/main/java/org/gradle/process/internal/ExecHandleBuilder.java
*/ ExecHandleBuilder setDaemon(boolean daemon); /** * Sets a handler for the output streams of the process. */ ExecHandleBuilder streamsHandler(StreamsHandler streamsHandler); /** * Sets the start-up timeout, when spawning a process. Not used when forking a process (the default). */ ExecHandleBuilder setTimeout(int timeoutMillis);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:10:02 UTC 2023 - 1.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
} /** Sets the response body to the UTF-8 encoded bytes of [body]. */ fun body(body: String): Builder = body(Buffer().writeUtf8(body)) fun streamHandler(streamHandler: StreamHandler) = apply { this.streamHandler = streamHandler } /** * Sets the response body to [body], chunked every [maxChunkSize] bytes. */ fun chunkedBody( body: Buffer,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 13.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
.streamHandler(body1) .build(), ) val body = MockStreamHandler() .sendResponse("response body\n") .exhaustResponse() .receiveRequest("request body\n") .exhaustRequest() server.enqueue( MockResponse.Builder() .clearHeaders() .streamHandler(body) .build(), ) val call =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 23.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/DefaultExecHandle.java
/** * The variables to set in the environment the executable is run in. */ private final Map<String, String> environment; private final StreamsHandler outputHandler; private final StreamsHandler inputHandler; private final boolean redirectErrorStream; private final ProcessLauncher processLauncher; private int timeoutMillis; private boolean daemon; /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 15.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/streams/EmptyStdInStreamsHandler.java
import org.gradle.api.UncheckedIOException; import org.gradle.process.internal.StreamsHandler; import java.io.IOException; import java.util.concurrent.Executor; /** * A handler that writes nothing to the process' stdin */ public class EmptyStdInStreamsHandler implements StreamsHandler { @Override public void connectStreams(Process process, String processName, Executor executor) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jul 11 16:06:58 UTC 2023 - 1.4K bytes - Viewed (0)