- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 416 for connectat (0.26 sec)
-
src/net/internal/socktest/sys_windows.go
return so.Err } sw.stats.getLocked(so.Cookie).Connected++ return nil } // ConnectEx wraps [syscall.ConnectEx]. func (sw *Switch) ConnectEx(s syscall.Handle, sa syscall.Sockaddr, b *byte, n uint32, nwr *uint32, o *syscall.Overlapped) (err error) { so := sw.sockso(s) if so == nil { return syscall.ConnectEx(s, sa, b, n, nwr, o) } sw.fmu.RLock() f, _ := sw.fltab[FilterConnect]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
} // Wait for an in-flight connect to complete or fail. if (connectResult == null) { connectResult = awaitTcpConnect(awaitTimeoutNanos, TimeUnit.NANOSECONDS) ?: continue } if (connectResult.isSuccess) { // We have a connected TCP connection. Cancel and defer the racing connects that all lost. cancelInFlightConnects()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.8K bytes - Viewed (0) -
src/net/internal/socktest/switch.go
Opened uint64 // number of sockets opened Connected uint64 // number of sockets connected Listened uint64 // number of sockets listened Accepted uint64 // number of sockets accepted Closed uint64 // number of sockets closed OpenFailed uint64 // number of sockets open failed ConnectFailed uint64 // number of sockets connect failed ListenFailed uint64 // number of sockets listen failed
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonClientTest.groovy
} def "tries to find a different daemon if connected to a stale daemon address"() { def resultMessage = Stub(BuildActionResult) DaemonClientConnection connection2 = Mock() when: client.execute(Stub(BuildAction), Stub(BuildActionParameters), Stub(ClientBuildRequestContext)) then: 2 * connector.connect(compatibilitySpec) >>> [connection, connection2]
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 10K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClient.java
public DaemonClient( DaemonConnector connector, OutputEventListener outputEventListener, ExplainingSpec<DaemonContext> compatibilitySpec, InputStream buildStandardInput, GlobalUserInputReceiver userInput, IdGenerator<UUID> idGenerator, ProcessEnvironment processEnvironment ) { this.connector = connector; this.outputEventListener = outputEventListener;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 16.5K 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) -
internal/event/target/nats_contrib_test.go
Enable: true, Address: xnet.Host{ Name: "localhost", Port: (xnet.Port(opts.Port)), IsPortSet: true, }, Subject: "test", } con, err := clientConfig.connectNats() if err != nil { t.Errorf("Could not connect to nats: %v", err) } defer con.Close() } func TestNatsConnUserPass(t *testing.T) { opts := natsserver.DefaultTestOptions opts.Port = 14223 opts.Username = "testminio"
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.3K bytes - Viewed (0) -
pkg/registry/core/pod/rest/subresources.go
) // ProxyREST implements the proxy subresource for a Pod type ProxyREST struct { Store *genericregistry.Store ProxyTransport http.RoundTripper } // Implement Connecter var _ = rest.Connecter(&ProxyREST{}) var proxyMethods = []string{"GET", "POST", "PUT", "PATCH", "DELETE", "HEAD", "OPTIONS"} // New returns an empty podProxyOptions object. func (r *ProxyREST) New() runtime.Object {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 9.2K bytes - Viewed (0) -
platforms/ide/tooling-api/src/integTest/groovy/org/gradle/integtests/tooling/ToolingApiClientJdkCompatibilityTest.groovy
GradleConnector connector = GradleConnector.newConnector(); connector.useGradleVersion(gradleVersion); ProjectConnection connection = null; try { connection = connector.forProjectDirectory(projectLocation).useGradleUserHomeDir(gradleUserHome).connect();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 10:21:26 UTC 2024 - 12.9K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller.go
if entryName == "" { return nil } proxy.SetWorkloadEntry(entryName, autoCreate) c.adsConnections.Connect(conn) err := c.onWorkloadConnect(entryName, proxy, conn.ConnectedAt(), autoCreate) if err != nil { log.Error(err) } return err } // ensureProxyCanControlEntry ensures the connected proxy's identity matches that of the WorkloadEntry it is associating with.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0)