Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 556 for sleeps (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top