Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 80 for listenErrs (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  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)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.8K bytes
    - Click Count (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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  3. 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
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 12.2K bytes
    - Click Count (0)
  4. 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
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 10.8K bytes
    - Click Count (0)
  5. 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.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 17:49:12 GMT 2025
    - 33.2K bytes
    - Click Count (1)
  6. 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.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 17:49:12 GMT 2025
    - 32.9K bytes
    - Click Count (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() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  8. 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) {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 2.3K bytes
    - Click Count (0)
  9. 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;
        }
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 8.3K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/AbstractService.java

        if (!monitor.isOccupiedByCurrentThread()) {
          listeners.dispatch();
        }
      }
    
      private void enqueueStartingEvent() {
        listeners.enqueue(STARTING_EVENT);
      }
    
      private void enqueueRunningEvent() {
        listeners.enqueue(RUNNING_EVENT);
      }
    
      private void enqueueStoppingEvent(State from) {
        if (from == State.STARTING) {
          listeners.enqueue(STOPPING_FROM_STARTING_EVENT);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 20.3K bytes
    - Click Count (0)
Back to Top