Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 289 for psignal (0.13 sec)

  1. cmd/signals.go

    			exit(stopProcess())
    		case osSignal := <-globalOSSignalCh:
    			logger.Info("Exiting on signal: %s", strings.ToUpper(osSignal.String()))
    			daemon.SdNotify(false, daemon.SdNotifyStopping)
    			exit(stopProcess())
    		case signal := <-globalServiceSignalCh:
    			switch signal {
    			case serviceRestart:
    				logger.Info("Restarting on service signal")
    				daemon.SdNotify(false, daemon.SdNotifyReloading)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 01 17:57:52 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  2. src/runtime/signal_unix.go

    		flags = sigtable[sig].flags
    	}
    
    	// If the signal is ignored, raising the signal is no-op.
    	if handler == _SIG_IGN || (handler == _SIG_DFL && flags&_SigIgn != 0) {
    		return
    	}
    
    	// Reset the signal handler and raise the signal.
    	// We are currently running inside a signal handler, so the
    	// signal is blocked. We need to unblock it before raising the
    	// signal, or the signal we raise will be ignored until we return
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 10 16:04:54 UTC 2024
    - 45K bytes
    - Viewed (0)
  3. src/cmd/vendor/golang.org/x/sys/unix/mkerrors.sh

    	}
    	printf("}\n\n");
    
    	printf("\n\n// Signal table\n");
    	printf("var signalList = [...]struct {\n");
    	printf("\tnum  syscall.Signal\n");
    	printf("\tname string\n");
    	printf("\tdesc string\n");
    	printf("} {\n");
    	qsort(signals, nelem(signals), sizeof signals[0], tuplecmp);
    	for(i=0; i<nelem(signals); i++) {
    		e = signals[i].num;
    		if(i > 0 && signals[i-1].num == e)
    			continue;
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  4. src/os/signal/doc.go

    asynchronous signal, a Go signal handler will be installed for that
    signal. If, later, Reset is called for that signal, the original
    handling for that signal will be reinstalled, restoring the non-Go
    signal handler if any.
    
    Go code built without -buildmode=c-archive or -buildmode=c-shared will
    install a signal handler for the asynchronous signals listed above,
    and save any existing signal handler. If a signal is delivered to a
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 18:11:00 UTC 2024
    - 11K bytes
    - Viewed (0)
  5. src/os/exec_unix.go

    		rusage: &rusage,
    	}, nil
    }
    
    func (p *Process) signal(sig Signal) error {
    	s, ok := sig.(syscall.Signal)
    	if !ok {
    		return errors.New("os: unsupported signal type")
    	}
    
    	// Which type of Process do we have?
    	switch p.mode {
    	case modeHandle:
    		// pidfd
    		return p.pidfdSendSignal(s)
    	case modePID:
    		// Regular PID
    		return p.pidSignal(s)
    	default:
    		panic("unreachable")
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go

    	// an asynchronous process.
    	signals.AfterShutdownDelayDuration = wrapLifecycleSignal(t, signals.AfterShutdownDelayDuration, before, nil)
    	signals.PreShutdownHooksStopped = wrapLifecycleSignal(t, signals.PreShutdownHooksStopped, before, nil)
    	signals.NotAcceptingNewRequest = wrapLifecycleSignal(t, signals.NotAcceptingNewRequest, before, nil)
    	signals.HTTPServerStoppedListening = wrapLifecycleSignal(t, signals.HTTPServerStoppedListening, before, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 38.3K bytes
    - Viewed (0)
  7. src/os/exec_test.go

    	signal.Notify(c, os.Interrupt)
    	defer signal.Stop(c)
    
    	p := &os.Process{Pid: os.Getpid()}
    	if err := p.Signal(os.Interrupt); err != nil {
    		t.Fatalf("Signal got err %v, want nil", err)
    	}
    
    	// Verify we actually received the signal.
    	select {
    	case <-time.After(1 * time.Second):
    		t.Error("timeout waiting for signal")
    	case <-c:
    		// Good
    	}
    }
    
    func TestProcessReleaseTwice(t *testing.T) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 18:08:44 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  8. src/runtime/sys_linux_ppc64x.s

    	MOVD	R1, R4
    
    	// Store g on gsignal's stack, so if we receive a signal
    	// during VDSO code we can find the g.
    	// If we don't have a signal stack, we won't receive signal,
    	// so don't bother saving g.
    	// When using cgo, we already saved g on TLS, also don't save
    	// g here.
    	// Also don't save g if we are already on the signal stack.
    	// We won't get a nested signal.
    	MOVBZ	runtime·iscgo(SB), R22
    	CMP	R22, $0
    	BNE	nosaveg
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 18:17:17 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  9. src/runtime/os_plan9.go

    // Called on the parent thread (main thread in case of bootstrap), can allocate memory.
    func mpreinit(mp *m) {
    	// Initialize stack and goroutine for note handling.
    	mp.gsignal = malg(32 * 1024)
    	mp.gsignal.m = mp
    	mp.notesig = (*int8)(mallocgc(_ERRMAX, nil, true))
    	// Initialize stack for handling strings from the
    	// errstr system call, as used in package syscall.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 15:41:45 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  10. src/runtime/cpuprof.go

    		cpuprof.addExtra()
    		cpuprof.log.close()
    	}
    	unlock(&cpuprof.lock)
    }
    
    // add adds the stack trace to the profile.
    // It is called from signal handlers and other limited environments
    // and cannot allocate memory or acquire locks that might be
    // held at the time of the signal, nor can it use substantial amounts
    // of stack.
    //
    //go:nowritebarrierrec
    func (p *cpuProfile) add(tagPtr *unsafe.Pointer, stk []uintptr) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 8.5K bytes
    - Viewed (0)
Back to top