- Sort Score
- Result 10 results
- Languages All
Results 321 - 330 of 701 for seconden (0.09 sec)
-
src/main/java/jcifs/util/ResourceManager.java
int cleaned = forceCleanup(); // Shutdown executor cleanupExecutor.shutdown(); try { if (!cleanupExecutor.awaitTermination(5, TimeUnit.SECONDS)) { cleanupExecutor.shutdownNow(); } } catch (InterruptedException e) { cleanupExecutor.shutdownNow(); Thread.currentThread().interrupt(); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 16.2K bytes - Viewed (0) -
src/main/java/jcifs/util/AuthenticationRateLimiter.java
if (!closed.compareAndSet(false, true)) { return; } cleanupScheduler.shutdownNow(); try { cleanupScheduler.awaitTermination(5, TimeUnit.SECONDS); } catch (InterruptedException e) { Thread.currentThread().interrupt(); log.warn("Interrupted while shutting down cleanup scheduler", e); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 15.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/RangeTest.java
Range<Integer> closedRange = Range.closed(4, 8); // first range open end, second range open start assertEquals(Range.closed(2, 4), Range.lessThan(2).gap(openRange)); assertEquals(Range.closed(2, 4), openRange.gap(Range.lessThan(2))); // first range closed end, second range open start assertEquals(Range.openClosed(2, 4), Range.atMost(2).gap(openRange));
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 24.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java
protected int maxRedirectCount; /** Executor service for concurrent processing of file operations. */ private final ExecutorService executor; /** Timeout in seconds for executor service termination during shutdown. */ private int executorTerminationTimeout = 300; /** * Constructs a new FileListIndexUpdateCallbackImpl with the specified parameters. *
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 28.9K bytes - Viewed (0) -
cmd/sts-handlers_test.go
runAllIAMSTSTests(testCase, &check{t, testCase.serverType}) }, ) } } func (s *TestSuiteIAM) TestSTSServiceAccountsWithUsername(c *check) { ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) defer cancel() bucket := "dillon-bucket" err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{}) if err != nil { c.Fatalf("bucket create error: %v", err) } // Create policy
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 100.2K bytes - Viewed (1) -
src/test/java/jcifs/ntlmssp/av/AvPairsTest.java
assertTrue(pairs.get(0) instanceof AvFlags, "First pair should be AvFlags instance"); // Check second pair (AvTimestamp) assertEquals(AvPair.MsvAvTimestamp, pairs.get(1).getType(), "Second pair should be MsvAvTimestamp"); assertTrue(pairs.get(1) instanceof AvTimestamp, "Second pair should be AvTimestamp instance"); // Check third pair (AvTargetName)
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 20.5K bytes - Viewed (0) -
docs/sts/assume-role.go
if err != nil { log.Fatalf("Error reading session policy file: %v", err) } policy = string(bs) } stsOpts.Policy = policy } if expiryDuration != 0 { stsOpts.DurationSeconds = int(expiryDuration.Seconds()) } li, err := cr.NewSTSAssumeRole(stsEndpoint, stsOpts) if err != nil { log.Fatalf("Error initializing STS Identity: %v", err) } stsEndpointURL, err := url.Parse(stsEndpoint) if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sat Aug 17 01:24:54 UTC 2024 - 4.4K bytes - Viewed (1) -
src/test/java/org/codelibs/fess/util/KuromojiCSVUtilTest.java
// Multiple quoted values - quotes are removed value = "\"first\",\"second\",\"third\""; result = KuromojiCSVUtil.parse(value); assertEquals(3, result.length); assertEquals("first", result[0]); assertEquals("second", result[1]); assertEquals("\"third\"", result[2]); // Mixed quoted and unquoted - quotes are removed from quoted values
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 12 07:34:10 UTC 2025 - 18.7K bytes - Viewed (0) -
cmd/iam-etcd-store.go
return case watchResp, ok := <-watchCh: if !ok { time.Sleep(1 * time.Second) // Upon an error on watch channel // re-init the watch channel. goto outerLoop } if err := watchResp.Err(); err != nil { iamLogIf(ctx, err) // log and retry. time.Sleep(1 * time.Second) // Upon an error on watch channel // re-init the watch channel.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.9K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/ServerMessageBlock2ResponseTest.java
// Ignore } }).start(); } startLatch.countDown(); assertTrue(endLatch.await(1, TimeUnit.SECONDS)); assertTrue(response.isReceived()); } @Test @DisplayName("Should handle concurrent error notifications") void testConcurrentError() throws InterruptedException {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 19.3K bytes - Viewed (0)