- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,605 for connectTo (0.21 sec)
-
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) -
pkg/test/framework/components/echo/kube/workload.go
w := &workload{ workloadConfig: cfg, ctx: ctx, } // If the pod is ready, connect. if err := w.Update(cfg.pod); err != nil { return nil, err } go watchPortForward(cfg, w) return w, nil } // watchPortForward wait watch the health of a port-forward connection. If a disconnect is detected, the workload is reconnected.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 25 19:46:28 UTC 2023 - 7.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/testFixtures/groovy/org/gradle/integtests/tooling/fixture/ToolingApiConnector.groovy
class ToolingApiConnector { GradleConnector connector private final OutputStream stdout private final OutputStream stderr ToolingApiConnector(GradleConnector connector, OutputStream stdout, OutputStream stderr) { this.stderr = stderr this.stdout = stdout this.connector = connector } def connect() { new ToolingApiConnection(connector.connect(), stdout, stderr) as ProjectConnection }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 1.7K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r213/ModelsWithGradleProjectIdentifierCrossVersionSpec.groovy
FetchProjectModelsBuildAction buildAction = new FetchProjectModelsBuildAction(modelType) def connector = connector() connector.forProjectDirectory(rootDir) connector.searchUpwards(searchUpwards) withConnection(connector) { connection -> connection.action(buildAction).run() } } BuildTestFixture getBuildTestFixture() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 4.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/ReportDaemonStatusClient.java
for (DaemonInfo daemon : daemons) { DaemonClientConnection connection = connector.maybeConnect(daemon); if (connection != null) { try { final ReportStatus statusCommand = new ReportStatus(idGenerator.generateId(), daemon.getToken()); final Status status = reportStatusDispatcher.dispatch(connection, statusCommand); if (status != null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DefaultDaemonConnector.java
DaemonClientConnection connection = connectToIdleDaemon(idleDaemons, constraint); if (connection != null) { return connection; } // Check to see if there are any compatible canceled daemons and wait to see if one becomes idle connection = connectToCanceledDaemon(busyDaemons, constraint); if (connection != null) { return connection; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 14.1K bytes - Viewed (0) -
internal/grid/connection_test.go
// Killing should cancel the context on the request. <-gotCall } func dummyRequestValidate(r *http.Request) error { return nil } func TestShouldConnect(t *testing.T) { var c Connection var cReverse Connection hosts := []string{"a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k", "l", "m", "n", "o", "p", "q", "r", "s", "t", "u", "v", "x", "y", "z", "0", "1", "2", "3", "4", "5", "6", "7", "8", "9"} for x := range hosts {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 6K bytes - Viewed (0)