- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 48 for listenErrs (0.18 sec)
-
internal/http/listener.go
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) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
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) -
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) -
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) -
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 May 05 03:35:11 GMT 2024 - Last Modified: Wed Jan 10 12:55:54 GMT 2024 - 2.3K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/lifecycle/DelegatingMojoExecutionListener.java
@Singleton public class DelegatingMojoExecutionListener implements MojoExecutionListener { private final List<MojoExecutionListener> listeners = new CopyOnWriteArrayList<>(); public void beforeMojoExecution(MojoExecutionEvent event) throws MojoExecutionException { for (MojoExecutionListener listener : listeners) { listener.beforeMojoExecution(event); } }
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) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
import java.util.Collections; import java.util.List; import java.util.Queue; import java.util.concurrent.Executor; import java.util.logging.Level; /** * A list of listeners for implementing a concurrency friendly observable object. * * <p>Listeners are registered once via {@link #addListener} and then may be invoked by {@linkplain * #enqueue enqueueing} and then {@linkplain #dispatch dispatching} events. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
internal/grid/debug.go
return nil, err } m := mux.NewRouter() m.Handle(RoutePath, manager.Handler()) 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) } xioutil.SafeClose(ready) for _, m := range res.Managers { for _, remote := range m.Targets() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 4.2K bytes - Viewed (0) -
istioctl/pkg/authz/analyzer.go
func NewAnalyzer(envoyConfig *configdump.Wrapper) (*Analyzer, error) { listeners, err := envoyConfig.GetDynamicListenerDump(true) if err != nil { return nil, fmt.Errorf("failed to get dynamic listener dump: %s", err) } return &Analyzer{listenerDump: listeners}, nil } // Print print the analysis results. func (a *Analyzer) Print(writer io.Writer) { var listeners []*listener.Listener for _, l := range a.listenerDump.DynamicListeners {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jul 13 01:59:17 GMT 2022 - 2.1K bytes - Viewed (0)