Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 83 for conns (0.08 sec)

  1. internal/http/listener_test.go

    				t.Fatalf("Test %d: error: expected = <nil>, got = %v", i+1, err)
    			}
    		}
    
    		for _, serverAddr := range listener.Addrs() {
    			conn, err := net.Dial("tcp", serverAddr.String())
    			if err != nil {
    				t.Fatalf("Test %d: error: expected = <nil>, got = %v", i+1, err)
    			}
    			conn.Close()
    		}
    
    		listener.Close()
    	}
    }
    
    func TestHTTPListenerAddr(t *testing.T) {
    	if runtime.GOOS == "windows" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 17:41:02 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    			return toStorageErr(err) != errDiskNotFound
    		}
    	}
    	conn := gm.Connection(endpoint.GridHost()).Subroute(endpoint.Path)
    	if conn == nil {
    		return nil, fmt.Errorf("unable to find connection for %s in targets: %v", endpoint.GridHost(), gm.Targets())
    	}
    	client := &storageRESTClient{
    		endpoint:      endpoint,
    		restClient:    restClient,
    		gridConn:      conn,
    		diskInfoCache: cachevalue.New[DiskInfo](),
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  3. internal/http/server.go

    type Server struct {
    	http.Server
    	Addrs         []string      // addresses on which the server listens for new connection.
    	TCPOptions    TCPOptions    // all the configurable TCP conn specific configurable options.
    	listenerMutex sync.Mutex    // to guard 'listener' field.
    	listener      *httpListener // HTTP listener for all 'Addrs' field.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  4. internal/kms/stub.go

    	return &KMS{
    		Type:           Builtin,
    		DefaultKey:     defaultKeyName,
    		latencyBuckets: defaultLatencyBuckets,
    		latency:        make([]atomic.Uint64, len(defaultLatencyBuckets)),
    		conn: &StubKMS{
    			KeyNames: []string{defaultKeyName},
    		},
    	}
    }
    
    // StubKMS is a KMS implementation for tests
    type StubKMS struct {
    	KeyNames []string
    }
    
    // Version returns the type of the KMS.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  5. internal/http/response-recorder.go

    	headers bytes.Buffer
    	body    bytes.Buffer
    	// Indicate if headers are written in the log
    	headersLogged bool
    }
    
    // Hijack - hijacks the underlying connection
    func (lrw *ResponseRecorder) Hijack() (net.Conn, *bufio.ReadWriter, error) {
    	hj, ok := lrw.ResponseWriter.(http.Hijacker)
    	if !ok {
    		return nil, nil, fmt.Errorf("response writer does not support hijacking. Type is %T", lrw.ResponseWriter)
    	}
    	return hj.Hijack()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. docs/fr/docs/tutorial/path-params-numeric-validations.md

    Passez `*`, comme premier paramètre de la fonction.
    
    Python ne fera rien avec ce `*`, mais il saura que tous les paramètres suivants doivent être appelés comme arguments "mots-clés" (paires clé-valeur), également connus sous le nom de <abbr title="De : K-ey W-ord Arg-uments"><code>kwargs</code></abbr>. Même s'ils n'ont pas de valeur par défaut.
    
    {* ../../docs_src/path_params_numeric_validations/tutorial003.py hl[7] *}
    
    # Avec `Annotated`
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 28 10:32:37 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  7. tests/transaction_test.go

    		return nil
    	}); err == nil {
    		t.Errorf("should returns error when commit with closed conn, got error %v", err)
    	}
    
    	if err := DB.Session(&gorm.Session{PrepareStmt: true}).Transaction(func(tx *gorm.DB) error {
    		return nil
    	}); err == nil {
    		t.Errorf("should returns error when commit with closed conn, got error %v", err)
    	}
    }
    
    func TestTransactionWithHooks(t *testing.T) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  8. api/go1.12.txt

    pkg crypto/tls, const TLS_CHACHA20_POLY1305_SHA256 uint16
    pkg crypto/tls, const VersionTLS13 = 772
    pkg crypto/tls, const VersionTLS13 ideal-int
    pkg crypto/tls, type RecordHeaderError struct, Conn net.Conn
    pkg debug/elf, const R_RISCV_32_PCREL = 57
    pkg debug/elf, const R_RISCV_32_PCREL R_RISCV
    pkg debug/pe, const IMAGE_FILE_MACHINE_ARMNT = 452
    pkg debug/pe, const IMAGE_FILE_MACHINE_ARMNT ideal-int
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Jan 02 21:21:53 UTC 2019
    - 13.5K bytes
    - Viewed (0)
  9. internal/kms/secret-key.go

    func NewBuiltin(keyID string, key []byte) (*KMS, error) {
    	if len(key) != 32 {
    		return nil, errors.New("kms: invalid key length " + strconv.Itoa(len(key)))
    	}
    	return &KMS{
    		Type:       Builtin,
    		DefaultKey: keyID,
    		conn: secretKey{
    			keyID: keyID,
    			key:   key,
    		},
    		latencyBuckets: defaultLatencyBuckets,
    		latency:        make([]atomic.Uint64, len(defaultLatencyBuckets)),
    	}, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  10. docs/features/connections.md

     * They don't specify whether a specific proxy server should be used or how to authenticate with that proxy server.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Feb 21 03:33:59 UTC 2022
    - 5.4K bytes
    - Viewed (0)
Back to top