- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 127 for Kistner (0.24 sec)
-
cni/pkg/pluginlistener/listener.go
} var err error listener, err := net.Listen("unix", path) if err != nil { return nil, fmt.Errorf("failed to listen on unix socket %q: %v", path, err) } // Update file permission so that cni plugin has permission to access it. if _, err := os.Stat(path); err != nil { return nil, fmt.Errorf("cni listener file %q doesn't exist", path) }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.7K bytes - Viewed (0) -
internal/http/listener.go
} case <-listener.ctx.Done(): } return nil, syscall.EINVAL } // Close - closes underneath all TCP listeners. func (listener *httpListener) Close() (err error) { listener.ctxCanceler() for i := range listener.tcpListeners { listener.tcpListeners[i].Close() } return 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) -
istioctl/pkg/writer/envoy/configdump/listener.go
return false } return true } func getFilterChains(l *listener.Listener) []*listener.FilterChain { res := l.FilterChains if l.DefaultFilterChain != nil { res = append(res, l.DefaultFilterChain) } return res } // retrieveListenerType classifies a Listener as HTTP|TCP|HTTP+TCP|UNKNOWN func retrieveListenerType(l *listener.Listener) string { nHTTP := 0 nTCP := 0
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) -
istioctl/pkg/writer/compare/listener.go
Kuat <******@****.***> 1712262548 -0700
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Apr 04 20:29:08 GMT 2024 - 2K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener_test.go
John Howard <******@****.***> 1707429512 -0800
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 21:58:32 GMT 2024 - 1.4K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSources.kt
return EventSource.Factory { request, listener -> val actualRequest = if (request.header("Accept") == null) { request.newBuilder().addHeader("Accept", "text/event-stream").build() } else { request } RealEventSource(actualRequest, listener).apply { connect(callFactory) } } } @JvmStatic
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Sat Apr 06 04:18:15 GMT 2024 - 1.6K bytes - Viewed (1) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/DefaultExecutionEventCatapult.java
listener.sessionStarted(event); break; case SessionEnded: listener.sessionEnded(event); break; case ProjectSkipped: listener.projectSkipped(event); break; case ProjectStarted: listener.projectStarted(event); break;
Java - Registered: Sun Apr 21 03:35:09 GMT 2024 - Last Modified: Wed Jan 10 12:55:54 GMT 2024 - 4.1K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
).setHeader("content-type", "text/event-stream") .build(), ) val source = newEventSource() assertThat(source.request().url.encodedPath).isEqualTo("/") listener.assertOpen() listener.assertEvent(null, null, "hey") listener.assertClose() } @RetryingTest(5) fun cancelInEventShortCircuits() { server.enqueue( MockResponse.Builder() .body( """
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 6.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
void call(L listener); } /** * Adds a listener that will be called using the given executor when events are later {@link * #enqueue enqueued} and {@link #dispatch dispatched}. */ public void addListener(L listener, Executor executor) { checkNotNull(listener, "listener"); checkNotNull(executor, "executor"); listeners.add(new PerListenerQueue<>(listener, executor)); } /**
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/CompoundProjectExecutionListener.java
for (ProjectExecutionListener listener : listeners) { listener.beforeProjectExecution(event); } } @Override public void beforeProjectLifecycleExecution(ProjectExecutionEvent event) throws LifecycleExecutionException { for (ProjectExecutionListener listener : listeners) { listener.beforeProjectLifecycleExecution(event); } }
Java - Registered: Sun Apr 21 03:35:09 GMT 2024 - Last Modified: Wed Jan 10 12:55:54 GMT 2024 - 2.3K bytes - Viewed (0)