Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 507 for Timers (0.03 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractService.java

       *
       * <p>This method should return promptly; prefer to do work on a different thread where it is
       * convenient. It is invoked exactly once on service startup, even when {@link #startAsync} is
       * called multiple times.
       */
      @ForOverride
      protected abstract void doStart();
    
      /**
       * This method should be used to initiate service shutdown. The invocation of this method should
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  2. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt

    ) {
      private var lastId: String? = null
    
      interface Callback {
        fun onEvent(
          id: String?,
          type: String?,
          data: String,
        )
    
        fun onRetryChange(timeMs: Long)
      }
    
      /**
       * Process the next event. This will result in a single call to [Callback.onEvent] *unless* the
       * data section was empty. Any number of calls to [Callback.onRetryChange] may occur while
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Oct 03 07:51:20 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  3. src/main/java/jcifs/util/transport/ConnectionTimeoutException.java

     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    package jcifs.util.transport;
    
    /**
     * Exception thrown when a network connection times out during SMB communication.
     * Indicates that the connection could not be established within the specified timeout period.
     *
     * @author mbechler
     */
    public class ConnectionTimeoutException extends TransportException {
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-rebalance.go

    		// time.
    		r := rand.New(rand.NewSource(time.Now().UnixNano()))
    		randSleepFor := func() time.Duration {
    			return 5*time.Second + time.Duration(float64(5*time.Second)*r.Float64())
    		}
    
    		timer := time.NewTimer(randSleepFor())
    		defer timer.Stop()
    
    		var (
    			quit     bool
    			traceMsg string
    			notify   bool // if status changed, notify nodes to reload rebalance metadata
    		)
    
    		for {
    			select {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 28.7K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb/MIENameTest.java

    import static org.junit.jupiter.api.Assertions.assertNull;
    import static org.junit.jupiter.api.Assertions.assertThrows;
    import static org.mockito.Mockito.mock;
    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verify;
    
    import java.nio.charset.StandardCharsets;
    import java.util.stream.Stream;
    
    import org.bouncycastle.asn1.ASN1ObjectIdentifier;
    import org.junit.jupiter.api.DisplayName;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 8.6K bytes
    - Viewed (0)
  6. src/test/java/jcifs/ACETest.java

                ace.getAccessMask();
    
                // Different methods called
                ace.isAllow();
                ace.getFlags();
    
                verify(ace, times(2)).getAccessMask();
                verify(ace, times(1)).isAllow();
                verify(ace, times(1)).getFlags();
            }
        }
    
        @Nested
        @DisplayName("Real-world Usage Scenarios")
        class RealWorldUsageTests {
    
            @Test
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 24.4K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/timer/HotThreadMonitorTarget.java

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.timer;
    
    import java.util.stream.Collectors;
    
    import org.apache.commons.text.StringEscapeUtils;
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.Constants;
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  8. internal/disk/stat_linux_s390x.go

    		Free:   uint64(s.Frsize) * s.Bavail,
    		Files:  s.Files,
    		Ffree:  s.Ffree,
    		FSType: getFSType(s.Type),
    	}
    	// Check for overflows.
    	// https://github.com/minio/minio/issues/8035
    	// XFS can show wrong values at times error out
    	// in such scenarios.
    	if info.Free > info.Total {
    		return info, fmt.Errorf("detected free space (%d) > total drive space (%d), fs corruption at (%s). please run 'fsck'", info.Free, info.Total, path)
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java

    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.io.CloseableUtil;
    import org.codelibs.core.io.InputStreamUtil;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutManager;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.crawler.Constants;
    import org.codelibs.fess.crawler.builder.RequestDataBuilder;
    import org.codelibs.fess.crawler.client.AbstractCrawlerClient;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Nov 23 12:19:14 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  10. src/test/java/jcifs/smb/SSPContextTest.java

    import static org.mockito.ArgumentMatchers.anyInt;
    import static org.mockito.ArgumentMatchers.eq;
    import static org.mockito.Mockito.inOrder;
    import static org.mockito.Mockito.never;
    import static org.mockito.Mockito.times;
    import static org.mockito.Mockito.verify;
    import static org.mockito.Mockito.verifyNoMoreInteractions;
    import static org.mockito.Mockito.when;
    
    import java.util.Arrays;
    import java.util.Objects;
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.2K bytes
    - Viewed (0)
Back to top