Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 1,377 for waitc (0.04 sec)

  1. src/math/tanh.go

    //      MAXLOG = 8.8029691931113054295988e+01 = log(2**127)
    //      MINLOG = -8.872283911167299960540e+01 = log(2**-128)
    //
    // A rational function is used for |x| < 0.625.  The form
    // x + x**3 P(x)/Q(x) of Cody & Waite is employed.
    // Otherwise,
    //      tanh(x) = sinh(x)/cosh(x) = 1  -  2/(exp(2x) + 1).
    //
    // ACCURACY:
    //
    //                      Relative error:
    // arithmetic   domain     # trials      peak         rms
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 11 16:34:30 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/lifecycle_signals.go

     	- the HTTP Server stops listening immediately
    	- any new request arriving on a new TCP socket is denied with
          a network error similar to 'connection refused'
        - the HTTP Server waits gracefully for existing requests to complete
          up to '60s' (dictated by ShutdownTimeout)
    	- active long running requests will receive a GOAWAY.
    
    T0+70s: HTTPServerStoppedListening:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 27 15:49:30 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  3. pkg/util/iptables/iptables.go

    // WaitString a constant for specifying the wait flag
    const WaitString = "-w"
    
    // WaitSecondsValue a constant for specifying the default wait seconds
    const WaitSecondsValue = "5"
    
    // WaitIntervalString a constant for specifying the wait interval flag
    const WaitIntervalString = "-W"
    
    // WaitIntervalUsecondsValue a constant for specifying the default wait interval useconds
    const WaitIntervalUsecondsValue = "100000"
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 19 01:20:51 UTC 2023
    - 28.6K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apimachinery/pkg/util/waitgroup/ratelimited_waitgroup.go

    	wg sync.WaitGroup
    	// Once Wait is initiated, all consecutive Done invocation will be
    	// rate limited using this rate limiter.
    	limiter RateLimiter
    	stopCtx context.Context
    
    	mu sync.Mutex
    	// wait indicate whether Wait is called, if true,
    	// then any Add with positive delta will return error.
    	wait bool
    	// number of request(s) currently using the wait group
    	count int
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 21 14:08:00 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  5. src/cmd/vendor/golang.org/x/sys/unix/zsysnum_dragonfly_amd64.go

    	SYS_OPEN  = 5 // { int open(char *path, int flags, int mode); }
    	SYS_CLOSE = 6 // { int close(int fd); }
    	SYS_WAIT4 = 7 // { int wait4(int pid, int *status, int options, struct rusage *rusage); } wait4 wait_args int
    	// SYS_NOSYS = 8;  // { int nosys(void); } __nosys nosys_args int
    	SYS_LINK                   = 9   // { int link(char *path, char *link); }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 27.6K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apimachinery/pkg/util/waitgroup/ratelimited_waitgroup_test.go

    			target.Add(1)
    		}()
    	}
    	wg.Wait()
    
    	waitingCh := make(chan struct{})
    	wg.Add(n)
    	for i := 0; i < n; i++ {
    		go func() {
    			defer wg.Done()
    
    			<-waitingCh
    			target.Done()
    		}()
    	}
    	defer wg.Wait()
    
    	now := time.Now()
    	t.Logf("Wait starting, N=%d, grace: %s, at: %s", n, grace, now)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 21 14:08:00 UTC 2023
    - 8.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/TestThread.java

      /**
       * Asserts that a prior call that had caused this thread to block or wait has since returned
       * normally.
       */
      public void assertPriorCallReturns(@Nullable String methodName) throws Exception {
        assertEquals(null, getResponse(methodName).getResult());
      }
    
      /**
       * Asserts that a prior call that had caused this thread to block or wait has since returned the
       * expected boolean value.
       */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/util/waitgroup/waitgroup.go

    	defer wg.mu.RUnlock()
    	if wg.wait && delta > 0 {
    		return fmt.Errorf("add with positive delta after Wait is forbidden")
    	}
    	wg.wg.Add(delta)
    	return nil
    }
    
    // Done decrements the WaitGroup counter.
    func (wg *SafeWaitGroup) Done() {
    	wg.wg.Done()
    }
    
    // Wait blocks until the WaitGroup counter is zero.
    func (wg *SafeWaitGroup) Wait() {
    	wg.mu.Lock()
    	wg.wait = true
    	wg.mu.Unlock()
    	wg.wg.Wait()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Feb 11 03:04:14 UTC 2018
    - 1.5K bytes
    - Viewed (0)
  9. platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/continuous/ContinuousBuildGateIntegrationTest.groovy

            and:
            // command the gate keeper to open the gate and shutdown
            command.releaseAll()
            server.expect(server.get("command").send("stop"))
            then:
            // waits for build to start and finish
            buildTriggeredAndSucceeded()
            // Change has been incorporated
            outputFile.text == "changed"
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  10. pkg/proxy/config/config.go

    func (c *EndpointSliceConfig) RegisterEventHandler(handler EndpointSliceHandler) {
    	c.eventHandlers = append(c.eventHandlers, handler)
    }
    
    // Run waits for cache synced and invokes handlers after syncing.
    func (c *EndpointSliceConfig) Run(stopCh <-chan struct{}) {
    	c.logger.Info("Starting endpoint slice config controller")
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 15.1K bytes
    - Viewed (0)
Back to top