Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 235 for listeners (0.27 sec)

  1. internal/http/listener.go

    func (listener *httpListener) Close() (err error) {
    	listener.ctxCanceler()
    
    	for i := range listener.listeners {
    		listener.listeners[i].Close()
    	}
    
    	return nil
    }
    
    // Addr - net.Listener interface compatible method returns net.Addr.  In case of multiple TCP listeners, it returns '0.0.0.0' as IP address.
    func (listener *httpListener) Addr() (addr net.Addr) {
    	addr = listener.listeners[0].Addr()
    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)
  2. istioctl/pkg/writer/envoy/configdump/listener.go

    		if l.Listener != nil {
    			listenerTyped := &listener.Listener{}
    			// Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
    			l.Listener.TypeUrl = v3.ListenerType
    			err = l.Listener.UnmarshalTo(listenerTyped)
    			if err != nil {
    				return nil, fmt.Errorf("unmarshal listener: %v", err)
    			}
    			listeners = append(listeners, listenerTyped)
    		}
    	}
    	if len(listeners) == 0 {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 12:37:14 GMT 2023
    - 18.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractService.java

      }
    
      /** @since 13.0 */
      @Override
      public final void addListener(Listener listener, Executor executor) {
        listeners.addListener(listener, executor);
      }
    
      @Override
      public String toString() {
        return getClass().getSimpleName() + " [" + state() + "]";
      }
    
      /**
       * Attempts to execute all the listeners in {@link #listeners} while not holding the {@link
       * #monitor}.
       */
    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)
  4. istioctl/pkg/authz/listener.go

    		return "", ""
    	}
    	return fmt.Sprintf("%s.%s", parts[2], parts[1]), parts[3]
    }
    
    // Print prints the AuthorizationPolicy in the listener.
    func Print(writer io.Writer, listeners []*listener.Listener) {
    	parsedListeners := parse(listeners)
    	if parsedListeners == nil {
    		return
    	}
    
    	actionToPolicy := map[rbacpb.RBAC_Action]map[string]struct{}{}
    	policyToRule := map[string]map[string]struct{}{}
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Sep 11 15:29:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/compare/listener.go

    	}
    	diff := difflib.UnifiedDiff{
    		FromFile: "Istiod Listeners",
    		A:        difflib.SplitLines(istiodBytes.String()),
    		ToFile:   "Envoy Listeners",
    		B:        difflib.SplitLines(envoyBytes.String()),
    		Context:  c.context,
    	}
    	text, err := difflib.GetUnifiedDiffString(diff)
    	if err != nil {
    		return err
    	}
    	if text != "" {
    		fmt.Fprintln(c.w, "Listeners Don't Match")
    		fmt.Fprintln(c.w, text)
    	} else {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Apr 04 20:29:08 GMT 2024
    - 2K bytes
    - Viewed (0)
  6. 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 May 05 03:35:11 GMT 2024
    - Last Modified: Wed Sep 06 11:28:54 GMT 2023
    - 36.7K bytes
    - Viewed (0)
  7. 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)
  8. maven-core/src/main/java/org/apache/maven/plugin/CompoundMojoExecutionListener.java

        private final Collection<MojoExecutionListener> listeners;
    
        CompoundMojoExecutionListener(Collection<MojoExecutionListener> listeners) {
            this.listeners = listeners; // NB this is live injected collection
        }
    
        public void beforeMojoExecution(MojoExecutionEvent event) throws MojoExecutionException {
            for (MojoExecutionListener listener : listeners) {
                listener.beforeMojoExecution(event);
            }
        }
    
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Mon Dec 26 15:12:32 GMT 2022
    - 1.9K bytes
    - Viewed (0)
  9. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

       * 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
       * Futures#addCallback addCallback()}.
       *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Jun 26 21:13:41 GMT 2023
    - 8K bytes
    - Viewed (0)
  10. maven-core/src/test/java/org/apache/maven/lifecycle/DelegatingMojoExecutionListener.java

            for (MojoExecutionListener listener : listeners) {
                listener.afterMojoExecutionSuccess(event);
            }
        }
    
        public void afterExecutionFailure(MojoExecutionEvent event) {
            for (MojoExecutionListener listener : listeners) {
                listener.afterExecutionFailure(event);
            }
        }
    
        public void addMojoExecutionListener(MojoExecutionListener listener) {
            this.listeners.add(listener);
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Mon Dec 26 15:12:32 GMT 2022
    - 2.2K bytes
    - Viewed (0)
Back to top