Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 199 for signalfd (0.16 sec)

  1. src/runtime/proc.go

    		exit(1)
    	}
    
    	// Save and block signals before getting an M.
    	// The signal handler may call needm itself,
    	// and we must avoid a deadlock. Also, once g is installed,
    	// any incoming signals will try to execute,
    	// but we won't have the sigaltstack settings and other data
    	// set up appropriately until the end of minit, which will
    	// unblock the signals. This is the same dance as when
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  2. pkg/kubelet/eviction/eviction_manager_test.go

    		PressureTransitionPeriod: time.Minute * 5,
    		Thresholds: []evictionapi.Threshold{
    			{
    				Signal:   evictionapi.SignalMemoryAvailable,
    				Operator: evictionapi.OpLessThan,
    				Value: evictionapi.ThresholdValue{
    					Quantity: quantityMustParse("1Gi"),
    				},
    			},
    			{
    				Signal:   evictionapi.SignalMemoryAvailable,
    				Operator: evictionapi.OpLessThan,
    				Value: evictionapi.ThresholdValue{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 119.9K bytes
    - Viewed (0)
  3. src/internal/syscall/unix/pidfd_linux.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package unix
    
    import "syscall"
    
    func PidFDSendSignal(pidfd uintptr, s syscall.Signal) error {
    	_, _, errno := syscall.Syscall(pidfdSendSignalTrap, pidfd, uintptr(s), 0)
    	if errno != 0 {
    		return errno
    	}
    	return nil
    }
    
    func PidFDOpen(pid, flags int) (uintptr, error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 01:23:00 UTC 2024
    - 591 bytes
    - Viewed (0)
  4. src/cmd/vendor/golang.org/x/sys/unix/zerrors_linux.go

    )
    
    // Signals
    const (
    	SIGABRT = syscall.Signal(0x6)
    	SIGALRM = syscall.Signal(0xe)
    	SIGFPE  = syscall.Signal(0x8)
    	SIGHUP  = syscall.Signal(0x1)
    	SIGILL  = syscall.Signal(0x4)
    	SIGINT  = syscall.Signal(0x2)
    	SIGIOT  = syscall.Signal(0x6)
    	SIGKILL = syscall.Signal(0x9)
    	SIGPIPE = syscall.Signal(0xd)
    	SIGQUIT = syscall.Signal(0x3)
    	SIGSEGV = syscall.Signal(0xb)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 185.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_progress.go

    		ctx = metadata.NewOutgoingContext(ctx, pr.contextMetadata)
    	}
    	go func() {
    		defer utilruntime.HandleCrash()
    		<-stopCh
    		pr.mux.Lock()
    		defer pr.mux.Unlock()
    		pr.stopped = true
    		pr.cond.Signal()
    	}()
    	timer := pr.clock.NewTimer(progressRequestPeriod)
    	defer timer.Stop()
    	for {
    		stopped := func() bool {
    			pr.mux.Lock()
    			defer pr.mux.Unlock()
    			for pr.waiting == 0 && !pr.stopped {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 24 09:56:38 UTC 2024
    - 3K bytes
    - Viewed (0)
  6. src/os/pidfd_other.go

    	return 0, syscall.ENOSYS
    }
    
    func (p *Process) pidfdRelease() {}
    
    func (_ *Process) pidfdWait() (*ProcessState, error) {
    	panic("unreachable")
    }
    
    func (_ *Process) pidfdSendSignal(_ syscall.Signal) error {
    	panic("unreachable")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 692 bytes
    - Viewed (0)
  7. pkg/scheduler/framework/runtime/waiting_pods_map.go

    // If this is the last remaining plugin to allow, then a success signal is delivered
    // to unblock the pod.
    func (w *waitingPod) Allow(pluginName string) {
    	w.mu.Lock()
    	defer w.mu.Unlock()
    	if timer, exist := w.pendingPlugins[pluginName]; exist {
    		timer.Stop()
    		delete(w.pendingPlugins, pluginName)
    	}
    
    	// Only signal success status after all plugins have allowed
    	if len(w.pendingPlugins) != 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  8. src/testing/benchmark.go

    			ctx.maxLen = n + 8 // Add additional slack to avoid too many jumps in size.
    		}
    	}
    	go func() {
    		// Signal that we're done whether we return normally
    		// or by FailNow's runtime.Goexit.
    		defer func() {
    			b.signal <- true
    		}()
    
    		b.runN(1)
    	}()
    	<-b.signal
    	if b.failed {
    		fmt.Fprintf(b.w, "%s--- FAIL: %s\n%s", b.chatty.prefix(), b.name, b.output)
    		return false
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  9. src/os/exec/exec_test.go

    	}
    
    	if *exitOnInterrupt {
    		c := make(chan os.Signal, 1)
    		signal.Notify(c, os.Interrupt)
    		go func() {
    			sig := <-c
    			fmt.Fprintf(os.Stderr, "%d: received %v\n", pid, sig)
    			os.Exit(0)
    		}()
    	} else {
    		signal.Ignore(os.Interrupt)
    	}
    
    	// Signal that the process is set up by closing stdout.
    	os.Stdout.Close()
    
    	if *read {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 20:13:53 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  10. src/os/exec_windows.go

    	if e != nil {
    		return nil, NewSyscallError("GetProcessTimes", e)
    	}
    	defer p.Release()
    	return &ProcessState{p.Pid, syscall.WaitStatus{ExitCode: ec}, &u}, nil
    }
    
    func (p *Process) signal(sig Signal) error {
    	handle, status := p.handleTransientAcquire()
    	switch status {
    	case statusDone:
    		return ErrProcessDone
    	case statusReleased:
    		return syscall.EINVAL
    	}
    	defer p.handleTransientRelease()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 5K bytes
    - Viewed (0)
Back to top