- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 45 for Wignall (0.19 sec)
-
istioctl/pkg/dashboard/dashboard.go
} return fmt.Errorf("failure running port forward process: %v", err) } func ClosePortForwarderOnInterrupt(fw kube.PortForwarder) { go func() { signals := make(chan os.Signal, 1) signal.Notify(signals, os.Interrupt) defer signal.Stop(signals) <-signals fw.Close() }() } func openBrowser(url string, writer io.Writer, browser bool) { var err error fmt.Fprintf(writer, "%s\n", url)
Go - Registered: Wed Mar 27 22:53:09 GMT 2024 - Last Modified: Fri Mar 01 15:24:34 GMT 2024 - 20.5K bytes - Viewed (0) -
cmd/service.go
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
cmd/admin-heal-ops.go
} // traverseAndHeal - traverses on-disk data and performs healing // according to settings. At each "safe" point it also checks if an // external quit signal has been received and quits if so. Since the // healing traversal may be mutating on-disk data when an external // quit signal is received, this routine cannot quit immediately and // has to wait until a safe point is reached, such as between scanning // two objects.
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Feb 15 23:13:30 GMT 2024 - 25.1K bytes - Viewed (1) -
guava-tests/test/com/google/common/collect/AbstractIteratorTest.java
@ElementTypesAreNonnullByDefault public class AbstractIteratorTest extends TestCase { public void testDefaultBehaviorOfNextAndHasNext() { // This sample AbstractIterator returns 0 on the first call, 1 on the // second, then signals that it's reached the end of the data Iterator<Integer> iter = new AbstractIterator<Integer>() { private int rep; @Override public @Nullable Integer computeNext() {
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Wed Feb 21 10:16:44 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Interceptor.kt
* responses coming back in. Typically interceptors add, remove, or transform headers on the request * or response. * * Implementations of this interface throw [IOException] to signal connectivity failures. This * includes both natural exceptions such as unreachable servers, as well as synthetic exceptions * when responses are of an unexpected type or cannot be decoded. *
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/AbstractIteratorTest.java
@ElementTypesAreNonnullByDefault public class AbstractIteratorTest extends TestCase { public void testDefaultBehaviorOfNextAndHasNext() { // This sample AbstractIterator returns 0 on the first call, 1 on the // second, then signals that it's reached the end of the data Iterator<Integer> iter = new AbstractIterator<Integer>() { private int rep; @Override public @Nullable Integer computeNext() {
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Wed Feb 21 10:16:44 GMT 2024 - 8.7K bytes - Viewed (0) -
cmd/leak-detect_test.go
"created by runtime.gc", // ignore the snapshot function. // since the snapshot is taken here the entry will have the current function too. "pickRelevantGoroutines", "runtime.MHeap_Scavenger", "signal.signal_recv", "sigterm.handler", "runtime_mcall", "goroutine in C code", } // Identify whether the stack trace entry is part of ignoredStackFn . func isIgnoredStackFn(stack string) (ok bool) { ok = true
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
} /** Used by [Call.execute] to signal it is in-flight. */ @Synchronized internal fun executed(call: RealCall) { runningSyncCalls.add(call) } /** Used by [AsyncCall.run] to signal completion. */ internal fun finished(call: AsyncCall) { call.callsPerHost.decrementAndGet() finished(runningAsyncCalls, call) } /** Used by [Call.execute] to signal completion. */
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/ExchangeCodec.kt
fun writeRequestHeaders(request: Request) /** Flush the request to the underlying socket. */ @Throws(IOException::class) fun flushRequest() /** Flush the request to the underlying socket and signal no more bytes will be transmitted. */ @Throws(IOException::class) fun finishRequest() /** * Parses bytes of a response header from an HTTP transport. *
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3K bytes - Viewed (0) -
common-protos/k8s.io/apimachinery/pkg/apis/testapigroup/v1/generated.proto
// If this value is nil, the default grace period will be used instead. // The grace period is the duration in seconds after the processes running in the carp are sent // a termination signal and the time when the processes are forcibly halted with a kill signal. // Set this value longer than the expected cleanup time for your process. // Defaults to 30 seconds. // +optional optional int64 terminationGracePeriodSeconds = 4;
Plain Text - Registered: Wed Mar 27 22:53:09 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 7.7K bytes - Viewed (0)