Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 457 for ontimeout (0.06 sec)

  1. cmd/namespace-lock.go

    // Lock - block until write lock is taken or timeout has occurred.
    func (di *distLockInstance) GetLock(ctx context.Context, timeout *dynamicTimeout) (LockContext, error) {
    	lockSource := getSource(2)
    	start := UTCNow()
    
    	newCtx, cancel := context.WithCancel(ctx)
    	if !di.rwMutex.GetLock(newCtx, cancel, di.opsID, lockSource, dsync.Options{
    		Timeout:       timeout.Timeout(),
    		RetryInterval: timeout.RetryInterval(),
    	}) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/job/ExecJob.java

            return this;
        }
    
        /**
         * Sets the timeout for this job execution.
         *
         * @param timeout the timeout in seconds (-1 for no timeout)
         * @return this ExecJob instance for method chaining
         */
        public ExecJob timeout(final int timeout) {
            this.timeout = timeout;
            return this;
        }
    
        /**
         * Sets whether to use local Fesen instance.
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt

            check(currentPart == this) { "closed" }
    
            return source.timeout().intersectWith(timeout) {
              when (val limit = currentPartBytesRemaining(maxByteCount = byteCount)) {
                0L -> -1L // No more bytes in this part.
                else -> source.read(sink, limit)
              }
            }
          }
    
          override fun timeout(): Timeout = timeout
        }
    
        /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 02:11:14 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb/SimpleMemoryManagementTest.java

    import static org.junit.jupiter.api.Assertions.assertThrows;
    import static org.junit.jupiter.api.Assertions.assertTrue;
    
    import org.junit.jupiter.api.BeforeEach;
    import org.junit.jupiter.api.Test;
    import org.junit.jupiter.api.Timeout;
    import org.mockito.Mockito;
    
    import jcifs.CIFSContext;
    import jcifs.Configuration;
    import jcifs.Credentials;
    
    /**
     * Simple memory management tests to validate basic resource cleanup functionality
     */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  5. docs/smb3-features/02-persistent-handles-design.md

        public static final String NAME = "DH2Q";  // Durable Handle V2 Request
        
        private long timeout;
        private int flags;
        private HandleGuid createGuid;
        
        public DurableHandleV2Request(long timeout, boolean persistent) {
            super(NAME);
            this.timeout = timeout;
            this.flags = persistent ? Smb2HandleCapabilities.SMB2_DHANDLE_FLAG_PERSISTENT : 0;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 31.6K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/netbios/NbtSocket.java

            if (calledName == null) {
                this.calledName = address.hostName;
            } else {
                this.calledName = new Name(calledName, 0x20, null);
            }
            soTimeout = Config.getInt("jcifs.smb1.netbios.soTimeout", DEFAULT_SO_TIMEOUT);
            connect();
        }
    
        /**
         * Returns the NetBIOS address associated with this socket.
         *
         * @return the NetBIOS address
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/CommandExtractor.java

             * @param process The process to monitor.
             * @param timeout The timeout for the process.
             */
            public MonitorThread(final Process process, final long timeout) {
                this.process = process;
                this.timeout = timeout;
            }
    
            @Override
            public void run() {
                ThreadUtil.sleepQuietly(timeout);
    
                if (!finished) {
                    try {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 16K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

         * all must complete within one timeout period.
         *
         * The default value is 0 which imposes no timeout.
         */
        fun callTimeout(
          timeout: Long,
          unit: TimeUnit,
        ) = apply {
          callTimeout = checkDuration("timeout", timeout, unit)
        }
    
        /**
         * Sets the default timeout for complete calls. A value of 0 means no timeout, otherwise values
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb/SmbTreeInternalTest.java

            // Arrange
            when(tree.send(eq(request), eq(RequestParam.NO_TIMEOUT), eq(RequestParam.NO_RETRY))).thenReturn(response);
    
            // Act
            CommonServerMessageBlockResponse out = tree.send(request, RequestParam.NO_TIMEOUT, RequestParam.NO_RETRY);
    
            // Assert
            assertSame(response, out);
            verify(tree).send(request, RequestParam.NO_TIMEOUT, RequestParam.NO_RETRY);
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/ResponseJvmTest.kt

            override fun read(
              sink: Buffer,
              byteCount: Long,
            ): Long {
              check(!closed)
              return data.read(sink, byteCount)
            }
    
            override fun timeout(): Timeout = Timeout.NONE
          }
        return source.buffer().asResponseBody(null, -1)
      }
    
      private fun newResponse(
        responseBody: ResponseBody,
        code: Int = 200,
        fn: Response.Builder.() -> Unit = {},
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 2.8K bytes
    - Viewed (0)
Back to top