Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 1,605 for connectTo (0.21 sec)

  1. 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)
  2. platforms/software/resources/src/main/java/org/gradle/internal/resource/transfer/UrlExternalResource.java

            try {
                URL url = location.getUri().toURL();
                URLConnection connection = url.openConnection();
                try {
                    return new DefaultExternalResourceMetaData(location.getUri(), connection.getLastModified(), connection.getContentLength(), connection.getContentType(), null, null);
                } finally {
                    connection.getInputStream().close();
                }
            } catch (FileNotFoundException e) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Oct 12 19:38:08 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/ReusePlan.kt

     */
    package okhttp3.internal.connection
    
    /** Reuse a connection from the pool. */
    internal class ReusePlan(
      val connection: RealConnection,
    ) : RoutePlanner.Plan {
      override val isReady = true
    
      override fun connectTcp() = error("already connected")
    
      override fun connectTlsEtc() = error("already connected")
    
      override fun handleSuccess() = connection
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1K bytes
    - Viewed (0)
  4. pilot/pkg/xds/discovery.go

    	s.pushQueue.ShutDown()
    }
    
    // Clients returns all currently connected clients. This method can be safely called concurrently,
    // but care should be taken with the underlying objects (ie model.Proxy) to ensure proper locking.
    // This method returns only fully initialized connections; for all connections, use AllClients
    func (s *DiscoveryServer) Clients() []*Connection {
    	s.adsClientsMutex.RLock()
    	defer s.adsClientsMutex.RUnlock()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 20:21:09 UTC 2024
    - 19K bytes
    - Viewed (0)
  5. pkg/test/framework/components/echo/kube/workload.go

    	w := &workload{
    		workloadConfig: cfg,
    		ctx:            ctx,
    	}
    
    	// If the pod is ready, connect.
    	if err := w.Update(cfg.pod); err != nil {
    		return nil, err
    	}
    
    	go watchPortForward(cfg, w)
    
    	return w, nil
    }
    
    // watchPortForward wait watch the health of a port-forward connection. If a disconnect is detected, the workload is reconnected.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Oct 25 19:46:28 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  6. platforms/ide/tooling-api/src/testFixtures/groovy/org/gradle/integtests/tooling/fixture/ToolingApiConnector.groovy

    class ToolingApiConnector {
        GradleConnector connector
        private final OutputStream stdout
        private final OutputStream stderr
    
        ToolingApiConnector(GradleConnector connector, OutputStream stdout, OutputStream stderr) {
            this.stderr = stderr
            this.stdout = stdout
            this.connector = connector
        }
    
        def connect() {
            new ToolingApiConnection(connector.connect(), stdout, stderr) as ProjectConnection
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:20 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  7. 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)
  8. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/ReportDaemonStatusClient.java

            for (DaemonInfo daemon : daemons) {
                DaemonClientConnection connection = connector.maybeConnect(daemon);
                if (connection != null) {
                    try {
                        final ReportStatus statusCommand = new ReportStatus(idGenerator.generateId(), daemon.getToken());
                        final Status status = reportStatusDispatcher.dispatch(connection, statusCommand);
                        if (status != null) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Dec 11 13:37:56 UTC 2023
    - 5K bytes
    - Viewed (0)
  9. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DefaultDaemonConnector.java

            DaemonClientConnection connection = connectToIdleDaemon(idleDaemons, constraint);
            if (connection != null) {
                return connection;
            }
    
            // Check to see if there are any compatible canceled daemons and wait to see if one becomes idle
            connection = connectToCanceledDaemon(busyDaemons, constraint);
            if (connection != null) {
                return connection;
            }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 14.1K bytes
    - Viewed (0)
  10. internal/grid/connection_test.go

    	// Killing should cancel the context on the request.
    	<-gotCall
    }
    
    func dummyRequestValidate(r *http.Request) error {
    	return nil
    }
    
    func TestShouldConnect(t *testing.T) {
    	var c Connection
    	var cReverse Connection
    	hosts := []string{"a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k", "l", "m", "n", "o", "p", "q", "r", "s", "t", "u", "v", "x", "y", "z", "0", "1", "2", "3", "4", "5", "6", "7", "8", "9"}
    	for x := range hosts {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 6K bytes
    - Viewed (0)
Back to top