Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 56 for listenErrs (0.06 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  2. internal/http/listener_test.go

    		listener, listenErrs := newHTTPListener(context.Background(),
    			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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 17:41:02 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  3. 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,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  4. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  5. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  6. 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 Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/ArtifactResolutionRequest.java

        }
    
        public List<ResolutionListener> getListeners() {
            return listeners;
        }
    
        public ArtifactResolutionRequest setListeners(List<ResolutionListener> listeners) {
            this.listeners = listeners;
    
            return this;
        }
    
        public ArtifactResolutionRequest addListener(ResolutionListener listener) {
            listeners.add(listener);
    
            return this;
        }
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/internal/impl/EventSpyImpl.java

                        InternalMavenSession.from(ee.getSession().getSession());
                Collection<Listener> listeners = session.getListeners();
                if (!listeners.isEmpty()) {
                    Event event = new DefaultEvent(session, ee);
                    for (Listener listener : listeners) {
                        listener.onEvent(event);
                    }
                }
            }
        }
    
        @Override
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  10. impl/maven-core/src/main/java/org/apache/maven/execution/scope/internal/MojoExecutionScope.java

            IdentityHashMap<WeakMojoExecutionListener, Object> listeners = new IdentityHashMap<>();
            for (Object provided : getScopeState().provided()) {
                if (provided instanceof WeakMojoExecutionListener) {
                    listeners.put((WeakMojoExecutionListener) provided, null);
                }
            }
            return listeners.keySet();
        }
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.3K bytes
    - Viewed (0)
Back to top