- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 375 for connect0 (0.11 sec)
-
src/net/tcpsock_posix.go
} return newTCPConn(fd, sd.Dialer.KeepAlive, sd.Dialer.KeepAliveConfig, testPreHookSetKeepAlive, testHookSetKeepAlive), nil } func selfConnect(fd *netFD, err error) bool { // If the connect failed, we clearly didn't connect to ourselves. if err != nil { return false } // The socket constructor can return an fd with raddr nil under certain // unknown conditions. The errors in the calls there to Getpeername
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 16:54:32 UTC 2024 - 6.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RouteDatabase.kt
import okhttp3.Route /** * A denylist of failed routes to avoid when creating a new connection to a target address. This is * used so that OkHttp can learn from its mistakes: if there was a failure attempting to connect to * a specific IP address or proxy server, that failure is remembered and alternate routes are * preferred. */ class RouteDatabase { private val _failedRoutes = mutableSetOf<Route>()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 14:55:09 UTC 2024 - 1.5K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
var origConnTime time.Time t.Run("initial connect", func(t *testing.T) { // connect origConnTime = time.Now() c1.OnConnect(makeConn(p, origConnTime)) // ensure the entry is connected checkNonAutoRegisteredEntryOrFail(t, store, weB, c1.instanceID) }) t.Run("reconnect", func(t *testing.T) { t.Run("same instance: disconnect then connect", func(t *testing.T) { // disconnect
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
mt := monitortest.New(t) setupLogging() ctx, cancel := context.WithCancel(context.Background()) defer cancel() fixture := connect(ctx) ztunClient := fixture.ztunClient uid := fixture.uid m, fds := readRequest(t, ztunClient) // we got am essage from ztun, so it should have observed us being connected mt.Assert(ztunnelConnected.Name(), nil, monitortest.Exactly(1))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 8.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
val connect1 = server.takeRequest() assertThat(connect1.requestLine).isEqualTo("CONNECT android.com:$port HTTP/1.1") assertThat(connect1.headers["Proxy-Authorization"]).isNull() val connect2 = server.takeRequest() assertThat(connect2.requestLine).isEqualTo("CONNECT android.com:$port HTTP/1.1") assertThat(connect2.headers["Proxy-Authorization"]).isEqualTo("password")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
defer p.connectedMutex.Unlock() if p.connected != nil && p.connected == c { close(p.connected.stopChan) p.connected = nil } } func (p *XdsProxy) registerStream(c *ProxyConnection) { p.connectedMutex.Lock() defer p.connectedMutex.Unlock() if p.connected != nil { proxyLog.Warnf("registered overlapping stream; closing previous") close(p.connected.stopChan) } p.connected = c }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/fixture/GradleBuildExperimentRunner.java
connector.useGradleUserHomeDir(context.getGradleUserHomeDir()); try (ProjectConnection connection = connector.connect()) { connection.getModel(BuildEnvironment.class); } } finally { connector.disconnect(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 13.5K bytes - Viewed (0) -
internal/grid/manager.go
if err != nil { writeErr(fmt.Errorf("reading connect: %w", err)) w.WriteHeader(http.StatusForbidden) return } if debugPrint { fmt.Printf("%s handler: Got message, length %v\n", m.local, len(msg)) } var message message _, _, err = message.parse(msg) if err != nil { writeErr(fmt.Errorf("error parsing grid connect: %w", err)) return } if message.Op != OpConnect {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 17:40:33 UTC 2024 - 9.8K 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) -
pkg/istio-agent/xds_proxy_delta.go
} func (p *XdsProxy) sendDeltaHealthRequest(req *discovery.DeltaDiscoveryRequest) { p.connectedMutex.Lock() // Immediately send if we are currently connected. if p.connected != nil && p.connected.deltaRequestsChan != nil { p.connected.deltaRequestsChan.Put(req) } // Otherwise place it as our initial request for new connections p.initialDeltaHealthRequest = req p.connectedMutex.Unlock() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0)