Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 448 for timedOut (0.04 sec)

  1. docs/smb3-features/05-rdma-smb-direct-design.md

                throw new IOException("RDMA send failed", e);
            }
        }
        
        @Override
        public ByteBuffer receive(int timeout) throws IOException {
            try {
                RdmaCompletionEvent event = endpoint.getCqProcessor().getCqEvent(timeout);
                if (event != null) {
                    return event.getBuffer();
                }
                return null;
            } catch (Exception e) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

              // No client for CONNECT tunnels:
              client = null,
              carrier = this,
              socket = socket,
            )
          socket.source.timeout().timeout(readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
          socket.sink.timeout().timeout(writeTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
          tunnelCodec.writeRequest(nextRequest.headers, requestLine)
          tunnelCodec.finishRequest()
          val response =
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        }
    
        /**
         * Asserts that at least {@code timeout} has passed but the expected completion time has not.
         */
        void assertCompletionNotExpected(long timeout) {
          Preconditions.checkArgument(timeout < expectedCompletionWaitMillis);
          assertAtLeastTimePassed(stopwatch, timeout);
          assertTimeNotPassed(stopwatch, expectedCompletionWaitMillis);
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 31.7K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt

    import okhttp3.internal.http2.ErrorCode
    import okhttp3.testing.Flaky
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    import org.junit.jupiter.api.extension.RegisterExtension
    import org.junitpioneer.jupiter.RetryingTest
    import org.opentest4j.TestAbortedException
    
    /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/timer/TimeoutTask.java

        private final boolean permanent;
    
        private long startTime;
    
        private int status = ACTIVE;
    
        TimeoutTask(final TimeoutTarget timeoutTarget, final int timeout, final boolean permanent) {
            this.timeoutTarget = timeoutTarget;
            this.timeoutMillis = timeout * 1000L;
            this.permanent = permanent;
            this.startTime = System.currentTimeMillis();
        }
    
        /**
         * Returns whether the task has expired.
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  6. 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)
    
      /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 20:36:00 UTC 2025
    - 40.3K bytes
    - Viewed (0)
  7. cmd/xl-storage-disk-id-check.go

    		dctx, dcancel := context.WithCancel(ctx)
    		started := time.Now()
    		go func() {
    			timeout := time.NewTimer(globalDriveConfig.GetMaxTimeout())
    			select {
    			case <-dctx.Done():
    				if !timeout.Stop() {
    					<-timeout.C
    				}
    			case <-timeout.C:
    				spent := time.Since(started)
    				goOffline(fmt.Errorf("unable to write+read for %v", spent.Round(time.Millisecond)), spent)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/entity/SearchRenderData.java

        protected long currentEndRecordNumber;
    
        /** List of page numbers for pagination navigation. */
        protected List<String> pageNumberList;
    
        /** Flag indicating whether the results are partial due to timeout or other issues. */
        protected boolean partialResults;
    
        /** The actual search query executed against the search engine. */
        protected String searchQuery;
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

        protected final ConcurrentHashMap<String, JobProcess> runningProcessMap = new ConcurrentHashMap<>();
    
        /** Timeout in seconds for process destruction */
        protected int processDestroyTimeout = 10;
    
        /**
         * Default constructor for ProcessHelper.
         * Initializes the process management system with default timeout values.
         */
        public ProcessHelper() {
            // Default constructor
        }
    
        /**
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 9.8K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

              }
    
              sink.copyTo(cacheBody.buffer, sink.size - bytesRead, bytesRead)
              cacheBody.emitCompleteSegments()
              return bytesRead
            }
    
            override fun timeout(): Timeout = source.timeout()
    
            @Throws(IOException::class)
            override fun close() {
              if (!cacheRequestClosed &&
                !discard(ExchangeCodec.DISCARD_STREAM_TIMEOUT_MILLIS, MILLISECONDS)
              ) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 10.3K bytes
    - Viewed (0)
Back to top