- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 75 for requestKind (0.23 sec)
-
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt
0, Socket(), ) recordedRequest = RecordedRequest("", headersOf(), listOf(), 0L, Buffer(), 0, Socket()) var requestUrl: HttpUrl? = recordedRequest.requestUrl var requestLine: String = recordedRequest.requestLine var method: String? = recordedRequest.method var path: String? = recordedRequest.path var headers: Headers = recordedRequest.headers val header: String? = recordedRequest.getHeader("")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonStopClient.java
DaemonClientConnection connection = connector.maybeConnect(daemon); if (connection == null) { continue; } try { LOGGER.debug("Requesting daemon {} stop when idle", daemon); stopDispatcher.dispatch(connection, new StopWhenIdle(idGenerator.generateId(), connection.getDaemon().getToken())); LOGGER.lifecycle("Gradle daemon stopped.");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.2K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/SendPartialResponseThenBlock.java
this.timeout = timeout; condition = lock.newCondition(); this.precondition = precondition; this.content = content; } @Override public void writeTo(int requestId, HttpExchange exchange) throws IOException { exchange.sendResponseHeaders(200, content.length); exchange.getResponseBody().write(content, 0, 1024); exchange.getResponseBody().flush(); lock.lock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt
import okhttp3.internal.http.ExchangeCodec import okhttp3.internal.http.ExchangeCodec.Carrier import okhttp3.internal.http.HTTP_CONTINUE import okhttp3.internal.http.RealInterceptorChain import okhttp3.internal.http.RequestLine import okhttp3.internal.http.StatusLine import okhttp3.internal.http.promisesBody import okhttp3.internal.http2.Header.Companion.RESPONSE_STATUS_UTF8 import okhttp3.internal.http2.Header.Companion.TARGET_AUTHORITY
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.9K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r86/ModelStreamingBuildAction.java
EclipseProject eclipseProject = controller.getModel(EclipseProject.class); GradleProject gradleProject = controller.getModel(GradleProject.class); // Intentionally sending models in an order different from requesting models controller.send(gradleProject); controller.send(eclipseProject); return new CustomModel(42); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 05 08:55:56 UTC 2024 - 1.3K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/isolated/ModelStreamingBuildAction.java
EclipseProject eclipseProject = controller.getModel(EclipseProject.class); GradleProject gradleProject = controller.getModel(GradleProject.class); // Intentionally sending models in an order different from requesting models controller.send(gradleProject); controller.send(eclipseProject); return new CustomModel(42); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/RequestStopIfSingleUsedDaemon.java
@Override public void execute(DaemonCommandExecution execution) { if (execution.isSingleUseDaemon()) { LOGGER.debug("Requesting daemon stop after processing {}", execution.getCommand()); // Does not take effect until after execution has completed execution.getDaemonStateControl().requestStop(""); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/Command.java
* limitations under the License. */ package org.gradle.launcher.daemon.protocol; import java.io.Serializable; import java.util.UUID; /** * Represents the initial message sent to the daemon, requesting that the daemon do some work. */ public class Command extends Message implements Serializable { private final UUID identifier; private final byte[] token; public Command(UUID identifier, byte[] token) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 1.5K bytes - Viewed (0) -
src/cmd/go/testdata/script/mod_get_issue47650.txt
# commit. cp go.mod go.mod.orig go get -x vcs-test.golang.org/git/issue47650.git/cmd/issue47650@21535ef346c3 stderr '^go: added vcs-test.golang.org/git/issue47650.git v0.1.1-0.20210811175200-21535ef346c3$' # Explicitly requesting that same version should succeed, fetching additional # history for the requested commit as needed in order to validate the # pseudo-version base. go clean -modcache cp go.mod.orig go.mod
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 11 22:29:11 UTC 2023 - 1.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/DispatchingFailureIntegrationSpec.groovy
expect: //This kind of failure more likely reproduces the problem file("settings.gradle") << "// empty" def projectdir = file("project dir").createDir() //requesting x failing builds creates enough stress to expose issues with unsynchronized dispatch 50.times { executer.usingProjectDirectory(projectdir) .withTasks("tasks")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.3K bytes - Viewed (0)