Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for listenErrs (0.15 sec)

  1. internal/http/server.go

    	// 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 {
    			interfaceFound = true
    		}
    	}
    	if !interfaceFound {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  2. internal/http/listener.go

    			}
    
    			listenErrs[i] = e
    			continue
    		}
    
    		if opts.Trace != nil {
    			opts.Trace(fmt.Sprint("adding listener to ", l.Addr()))
    		}
    
    		listeners = append(listeners, l)
    	}
    
    	if len(listeners) == 0 {
    		// No listeners initialized, no need to continue
    		return
    	}
    
    	listener = &httpListener{
    		listeners: listeners,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  3. internal/grid/debug.go

    			return nil, err
    		}
    		m := mux.NewRouter()
    		m.Handle(RoutePath, manager.Handler())
    		res.Managers = append(res.Managers, manager)
    		res.Servers = append(res.Servers, startHTTPServer(listeners[i], m))
    		res.Listeners = append(res.Listeners, listeners[i])
    		res.Mux = append(res.Mux, m)
    	}
    	xioutil.SafeClose(ready)
    	for _, m := range res.Managers {
    		for _, remote := range m.Targets() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 08 18:15:27 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  4. cmd/consolelogger.go

    	if err != nil {
    		logger.FatalIf(err, "Unable to start console logging subsystem")
    	}
    
    	sys.nodeName = host.Name
    }
    
    // HasLogListeners returns true if console log listeners are registered
    // for this node or peers
    func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool {
    	return sys != nil && sys.pubsub.Subscribers() > 0
    }
    
    // Subscribe starts console logging for this node.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.5K bytes
    - Viewed (0)
  5. internal/grid/connection_test.go

    		AddAuth:      func(aud string) string { return aud },
    		AuthRequest:  dummyRequestValidate,
    		BlockConnect: connReady,
    	})
    	errFatal(err)
    
    	localServer := startServer(t, listeners[0], wrapServer(local.Handler()))
    	remoteServer := startServer(t, listeners[1], wrapServer(remote.Handler()))
    	close(connReady)
    
    	defer func() {
    		local.debugMsg(debugShutdown)
    		remote.debugMsg(debugShutdown)
    		remoteServer.Close()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 6K bytes
    - Viewed (0)
Back to top