Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 473 for _timeout (0.04 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/SpecificHostSocketFactory.kt

          override fun connect(
            endpoint: SocketAddress?,
            timeout: Int,
          ) {
            val requested = (endpoint as InetSocketAddress)
            val inetSocketAddress = hostMapping[requested.address] ?: defaultAddress ?: requested
            Platform.get().log("Socket connection to: $inetSocketAddress was: $requested")
            super.connect(inetSocketAddress, timeout)
          }
        }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  2. tests/compose.yml

            fi;
            echo "Waiting for database to be ready... ($$counter/12)";
            sleep 5;
            counter=$$(($$counter + 1));
          done;
          # timeout handling
          if [ $$counter -gt 20 ]; then
            echo "Error: Database failed to start within timeout";
            exit 1;
          fi;
          # keep the container running: wait for the database process in the foreground
          wait
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Mon Aug 04 04:07:30 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/SmbComTransaction.java

                    + ",maxParameterCount=" + maxParameterCount + ",maxDataCount=" + maxDataCount + ",maxSetupCount=" + (int) maxSetupCount
                    + ",flags=0x" + Hexdump.toHexString(flags, 2) + ",timeout=" + timeout + ",parameterCount=" + parameterCount
                    + ",parameterOffset=" + parameterOffset + ",parameterDisplacement=" + parameterDisplacement + ",dataCount=" + dataCount
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

         * @throws CancellationException {@inheritDoc}
         */
        @CanIgnoreReturnValue
        @Override
        public V get(long timeout, TimeUnit unit)
            throws InterruptedException, TimeoutException, ExecutionException {
          return sync.get(unit.toNanos(timeout));
        }
    
        /*
         * Improve the documentation of when InterruptedException is thrown. Our
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jan 30 16:59:10 UTC 2025
    - 13.7K bytes
    - Viewed (0)
  5. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java

        super.connect(new UnixSocketAddress(path), 0);
      }
    
      @Override public void connect(SocketAddress endpoint, int timeout) throws IOException {
        this.inetSocketAddress = (InetSocketAddress) endpoint;
        super.connect(new UnixSocketAddress(path), timeout);
      }
    
      @Override public InetAddress getInetAddress() {
        return inetSocketAddress.getAddress();
      }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Feb 12 16:33:52 UTC 2019
    - 1.9K bytes
    - Viewed (0)
  6. src/test/java/jcifs/util/SimpleCircuitBreakerTest.java

        }
    
        @Test
        @DisplayName("Test transition to HALF_OPEN after timeout")
        void testTransitionToHalfOpen() throws Exception {
            // Open the circuit
            circuitBreaker.tripBreaker();
            assertEquals(SimpleCircuitBreaker.State.OPEN, circuitBreaker.getState());
    
            // Wait for timeout
            Thread.sleep(150);
    
            // Next call should transition to HALF_OPEN
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 10.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/Platform.java

        return future.blockingGet();
      }
    
      static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
        return future.blockingGet(timeout, unit);
      }
    
      private Platform() {}
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  8. src/test/java/jcifs/internal/smb1/com/SmbComLockingAndXTest.java

            // set fields via reflection
            setField(cmd, "fid", 0x1234);
            setField(cmd, "typeOfLock", (byte) 0x05);
            setField(cmd, "newOpLockLevel", (byte) 0x01);
            setField(cmd, "timeout", 3000L);
            // arrays of one lock and one unlock range
            LockingAndXRange lock = new LockingAndXRange(false);
            lock.encode(new byte[20], 0); // initialise fields by encoding to set pid etc (though not needed)
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  9. src/main/java/jcifs/netbios/NameServiceClientImpl.java

            }
            return this.nextNameTrnId;
        }
    
        void ensureOpen(final int timeout) throws IOException {
            this.closeTimeout = 0;
            if (this.transportContext.getConfig().getNetbiosSoTimeout() != 0) {
                this.closeTimeout = Math.max(this.transportContext.getConfig().getNetbiosSoTimeout(), timeout);
            }
            // If socket is still good, the new closeTimeout will
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 38.5K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb2/rdma/disni/DisniRdmaConnection.java

                // RdmaCompletionEvent event = endpoint.getCqProcessor().getCqEvent(timeout);
                // if (event != null) {
                //     return event.getBuffer();
                // }
                // return null;
    
                // For skeleton implementation, return null (timeout)
                return null;
    
            } catch (Exception e) {
                state = RdmaConnectionState.ERROR;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 10.2K bytes
    - Viewed (0)
Back to top