Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for maxIdleConnsPerHost (0.23 sec)

  1. internal/http/transports.go

    	CurvePreferences []tls.CurveID
    
    	// HTTP2
    	EnableHTTP2 bool
    
    	// TCP Options
    	TCPOptions TCPOptions
    }
    
    func (s ConnSettings) getDefaultTransport(maxIdleConnsPerHost int) *http.Transport {
    	if maxIdleConnsPerHost <= 0 {
    		maxIdleConnsPerHost = 1024
    	}
    
    	dialContext := s.DialContext
    	if dialContext == nil {
    		dialContext = DialContextWithLookupHost(s.LookupHost, NewInternodeDialContext(s.DialTimeout, s.TCPOptions))
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jan 30 00:50:37 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  2. internal/dsync/dsync-client_test.go

    func newClient(endpoint string) NetLocker {
    	u, err := url.Parse(endpoint)
    	if err != nil {
    		panic(err)
    	}
    
    	tr := &http.Transport{
    		Proxy:                 http.ProxyFromEnvironment,
    		MaxIdleConnsPerHost:   1024,
    		WriteBufferSize:       32 << 10, // 32KiB moving up from 4KiB default
    		ReadBufferSize:        32 << 10, // 32KiB moving up from 4KiB default
    		IdleConnTimeout:       15 * time.Second,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 20 17:36:09 GMT 2022
    - 4.4K bytes
    - Viewed (0)
  3. cmd/utils.go

    		RootCAs:     globalRootCAs,
    		TCPOptions:  globalTCPOptions,
    	}
    }
    
    // NewInternodeHTTPTransport returns a transport for internode MinIO
    // connections.
    func NewInternodeHTTPTransport(maxIdleConnsPerHost int) func() http.RoundTripper {
    	return xhttp.ConnSettings{
    		LookupHost:       globalDNSCache.LookupHost,
    		DialTimeout:      rest.DefaultTimeout,
    		RootCAs:          globalRootCAs,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 31.3K bytes
    - Viewed (0)
  4. cmd/globals.go

    	ConnClientReadDeadline  time.Duration
    	ConnClientWriteDeadline time.Duration
    
    	ShutdownTimeout     time.Duration
    	IdleTimeout         time.Duration
    	ReadHeaderTimeout   time.Duration
    	MaxIdleConnsPerHost int
    
    	SendBufSize, RecvBufSize int
    	CrossDomainXML           string
    	// The layout of disks as interpreted
    	Layout disksLayout
    }
    
    var (
    	// Global user opts context
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  5. cmd/server-main.go

    		RecvBufSize:        ctxt.RecvBufSize,
    	}
    
    	// allow transport to be HTTP/1.1 for proxying.
    	globalProxyEndpoints = GetProxyEndpoints(globalEndpoints)
    	globalInternodeTransport = NewInternodeHTTPTransport(ctxt.MaxIdleConnsPerHost)()
    	globalRemoteTargetTransport = NewRemoteTargetHTTPTransport(false)()
    	globalForwarder = handlers.NewForwarder(&handlers.Forwarder{
    		PassHost:     true,
    		RoundTripper: globalRemoteTargetTransport,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 33K bytes
    - Viewed (1)
  6. cmd/common-main.go

    	ctxt.ShutdownTimeout = ctx.Duration("shutdown-timeout")
    	ctxt.IdleTimeout = ctx.Duration("idle-timeout")
    	ctxt.ReadHeaderTimeout = ctx.Duration("read-header-timeout")
    	ctxt.MaxIdleConnsPerHost = ctx.Int("max-idle-conns-per-host")
    
    	if conf := ctx.String("config"); len(conf) > 0 {
    		err = mergeServerCtxtFromConfigFile(conf, ctxt)
    	} else {
    		err = mergeDisksLayoutFromArgs(serverCmdArgs(ctx), ctxt)
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 35.5K bytes
    - Viewed (2)
  7. api/go1.txt

    pkg net/http, type Transport struct, DisableCompression bool
    pkg net/http, type Transport struct, DisableKeepAlives bool
    pkg net/http, type Transport struct, MaxIdleConnsPerHost int
    pkg net/http, type Transport struct, Proxy func(*Request) (*url.URL, error)
    pkg net/http, type Transport struct, TLSClientConfig *tls.Config
    pkg net/http, var DefaultClient *Client
    Plain Text
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Aug 14 18:58:28 GMT 2013
    - 1.7M bytes
    - Viewed (1)
Back to top