- Sort Score
- Result 10 results
- Languages All
Results 571 - 580 of 1,115 for _start (0.15 sec)
-
cmd/erasure-metadata-utils.go
return nil } nums := make([]int, cardinality) keyCrc := crc32.Checksum([]byte(key), crc32.IEEETable) start := int(keyCrc % uint32(cardinality)) for i := 1; i <= cardinality; i++ { nums[i-1] = 1 + ((start + i) % cardinality) } return nums } // Reads all `xl.meta` metadata as a FileInfo slice. // Returns error slice indicating the failed metadata reads.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/TestLocking.java
int ti; for (ti = 0; ti < t.numThreads; ti++) { threads[ti] = new Thread(t); logger.info(threads[ti].getName()); threads[ti].start(); } while (t.numComplete < t.numThreads) { long delay; do { delay = 2L; synchronized (t) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 4.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/ServerMessageBlock2Test.java
boolean haveResponseCalled = false; @Override protected void haveResponse(byte[] buffer, int start, int len) throws SMBProtocolDecodingException { haveResponseCalled = true; super.haveResponse(buffer, start, len); } }; byte[] buffer = new byte[256];
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 39.5K bytes - Viewed (0) -
docs/pt/docs/advanced/security/oauth2-scopes.md
A própria *operação de rota* também declara o escopo, `"items"`, então ele também estará na lista de `security_scopes.scopes` passado para o `get_current_user`. Aqui está como a hierarquia de dependências e escopos parecem: * A *operação de rota* `read_own_items` possui:
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 10:49:48 UTC 2025 - 14.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/net/UrlEscapersTest.java
assertSame(e, urlFormParameterEscaper()); assertBasicUrlEscaper(e); /* * Specified as safe by RFC 2396 but not by java.net.URLEncoder. These tests will start failing * when the escaper is made compliant with RFC 2396, but that's a good thing (just change them * to assertUnescaped). */ assertEscaping(e, "%21", '!'); assertEscaping(e, "%28", '(');
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 2.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
pb.redirectErrorStream(true); if (logger.isDebugEnabled()) { logger.debug("Thumbnail Command: {}", cmdList); } p = pb.start(); ist = new InputStreamThread(p.getInputStream(), Charset.defaultCharset(), 0, s -> { if (logger.isDebugEnabled()) { logger.debug(s); } });
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Fri Jul 18 14:34:06 UTC 2025 - 14.7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/util/ThreadDumpUtilTest.java
latch.await(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }, "CustomTestThread"); customThread.start(); try { Consumer<String> searchConsumer = line -> { if (line.contains("CustomTestThread")) { customThreadFound.incrementAndGet(); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 12 07:34:10 UTC 2025 - 15.5K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessTimeResourceProviderTest.java
} catch (Exception e) { exceptions[index] = e; } }); } // Start all threads for (Thread thread : threads) { thread.start(); } // Wait for all threads to complete for (Thread thread : threads) { thread.join(); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 17.4K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/cache/LoadingCacheSingleThreadBenchmark.java
@Override public Integer load(Integer from) { return (int) misses.incrementAndGet(); } }); // To start, fill up the cache. // Each miss both increments the counter and causes the map to grow by one, // so until evictions begin, the size of the map is the greatest return // value seen so far
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 3.4K bytes - Viewed (0) -
src/test/java/jcifs/util/SmbCircuitBreakerTest.java
CountDownLatch startLatch = new CountDownLatch(1); CountDownLatch holdLatch = new CountDownLatch(1); CountDownLatch completeLatch = new CountDownLatch(1); // Start a long-running operation Thread longRunningThread = new Thread(() -> { try { cbWithTracking.executeWithCircuitBreaker(() -> { try {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 23.2K bytes - Viewed (0)