Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 95 for listenErrs (0.05 sec)

  1. internal/http/listener.go

    		if e != nil {
    			opts.Trace("listenCfg.Listen: " + e.Error())
    
    			listenErrs[i] = e
    			continue
    		}
    		opts.Trace("adding listener to " + l.Addr().String())
    
    		listeners = append(listeners, l)
    	}
    
    	if len(listeners) == 0 {
    		// No listeners initialized, no need to continue
    		return listener, listenErrs
    	}
    	listeners = slices.Clip(listeners)
    
    	ctx, cancel := context.WithCancel(ctx)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  2. 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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  3. internal/http/listener_test.go

    		listener, listenErrs := newHTTPListener(t.Context(),
    			testCase.serverAddrs,
    			TCPOptions{},
    		)
    		for i, expectedListenErr := range testCase.expectedListenErrs {
    			if !expectedListenErr {
    				if listenErrs[i] != nil {
    					t.Fatalf("Test %d:, listenErrs[%d] error: expected = <nil>, got = %v", testIdx+1, i, listenErrs[i])
    				}
    			} else if listenErrs[i] == nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Service.java

       * suggested that listeners are added before the service starts.
       *
       * <p>{@code addListener} guarantees execution ordering across calls to a given listener but not
       * across calls to multiple listeners. Specifically, a given listener will have its callbacks
       * invoked in the same order as the underlying service enters those states. Additionally, at most
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Service.java

       * suggested that listeners are added before the service starts.
       *
       * <p>{@code addListener} guarantees execution ordering across calls to a given listener but not
       * across calls to multiple listeners. Specifically, a given listener will have its callbacks
       * invoked in the same order as the underlying service enters those states. Additionally, at most
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

       * across calls to multiple listeners. Specifically, a given listener will have its callbacks
       * invoked in the same order as the underlying service enters those states. Additionally, at most
       * one of the listener's callbacks will execute at once. However, multiple listeners' callbacks
       * may execute concurrently, and listeners may execute in an order different from the one in which
       * they were registered.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  7. guava/src/com/google/common/util/concurrent/ServiceManager.java

       * across calls to multiple listeners. Specifically, a given listener will have its callbacks
       * invoked in the same order as the underlying service enters those states. Additionally, at most
       * one of the listener's callbacks will execute at once. However, multiple listeners' callbacks
       * may execute concurrently, and listeners may execute in an order different from the one in which
       * they were registered.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 17:49:12 UTC 2025
    - 32.9K bytes
    - Viewed (0)
  8. internal/grid/debug.go

    		}
    		m := mux.NewRouter()
    		m.Handle(RoutePath, manager.Handler(dummyRequestValidate))
    		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)
    	}
    	close(ready)
    	for _, m := range res.Managers {
    		for _, remote := range m.Targets() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/CompoundProjectExecutionListener.java

        public CompoundProjectExecutionListener(Collection<ProjectExecutionListener> listeners) {
            this.listeners = listeners; // NB this is live injected collection
        }
    
        @Override
        public void beforeProjectExecution(ProjectExecutionEvent event) throws LifecycleExecutionException {
            for (ProjectExecutionListener listener : listeners) {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  10. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java

            return updateScope;
        }
    
        private void fireEvent(int event, List<ResolutionListener> listeners, ResolutionNode node) {
            fireEvent(event, listeners, node, null);
        }
    
        private void fireEvent(int event, List<ResolutionListener> listeners, ResolutionNode node, Artifact replacement) {
            fireEvent(event, listeners, node, replacement, null);
        }
    
        private void fireEvent(
                int event,
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 36.5K bytes
    - Viewed (0)
Back to top