Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 268 for signalfd (0.52 sec)

  1. 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)
  2. 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)
    				stop := stopProcess()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 01 17:57:52 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go

    		defer notAcceptingNewRequestCh.Signal()
    
    		// wait for the delayed stopCh before closing the handler chain
    		<-delayedStopCh.Signaled()
    
    		// Additionally wait for preshutdown hooks to also be finished, as some of them need
    		// to send API calls to clean up after themselves (e.g. lease reconcilers removing
    		// itself from the active servers).
    		<-preShutdownHooksHasStoppedCh.Signaled()
    	}()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 42.9K bytes
    - Viewed (0)
  7. 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:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:49 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  8. src/os/exec_posix.go

    			res = "exit status " + itoa.Uitox(uint(code))
    		} else { // unix systems use small decimal integers
    			res = "exit status " + itoa.Itoa(code) // unix
    		}
    	case status.Signaled():
    		res = "signal: " + status.Signal().String()
    	case status.Stopped():
    		res = "stop signal: " + status.StopSignal().String()
    		if status.StopSignal() == syscall.SIGTRAP && status.TrapCause() != 0 {
    			res += " (trap " + itoa.Itoa(status.TrapCause()) + ")"
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 22:06:47 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  9. 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)
  10. src/runtime/preempt.go

    // the thread using an OS mechanism (e.g., signals) and inspecting its
    // state to determine if the goroutine was at an asynchronous
    // safe-point. Since the thread suspension itself is generally
    // asynchronous, it also checks if the running goroutine wants to be
    // preempted, since this could have changed. If all conditions are
    // satisfied, it adjusts the signal context to make it look like the
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 15:41:45 UTC 2024
    - 15.1K bytes
    - Viewed (0)
Back to top