- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 2,378 for connectTo (0.14 sec)
-
pkg/istio-agent/xds_proxy_delta.go
// Every time envoy makes a fresh connection to the agent, we reestablish a new connection to the upstream xds // This ensures that a new connection between istiod and agent doesn't end up consuming pending messages from envoy // as the new connection may not go to the same istiod. Vice versa case also applies.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonStopClientTest.groovy
then: 1 * connector.maybeConnect(daemon1) >>> connection _ * connection.daemon >> daemon1 1 * connection.dispatch({it instanceof StopWhenIdle}) 1 * connection.receive() >> new Success(null) 1 * connection.dispatch({it instanceof Finished}) 1 * connection.stop() and: 1 * connector.maybeConnect(daemon2) >>> connection _ * connection.daemon >> daemon2
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/egressselector/egress_selector.go
} type proxyServerConnector interface { // connect establishes connection to the proxy server, and returns a // proxier based on the connection. // // The provided Context must be non-nil. The context is used for connecting to the proxy only. // If the context expires before the connection is complete, an error is returned. // Once successfully connected to the proxy, any expiration of the context will not affect the connection.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 12.5K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r65/ToolingApiShutdownCrossVersionSpec.groovy
} def "cannot run build operations on project connection after disconnect"() { setup: def connector = toolingApi.connector() ProjectConnection connection = connector.connect() connection.getModel(GradleProject) connector.disconnect() when: connection.getModel(GradleProject) then: def e = thrown(RuntimeException)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 11.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/NotifyDaemonAboutChangedPathsClient.java
DaemonClientConnection connection = connector.maybeConnect(daemonInfo); if (connection == null) { continue; } dispatch(connection, new InvalidateVirtualFileSystemAfterChange(changedPaths, idGenerator.generateId(), connection.getDaemon().getToken())); } } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 3.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonTcpServerConnector.java
lifecycleLock.lock(); try { if (stopped) { throw new IllegalStateException("server connector cannot be started as it is either stopping or has been stopped"); } if (started) { throw new IllegalStateException("server connector cannot be started as it has already been started"); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 4.1K bytes - Viewed (0) -
src/net/dial.go
} // DialContext connects to the address on the named network using // the provided context. // // The provided Context must be non-nil. If the context expires before // the connection is complete, an error is returned. Once successfully // connected, any expiration of the context will not affect the // connection. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 20 06:04:31 UTC 2024 - 26.9K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/DefaultGradleConnectorTest.groovy
} def canSpecifyUserHomeDir() { DefaultProjectConnection connection = Mock() File userDir = new File('user-dir') when: def result = connector.useGradleUserHomeDir(userDir).forProjectDirectory(projectDir).connect() then: result == connection and:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 4.3K bytes - Viewed (0) -
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()));
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.2K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/toolingApi/runBuild/kotlin/src/main/java/org/gradle/sample/Main.java
// Configure the connector and create the connection GradleConnector connector = GradleConnector.newConnector(); if (args.length > 0) { connector.useInstallation(new File(args[0])); if (args.length > 1) { connector.useGradleUserHomeDir(new File(args[1])); } } connector.forProjectDirectory(new File("."));
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 1.1K bytes - Viewed (0)