- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 604 for connectTo (0.38 sec)
-
internal/grid/connection.go
<-o.blockConnect } c.connect() }() } if debugPrint { fmt.Println(c.Local, "->", c.Remote, "Should local connect:", c.shouldConnect(), "side:", c.side) } if debugReqs { fmt.Println("Created connection", c.String()) } return c } // Subroute returns a static subroute for the connection. func (c *Connection) Subroute(s string) *Subroute { if c == nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DefaultDaemonConnectorTest.groovy
expect: def connection = connector.maybeConnect({it.pid == 1} as DummyExplainingSpec) connection && connection.connection.num == 1 } def "connect() returns connection to any existing daemon that matches spec"() { given: startIdleDaemon() startIdleDaemon() expect: def connection = connector.connect({it.pid < 12} as ExplainingSpec)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 10:50:51 UTC 2024 - 6.4K 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) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DaemonClientTest.groovy
and: connector.connect(compatibilitySpec) >> connection _ * connection.daemon >> Stub(DaemonConnectDetails) 1 * connection.dispatch({ it instanceof Build }) 1 * connection.receive() >> new BuildStarted(new DaemonDiagnostics(new File("log"), 123L)) 1 * connection.receive() >> null 1 * connection.markSuspect() 1 * connection.dispatch({ it instanceof CloseInput })
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 10K bytes - Viewed (0) -
platforms/ide/tooling-api/src/testFixtures/groovy/org/gradle/integtests/tooling/fixture/ToolingApi.groovy
connector.useGradleUserHomeDir(new File(context.gradleUserHomeDir.path)) try (def connection = connector.connect()) { connection.getModel(BuildEnvironment.class) } } isolateFromGradleOwnBuild(connector) connector.useGradleUserHomeDir(new File(gradleUserHomeDir.path))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 14 10:07:23 UTC 2024 - 12K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonClient.java
// Attempt to connect to an existing idle and compatible daemon int saneNumberOfAttempts = 100; //is it sane enough? for (int i = 1; i < saneNumberOfAttempts; i++) { final DaemonClientConnection connection = connector.connect(compatibilitySpec); // No existing, compatible daemon is available to try if (connection == null) { break; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 16.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
import java.io.Closeable import java.io.IOException import java.util.concurrent.LinkedBlockingDeque import okhttp3.internal.concurrent.TaskFaker import okhttp3.internal.connection.RealConnection import okhttp3.internal.connection.RoutePlanner import okhttp3.internal.connection.RoutePlanner.ConnectResult class FakeRoutePlanner( val factory: TestValueFactory = TestValueFactory(), val taskFaker: TaskFaker = factory.taskFaker,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 6.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
assertEvents( "plan 1 TCP connected", "plan 0 cancel", "plan 1 TLS connecting...", "plan 1 TLS connect failed", "plan 2 TCP connecting...", "plan 2 TCP connected", "plan 2 TLS connecting...", "plan 2 TLS connected", ) taskFaker.advanceUntil(270.ms) assertEvents( "plan 0 TCP connect canceled", )
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 24 04:40:49 UTC 2024 - 20.9K 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)