- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 121 for listenErrs (0.28 sec)
-
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) -
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) -
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) -
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) -
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) -
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-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) -
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) -
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) -
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)