Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 75 for requestKind (0.23 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top