Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 701 for seconden (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top