Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 88 for Signalfd (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top