- Sort Score
- Result 10 results
- Languages All
Results 2281 - 2290 of 2,395 for batch (0.02 sec)
-
cmd/xl-storage-format-v2_test.go
hdr := xl.versions[i].header ver, err := xl.getIdx(i) if err != nil { t.Error(err) continue } gotHdr := ver.header() if hdr != gotHdr { t.Errorf("Header does not match, index: %+v != meta: %+v", hdr, gotHdr) } } } t.Run("load-legacy", func(t *testing.T) { var xl xlMetaV2 err = xl.Load(data) if err != nil { t.Fatal(err) } test(t, &xl) })
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 37.8K bytes - Viewed (0) -
android/guava/src/com/google/common/primitives/Chars.java
* Returns a comparator that compares two {@code char} arrays <a * href="http://en.wikipedia.org/wiki/Lexicographical_order">lexicographically</a>; not advisable * for sorting user-visible strings as the ordering may not match the conventions of the user's * locale. That is, it compares, using {@link #compare(char, char)}), the first pair of values * that follow any common prefix, or when one array is a prefix of the other, treats the shorterRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 24.2K bytes - Viewed (0) -
cmd/erasure-server-pool.go
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 89.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt
* awkward [InterruptedException]. */ @Throws(InterruptedIOException::class) internal fun waitForIo() { try { wait() } catch (_: InterruptedException) { Thread.currentThread().interrupt() // Retain interrupted status. throw InterruptedIOException() } } /**
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Jul 07 18:57:05 UTC 2025 - 22.4K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java
if (existingCounter.compareAndSet(oldValue, newValue)) { // newValue can't == 0, so no need to check & remove return oldValue; } } catch (ArithmeticException overflow) { throw new IllegalArgumentException( "Overflow adding " + occurrences + " occurrences to a count of " + oldValue); } } else {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Dec 08 22:42:14 UTC 2025 - 22.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/reflect/ClassPathTest.java
for (String entry : entries) { jarOut.putNextEntry(new ZipEntry(entry)); Resources.copy(ClassPathTest.class.getResource(entry), jarOut); jarOut.closeEntry(); } } catch (Throwable e) { throw closer.rethrow(e); } finally { closer.close(); } } private static Manifest manifest(String content) throws IOException {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 21:00:51 UTC 2025 - 23K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
*/ private fun awaitWatchdogIdle() { val latch = CountDownLatch(1) val watchdogJob: AsyncTimeout = object : AsyncTimeout() { override fun timedOut() { latch.countDown() } } watchdogJob.deadlineNanoTime(System.nanoTime()) // Due immediately! watchdogJob.enter() latch.await() } private fun connectWithSettings(
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 75.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
public void run() { for (int j = 0; j < getsPerTask; j++) { try { cache.getUnchecked("key" + random.nextInt(nUniqueKeys)); } catch (RuntimeException e) { } } } }); } threadPool.shutdown(); threadPool.awaitTermination(300, SECONDS);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 30 22:03:28 UTC 2025 - 25.4K bytes - Viewed (0) -
schema/relationship.go
if matched { return nil } } } } var ( name string idx = strings.IndexByte(str, ',') settings = ParseTagSetting(str, ",") ) // optimize match english letters and midline // The following code is basically called in for. // In order to avoid the performance problems caused by repeated compilation of regular expressions,Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Sun Nov 16 04:11:05 UTC 2025 - 23.1K bytes - Viewed (1) -
cmd/erasure-metadata.go
// We have removed this check to allow reading objects with different DataDir // values in a few drives (due to a rebalance-stop race bug) // provided their their etags or ModTimes match. if !meta.Deleted && meta.Size != 0 { fmt.Fprintf(h, "%v+%v", meta.Erasure.DataBlocks, meta.Erasure.ParityBlocks) fmt.Fprintf(h, "%v", meta.Erasure.Distribution) } if meta.IsRemote() {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 21.3K bytes - Viewed (0)