Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 1,105 for psignal (0.43 sec)

  1. 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)
  2. 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)
  3. 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)
  4. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_context.go

    }
    
    // initializationSignalFrom returns an initialization signal function
    // which when called signals that watch initialization has already finished
    // to priority and fairness dispatcher.
    func initializationSignalFrom(ctx context.Context) (InitializationSignal, bool) {
    	signal, ok := ctx.Value(priorityAndFairnessInitializationSignalKey).(InitializationSignal)
    	return signal, ok && signal != nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 14 14:39:15 UTC 2021
    - 2.9K bytes
    - Viewed (0)
  5. src/runtime/debuglog_on.go

    func getCachedDlogger() *dlogger {
    	mp := acquirem()
    	// We don't return a cached dlogger if we're running on the
    	// signal stack in case the signal arrived while in
    	// get/putCachedDlogger. (Too bad we don't have non-atomic
    	// exchange!)
    	var l *dlogger
    	if getg() != mp.gsignal {
    		l = mp.dlogCache
    		mp.dlogCache = nil
    	}
    	releasem(mp)
    	return l
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 28 18:17:57 UTC 2021
    - 1.1K bytes
    - Viewed (0)
  6. src/cmd/cgo/internal/testcshared/testdata/libgo5/libgo5.go

    package main
    
    import "C"
    
    import (
    	"os"
    	"os/signal"
    	"syscall"
    	"time"
    )
    
    // The channel used to read SIGIO signals.
    var sigioChan chan os.Signal
    
    // CatchSIGIO starts catching SIGIO signals.
    //
    //export CatchSIGIO
    func CatchSIGIO() {
    	sigioChan = make(chan os.Signal, 1)
    	signal.Notify(sigioChan, syscall.SIGIO)
    }
    
    // ResetSIGIO stops catching SIGIO signals.
    //
    //export ResetSIGIO
    func ResetSIGIO() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Sep 14 13:19:50 UTC 2023
    - 986 bytes
    - Viewed (0)
  7. src/os/signal/signal_test.go

    }
    
    func waitSig(t *testing.T, c <-chan os.Signal, sig os.Signal) {
    	t.Helper()
    	waitSig1(t, c, sig, false)
    }
    func waitSigAll(t *testing.T, c <-chan os.Signal, sig os.Signal) {
    	t.Helper()
    	waitSig1(t, c, sig, true)
    }
    
    func waitSig1(t *testing.T, c <-chan os.Signal, sig os.Signal, all bool) {
    	t.Helper()
    
    	// Sleep multiple times to give the kernel more tries to
    	// deliver the signal.
    	start := time.Now()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Nov 09 15:34:56 UTC 2023
    - 27.2K bytes
    - Viewed (0)
  8. src/cmd/cgo/internal/testcarchive/testdata/libgo3/libgo3.go

    package main
    
    import "C"
    
    import (
    	"os"
    	"os/signal"
    	"syscall"
    	"time"
    )
    
    // The channel used to read SIGIO signals.
    var sigioChan chan os.Signal
    
    // CatchSIGIO starts catching SIGIO signals.
    //
    //export CatchSIGIO
    func CatchSIGIO() {
    	sigioChan = make(chan os.Signal, 1)
    	signal.Notify(sigioChan, syscall.SIGIO)
    }
    
    // ResetSIGIO stops catching SIGIO signals.
    //
    //export ResetSIGIO
    func ResetSIGIO() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 11:59:56 UTC 2023
    - 1020 bytes
    - Viewed (0)
  9. src/runtime/os_openbsd.go

    func mpreinit(mp *m) {
    	gsignalSize := int32(32 * 1024)
    	if GOARCH == "mips64" {
    		gsignalSize = int32(64 * 1024)
    	}
    	mp.gsignal = malg(gsignalSize)
    	mp.gsignal.m = mp
    }
    
    // Called to initialize a new m (including the bootstrap m).
    // Called on the new thread, can not allocate memory.
    func minit() {
    	getg().m.procid = uint64(getthrid())
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  10. src/runtime/os_dragonfly.go

    			physPageSize = val
    		}
    	}
    	return i / 2
    }
    
    // raise sends a signal to the calling thread.
    //
    // It must be nosplit because it is used by the signal handler before
    // it definitely has a Go stack.
    //
    //go:nosplit
    func raise(sig uint32) {
    	lwp_kill(-1, lwp_gettid(), int(sig))
    }
    
    func signalM(mp *m, sig int) {
    	lwp_kill(-1, int32(mp.procid), sig)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Dec 05 20:34:30 UTC 2023
    - 7.1K bytes
    - Viewed (0)
Back to top