Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 460 for signalfd (0.27 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/lifecycle_signals.go

    type lifecycleSignal interface {
    	// Signal signals the event, indicating that the event has occurred.
    	// Signal is idempotent, once signaled the event stays signaled and
    	// it immediately unblocks any goroutine waiting for this event.
    	Signal()
    
    	// Signaled returns a channel that is closed when the underlying event
    	// has been signaled. Successive calls to Signaled return the same value.
    	Signaled() <-chan struct{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 27 15:49:30 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  2. src/internal/fuzz/sys_posix.go

    // If not, -1 and false.
    func terminationSignal(err error) (os.Signal, bool) {
    	exitErr, ok := err.(*exec.ExitError)
    	if !ok || exitErr.ExitCode() >= 0 {
    		return syscall.Signal(-1), false
    	}
    	status := exitErr.Sys().(syscall.WaitStatus)
    	return status.Signal(), status.Signaled()
    }
    
    // isCrashSignal returns whether a signal was likely to have been caused by an
    // error in the program that received it, triggered by a fuzz input. For
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 12 19:47:40 UTC 2022
    - 4.1K bytes
    - Viewed (0)
  3. src/cmd/cgo/internal/testsanitizers/testdata/tsan11.go

    // This program hung when run under the C/C++ ThreadSanitizer. TSAN defers
    // asynchronous signals until the signaled thread calls into libc. The runtime's
    // sysmon goroutine idles itself using direct usleep syscalls, so it could
    // run for an arbitrarily long time without triggering the libc interceptors.
    // See https://golang.org/issue/18717.
    
    import (
    	"os"
    	"os/signal"
    	"syscall"
    )
    
    /*
    #cgo CFLAGS: -g -fsanitize=thread
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 11:59:56 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  4. src/runtime/testdata/testwinsignal/main.go

    import (
    	"fmt"
    	"io"
    	"log"
    	"os"
    	"os/signal"
    	"syscall"
    	"time"
    )
    
    func main() {
    	// Ensure that this process terminates when the test times out,
    	// even if the expected signal never arrives.
    	go func() {
    		io.Copy(io.Discard, os.Stdin)
    		log.Fatal("stdin is closed; terminating")
    	}()
    
    	// Register to receive all signals.
    	c := make(chan os.Signal, 1)
    	signal.Notify(c)
    
    	// Get console window handle.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 18 07:37:53 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  5. src/syscall/syscall_js.go

    }
    
    // A Signal is a number describing a process signal.
    // It implements the [os.Signal] interface.
    type Signal int
    
    const (
    	_ Signal = iota
    	SIGCHLD
    	SIGINT
    	SIGKILL
    	SIGTRAP
    	SIGQUIT
    	SIGTERM
    )
    
    func (s Signal) Signal() {}
    
    func (s Signal) String() string {
    	if 0 <= s && int(s) < len(signals) {
    		str := signals[s]
    		if str != "" {
    			return str
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 21:03:59 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  6. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultFileLockManagerAwaitableFileLockReleasedSignalTest.groovy

        @Subject def signal = new DefaultFileLockManager.AwaitableFileLockReleasedSignal()
    
        def "can reuse signal"() {
            given:
            def signalCount = new AtomicInteger()
    
            when:
            start {
                while (signalCount.get() < 2) {
                    def signaled = signal.await(10000)
                    if (signaled) {
                        signalCount.incrementAndGet()
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:08:47 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  7. src/runtime/sigqueue.go

    		}
    	}
    }
    
    // signalWaitUntilIdle waits until the signal delivery mechanism is idle.
    // This is used to ensure that we do not drop a signal notification due
    // to a race between disabling a signal and receiving a signal.
    // This assumes that signal delivery has already been disabled for
    // the signal(s) in question, and here we are just waiting to make sure
    // that all the signals have been delivered to the user channels
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  8. src/os/signal/example_test.go

    	// Set up channel on which to send signal notifications.
    	// We must use a buffered channel or risk missing the signal
    	// if we're not ready to receive when the signal is sent.
    	c := make(chan os.Signal, 1)
    
    	// Passing no signals to Notify means that
    	// all signals will be sent to the channel.
    	signal.Notify(c)
    
    	// Block until any signal is received.
    	s := <-c
    	fmt.Println("Got signal:", s)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 01 18:38:23 UTC 2017
    - 1001 bytes
    - Viewed (0)
  9. platforms/core-runtime/time/src/main/java/org/gradle/internal/time/ExponentialBackoff.java

        }
    
        public static <T extends Signal> ExponentialBackoff<T> of(int amount, TimeUnit unit, T signal) {
            return new ExponentialBackoff<T>((int) TimeUnit.MILLISECONDS.convert(amount, unit), signal, SLOT_TIME);
        }
    
        public static ExponentialBackoff<Signal> of(int amount, TimeUnit unit, int slotTime, TimeUnit slotTimeUnit) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 12 08:49:35 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  10. src/cmd/vendor/golang.org/x/sys/plan9/mkerrors.sh

    			buf[0] += a - A;
    		printf("\t%d: \"%s\",\n", e, buf);
    	}
    	printf("}\n\n");
    	
    	printf("\n\n// Signal table\n");
    	printf("var signals = [...]string {\n");
    	qsort(signals, nelem(signals), sizeof signals[0], intcmp);
    	for(i=0; i<nelem(signals); i++) {
    		e = signals[i];
    		if(i > 0 && signals[i-1] == e)
    			continue;
    		strcpy(buf, strsignal(e));
    		// lowercase first letter: Bad -> bad, but STREAM -> STREAM.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Oct 26 00:11:50 UTC 2022
    - 5.9K bytes
    - Viewed (2)
Back to top