- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 6,976 for waiting (2.8 sec)
-
docs/es/docs/tutorial/first-steps.md
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 20:41:43 UTC 2025 - 13.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// being resumed. To avoid a flake in this scenario, calculate how long that thread actually // waited and assert based on that time. Empirically, the race where the thread ends up waiting // for 5.5 seconds happens about 2% of the time. boolean longWait = NANOSECONDS.toSeconds(thread.timeSpentBlocked) >= 5; // Count how long it actually took to return; we'll accept any number between the expected delayRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:45:32 UTC 2025 - 46.8K bytes - Viewed (0) -
cmd/endpoint.go
"elapsed", "", )) ctx := logger.SetReqInfo(GlobalContext, reqInfo) bootLogOnceIf(ctx, fmt.Errorf("%s resolves to localhost in a containerized deployment, waiting for it to resolve to a valid IP", endpoints[i].Hostname()), endpoints[i].Hostname(), logger.ErrorKind) } continue } // return err if not Docker or Kubernetes
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 34.5K bytes - Viewed (0) -
internal/config/notify/help.go
Optional: true, Type: "on|off", }, config.HelpKV{ Key: target.NATSStreamingMaxPubAcksInFlight, Description: "[DEPRECATED] number of messages to publish without waiting for ACKs", Optional: true, Type: "number", }, config.HelpKV{ Key: target.NATSStreamingClusterID, Description: "[DEPRECATED] unique ID for NATS streaming cluster",Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 19.2K bytes - Viewed (0) -
internal/lru/lru.go
c.evictList.Remove(e) delete(c.items, e.Key) c.removeFromBucket(e) if c.onEvict != nil { c.onEvict(e.Key, e.Value) } } // deleteExpired deletes expired records from the oldest bucket, waiting for the newest entry // in it to expire first. func (c *LRU[K, V]) deleteExpired() { c.mu.Lock() bucketIdx := c.nextCleanupBucket timeToExpire := time.Until(c.buckets[bucketIdx].newestEntry)
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Fri Apr 25 08:22:26 UTC 2025 - 12.5K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
// Even if Read returns n < len(p), it may use all of p as scratch space during the call. // If some data is available but not len(p) bytes, Read conventionally returns what is available instead of waiting for more. // When Read encounters an error or end-of-file condition after successfully reading n > 0 bytes, it returns the number of bytes read.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 13.3K bytes - Viewed (0) -
docs/ja/docs/tutorial/first-steps.md
<span style="color: green;">INFO</span>: Started reloader process [28720] <span style="color: green;">INFO</span>: Started server process [28722] <span style="color: green;">INFO</span>: Waiting for application startup. <span style="color: green;">INFO</span>: Application startup complete. ``` </div> /// note | 備考 `uvicorn main:app`は以下を示します: * `main`: `main.py`ファイル (Python "module")。
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Oct 11 17:48:49 UTC 2025 - 11K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
timeout = resp.getExpiration() - System.currentTimeMillis(); if (timeout <= 0) { throw new TransportException(this + " timedout waiting for response to " + req); } } else { resp.wait(); if (log.isTraceEnabled()) {
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 69.8K bytes - Viewed (0) -
CHANGELOG.md
use it to compose a cache URL from the query body. * New: Publish events when calls must wait to execute. `EventListener.dispatcherQueueStart()` is invoked when a call starts waiting, and `dispatcherQueueEnd()` is invoked when it's done. * New: `Request.toCurl()` returns a copy-pasteable [curl] command consistent with Chrome’s and Firefox’s ‘copy as cURL’ features.
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 05 16:02:59 UTC 2025 - 36.2K bytes - Viewed (2) -
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java
* @param reader The supplier for DocumentReader. * @param docPerReq The number of documents to process per request. * @param waitController The runnable to control waiting between requests. * @return A Promise that will be resolved with the SuggestIndexResponse or rejected with an error. */Registered: Sat Dec 20 13:04:59 UTC 2025 - Last Modified: Mon Nov 24 03:40:05 UTC 2025 - 34.4K bytes - Viewed (0)