- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 387 for connectat (0.12 sec)
-
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) -
pilot/pkg/xds/debug.go
adsClients.Total = len(connections) for _, c := range connections { adsClient := AdsClient{ ConnectionID: c.ID(), ConnectedAt: c.ConnectedAt(), PeerAddress: c.Peer(), } adsClients.Connected = append(adsClients.Connected, adsClient) } writeJSON(w, adsClients, req) } // adsz implements a status and debug interface for ADS. // It is mapped to /debug/adsz
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r65/ToolingApiShutdownCrossVersionSpec.groovy
} def "cannot create new project connection after disconnect"() { setup: def connector = toolingApi.connector() withConnection(connector) { connection -> connection.getModel(EclipseProject) } connector.disconnect() when: connector.connect() 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) -
guava/src/com/google/common/graph/Network.java
Graph<N> asGraph(); // // Network properties // /** * Returns true if the edges in this network are directed. Directed edges connect a {@link * EndpointPair#source() source node} to a {@link EndpointPair#target() target node}, while * undirected edges connect a pair of nodes to each other. */ boolean isDirected(); /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jan 22 17:29:38 UTC 2024 - 22.3K bytes - Viewed (0)