Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 161 - 170 of 556 for Timeout (0.06 seconds)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

        private var editCount = 0
    
        override fun poll(): T = delegate.poll()
    
        override fun poll(
          timeout: Long,
          unit: TimeUnit,
        ): T? {
          return taskRunner.withLock {
            val waitUntil = nanoTime + unit.toNanos(timeout)
            while (true) {
              val result = poll()
              if (result != null) return@withLock result
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 11.9K bytes
    - Click Count (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/Hc4HttpClient.java

        private TimeoutTask connectionMonitorTask;
    
        /** Connection timeout in milliseconds */
        protected Integer connectionTimeout;
    
        /** Maximum total number of connections */
        protected Integer maxTotalConnections;
    
        /** Maximum connections per route */
        protected Integer maxConnectionsPerRoute;
    
        /** Socket timeout in milliseconds */
        protected Integer soTimeout;
    
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Fri Jan 09 23:46:52 GMT 2026
    - 54.4K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/ForwardingFuture.java

        return delegate().get();
      }
    
      @Override
      @CanIgnoreReturnValue
      @ParametricNullness
      public V get(long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
        return delegate().get(timeout, unit);
      }
    
      // TODO(cpovirk): Use standard Javadoc form for SimpleForwarding* class and constructor
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 3.6K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/core/timer/TimeoutTarget.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.core.timer;
    
    /**
     * This is an interface for handling timeouts.
     *
     * @author higa
     *
     */
    @FunctionalInterface
    public interface TimeoutTarget {
    
        /**
         * Describes the processing for a timeout.
         */
        void expired();
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Sat May 10 01:32:17 GMT 2025
    - 872 bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/ExchangeCodec.kt

          call: RealCall,
          e: IOException?,
        )
    
        fun noNewExchanges()
    
        fun cancel()
      }
    
      companion object {
        /**
         * The timeout to use while discarding a stream of input data. Since this is used for connection
         * reuse, this timeout should be significantly less than the time it takes to establish a new
         * connection.
         */
        const val DISCARD_STREAM_TIMEOUT_MILLIS = 100
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jul 29 21:11:09 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  6. internal/http/dial_linux.go

    				// ~ cat /proc/sys/net/ipv4/tcp_keepalive_intvl (defaults to 75 secs, we reduce it to 15 secs)
    				_ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPINTVL, 15)
    			}
    
    			// Set tcp user timeout in addition to the keep-alive - tcp-keepalive is not enough to close a socket
    			// with dead end because tcp-keepalive is not fired when there is data in the socket buffer.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jul 23 10:53:03 GMT 2024
    - 5K bytes
    - Click Count (0)
  7. src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaConnection.java

            }
        }
    
        @Override
        public ByteBuffer receive(int timeout) throws IOException {
            if (state != RdmaConnectionState.ESTABLISHED && state != RdmaConnectionState.CONNECTED) {
                throw new IOException("Connection not established");
            }
    
            try {
                socket.setSoTimeout(timeout);
    
                // First, read the header to determine message size
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  8. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt

      @Throws(InterruptedException::class)
      fun takeRequest(): RecordedRequest = delegate.takeRequest().unwrap()
    
      @Throws(InterruptedException::class)
      fun takeRequest(
        timeout: Long,
        unit: TimeUnit,
      ): RecordedRequest? = delegate.takeRequest(timeout, unit)?.unwrap()
    
      @JvmName("-deprecated_requestCount")
      fun getRequestCount(): Int = delegate.requestCount
    
      fun enqueue(response: MockResponse) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Jun 18 00:19:42 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  9. src/test/java/jcifs/SmbWatchHandleTest.java

                    // Do nothing
                }
            };
    
            // Execute with timeout
            ExecutorService executor = Executors.newSingleThreadExecutor();
            try {
                Future<List<FileNotifyInformation>> future = executor.submit(() -> blockingHandle.watch());
    
                // Verify timeout occurs
                assertThrows(TimeoutException.class, () -> {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 13.2K bytes
    - Click Count (1)
  10. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

       * given time.
       *
       * @param timeout how long to wait before giving up, in units of [unit]
       * @param unit a [TimeUnit] determining how to interpret the [timeout] parameter
       * @return the head of the request queue
       */
      @Throws(InterruptedException::class)
      public fun takeRequest(
        timeout: Long,
        unit: TimeUnit,
      ): RecordedRequest? = requestQueue.poll(timeout, unit)
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 40.3K bytes
    - Click Count (0)
Back to Top