- Sort Score
- Num 10 results
- Language All
Results 171 - 180 of 254 for WAITING (0.07 seconds)
-
docs/es/docs/tutorial/first-steps.md
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 13.3K bytes - Click Count (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
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.5K bytes - Click Count (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 delayCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:45:32 GMT 2025 - 46.8K bytes - Click Count (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",Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 19.2K bytes - Click Count (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)
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Fri Apr 25 08:22:26 GMT 2025 - 12.5K bytes - Click Count (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.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.3K bytes - Click Count (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")。
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Oct 11 17:48:49 GMT 2025 - 11K bytes - Click Count (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.
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 05 16:02:59 GMT 2025 - 36.2K bytes - Click Count (2) -
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()) {
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 69.8K bytes - Click Count (0) -
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. */Created: Sat Dec 20 13:04:59 GMT 2025 - Last Modified: Mon Nov 24 03:40:05 GMT 2025 - 34.4K bytes - Click Count (0)