- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 80 for listenErrs (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
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 mostCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 12.2K bytes - Click Count (0) -
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 mostCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 10.8K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
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) -
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)