Search Options

Results per page
Sort
Preferred Languages
Advance

Results 2281 - 2290 of 2,395 for batch (0.02 sec)

  1. 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)
  2. 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 shorter
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 24.2K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    		// is '.minio.sys'
    		if bucket == minioMetaBucket {
    			if wildcard.Match("buckets/*/.metacache/*", entry.name) {
    				return nil
    			}
    			if wildcard.Match("tmp/*", entry.name) {
    				return nil
    			}
    			if wildcard.Match("multipart/*", entry.name) {
    				return nil
    			}
    			if wildcard.Match("tmp-old/*", entry.name) {
    				return nil
    			}
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 89.2K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top