Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 88 for Signalfd (0.17 sec)

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

    	waitForAPIServerStarted(t, doer)
    
    	// act
    	if isChanClosed(s.lifecycleSignals.MuxAndDiscoveryComplete.Signaled(), 1*time.Second) {
    		t.Fatalf("%s is closed whereas the TestSignal is still open", s.lifecycleSignals.MuxAndDiscoveryComplete.Name())
    	}
    
    	close(testSignal1)
    	if isChanClosed(s.lifecycleSignals.MuxAndDiscoveryComplete.Signaled(), 1*time.Second) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 38.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go

    	go func() {
    		defer stopHTTPServer(errors.New("time to stop HTTP server"))
    
    		timeToStopHttpServerCh := notAcceptingNewRequestCh.Signaled()
    		if s.ShutdownSendRetryAfter {
    			timeToStopHttpServerCh = drainedCh.Signaled()
    		}
    
    		<-timeToStopHttpServerCh
    	}()
    
    	// Start the audit backend before any request comes in. This means we must call Backend.Run
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 42.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/request/server_shutdown_signal.go

    // 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
    // associated with the request context.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 27 15:49:30 UTC 2023
    - 1.9K bytes
    - Viewed (0)
  4. src/iter/iter.go

    // or after calling stop. These calls will continue
    // to return the zero V and false.
    //
    // Stop ends the iteration. It must be called when the caller is
    // no longer interested in next values and next has not yet
    // signaled that the sequence is over (with a false boolean return).
    // It is valid to call stop multiple times and when next has
    // already returned false.
    //
    // It is an error to call next or stop from multiple goroutines
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:09:28 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  5. src/runtime/time_linux_amd64.s

    	MOVQ	0(SP), CX	// monotonic sec
    	IMULQ	$1000000000, CX
    	MOVQ	8(SP), DX	// monotonic nsec
    
    	MOVQ	R12, SP		// Restore real 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.
    	MOVQ	8(SP), SI
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat Nov 06 10:24:44 UTC 2021
    - 2K bytes
    - Viewed (0)
  6. src/runtime/signal_arm.go

    	// This extra slot is known to gentraceback.
    	sp := c.sp() - 4
    	c.set_sp(sp)
    	*(*uint32)(unsafe.Pointer(uintptr(sp))) = c.lr()
    	// Set up PC and LR to pretend the function being signaled
    	// calls targetPC at resumePC.
    	c.set_lr(uint32(resumePC))
    	c.set_pc(uint32(targetPC))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 28 18:17:57 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  7. src/runtime/signal_loong64.go

    	// This extra slot is known to gentraceback.
    	sp := c.sp() - 8
    	c.set_sp(sp)
    	*(*uint64)(unsafe.Pointer(uintptr(sp))) = c.link()
    	// Set up PC and LR to pretend the function being signaled
    	// calls targetPC at resumePC.
    	c.set_link(uint64(resumePC))
    	c.set_pc(uint64(targetPC))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 21 06:51:28 UTC 2023
    - 3K bytes
    - Viewed (0)
  8. src/runtime/signal_riscv64.go

    	// This extra slot is known to gentraceback.
    	sp := c.sp() - goarch.PtrSize
    	c.set_sp(sp)
    	*(*uint64)(unsafe.Pointer(uintptr(sp))) = c.ra()
    	// Set up PC and LR to pretend the function being signaled
    	// calls targetPC at resumePC.
    	c.set_ra(uint64(resumePC))
    	c.set_pc(uint64(targetPC))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Oct 04 02:55:17 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  9. src/runtime/signal_mipsx.go

    	// This extra slot is known to gentraceback.
    	sp := c.sp() - 4
    	c.set_sp(sp)
    	*(*uint32)(unsafe.Pointer(uintptr(sp))) = c.link()
    	// Set up PC and LR to pretend the function being signaled
    	// calls targetPC at resumePC.
    	c.set_link(uint32(resumePC))
    	c.set_pc(uint32(targetPC))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 28 18:17:57 UTC 2021
    - 3.1K bytes
    - Viewed (0)
  10. src/runtime/signal_mips64x.go

    	// This extra slot is known to gentraceback.
    	sp := c.sp() - 8
    	c.set_sp(sp)
    	*(*uint64)(unsafe.Pointer(uintptr(sp))) = c.link()
    	// Set up PC and LR to pretend the function being signaled
    	// calls targetPC at resumePC.
    	c.set_link(uint64(resumePC))
    	c.set_pc(uint64(targetPC))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 28 18:17:57 UTC 2021
    - 3.2K bytes
    - Viewed (0)
Back to top