- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 972 for Signal (0.08 sec)
-
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
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Fri Feb 17 20:31:46 UTC 2023 - 13K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
* signal the first active guard that is satisfied. But the corresponding thread may have already * been interrupted and is waiting to reacquire the lock while still registered in activeGuards, * in which case the signal is a no-op, and the bigger-picture signal is lost unless interrupted * threads take special action by participating in the signal-passing game. */ /*
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 42.8K bytes - Viewed (0) -
misc/go_android_exec/main.go
return 0, err } // Forward SIGQUIT from the go command to show backtraces from // the binary instead of from this wrapper. quit := make(chan os.Signal, 1) signal.Notify(quit, syscall.SIGQUIT) go func() { for range quit { // We don't have the PID of the running process; use the // binary name instead. adb("exec-out", "killall -QUIT "+binName) } }()
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon Aug 21 17:46:57 UTC 2023 - 15.3K 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.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 25.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
*/ @NullUnmarked public class UninterruptiblesTest extends TestCase { private static final String EXPECTED_TAKE = "expectedTake"; /** Timeout to use when we don't expect the timeout to expire. */ private static final long LONG_DELAY_MS = 2500; private static final long SLEEP_SLACK = 2; private final TearDownStack tearDownStack = new TearDownStack();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 31.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/ConnectionSpec.kt
} else { sslSocket.enabledProtocols } // In accordance with https://tools.ietf.org/html/draft-ietf-tls-downgrade-scsv-00 the SCSV // cipher is added to signal that a protocol fallback has taken place. val supportedCipherSuites = sslSocket.supportedCipherSuites val indexOfFallbackScsv = supportedCipherSuites.indexOf( "TLS_FALLBACK_SCSV",
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 13.4K bytes - Viewed (0) -
cmd/handler-api.go
t.objectMaxVersions = cfg.ObjectMaxVersions if t.staleUploadsCleanupInterval != cfg.StaleUploadsCleanupInterval { t.staleUploadsCleanupInterval = cfg.StaleUploadsCleanupInterval // signal that cleanup interval has changed select { case staleUploadsCleanupIntervalChangedCh <- struct{}{}: default: // in case the channel is blocked... } } } func (t *apiConfig) odirectEnabled() bool {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 10.4K bytes - Viewed (0) -
cmd/admin-handlers_test.go
case stopCmd: return madmin.ServiceActionStop } return madmin.ServiceActionRestart } // testServiceSignalReceiver - Helper function that simulates a // go-routine waiting on service signal. func testServiceSignalReceiver(cmd cmdType, t *testing.T) { expectedCmd := cmd.toServiceSignal() serviceCmd := <-globalServiceSignalCh if serviceCmd != expectedCmd {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.9K bytes - Viewed (0) -
cmd/globals.go
globalTLSCerts *certs.Manager globalHTTPServer *xhttp.Server globalTCPOptions xhttp.TCPOptions globalHTTPServerErrorCh = make(chan error) globalOSSignalCh = make(chan os.Signal, 1) // global Trace system to send HTTP request/response // and Storage/OS calls info to registered listeners. globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 16.2K bytes - Viewed (1) -
cmd/data-scanner_test.go
Validity: 12 * time.Hour, LockEnabled: true, } expiryWorker := func(wg *sync.WaitGroup, readyCh chan<- struct{}, taskCh <-chan expiryOp, gotExpired *[]ObjectToDelete) { defer wg.Done() // signal the calling goroutine that the worker is ready tor receive tasks close(readyCh) var expired []ObjectToDelete for t := range taskCh { switch v := t.(type) { case noncurrentVersionsTask:
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12K bytes - Viewed (0)