Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 1,052 for signalfd (0.36 sec)

  1. 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)
  2. src/runtime/signal_solaris.go

    	/* 56 */ {_SigNotify, "real time signal"},
    	/* 57 */ {_SigNotify, "real time signal"},
    	/* 58 */ {_SigNotify, "real time signal"},
    	/* 59 */ {_SigNotify, "real time signal"},
    	/* 60 */ {_SigNotify, "real time signal"},
    	/* 61 */ {_SigNotify, "real time signal"},
    	/* 62 */ {_SigNotify, "real time signal"},
    	/* 63 */ {_SigNotify, "real time signal"},
    	/* 64 */ {_SigNotify, "real time signal"},
    	/* 65 */ {_SigNotify, "real time signal"},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 16 20:27:15 UTC 2019
    - 4.5K bytes
    - Viewed (0)
  3. src/os/signal/signal_linux_test.go

    // license that can be found in the LICENSE file.
    
    //go:build linux
    
    package signal
    
    import (
    	"os"
    	"syscall"
    	"testing"
    	"time"
    )
    
    const prSetKeepCaps = 8
    
    // This test validates that syscall.AllThreadsSyscall() can reliably
    // reach all 'm' (threads) of the nocgo runtime even when one thread
    // is blocked waiting to receive signals from the kernel. This monitors
    // for a regression vs. the fix for #43149.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 28 18:17:57 UTC 2021
    - 1.1K bytes
    - Viewed (0)
  4. src/cmd/cgo/internal/testsanitizers/testdata/tsan9.go

    // license that can be found in the LICENSE file.
    
    package main
    
    // This program failed when run under the C/C++ ThreadSanitizer. The
    // TSAN library was not keeping track of whether signals should be
    // delivered on the alternate signal stack, and the Go signal handler
    // was not preserving callee-saved registers from C callers.
    
    /*
    #cgo CFLAGS: -g -fsanitize=thread
    #cgo LDFLAGS: -g -fsanitize=thread
    
    #include <stdlib.h>
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 11:59:56 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  5. src/runtime/testdata/testprogcgo/eintr.go

    		}
    	}
    	return r1, r2
    }
    
    // winch sends a few SIGWINCH signals to the process.
    func winch() {
    	ticker := time.NewTicker(100 * time.Microsecond)
    	defer ticker.Stop()
    	pid := syscall.Getpid()
    	for n := 10; n > 0; n-- {
    		syscall.Kill(pid, syscall.SIGWINCH)
    		<-ticker.C
    	}
    }
    
    // sendSomeSignals triggers a few SIGURG and SIGWINCH signals.
    func sendSomeSignals() {
    	done := make(chan struct{})
    	go func() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 05 17:54:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  6. pkg/util/interrupt/interrupt.go

    	h.once.Do(func() {
    		for _, fn := range h.notify {
    			fn()
    		}
    	})
    }
    
    // Signal is called when an os.Signal is received, and guarantees that all notifications
    // are executed, then the final handler is executed. This function should only be called once
    // per Handler instance.
    func (h *Handler) Signal(s os.Signal) {
    	h.once.Do(func() {
    		for _, fn := range h.notify {
    			fn()
    		}
    		if h.final == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 16 09:22:35 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  7. src/runtime/cgo/gcc_netbsd.c

    	free(v);
    
    	// On NetBSD, a new thread inherits the signal stack of the
    	// creating thread. That confuses minit, so we remove that
    	// signal stack here before calling the regular mstart. It's
    	// a bit baroque to remove a signal stack here only to add one
    	// in minit, but it's a simple change that keeps NetBSD
    	// working like other OS's. At this point all signals are
    	// blocked, so there is no race.
    	memset(&ss, 0, sizeof ss);
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Aug 15 03:55:51 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  8. src/runtime/export_unix_test.go

    	ready(mp)
    
    	// Wait for the signal. We use a pipe rather than a note
    	// because write is always async-signal-safe.
    	entersyscallblock()
    	var b byte
    	read(waitForSigusr1.rdpipe, noescape(unsafe.Pointer(&b)), 1)
    	exitsyscall()
    
    	gotM := waitForSigusr1.mID
    	testSigusr1 = nil
    
    	unlockOSThread()
    
    	if b != 0 {
    		// timeout signal from caller
    		return -1, -1
    	}
    	return mp.id, gotM
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 20 21:27:51 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  9. src/runtime/testdata/testprogcgo/racesig.go

    //go:build unix
    // +build unix
    
    package main
    
    // Test that an external C thread that is calling malloc can be hit
    // with SIGCHLD signals. This used to fail when built with the race
    // detector, because in that case the signal handler would indirectly
    // call the C malloc function.
    
    /*
    #include <errno.h>
    #include <signal.h>
    #include <stdint.h>
    #include <stdio.h>
    #include <stdlib.h>
    #include <pthread.h>
    #include <sched.h>
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 01:46:05 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/endpoints/request/server_shutdown_signal.go

    const serverShutdownSignalKey serverShutdownSignalKeyType = iota
    
    // ServerShutdownSignal is associated with the request context so
    // the request handler logic has access to signals rlated to
    // the server shutdown events
    type ServerShutdownSignal interface {
    	// Signaled when the apiserver is not receiving any new request
    	ShuttingDown() <-chan struct{}
    }
    
    // ServerShutdownSignalFrom returns the ServerShutdownSignal instance
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 27 15:49:30 UTC 2023
    - 1.9K bytes
    - Viewed (0)
Back to top