Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 121 for listenErrs (0.28 sec)

  1. internal/http/listener.go

    				opts.Trace(fmt.Sprint("listenCfg.Listen: ", e.Error()))
    			}
    
    			listenErrs[i] = e
    			continue
    		}
    
    		tcpListener, ok := l.(*net.TCPListener)
    		if !ok {
    			listenErrs[i] = fmt.Errorf("unexpected listener type found %v, expected net.TCPListener", l)
    			if opts.Trace != nil {
    				opts.Trace(fmt.Sprint("net.TCPListener: ", listenErrs[i].Error()))
    			}
    			continue
    		}
    		if opts.Trace != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 5.8K 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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Jun 12 16:09:28 GMT 2023
    - 11.8K bytes
    - Viewed (0)
  3. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  4. 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(final State from) {
        if (from == State.STARTING) {
          listeners.enqueue(STOPPING_FROM_STARTING_EVENT);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 20.4K bytes
    - Viewed (0)
  5. 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,
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Wed Sep 06 11:28:54 GMT 2023
    - 36.7K bytes
    - Viewed (0)
  6. maven-core/src/test/java/org/apache/maven/lifecycle/DelegatingProjectExecutionListener.java

            for (ProjectExecutionListener listener : listeners) {
                listener.afterProjectExecutionFailure(event);
            }
        }
    
        public void addProjectExecutionListener(ProjectExecutionListener listener) {
            this.listeners.add(listener);
        }
    
        public void removeProjectExecutionListener(ProjectExecutionListener listener) {
            this.listeners.remove(listener);
        }
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Mon Dec 26 15:12:32 GMT 2022
    - 2.4K bytes
    - Viewed (0)
  7. maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

                    // won't happen
                }
            }
    
            if (listeners == null) {
                listeners = new ArrayList<>();
    
                if (logger.isDebugEnabled()) {
                    listeners.add(new DebugResolutionListener(logger));
                }
    
                listeners.add(new WarningResolutionListener(logger));
            }
    
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Thu Apr 25 05:46:50 GMT 2024
    - 24.8K bytes
    - Viewed (0)
  8. maven-core/src/main/java/org/apache/maven/lifecycle/internal/CompoundProjectExecutionListener.java

        private final Collection<ProjectExecutionListener> listeners;
    
        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) {
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Wed Jan 10 12:55:54 GMT 2024
    - 2.3K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/envoy/configdump/listener.go

    	w, listeners, err := c.setupListenerConfigWriter()
    	if err != nil {
    		return err
    	}
    	// Sort by port, addr, type
    	sort.Slice(listeners, func(i, j int) bool {
    		if listeners[i].GetInternalListener() != nil && listeners[j].GetInternalListener() != nil {
    			return listeners[i].GetName() < listeners[j].GetName()
    		}
    		iPort := retrieveListenerPort(listeners[i])
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 18.1K bytes
    - Viewed (0)
  10. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

       * more futures or adding more {@code directExecutor()} listeners inline -- consider {@link
       * MoreExecutors#directExecutor}. Otherwise, avoid it: See the warnings on the docs for {@code
       * directExecutor}.
       *
       * <p>This is the most general listener interface. For common operations performed using
       * listeners, see {@link Futures}. For a simplified but general listener interface, see {@link
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jun 26 21:13:41 GMT 2023
    - 8K bytes
    - Viewed (0)
Back to top