- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 479 for Sait (0.23 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
override fun coordinatorNotify(taskRunner: TaskRunner) { taskRunner.condition.signal() } /** * Wait a duration in nanoseconds. Unlike [java.lang.Object.wait] this interprets 0 as * "don't wait" instead of "wait forever". */ @Throws(InterruptedException::class) @Suppress("PLATFORM_CLASS_MAPPED_TO_KOTLIN") override fun coordinatorWait(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/QueuesTest.java
private void assertInterruptibleDrained(BlockingQueue<Object> q) { // nothing to drain, thus this should wait doing nothing try { assertEquals(0, Queues.drain(q, ImmutableList.of(), 0, 10, MILLISECONDS)); } catch (InterruptedException e) { throw new AssertionError(); } // but does the wait actually occurs? @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/QueuesTest.java
private void assertInterruptibleDrained(BlockingQueue<Object> q) { // nothing to drain, thus this should wait doing nothing try { assertEquals(0, Queues.drain(q, ImmutableList.of(), 0, 10, MILLISECONDS)); } catch (InterruptedException e) { throw new AssertionError(); } // but does the wait actually occurs? @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
Example: ` # Apply a waypoint to the current namespace istioctl x waypoint apply # Apply a waypoint to a specific namespace and wait for it to be ready istioctl x waypoint apply --namespace default --wait`, RunE: func(cmd *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClientWithRevision(revision) if err != nil {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:40 GMT 2024 - 15K bytes - Viewed (0) -
buildscripts/verify-healing-with-root-disks.sh
args+=("http://localhost:$((start_port + i))${WORK_DIR}/mnt/disk$i/ ") done for i in $(seq 1 4); do "${MINIO[@]}" --address ":$((start_port + i))" ${args[@]} 2>&1 >"${WORK_DIR}/server$i.log" & done # Wait until all nodes return 403 for i in $(seq 1 4); do while [ "$(curl -m 1 -s -o /dev/null -w "%{http_code}" http://localhost:$((start_port + i)))" -ne "403" ]; do echo -n "." sleep 1 done done }
Shell Script - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri May 26 05:07:25 GMT 2023 - 2.2K 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,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
cmd/admin-heal-ops.go
fmt.Printf("Task in the queue: %#v\n", task) } default: // task queue is full, no more workers, we shall move on and heal later. return nil } // Don't wait for result return nil } // respCh must be set to wait for result. // We make it size 1, so a result can always be written // even if we aren't listening. task.respCh = make(chan healResult, 1) select {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
docs/en/docs/async.md
```Python hl_lines="2" @app.get('/') def results(): results = some_library() return results ``` --- If your application (somehow) doesn't have to communicate with anything else and wait for it to respond, use `async def`. --- If you just don't know, use normal `def`. ---
Plain Text - Registered: Sun Apr 21 07:19:11 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 23K bytes - Viewed (0) -
cmd/data-scanner.go
// proceed to heal nonetheless, since // this object might be dangling. entry, _ = entries.firstFound() } wait := noWait if f.weSleep() { // wait timer per object. wait = scannerSleeper.Timer(ctx) } defer wait() f.updateCurrentPath(entry.name) stopFn := globalScannerMetrics.log(scannerMetricHealAbandonedObject, f.root, entry.name)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 09:40:19 GMT 2024 - 46.9K bytes - Viewed (0) -
cmd/background-heal-ops.go
// while counting the number of concurrent connections return int(globalHTTPListen.Subscribers()) + int(globalTrace.Subscribers()) } func waitForLowIO(maxIO int, maxWait time.Duration, currentIO func() int) { // No need to wait run at full speed. if maxIO <= 0 { return } const waitTick = 100 * time.Millisecond tmpMaxWait := maxWait for currentIO() >= maxIO { if tmpMaxWait > 0 { if tmpMaxWait < waitTick {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0)