Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 75 for dialing (0.11 sec)

  1. src/crypto/tls/handshake_test.go

    func localPipe(t testing.TB) (net.Conn, net.Conn) {
    	localListener.mu.Lock()
    	defer localListener.mu.Unlock()
    
    	addr := localListener.addr
    
    	var err error
    Dialing:
    	// We expect a rare mismatch, but probably not 5 in a row.
    	for i := 0; i < 5; i++ {
    		tooSlow := time.NewTimer(1 * time.Second)
    		defer tooSlow.Stop()
    		var c1 net.Conn
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/util/runtime/runtime_test.go

    				}
    				theSocket := tmpFile.Name()
    				os.Remove(theSocket)
    				tmpFile.Close()
    
    				con, err := net.Listen("unix", theSocket)
    				if err != nil {
    					t.Fatalf("unexpected error while dialing a socket: %v", err)
    				}
    				defer con.Close()
    
    				if !isExistingSocket("unix://" + theSocket) {
    					t.Fatalf("isExistingSocket(%q) gave unexpected result. Should have been true, instead of false", theSocket)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 06:33:22 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/options/serving_test.go

    			for _, caCert := range caCerts {
    				roots.AddCert(caCert)
    			}
    
    			<-startedCh
    
    			// try to dial
    			addr := fmt.Sprintf("localhost:%d", secureOptions.BindPort)
    			t.Logf("Dialing %s as %q", addr, test.ServerName)
    			conn, err := tls.Dial("tcp", addr, &tls.Config{
    				RootCAs:    roots,
    				ServerName: test.ServerName, // used for SNI in the client HELLO packet
    			})
    			if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 15:52:39 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  4. src/net/http/httptest/server.go

    			// but never sent a request). StateNew connections are
    			// super rare and have only been seen (in
    			// previously-flaky tests) in the case of
    			// socket-late-binding races from the http Client
    			// dialing this server and then getting an idle
    			// connection before the dial completed. There is thus
    			// a connected connection in StateNew with no
    			// associated Request. We only close StateIdle and
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 10 17:26:10 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  5. pilot/pkg/bootstrap/server_test.go

    				// See https://www.mailgun.com/blog/http-2-cleartext-h2c-client-example-go/
    				// So http2.Transport doesn't complain the URL scheme isn't 'https'
    				AllowHTTP: true,
    				// Pretend we are dialing a TLS endpoint. (Note, we ignore the passed tls.Config)
    				DialTLSContext: func(_ context.Context, network, addr string, _ *tls.Config) (net.Conn, error) {
    					return net.Dial(network, addr)
    				},
    			},
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/server/config.go

    	// TODO: move into SecureServing(WithLoopback) as soon as insecure serving is gone
    	LoopbackClientConfig *restclient.Config
    
    	// EgressSelector provides a lookup mechanism for dialing outbound connections.
    	// It does so based on a EgressSelectorConfiguration which was read at startup.
    	EgressSelector *egressselector.EgressSelector
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 47.7K bytes
    - Viewed (0)
  7. cmd/erasure-healing.go

    const (
    	xMinIOHealing = ReservedMetadataPrefix + "healing"
    	xMinIODataMov = ReservedMetadataPrefix + "data-mov"
    )
    
    // SetHealing marks object (version) as being healed.
    // Note: this is to be used only from healObject
    func (fi *FileInfo) SetHealing() {
    	if fi.Metadata == nil {
    		fi.Metadata = make(map[string]string)
    	}
    	fi.Metadata[xMinIOHealing] = "true"
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.8K bytes
    - Viewed (0)
  8. cmd/erasure-healing-common.go

    		meta.DataDir = latestMeta.DataDir
    		switch scanMode {
    		case madmin.HealDeepScan:
    			// disk has a valid xl.meta but may not have all the
    			// parts. This is considered an outdated disk, since
    			// it needs healing too.
    			verifyResp, verifyErr = onlineDisk.VerifyFile(ctx, bucket, object, meta)
    		default:
    			verifyResp, verifyErr = onlineDisk.CheckParts(ctx, bucket, object, meta)
    		}
    
    		for p := range latestMeta.Parts {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  9. cmd/erasure-healing-common_test.go

    Anis Eleuch <******@****.***> 1718034687 +0100
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 23K bytes
    - Viewed (0)
  10. platforms/documentation/docs/src/docs/userguide/dep-man/02-declaring-dependency-versions/dependency_locking.adoc

    This is called _dependency locking_.
    
    It enables, amongst others, the following scenarios:
    
    * Companies dealing with multi repositories no longer need to rely on `-SNAPSHOT` or changing dependencies,
    which sometimes result in cascading failures when a dependency introduces a bug or incompatibility.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jun 06 16:55:22 UTC 2024
    - 15.5K bytes
    - Viewed (0)
Back to top