- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 99 for Wignall (0.26 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 Mar 24 19:28:08 GMT 2024 - Last Modified: Wed Jul 12 14:18:30 GMT 2023 - 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 Mar 22 12:43:11 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 Mar 27 22:53:09 GMT 2024 - Last Modified: Fri Mar 01 15:24:34 GMT 2024 - 20.5K bytes - Viewed (0) -
misc/ios/go_ios_exec.go
sys.exit(1) # Don't stop on signals. sigs = process.GetUnixSignals() for i in range(0, sigs.GetNumSignals()): sig = sigs.GetSignalAtIndex(i) sigs.SetShouldStop(sig, False) sigs.SetShouldNotify(sig, False) event = lldb.SBEvent() running = False prev_handler = None def signal_handler(signal, frame): process.Signal(signal) def run_program():
Go - Registered: Tue Mar 26 11:13:08 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 23.4K 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) -
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 Mar 27 22:53:09 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 Mar 22 12:43:11 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 1.7K 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 Mar 22 12:43:11 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/plugin/PluginIncompatibleException.java
* specific language governing permissions and limitations * under the License. */ package org.apache.maven.plugin; import org.apache.maven.model.Plugin; /** * Signals a plugin which is not compatible with the current Maven runtime. */ public class PluginIncompatibleException extends PluginManagerException { public PluginIncompatibleException(Plugin plugin, String message) {
Java - Registered: Sun Mar 24 03:35:10 GMT 2024 - Last Modified: Tue Nov 22 13:26:01 GMT 2022 - 1.3K bytes - Viewed (0)