Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 613 for dial (0.13 sec)

  1. src/net/lookup_windows_test.go

    	for _, ans := range rx.FindAllStringSubmatch(r, -1) {
    		ptr = append(ptr, absDomainName(ans[1]))
    	}
    	return
    }
    
    func localIP() (ip IP, err error) {
    	conn, err := Dial("udp", "golang.org:80")
    	if err != nil {
    		return nil, err
    	}
    	defer conn.Close()
    
    	localAddr := conn.LocalAddr().(*UDPAddr)
    
    	return localAddr.IP, nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  2. src/os/readfrom_linux_test.go

    		var err error
    		server, err = ln.Accept()
    		if err != nil {
    			t.Errorf("Accept new connection error: %v", err)
    		}
    		ch <- struct{}{}
    	}()
    	client, err = net.Dial(proto, ln.Addr().String())
    	<-ch
    	if err != nil {
    		t.Fatalf("Dial new connection error: %v", err)
    	}
    	return client, server
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 21:49:26 UTC 2024
    - 20.3K bytes
    - Viewed (0)
  3. security/pkg/nodeagent/sds/sdsservice_test.go

    		var d net.Dialer
    		return d.DialContext(ctx, "unix", socket)
    	}))
    
    	conn, err := grpc.Dial(socket, opts...)
    	if err != nil {
    		return nil, err
    	}
    
    	return conn, nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jan 17 20:12:58 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  4. internal/grid/manager.go

    			// No connection to local.
    			continue
    		}
    		m.targets[host] = newConnection(connectionParams{
    			ctx:           ctx,
    			id:            m.ID,
    			local:         o.Local,
    			remote:        host,
    			dial:          o.Dialer,
    			handlers:      &m.handlers,
    			auth:          o.AddAuth,
    			blockConnect:  o.BlockConnect,
    			tlsConfig:     o.TLSConfig,
    			publisher:     o.TraceTo,
    			incomingBytes: o.Incoming,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 17:40:33 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/devicemanager/plugin/v1beta1/stub.go

    		defer m.wg.Done()
    		m.server.Serve(sock)
    	}()
    
    	var lastDialErr error
    	wait.PollImmediate(1*time.Second, 10*time.Second, func() (bool, error) {
    		var conn *grpc.ClientConn
    		_, conn, lastDialErr = dial(m.socket)
    		if lastDialErr != nil {
    			return false, nil
    		}
    		conn.Close()
    		return true, nil
    	})
    	if lastDialErr != nil {
    		return lastDialErr
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 11:19:10 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  6. common/config/.golangci.yml

        # This is not helpful. The new function is not very usable and the current function will not be removed
        - linters:
            - staticcheck
          text: 'SA1019: grpc.Dial is deprecated: use NewClient instead'
        - linters:
            - staticcheck
          text: 'SA1019: grpc.DialContext is deprecated: use NewClient instead'
        - linters:
            - staticcheck
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 04 20:03:06 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  7. common/scripts/metallb-native.yaml

                    minimum: 0
                    type: integer
                  peerAddress:
                    description: Address to dial when establishing the session.
                    type: string
                  peerPort:
                    description: Port to dial when establishing the session.
                    maximum: 16384
                    minimum: 0
                    type: integer
                  routerID:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 23 23:56:31 UTC 2024
    - 63.9K bytes
    - Viewed (0)
  8. internal/grid/connection.go

    	StateShutdown
    
    	// MaxDeadline is the maximum deadline allowed,
    	// Approx 49 days.
    	MaxDeadline = time.Duration(math.MaxUint32) * time.Millisecond
    )
    
    // ContextDialer is a dialer that can be used to dial a remote.
    type ContextDialer func(ctx context.Context, network, address string) (net.Conn, error)
    
    // DialContext implements the Dialer interface.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  9. src/cmd/pprof/pprof.go

    	// url.Parse will recognize it as a link and ultimately report an error,
    	// similar to `abc:123/mem_2023-11-02_03:55:24:
    	// Get "http://abc:123/mem_2023-11-02_03:55:24": dial tcp: lookup abc: no such host`
    	if _, openErr := os.Stat(src); openErr == nil {
    		return nil, "", nil
    	}
    	sourceURL, timeout := adjustURL(src, duration, timeout)
    	if sourceURL == "" {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 19:41:17 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  10. docs/metrics/v3.md

    | `minio_system_network_internode_dial_errors_total`   | `counter` | Total number of internode TCP dial timeouts and errors   | `server,pool_index` |
    | `minio_system_network_internode_dial_avg_time_nanos` | `gauge`   | Average dial time of internodes TCP calls in nanoseconds | `server,pool_index` |
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 06 09:36:25 UTC 2024
    - 40.9K bytes
    - Viewed (0)
Back to top