Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 13 of 13 for DialContext (0.06 seconds)

  1. internal/grid/connection_test.go

    		})
    	}
    	connReady := make(chan struct{})
    	// We fake a local and remote server.
    	localHost := hosts[0]
    	remoteHost := hosts[1]
    	local, err := NewManager(t.Context(), ManagerOptions{
    		Dialer: ConnectWS(dialer.DialContext,
    			dummyNewToken,
    			nil),
    		Local:        localHost,
    		Hosts:        hosts,
    		AuthFn:       dummyNewToken,
    		AuthToken:    dummyTokenValidate,
    		BlockConnect: connReady,
    	})
    	errFatal(err)
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  2. internal/grid/debug.go

    	ready := make(chan struct{})
    	ctx, cancel := context.WithCancel(context.Background())
    	res.cancel = cancel
    	for i, host := range hosts {
    		manager, err := NewManager(ctx, ManagerOptions{
    			Dialer: ConnectWS(dialer.DialContext,
    				dummyNewToken,
    				nil),
    			Local:        host,
    			Hosts:        hosts,
    			AuthFn:       dummyNewToken,
    			AuthToken:    dummyTokenValidate,
    			BlockConnect: ready,
    			RoutePath:    RoutePath,
    		})
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  3. cmd/object-api-utils.go

    	var d net.Dialer
    	var retry int
    	for retry < len(hosts) {
    		ctx, cancel := context.WithTimeout(GlobalContext, 300*time.Millisecond)
    
    		host = hosts[rng.Intn(len(hosts))]
    		conn, err := d.DialContext(ctx, "tcp", host)
    		cancel()
    		if err != nil {
    			retry++
    			continue
    		}
    		conn.Close()
    		break
    	}
    
    	return host
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 37.3K bytes
    - Click Count (0)
Back to Top