- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 169 for connectTo (0.23 sec)
-
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/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/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r63/DistributionChecksumCrossVersionSpec.groovy
withConnection { connection -> connection.newBuild().forTasks("wrapper").run() } file('gradle/wrapper/gradle-wrapper.properties') << 'distributionSha256Sum=bad' when: def connector = this.connector() connector.useBuildDistribution() withConnection(connector) { ProjectConnection connection -> connection.newBuild().forTasks("help").run() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 1.8K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r213/ModelsWithGradleProjectIdentifierCrossVersionSpec.groovy
FetchProjectModelsBuildAction buildAction = new FetchProjectModelsBuildAction(modelType) def connector = connector() connector.forProjectDirectory(rootDir) connector.searchUpwards(searchUpwards) withConnection(connector) { connection -> connection.action(buildAction).run() } } BuildTestFixture getBuildTestFixture() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 4.3K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r56/TestLauncherDebugTestsCrossVersionTest.groovy
} """ } def "build fails if debugger is not ready"() { setup: // port is assigned but not connected def port = jdwpClient.port when: withConnection { connection -> connection.newTestLauncher() .withJvmTestClasses("example.MyTest") .debugTestsOn(port) .run() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 3.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/DaemonInitialCommunicationFailureIntegrationSpec.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 07:46:29 UTC 2024 - 6.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/config.go
// The TracerProvider can add tracing the connection TracerProvider oteltrace.TracerProvider } // Config is configuration for creating a storage backend. type Config struct { // Type defines the type of storage backend. Default ("") is "etcd3". Type string // Prefix is the prefix to all keys passed to storage.Interface methods. Prefix string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 4.3K bytes - Viewed (0) -
internal/grid/muxserver.go
cancel context.CancelFunc inbound chan []byte parent *Connection sendMu sync.Mutex recvMu sync.Mutex outBlock chan struct{} clientPingInterval time.Duration } func newMuxStateless(ctx context.Context, msg message, c *Connection, handler StatelessHandler) *muxServer { var cancel context.CancelFunc ctx = setCaller(ctx, c.remote)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
internal/http/dial_linux.go
// Enable TCP open // https://lwn.net/Articles/508865/ - 32k queue size. _ = syscall.SetsockoptInt(fd, syscall.SOL_TCP, unix.TCP_FASTOPEN, 32*1024) // Enable TCP fast connect // TCPFastOpenConnect sets the underlying socket to use // the TCP fast open connect. This feature is supported // since Linux 4.11. _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_FASTOPEN_CONNECT, 1) // Enable TCP quick ACK, John Nagle says
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 4.8K bytes - Viewed (3) -
pkg/kube/apimirror/probe.go
// +optional HTTPHeaders []HTTPHeader `json:"httpHeaders,omitempty" protobuf:"bytes,5,rep,name=httpHeaders"` } // URIScheme identifies the scheme used for connection to a host for Get actions type URIScheme string const ( // URISchemeHTTP means that the scheme used will be http:// URISchemeHTTP URIScheme = "HTTP" // URISchemeHTTPS means that the scheme used will be https://
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 4.4K bytes - Viewed (0)