Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for Inhibit (0.16 sec)

  1. pkg/kubelet/nodeshutdown/systemd/inhibit_linux.go

    	mode := "delay"
    
    	call := obj.Call("org.freedesktop.login1.Manager.Inhibit", 0, what, who, why, mode)
    	if call.Err != nil {
    		return InhibitLock(0), fmt.Errorf("failed creating systemd inhibitor: %w", call.Err)
    	}
    
    	var fd uint32
    	err := call.Store(&fd)
    	if err != nil {
    		return InhibitLock(0), fmt.Errorf("failed storing inhibit lock file descriptor: %w", err)
    	}
    
    	return InhibitLock(fd), nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 04 06:56:50 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  2. pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux.go

    	stop := make(chan struct{})
    	go func() {
    		// Monitor for shutdown events. This follows the logind Inhibit Delay pattern described on https://www.freedesktop.org/wiki/Software/systemd/inhibit/
    		// 1. When shutdown manager starts, an inhibit lock is taken.
    		// 2. When shutdown(true) event is received, process the shutdown and release the inhibit lock.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 09 08:02:40 UTC 2022
    - 15.5K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

        TestGuard guard = new TestGuard(true);
        thread1.callAndAssertThrows(IllegalMonitorStateException.class, waitFor(), guard);
      }
    
      public void testNulls() {
        monitor.enter(); // Inhibit IllegalMonitorStateException
        new NullPointerTester()
            .setDefault(Monitor.Guard.class, new TestGuard(true))
            .testAllPublicInstanceMethods(monitor);
      }
    
      // TODO: Test enter(long, TimeUnit).
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Apr 26 20:07:17 UTC 2023
    - 8K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/MonitorTestCase.java

        TestGuard guard = new TestGuard(true);
        thread1.callAndAssertThrows(IllegalMonitorStateException.class, waitFor(), guard);
      }
    
      public void testNulls() {
        monitor.enter(); // Inhibit IllegalMonitorStateException
        new NullPointerTester()
            .setDefault(Monitor.Guard.class, new TestGuard(true))
            .testAllPublicInstanceMethods(monitor);
      }
    
      // TODO: Test enter(long, TimeUnit).
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Apr 26 20:07:17 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  5. src/syscall/syscall_windows_test.go

    	if err != nil {
    		t.Skipf("MkdirAll failed: %v", err)
    	}
    	err = os.Chdir(dirname)
    	if err != nil {
    		t.Skipf("Chdir failed: %v", err)
    	}
    	// Change out of the temporary directory so that we don't inhibit its
    	// removal during test cleanup.
    	defer os.Chdir(`\`)
    
    	syscall.Getwd()
    }
    
    func TestGetStartupInfo(t *testing.T) {
    	var si syscall.StartupInfo
    	err := syscall.GetStartupInfo(&si)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Aug 17 16:33:09 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  6. src/regexp/backtrack.go

    			//   b.push(inst.Out, pos, false)
    			//   b.push(inst.Arg, pos, false)
    			// If during the processing of inst.Out, we encounter
    			// inst.Arg via another path, we want to process it then.
    			// Pushing it here will inhibit that. Instead, re-push
    			// inst with arg==true as a reminder to push inst.Arg out
    			// later.
    			if arg {
    				// Finished inst.Out; try inst.Arg.
    				arg = false
    				pc = inst.Arg
    				goto CheckAndLoop
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Sep 14 17:25:39 UTC 2023
    - 8.8K bytes
    - Viewed (0)
  7. pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux_test.go

    				assert.Equal(t, tc.expectedPodToGracePeriodOverride, killedPodsToGracePeriods)
    				assert.Equal(t, tc.expectedDidOverrideInhibitDelay, fakeDbus.didOverrideInhibitDelay, "override system inhibit delay differs")
    				if tc.expectedPodStatuses != nil {
    					for _, pod := range tc.activePods {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  8. src/runtime/mgclimit.go

    // license that can be found in the LICENSE file.
    
    package runtime
    
    import "internal/runtime/atomic"
    
    // gcCPULimiter is a mechanism to limit GC CPU utilization in situations
    // where it might become excessive and inhibit application progress (e.g.
    // a death spiral).
    //
    // The core of the limiter is a leaky bucket mechanism that fills with GC
    // CPU time and drains with mutator time. Because the bucket fills and
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 22 22:07:41 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  9. src/cmd/vendor/golang.org/x/arch/x86/x86asm/gnu.go

    			continue
    		}
    		args = append(args, gnuArg(&inst, pc, symname, a, &usedPrefixes))
    	}
    
    	// The default is to print the arguments in reverse Intel order.
    	// A few instructions inhibit this behavior.
    	switch inst.Op {
    	case BOUND, LCALL, ENTER, LJMP:
    		// no reverse
    	default:
    		// reverse args
    		for i, j := 0, len(args)-1; i < j; i, j = i+1, j-1 {
    			args[i], args[j] = args[j], args[i]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 21.4K bytes
    - Viewed (0)
  10. src/net/dial_test.go

    	testHookDialTCP = func(ctx context.Context, net string, laddr, raddr *TCPAddr) (*TCPConn, error) {
    		// Wait until Happy Eyeballs kicks in and both connections are dialing,
    		// and inhibit cancellation.
    		// This forces dialParallel to juggle two successful connections.
    		dialing.Done()
    		dialing.Wait()
    
    		// Now ignore the provided context (which will be canceled) and use a
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 30.3K bytes
    - Viewed (0)
Back to top