- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 88 for Signalfd (0.18 sec)
-
pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go
// op4(v1, n2) ends with success const ( mainVolumeName = "main-volume" opZVolumeName = "other-volume" node1 = "node1" node2 = "node2" // delay after an operation is signaled to finish to ensure it actually // finishes before running the next operation. delay = 50 * time.Millisecond // Replicates the default AttachDetachController reconcile period
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 36.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/syscall_bsd.go
return -1 } return int(w >> shift) } func (w WaitStatus) Signaled() bool { return w&mask != stopped && w&mask != 0 } func (w WaitStatus) Signal() syscall.Signal { sig := syscall.Signal(w & mask) if sig == stopped || sig == 0 { return -1 } return sig } func (w WaitStatus) CoreDump() bool { return w.Signaled() && w&core != 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 29 21:28:33 UTC 2023 - 15K bytes - Viewed (0) -
src/runtime/sys_linux_loong64.s
JMP finish nosaveg: JAL (R20) finish: MOVV 0(R3), R7 // sec MOVV 8(R3), R5 // nsec MOVV R23, R3 // restore SP // Restore vdsoPC, vdsoSP // We don't worry about being signaled between the two stores. // If we are not in a signal handler, we'll restore vdsoSP to 0, // and no one will care about vdsoPC. If we are in a signal handler, // we cannot receive another signal. MOVV 16(R3), R25
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Aug 25 20:58:13 UTC 2023 - 14.2K bytes - Viewed (0) -
src/runtime/sys_linux_s390x.s
nosaveg: BL R9 // to vdso lookup finish: MOVD 0(R15), R3 // sec MOVD 8(R15), R5 // nsec MOVD R7, R15 // Restore SP // Restore vdsoPC, vdsoSP // We don't worry about being signaled between the two stores. // If we are not in a signal handler, we'll restore vdsoSP to 0, // and no one will care about vdsoPC. If we are in a signal handler, // we cannot receive another signal. MOVD 24(R15), R12
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 24 18:53:44 UTC 2023 - 12.5K bytes - Viewed (0) -
pkg/kube/controllers/queue.go
// processed at least once, but may have failed. func (q Queue) HasSynced() bool { return q.initialSync.Load() } // Closed returns a chan that will be signaled when the Instance has stopped processing tasks. func (q Queue) Closed() <-chan struct{} { return q.closed } // processNextItem is the main workFn loop for the queue func (q Queue) processNextItem() bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/syscall_aix.go
func (w WaitStatus) ExitStatus() int { if !w.Exited() { return -1 } return int((w >> 8) & 0xFF) } func (w WaitStatus) Signaled() bool { return w&0x40 == 0 && w&0xFF != 0 } func (w WaitStatus) Signal() Signal { if !w.Signaled() { return -1 } return Signal(w>>16) & 0xFF } func (w WaitStatus) Continued() bool { return w&0x01000000 != 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 29 21:28:33 UTC 2023 - 16.1K bytes - Viewed (0) -
src/syscall/syscall_solaris.go
return -1 } return int(w >> shift) } func (w WaitStatus) Signaled() bool { return w&mask != stopped && w&mask != 0 } func (w WaitStatus) Signal() Signal { sig := Signal(w & mask) if sig == stopped || sig == 0 { return -1 } return sig } func (w WaitStatus) CoreDump() bool { return w.Signaled() && w&core != 0 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:03:59 UTC 2024 - 15.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config.go
func (c *Config) DrainedNotify() <-chan struct{} { return c.lifecycleSignals.InFlightRequestsDrained.Signaled() } // ShutdownInitiated returns a lifecycle signal of apiserver shutdown having been initiated. func (c *Config) ShutdownInitiatedNotify() <-chan struct{} { return c.lifecycleSignals.ShutdownInitiated.Signaled() } // Complete fills in any fields not set that are required to have valid data and can be derived
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 47.7K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/plan9/syscall_plan9.go
if fd != -1 { Close(fd) } return } type Waitmsg struct { Pid int Time [3]uint32 Msg string } func (w Waitmsg) Exited() bool { return true } func (w Waitmsg) Signaled() bool { return false } func (w Waitmsg) ExitStatus() int { if len(w.Msg) == 0 { // a normal exit returns no message return 0 } return 1 } //sys await(s []byte) (n int, err error)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 16 22:24:28 UTC 2022 - 7K bytes - Viewed (0) -
src/os/file_posix.go
n, err = f.pfd.Read(b) runtime.KeepAlive(f) return n, err } // pread reads len(b) bytes from the File starting at byte offset off. // It returns the number of bytes read and the error, if any. // EOF is signaled by a zero count with err set to nil. func (f *File) pread(b []byte, off int64) (n int, err error) { n, err = f.pfd.Pread(b, off) runtime.KeepAlive(f) return n, err } // write writes len(b) bytes to the File.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:33:12 UTC 2024 - 7.1K bytes - Viewed (0)