Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 1,122 for signalM (0.29 sec)

  1. src/cmd/cgo/internal/testcarchive/testdata/main5.c

    			if (verbose) {
    				printf("attempting external signal test\n");
    			}
    
    			fprintf(stderr, "OK\n");
    			fflush(stderr);
    
    			// The program should be interrupted before
    			// this sleep finishes. We use select rather
    			// than sleep because in older versions of
    			// glibc the sleep function does some signal
    			// fiddling to handle SIGCHLD.  If this
    			// program is fiddling signals just when the
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 11:59:56 UTC 2023
    - 2K bytes
    - Viewed (0)
  2. pkg/kubelet/eviction/api/types.go

    	OpLessThan ThresholdOperator = "LessThan"
    )
    
    // OpForSignal maps Signals to ThresholdOperators.
    // Today, the only supported operator is "LessThan". This may change in the future,
    // for example if "consumed" (as opposed to "available") type signals are added.
    // In both cases the directionality of the threshold is implicit to the signal type
    // (for a given signal, the decision to evict will be made when crossing the threshold
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  3. src/cmd/cgo/internal/testcarchive/testdata/libgo4/libgo4.go

    package main
    
    /*
    #include <signal.h>
    #include <pthread.h>
    
    // Raise SIGIO.
    static void CRaiseSIGIO(pthread_t* p) {
    	pthread_kill(*p, SIGIO);
    }
    */
    import "C"
    
    import (
    	"os"
    	"os/signal"
    	"sync/atomic"
    	"syscall"
    )
    
    var sigioCount int32
    
    // Catch SIGIO.
    //
    //export GoCatchSIGIO
    func GoCatchSIGIO() {
    	c := make(chan os.Signal, 1)
    	signal.Notify(c, syscall.SIGIO)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 11:59:56 UTC 2023
    - 854 bytes
    - Viewed (0)
  4. src/runtime/sigqueue_plan9.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: Tue Apr 05 17:54:15 UTC 2022
    - 3.3K bytes
    - Viewed (0)
  5. 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)
  6. src/runtime/sys_libc.go

    		// first call on an M, until that libcCall instance
    		// returns.  Reentrance only matters for signals, as
    		// libc never calls back into Go.  The tricky case is
    		// where we call libcX from an M and record g/pc/sp.
    		// Before that call returns, a signal arrives on the
    		// same M and the signal handling code calls another
    		// libc function.  We don't want that second libcCall
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 05 17:54:15 UTC 2022
    - 1.8K bytes
    - Viewed (0)
  7. 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)
  8. src/runtime/sys_linux_loong64.s

    	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
    	MOVV	R25, m_vdsoSP(R24)
    	MOVV	8(R3), R25
    	MOVV	R25, m_vdsoPC(R24)
    
    	MOVV	R7, sec+0(FP)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Aug 25 20:58:13 UTC 2023
    - 14.2K bytes
    - Viewed (0)
  9. src/internal/fuzz/sys_windows.go

    	return false
    }
    
    // terminationSignal returns -1 and false because Windows doesn't have signals.
    func terminationSignal(err error) (os.Signal, bool) {
    	return syscall.Signal(-1), false
    }
    
    // isCrashSignal is not implemented because Windows doesn't have signals.
    func isCrashSignal(signal os.Signal) bool {
    	panic("not implemented: no signals on windows")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jul 20 18:35:25 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  10. 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)
Back to top