- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 556 for sleeps (0.21 sec)
-
mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt
} fun shutdownOutput() { javaNetSocket.shutdownOutput() } /** Sleeps [nanos], throwing if the socket is closed before that period has elapsed. */ fun sleepWhileOpen(nanos: Long) { var ms = nanos / 1_000_000L val ns = nanos - (ms * 1_000_000L) while (ms > 100) { Thread.sleep(100) if (javaNetSocket.isClosed) throw InterruptedIOException("socket closed") ms -= 100L
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 3.3K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/ThrottledSink.kt
* See the License for the specific language governing permissions and * limitations under the License. * */ package mockwebserver3.internal import okio.Buffer import okio.Sink /** * A sink that sleeps [periodDelayNanos] every [bytesPerPeriod] bytes. Unlike [okio.Throttler], * this permits any interval to be used. */ internal class ThrottledSink( private val socket: MockWebServerSocket, private val delegate: Sink,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 12:43:16 UTC 2025 - 1.5K bytes - Viewed (0) -
ci/official/utilities/setup_docker.sh
if [[ "$TFCI_DOCKER_PULL_ENABLE" == 1 ]]; then # Simple retry logic for docker-pull errors. Sleeps if a pull fails. # Pulling an already-pulled container image will finish instantly, so # repeating the command costs nothing. docker pull "$TFCI_DOCKER_IMAGE" || sleep 15 docker pull "$TFCI_DOCKER_IMAGE" || sleep 30 docker pull "$TFCI_DOCKER_IMAGE" || sleep 60 docker pull "$TFCI_DOCKER_IMAGE" fi
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Thu Jan 09 18:37:25 UTC 2025 - 2.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/auth/chain/CommandChain.java
} } currentProcess = null; } } /** * Monitor thread that handles process timeout and termination. * This thread sleeps for the specified timeout duration and terminates the process if it hasn't finished. */ protected static class MonitorThread extends Thread { /** The process to monitor. */
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 13.1K bytes - Viewed (0) -
cmd/data-scanner.go
t := time.Now() return func() { doneAt := time.Now() d.Sleep(ctx, doneAt.Sub(t)) } } // Sleep sleeps the specified time multiplied by the sleep factor. // If the factor is updated the sleep will be done again with the new factor. func (d *dynamicSleeper) Sleep(ctx context.Context, base time.Duration) { for { // Grab current values d.mu.RLock()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.5K bytes - Viewed (0) -
cmd/utils.go
return len(s) >= len(prefix) && (s[0:len(prefix)] == prefix || strings.EqualFold(s[0:len(prefix)], prefix)) } func ptr[T any](a T) *T { return &a } // sleepContext sleeps for d duration or until ctx is done. func sleepContext(ctx context.Context, d time.Duration) error { select { case <-ctx.Done(): return ctx.Err() case <-time.After(d): } return nil }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 33K bytes - Viewed (0) -
docs/en/docs/tutorial/first-steps.md
# First Steps { #first-steps } The simplest FastAPI file could look like this: {* ../../docs_src/first_steps/tutorial001.py *} Copy that to a file `main.py`. Run the live server: <div class="termy"> ```console $ <font color="#4E9A06">fastapi</font> dev <u style="text-decoration-style:solid">main.py</u> <span style="background-color:#009485"><font color="#D3D7CF"> FastAPI </font></span> Starting development server 🚀
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 11K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractorTest.java
private File createScriptTempFile(final int sleep) { String extention; String content; if (File.separator.equals("/")) { // Unix extention = ".sh"; content = "#!/bin/bash\nsleep " + sleep + ";cp $1 $2"; } else { // Windows extention = ".bat"; content = "ping localhost -n " + sleep + "\r\ncopy %1 %2"; } File file;
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Mar 15 06:52:00 UTC 2025 - 9.8K bytes - Viewed (0) -
docs/en/docs/tutorial/security/first-steps.md
# Security - First Steps { #security-first-steps } Let's imagine that you have your **backend** API in some domain. And you have a **frontend** in another domain or in a different path of the same domain (or in a mobile application). And you want to have a way for the frontend to authenticate with the backend, using a **username** and **password**. We can use **OAuth2** to build that with **FastAPI**.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 8.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
} } finally { if (interrupted) { Thread.currentThread().interrupt(); } } } // TODO(user): Support Sleeper somehow (wrapper or interface method)? /** * Invokes {@code unit.}{@link TimeUnit#sleep(long) sleep(sleepFor)} uninterruptibly. * * @since 33.4.0 (but since 28.0 in the JRE flavor) */ @J2ktIncompatible @GwtIncompatible // concurrency
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.8K bytes - Viewed (0)