- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,866 for connectTo (1.94 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
// Play it back. val connection = connect(peer) connection.newStream(headerEntries("a", "android"), false) connection.withLock { if (!connection.isHealthy(System.nanoTime())) { throw ConnectionShutdownException() } } connection.writePing() connection.shutdown(ErrorCode.PROTOCOL_ERROR) assertThat(connection.openStreamCount()).isEqualTo(1)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
src/net/rpc/server.go
// Accept accepts connections on the listener and serves requests // to [DefaultServer] for each incoming connection. // Accept blocks; the caller typically invokes it in a go statement. func Accept(lis net.Listener) { DefaultServer.Accept(lis) } // Can connect to RPC service using HTTP CONNECT to rpcPath. var connected = "200 Connected to Go RPC" // ServeHTTP implements an [http.Handler] that answers RPC requests.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 21.6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r63/DistributionChecksumCrossVersionSpec.groovy
withConnection { connection -> connection.newBuild().forTasks("wrapper").run() } file('gradle/wrapper/gradle-wrapper.properties') << 'distributionSha256Sum=bad' when: def connector = this.connector() connector.useBuildDistribution() withConnection(connector) { ProjectConnection connection -> connection.newBuild().forTasks("help").run() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 1.8K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r70/BuildSrcCrossVersionSpec.groovy
when: withConnectionToBuildSrc { connection -> def build = connection.newBuild() build.forTasks("help").run() } then: noExceptionThrown() } def "buildSrc with settings file can execute standalone"() { buildSrc.file("settings.gradle").touch() when: withConnectionToBuildSrc { connection -> def build = connection.newBuild()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 2.9K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r18/ProjectLevelModelCrossVersionSpec.groovy
Map<String, CustomModel> result = withConnection { connection -> connection.action(new UseGradleBuildToFetchProjectModel()).run() } then: result != null result.keySet() == ['test', 'a', 'b', 'c'] as Set result.values()*.value as Set == [':', ':a', ':b', ':b:c'] as Set when: withConnector { connector -> connector.searchUpwards(true)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 3.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MessageHubBackedServerTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.4K bytes - Viewed (0) -
src/net/fd_windows.go
} // Call ConnectEx API. if err := fd.pfd.ConnectEx(ra); err != nil { select { case <-ctx.Done(): return nil, mapErr(ctx.Err()) default: if _, ok := err.(syscall.Errno); ok { err = os.NewSyscallError("connectex", err) } return nil, err } } // Refresh socket properties.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 16:46:10 UTC 2024 - 6.2K bytes - Viewed (0) -
platforms/software/resources/src/main/java/org/gradle/internal/resource/transfer/UrlExternalResource.java
try { URL url = location.getUri().toURL(); URLConnection connection = url.openConnection(); try { return new DefaultExternalResourceMetaData(location.getUri(), connection.getLastModified(), connection.getContentLength(), connection.getContentType(), null, null); } finally { connection.getInputStream().close(); } } catch (FileNotFoundException e) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 4.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ReusePlan.kt
*/ package okhttp3.internal.connection /** Reuse a connection from the pool. */ internal class ReusePlan( val connection: RealConnection, ) : RoutePlanner.Plan { override val isReady = true override fun connectTcp() = error("already connected") override fun connectTlsEtc() = error("already connected") override fun handleSuccess() = connection
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
s.pushQueue.ShutDown() } // Clients returns all currently connected clients. This method can be safely called concurrently, // but care should be taken with the underlying objects (ie model.Proxy) to ensure proper locking. // This method returns only fully initialized connections; for all connections, use AllClients func (s *DiscoveryServer) Clients() []*Connection { s.adsClientsMutex.RLock() defer s.adsClientsMutex.RUnlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0)