Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 251 - 260 of 550 for timedout (0.07 seconds)

  1. guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

          monitor.leave();
        }
      }
    
      @CanIgnoreReturnValue // pushed down from class to method
      @Override
      public @Nullable E poll(long timeout, TimeUnit unit) throws InterruptedException {
        Monitor monitor = this.monitor;
        if (monitor.enterWhen(notEmpty, timeout, unit)) {
          try {
            return q.poll();
          } finally {
            monitor.leave();
          }
        } else {
          return null;
        }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 19K bytes
    - Click Count (0)
  2. src/test/java/jcifs/smb/SmbCopyUtilTest.java

    import static org.mockito.Mockito.doThrow;
    import static org.mockito.Mockito.lenient;
    import static org.mockito.Mockito.mock;
    import static org.mockito.Mockito.never;
    import static org.mockito.Mockito.timeout;
    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verify;
    import static org.mockito.Mockito.when;
    
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Nested;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

              public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
                delegate.awaitRunning(timeout, unit);
              }
    
              @Override
              public final void awaitTerminated() {
                delegate.awaitTerminated();
              }
    
              @Override
              public final void awaitTerminated(long timeout, TimeUnit unit) throws TimeoutException {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 25.6K bytes
    - Click Count (0)
  4. CHANGELOG/CHANGELOG-1.18.md

     
    #### kube-proxy:
    - Added kube-proxy flags `--ipvs-tcp-timeout`, `--ipvs-tcpfin-timeout`, `--ipvs-udp-timeout` to configure IPVS connection timeouts. ([#85517](https://github.com/kubernetes/kubernetes/pull/85517), [@andrewsykim](https://github.com/andrewsykim)) [SIG Cluster Lifecycle and Network]
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Wed Jun 16 17:18:28 GMT 2021
    - 373.2K bytes
    - Click Count (0)
  5. src/main/java/jcifs/util/transport/RequestTimeoutException.java

     */
    package jcifs.util.transport;
    
    /**
     * Exception thrown when a request times out during SMB communication.
     * Indicates that a request could not be completed within the specified timeout period.
     *
     * @author mbechler
     */
    public class RequestTimeoutException extends TransportException {
    
        /**
         *
         */
        private static final long serialVersionUID = -8825922797594232534L;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2K bytes
    - Click Count (0)
  6. internal/kms/kes.go

    		}
    	}
    
    	list := make([]madmin.KMSAPI, 0, len(APIs))
    	for _, api := range APIs {
    		list = append(list, madmin.KMSAPI{
    			Method:  api.Method,
    			Path:    api.Path,
    			MaxBody: api.MaxBody,
    			Timeout: int64(api.Timeout.Truncate(time.Second).Seconds()),
    		})
    	}
    	return list, nil
    }
    
    // Stat returns the current KES status containing a
    // list of KES endpoints and the default key ID.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Aug 18 06:43:03 GMT 2024
    - 7.3K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt

    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Disabled
    import org.junit.jupiter.api.Tag
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    import org.junit.jupiter.api.assertThrows
    import org.junit.jupiter.api.extension.RegisterExtension
    
    @Timeout(30)
    @Tag("Slowish")
    class ServerTruncatesRequestTest {
      @RegisterExtension
      @JvmField
      val platform = PlatformRule()
    
      @RegisterExtension
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 11:54:15 GMT 2026
    - 10.7K bytes
    - Click Count (0)
  8. src/main/java/jcifs/internal/smb2/persistent/HandleType.java

         * No durability - standard handle
         */
        NONE(0),
    
        /**
         * SMB 2.1 durable handle - survives network loss
         */
        DURABLE_V1(1),
    
        /**
         * SMB 3.0 durable handle V2 - with timeout configuration
         */
        DURABLE_V2(2),
    
        /**
         * SMB 3.0 persistent handle - survives server reboot
         */
        PERSISTENT(3);
    
        private final int value;
    
        HandleType(int value) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 04:51:33 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/ConnectionReuseTest.kt

    import okhttp3.tls.HandshakeCertificates
    import org.bouncycastle.tls.TlsFatalAlert
    import org.junit.jupiter.api.Tag
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    import org.junit.jupiter.api.extension.RegisterExtension
    
    @Timeout(30)
    @Tag("Slowish")
    class ConnectionReuseTest {
      @RegisterExtension
      val platform: PlatformRule = PlatformRule()
    
      @RegisterExtension
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 12.3K bytes
    - Click Count (1)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        private final AbstractFuture<?> future;
        private final long timeout;
        private final TimeUnit unit;
        private Exception exception;
        private volatile long startTime;
        private long timeSpentBlocked;
    
        TimedWaiterThread(AbstractFuture<?> future, long timeout, TimeUnit unit) {
          this.future = future;
          this.timeout = timeout;
          this.unit = unit;
        }
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
Back to Top