- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 91 for Wignall (0.23 sec)
-
cmd/signals.go
exit(stopProcess()) case osSignal := <-globalOSSignalCh: logger.Info("Exiting on signal: %s", strings.ToUpper(osSignal.String())) daemon.SdNotify(false, daemon.SdNotifyStopping) exit(stopProcess()) case signal := <-globalServiceSignalCh: switch signal { case serviceRestart: logger.Info("Restarting on service signal") daemon.SdNotify(false, daemon.SdNotifyReloading) stop := stopProcess()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
} /** * Signals some other thread waiting on a satisfied guard, if one exists. * * <p>We manage calls to this method carefully, to signal only when necessary, but never losing a * signal, which is the classic problem of this kind of concurrency construct. We must signal if
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Dec 04 18:22:01 GMT 2023 - 38.6K bytes - Viewed (0) -
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 Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
cmd/service.go
Go - Registered: Sun Apr 21 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 Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cni/cmd/install-cni/main.go
package main import ( "context" "os" "os/signal" "syscall" "istio.io/istio/cni/pkg/cmd" "istio.io/istio/pkg/log" ) func main() { // Create context that cancels on termination signal ctx, cancel := context.WithCancel(context.Background()) sigChan := make(chan os.Signal, 1) signal.Notify(sigChan, os.Interrupt, syscall.SIGTERM) go func(sigChan chan os.Signal, cancel context.CancelFunc) { sig := <-sigChan
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingCondition.java
} @Override public boolean awaitUntil(Date deadline) throws InterruptedException { return delegate().awaitUntil(deadline); } @Override public void signal() { delegate().signal(); } @Override public void signalAll() { delegate().signalAll(); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 1.7K bytes - Viewed (0) -
api/go1.18.txt
pkg syscall (freebsd-386-cgo), type SysProcAttr struct, Pdeathsig Signal pkg syscall (freebsd-amd64), type SysProcAttr struct, Pdeathsig Signal pkg syscall (freebsd-amd64-cgo), type SysProcAttr struct, Pdeathsig Signal pkg syscall (freebsd-arm), type SysProcAttr struct, Pdeathsig Signal pkg syscall (freebsd-arm-cgo), type SysProcAttr struct, Pdeathsig Signal
Plain Text - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Feb 17 20:31:46 GMT 2023 - 13K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/InternersTest.java
Interner<Integer> pool = Interners.newWeakInterner(); assertSame(canonical, pool.intern(canonical)); WeakReference<Integer> signal = new WeakReference<>(canonical); canonical = null; // Hint to the JIT that canonical is unreachable GcFinalization.awaitClear(signal); assertSame(not, pool.intern(not)); } public void testAsFunction_simplistic() { String canonical = "a";
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4K 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 Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0)