- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 57 for Signalfd (0.16 sec)
-
src/cmd/vendor/golang.org/x/sys/unix/mkerrors.sh
#include <sys/ioctl.h> #include <sys/mman.h> #include <sys/mount.h> #include <sys/prctl.h> #include <sys/stat.h> #include <sys/types.h> #include <sys/time.h> #include <sys/select.h> #include <sys/signalfd.h> #include <sys/socket.h> #include <sys/timerfd.h> #include <sys/uio.h> #include <sys/xattr.h> #include <netinet/udp.h> #include <linux/audit.h> #include <linux/bpf.h> #include <linux/can.h>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 20.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/syscall_linux.go
_, err := setfsuid(uid) return err } func Signalfd(fd int, sigmask *Sigset_t, flags int) (newfd int, err error) { return signalfd(fd, sigmask, _C__NSIG/8, flags) } //sys Setpriority(which int, who int, prio int) (err error) //sys Setxattr(path string, attr string, data []byte, flags int) (err error)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 05:26:45 UTC 2024 - 77.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/zsyscall_linux.go
if e1 != 0 { err = errnoErr(e1) } return } // THIS FILE IS GENERATED BY THE COMMAND AT THE TOP; DO NOT EDIT func signalfd(fd int, sigmask *Sigset_t, maskSize uintptr, flags int) (newfd int, err error) { r0, _, e1 := Syscall6(SYS_SIGNALFD4, uintptr(fd), uintptr(unsafe.Pointer(sigmask)), uintptr(maskSize), uintptr(flags), 0, 0) newfd = int(r0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 05:26:45 UTC 2024 - 54.6K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultFileLockManagerAwaitableFileLockReleasedSignalTest.groovy
def "can reuse signal"() { given: def signalCount = new AtomicInteger() when: start { while (signalCount.get() < 2) { def signaled = signal.await(10000) if (signaled) { signalCount.incrementAndGet() } } } then: poll { assert signal.waiting }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandlerTest.groovy
def "client receives signal when lock is released"() { def signaled = new AtomicBoolean() when: int port = handler.reservePort() handler.start(10) { signal -> signal.trigger() } client.reservePort() client.start(11) {} client.maybePingOwner(port, 10, "lock 1", 50000) { signaled.set(true) } then: poll {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 6.1K bytes - Viewed (0) -
src/runtime/netpoll_windows.go
// so we still need to use a timeout with GetQueuedCompletionStatusEx. // TODO: Improve the Go scheduler to support non-blocking timers. signaled := netpollQueueTimer(delay) if signaled { // There is a small window between the SetWaitableTimer and the NtAssociateWaitCompletionPacket // where the timer can expire. We can return immediately in this case. return gList{}, 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 9.4K bytes - Viewed (0) -
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/ExponentialBackoff.java
Result<T> result; while (!(result = query.run()).isSuccessful()) { if (timer.hasExpired()) { break; } boolean signaled = signal.await(backoffPeriodFor(++iteration)); if (signaled) { iteration = 0; } } return result.getValue(); } long backoffPeriodFor(int iteration) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:49:35 UTC 2024 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
waitForAPIServerStarted(t, doer) // act if isChanClosed(s.lifecycleSignals.MuxAndDiscoveryComplete.Signaled(), 1*time.Second) { t.Fatalf("%s is closed whereas the TestSignal is still open", s.lifecycleSignals.MuxAndDiscoveryComplete.Name()) } close(testSignal1) if isChanClosed(s.lifecycleSignals.MuxAndDiscoveryComplete.Signaled(), 1*time.Second) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
go func() { defer stopHTTPServer(errors.New("time to stop HTTP server")) timeToStopHttpServerCh := notAcceptingNewRequestCh.Signaled() if s.ShutdownSendRetryAfter { timeToStopHttpServerCh = drainedCh.Signaled() } <-timeToStopHttpServerCh }() // Start the audit backend before any request comes in. This means we must call Backend.Run
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 42.9K bytes - Viewed (0) -
src/iter/iter.go
// or after calling stop. These calls will continue // to return the zero V and false. // // Stop ends the iteration. It must be called when the caller is // no longer interested in next values and next has not yet // signaled that the sequence is over (with a false boolean return). // It is valid to call stop multiple times and when next has // already returned false. // // It is an error to call next or stop from multiple goroutines
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:09:28 UTC 2024 - 6.6K bytes - Viewed (0)