Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 87 for _milliseconds (0.11 sec)

  1. internal/lsync/lrwmutex.go

    			lm.isWriteLock = true
    			locked = true
    		}
    	} else {
    		if !lm.isWriteLock {
    			lm.ref++
    			locked = true
    		}
    	}
    
    	return locked
    }
    
    const (
    	lockRetryInterval = 50 * time.Millisecond
    )
    
    // lockLoop will acquire either a read or a write lock
    //
    // The call will block until the lock is granted using a built-in
    // timing randomized back-off algorithm to try again until successful
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  2. internal/ringbuffer/ring_buffer_test.go

    		done := make(chan struct{})
    		go func() {
    			defer close(done)
    			time.Sleep(10 * time.Millisecond)
    			fn()
    		}()
    		rb.CloseWithError(errors.New("test error"))
    		<-done
    
    		rb.Reset()
    		done = make(chan struct{})
    		go func() {
    			defer close(done)
    			fn()
    		}()
    		time.Sleep(10 * time.Millisecond)
    		rb.CloseWithError(errors.New("test error"))
    		<-done
    	}
    	testCancel(func() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  3. cmd/metrics-v3-cache.go

    	m.writesKBPerSec = float64(ioStats.WriteSectors) * float64(sectorSize) / kib / durationSecs
    	if ioStats.WriteIOs > 0 {
    		m.writesAwait = float64(ioStats.WriteTicks) / float64(ioStats.WriteIOs)
    	}
    
    	// TotalTicks is in milliseconds
    	m.percUtil = float64(ioStats.TotalTicks) * 100 / (durationSecs * 1000)
    
    	return
    }
    
    func newDriveMetricsCache() *cachevalue.Cache[storageMetrics] {
    	var (
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  4. tensorflow/c/eager/c_api_experimental.cc

        status->status = tensorflow::errors::FailedPrecondition(
            "Coordination service is not enabled.");
        return;
      }
      absl::Duration timeout;
      if (timeout_in_ms > 0) {
        timeout = absl::Milliseconds(timeout_in_ms);
      } else {
        // Block until the key-value is set or the worker shuts down.
        timeout = absl::InfiniteDuration();
      }
      auto status_or_value = coord_agent->GetKeyValue(key, timeout);
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

            if (logger.isDebugEnabled()) {
                logger.debug("Executor Thread Pool: {}", nThreads);
            }
            return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(nThreads),
                    new ThreadPoolExecutor.CallerRunsPolicy());
        }
    
        @Override
        public void store(final DataStoreParams paramMap, final Map<String, Object> dataMap) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  6. internal/event/targetlist_test.go

    	return nil
    }
    
    func (target ExampleTarget) send(eventData Event) error {
    	b := make([]byte, 1)
    	if _, err := rand.Read(b); err != nil {
    		panic(err)
    	}
    
    	time.Sleep(time.Duration(b[0]) * time.Millisecond)
    
    	if target.sendErr {
    		return errors.New("send error")
    	}
    
    	return nil
    }
    
    // SendFromStore - interface compatible method does no-op.
    func (target *ExampleTarget) SendFromStore(_ store.Key) error {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  7. cmd/metacache-set.go

    	retries := 0
    	rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix))
    
    	const (
    		retryDelay    = 50 * time.Millisecond
    		retryDelay250 = 250 * time.Millisecond
    	)
    
    	for {
    		if contextCanceled(ctx) {
    			return entries, ctx.Err()
    		}
    
    		// If many failures, check the cache state.
    		if retries > 10 {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/sso/aad/AzureAdAuthenticator.java

                        context.acquireTokenByRefreshToken(refreshToken, new ClientCredential(getClientId(), getClientSecret()), null, null);
                final AuthenticationResult result = future.get(acquisitionTimeout, TimeUnit.MILLISECONDS);
                if (result == null) {
                    throw new SsoLoginException("authentication result was null");
                }
                return result;
            } catch (final Exception e) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 28.2K bytes
    - Viewed (0)
  9. cmd/listen-notification-handlers.go

    			return
    		}
    		t := time.NewTicker(time.Duration(pingInterval) * time.Second)
    		defer t.Stop()
    		emptyEventTicker = t.C
    	} else {
    		// Deprecated Apr 2023
    		t := time.NewTicker(500 * time.Millisecond)
    		defer t.Stop()
    		keepAliveTicker = t.C
    	}
    
    	enc := json.NewEncoder(w)
    	for {
    		select {
    		case ev := <-mergeCh:
    			_, err := w.Write(ev)
    			if err != nil {
    				return
    			}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  10. internal/rest/client.go

    		auth:                     auth,
    		connected:                connected,
    		lastConn:                 time.Now().UnixNano(),
    		MaxErrResponseSize:       4096,
    		HealthCheckReconnectUnit: 200 * time.Millisecond,
    		HealthCheckTimeout:       time.Second,
    	}
    	if err != nil {
    		clnt.lastErr = err
    		clnt.lastErrTime = time.Now()
    	}
    
    	if clnt.HealthCheckFn != nil {
    		// make connection pre-emptively.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
Back to top