- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 523 for kuwait (0.09 sec)
-
android/guava/src/com/google/common/collect/Queues.java
* numElements} elements are not available, it will wait for them up to the specified timeout. * * @param q the blocking queue to be drained * @param buffer where to add the transferred elements * @param numElements the number of elements to be waited for * @param timeout how long to wait before giving up * @return the number of elements transferred
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 18.3K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt
} /** For testing: force this web socket to release its threads. */ @Throws(InterruptedException::class) fun tearDown() { taskQueue.shutdown() taskQueue.idleLatch().await(10, TimeUnit.SECONDS) } @Synchronized fun sentPingCount(): Int = sentPingCount @Synchronized fun receivedPingCount(): Int = receivedPingCount
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 21.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt
override fun responseHeadersEnd( call: Call, response: Response, ) { try { // Wait for the server to send the duplex response before acting on the 301 response // and resetting the stream. duplexResponseSent.await() } catch (e: InterruptedException) { throw AssertionError() }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 24.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Service.java
*/ void awaitRunning(); /** * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no more * than the given time. * * @param timeout the maximum time to wait * @throws TimeoutException if the service has not reached the given state within the deadline * @throws IllegalStateException if the service reaches a state from which it is not possible to
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 03:10:51 UTC 2024 - 12.2K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java
awaitTermination(0); } /** * Waits for the crawling process to terminate for a specified duration. * @param millis The maximum time to wait in milliseconds. A value of 0 means wait indefinitely. */ public void awaitTermination(final long millis) { if (parentThread != null) { try { parentThread.join(millis);
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 14K bytes - Viewed (0) -
cmd/data-usage.go
return map[string]uint64{}, nil } cache := dataUsageCache{} prefixUsageCache.InitOnce(30*time.Second, // No need to fail upon Update() error, fallback to old value. cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func(ctx context.Context) (map[string]uint64, error) { m := make(map[string]uint64) for _, pool := range z.serverPools { for _, er := range pool.sets { // Load bucket usage prefixes
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 5.6K bytes - Viewed (0) -
cmd/perf-tests.go
atomic.AddUint64(&totalBytesWritten, uint64(info.Size)) objCountPerThread[i]++ mu.Lock() uploadTimes = append(uploadTimes, response) mu.Unlock() } }(i) } wg.Wait() // We already saw write failures, no need to proceed into read's if retError != "" { return SpeedTestResult{ Uploads: totalBytesWritten, Downloads: totalBytesRead, UploadTimes: uploadTimes,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.7K bytes - Viewed (0) -
.github/dependabot.yml
version: 2 updates: # TODO(b/170636568): Enable Maven updates? Perhaps wait until we can more # easily import the generated PRs into our internal repo. # - package-ecosystem: "maven" # directory: "/" # schedule: # interval: "weekly" # groups: # dependencies: # applies-to: version-updates # patterns: # - "*" # - package-ecosystem: "maven" # directory: "/android" # schedule:
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Mar 21 21:15:53 UTC 2025 - 762 bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* than the given time. The manager will become healthy after all the component services have * reached the {@linkplain State#RUNNING running} state. * * @param timeout the maximum time to wait * @throws TimeoutException if not all of the services have finished starting within the deadline * @throws IllegalStateException if the service manager reaches a state from which it cannot
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 33.2K bytes - Viewed (1) -
cmd/untar.go
return err } } header, err := tarReader.Next() switch { // if no more files are found return case err == io.EOF: wg.Wait() return asyncErr // return any other error case err != nil: wg.Wait() extra := "" if n > 0 { extra = fmt.Sprintf(" after %d successful object(s)", n) } return fmt.Errorf("tar file error: %w%s", err, extra)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 6K bytes - Viewed (2)