Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for connections (0.37 sec)

  1. src/database/sql/sql.go

    // ErrConnDone is returned by any operation that is performed on a connection
    // that has already been returned to the connection pool.
    var ErrConnDone = errors.New("sql: connection is already closed")
    
    // Conn returns a single connection by either opening a new connection
    // or returning an existing connection from the connection pool. Conn will
    // block until either a connection is returned or ctx is canceled.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:53 UTC 2024
    - 103.6K bytes
    - Viewed (0)
  2. src/net/http/server.go

    // an HTTP handler to take over the connection.
    //
    // The default [ResponseWriter] for HTTP/1.x connections supports
    // Hijacker, but HTTP/2 connections intentionally do not.
    // ResponseWriter wrappers may also not support Hijacker. Handlers
    // should always test for this ability at runtime.
    type Hijacker interface {
    	// Hijack lets the caller take over the connection.
    	// After a call to Hijack the HTTP server library
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 123.4K bytes
    - Viewed (0)
  3. src/database/sql/sql_test.go

    	// Wait until the goroutine we've just created has started waiting.
    	<-drv.waitingCh
    	// Now close the busy connections. This provides a connection for
    	// the blocked goroutine and then fills up the idle queue.
    	for _, v := range rows {
    		v.Close()
    	}
    	// At this point we give the new connection to DB. This connection is
    	// now useless, since the idle queue is full and there are no pending
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  4. src/net/http/transport_test.go

    		ConnectStart:         func(network, addr string) { logf("ConnectStart: Connecting to %s %s ...", network, addr) },
    		ConnectDone: func(network, addr string, err error) {
    			if err != nil {
    				t.Errorf("ConnectDone: %v", err)
    			}
    			logf("ConnectDone: connected to %s %s = %v", network, addr, err)
    		},
    		WroteHeaderField: func(key string, value []string) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 192.6K bytes
    - Viewed (0)
  5. src/net/http/serve_test.go

    			c.Write([]byte("HTTP/1.0 200 OK\r\nConnection: close\r\n\r\nHello."))
    			c.Close()
    			panic("intentional panic")
    		},
    	}
    
    	// A stateLog is a log of states over the lifetime of a connection.
    	type stateLog struct {
    		active   net.Conn // The connection for which the log is recorded; set to the first connection seen in StateNew.
    		got      []ConnState
    		want     []ConnState
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 202K bytes
    - Viewed (0)
  6. samples/addons/grafana.yaml

    ,"targets":[{"datasource":{"type":"prometheus","uid":"$datasource"},"expr":"sum(envoy_cluster_upstream_cx_active{cluster_name=\"xds-grpc\"})","legendFormat":"Connections (client reported)"},{"datasource":{"type":"prometheus","uid":"$datasource"},"expr":"sum(pilot_xds{})","legendFormat":"Connections (server reported)"}],"title":"Connections","type":"timeseries"},{"datasource":{"type":"datasource","uid":"-- Mixed --"},"description":"Number of push errors. Many of these are at least potentional fatal...
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 20:46:28 UTC 2024
    - 242.3K bytes
    - Viewed (0)
  7. pkg/config/validation/validation.go

    			}
    
    			// Validate per-port connection pool settings
    			errs = AppendValidation(errs, validateConnectionPool(i.ConnectionPool))
    			if i.ConnectionPool != nil && i.ConnectionPool.Http != nil && i.Port != nil && !protocol.Parse(i.Port.Protocol).IsHTTP() {
    				errs = AppendWarningf(errs,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 04:03:33 UTC 2024
    - 107.2K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet.go

    	livenessManager  proberesults.Manager
    	readinessManager proberesults.Manager
    	startupManager   proberesults.Manager
    
    	// How long to keep idle streaming command execution/port forwarding
    	// connections open before terminating them
    	streamingConnectionIdleTimeout time.Duration
    
    	// The EventRecorder to use
    	recorder record.EventRecorder
    
    	// Policy for handling garbage collection of dead containers.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  9. cluster/gce/util.sh

          --project "${NETWORK_PROJECT}" \
          --network "${NETWORK}" \
          --source-ranges "0.0.0.0/0" \
          --allow "tcp:22" &
      fi
    
      # Open up TCP 3389 to allow RDP connections.
      if [[ ${NUM_WINDOWS_NODES} -gt 0 ]]; then
        if ! gcloud compute firewall-rules describe --project "${NETWORK_PROJECT}" "${NETWORK}-default-rdp" &>/dev/null; then
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 21:47:17 UTC 2024
    - 161.6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/Maps.java

          Map<K, ? extends V> map) {
        if (map instanceof SortedMap) {
          return Collections.unmodifiableSortedMap((SortedMap<K, ? extends V>) map);
        } else {
          return Collections.unmodifiableMap(map);
        }
      }
    
      static class MapDifferenceImpl<K extends @Nullable Object, V extends @Nullable Object>
          implements MapDifference<K, V> {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sun Jun 02 13:36:19 UTC 2024
    - 159.5K bytes
    - Viewed (0)
Back to top