Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newHTTPListener (0.24 sec)

  1. internal/http/listener_test.go

    		{[]string{"[::1]:9090", "localhost:0"}, time.Duration(0), time.Duration(0), time.Duration(0), []bool{false}},                    // 10
    	}
    
    	for testIdx, testCase := range testCases {
    		listener, listenErrs := newHTTPListener(context.Background(),
    			testCase.serverAddrs,
    			TCPOptions{},
    		)
    		for i, expectedListenErr := range testCase.expectedListenErrs {
    			if !expectedListenErr {
    				if listenErrs[i] != nil {
    Go
    - Registered: Sun Apr 07 19:28:10 GMT 2024
    - Last Modified: Mon Jun 12 16:09:28 GMT 2023
    - 11.8K bytes
    - Viewed (0)
  2. internal/http/listener.go

    	Trace              func(msg string) // Trace when starting.
    }
    
    // newHTTPListener - creates new httpListener object which is interface compatible to net.Listener.
    // httpListener is capable to
    // * listen to multiple addresses
    // * controls incoming connections only doing HTTP protocol
    func newHTTPListener(ctx context.Context, serverAddrs []string, opts TCPOptions) (listener *httpListener, listenErrs []error) {
    Go
    - Registered: Sun Apr 07 19:28:10 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  3. internal/http/server.go

    		tlsConfig = srv.TLSConfig.Clone()
    	}
    	handler := srv.Handler // if srv.Handler holds non-synced state -> possible data race
    
    	// Create new HTTP listener.
    	var listener *httpListener
    	listener, listenErrs := newHTTPListener(
    		listenCtx,
    		srv.Addrs,
    		srv.TCPOptions,
    	)
    
    	var interfaceFound bool
    	for i := range listenErrs {
    		if listenErrs[i] != nil {
    			listenErrCallback(srv.Addrs[i], listenErrs[i])
    		} else {
    Go
    - Registered: Sun Apr 07 19:28:10 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
Back to top