COUNT - Code Search

docs/distributed/decom.sh

./mc admin decom start myminio/ http://localhost:9000/tmp/xl/{1...10}/disk{0...1}

count=0
until $(./mc admin decom status myminio/ | grep -q Complete); do
	echo "waiting for decom to finish..."
	count=$((count + 1))
	if [ ${count} -eq 120 ]; then
		./mc cat /tmp/expanded_*.log
	fi
	sleep 1
done

kill $pid_1
kill $pid_2

sleep 5

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Mon May 27 19:17:46 UTC 2024

- 6.4K bytes

- Viewed (0)

github.com/codelibs/corelib

src/test/java/org/codelibs/core/io/ClassTraversalTest.java

import org.junit.Before;
import org.junit.Test;

/**
 * @author taedium
 */
public class ClassTraversalTest {

    private static int count = 0;

    /**
     * @throws Exception
     */
    @Before
    public void setUp() throws Exception {
        count = 0;
    }

    /**
     * @throws Exception
     */
    @Test
    public void testForEachJarFile() throws Exception {

Registered: Sat Dec 20 08:55:33 UTC 2025

- Last Modified: Sat May 10 01:32:17 UTC 2025

- 5.1K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/collect/TreeMultiset.java

  @Override
  public int setCount(@ParametricNullness E element, int count) {
    checkNonnegative(count, "count");
    if (!range.contains(element)) {
      checkArgument(count == 0);
      return 0;
    }

    AvlNode<E> root = rootReference.get();
    if (root == null) {
      if (count > 0) {
        add(element, count);
      }
      return 0;
    }

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Tue Dec 09 15:58:48 UTC 2025

- 34.3K bytes

- Viewed (0)

github.com/codelibs/fess-crawler

fess-crawler/src/test/java/org/codelibs/fess/crawler/util/CrawlerWebServer.java

        final StringBuilder buf = new StringBuilder();
        buf.append("<html><head><title>Title ");
        buf.append(count);
        buf.append("</title></head><body><h1>Content ");
        buf.append(count);
        buf.append("</h1><br>");
        buf.append("<a href=\"index.html\">Index</a><br>");
        for (int i = 1; i <= 10; i++) {
            buf.append("<a href=\"file");
            buf.append(count);

Registered: Sat Dec 20 11:21:39 UTC 2025

- Last Modified: Sat Mar 15 06:52:00 UTC 2025

- 6.3K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/smb2/io/Smb2WriteResponseTest.java

        }

        @ParameterizedTest
        @DisplayName("Should read various count values")
        @ValueSource(ints = { 0, 1, 100, 1024, 65536, Integer.MAX_VALUE })
        void testReadVariousCountValues(int count) throws SMBProtocolDecodingException {
            byte[] buffer = createValidWriteResponse(count, 0);

            int bytesRead = response.readBytesWireFormat(buffer, 0);

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Thu Aug 14 05:31:44 UTC 2025

- 15.9K bytes

- Viewed (0)

github.com/go-gorm/gorm

tests/joins_table_test.go

		t.Fatalf("failed to delete person, got error: %v", err)
	}

	if count := DB.Unscoped().Model(&person2).Association("Addresses").Count(); count != 2 {
		t.Errorf("person's addresses expects 2, got %v", count)
	}

	if count := DB.Model(&person2).Association("Addresses").Count(); count != 0 {
		t.Errorf("person's addresses expects 2, got %v", count)
	}

Registered: Sun Dec 28 09:35:17 UTC 2025

- Last Modified: Thu Sep 10 13:46:18 UTC 2020

- 3.5K bytes

- Viewed (1)

github.com/go-gorm/gorm

tests/associations_many2many_test.go

	}

	count := 3

	var languages []Language
	for i := 0; i < count; i++ {
		language := Language{Code: fmt.Sprintf("consurrent %d", i)}
		db.Create(&language)
		languages = append(languages, language)
	}

	user := User{}
	db.Create(&user)
	db.Preload("Languages").FirstOrCreate(&user)

	var wg sync.WaitGroup
	for i := 0; i < count; i++ {
		wg.Add(1)

Registered: Sun Dec 28 09:35:17 UTC 2025

- Last Modified: Sat Jun 10 13:05:19 UTC 2023

- 13.2K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/dcerpc/msrpc/netdfs.idl

		uint32_t num_stores;
		[size_is(num_stores)] DfsStorageInfo *stores;
	} DfsInfo3;

	typedef struct {
		uint32_t count;
		[size_is(count)] DfsInfo3 *s;
	} DfsEnumArray3;

	typedef struct {
		[string] wchar_t *dfs_name;
	} DfsInfo200;

	typedef struct {
		uint32_t count;
		[size_is(count)] DfsInfo200 *s;
	} DfsEnumArray200;

	typedef struct {
		uint32_t flags;
		[string] wchar_t *dfs_name;

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Fri Mar 22 20:39:42 UTC 2019

- 1.7K bytes

- Viewed (0)

github.com/google/guava

guava-testlib/src/com/google/common/collect/testing/google/AbstractMultisetSetCountTester.java

   * UnsupportedOperationException."
   */
  abstract void setCountNoCheckReturnValue(E element, int count);

  private void assertSetCountIncreasingFailure(E element, int count) {
    try {
      setCountNoCheckReturnValue(element, count);
      fail("a call to multiset.setCount() to increase an element's count should throw");
    } catch (UnsupportedOperationException expected) {
    }
  }

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Thu Aug 07 16:05:33 UTC 2025

- 13K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java

     */
    private void incrementFailureCount(ChangeNotificationHandle handle) {
        failureCounts.compute(handle.getDirectoryPath(), (path, count) -> count == null ? 1 : count + 1);
    }

    /**
     * Reset failure count for a handle (called on successful operations)
     *
     * @param handle notification handle
     */
    private void resetFailureCount(ChangeNotificationHandle handle) {

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Sat Aug 30 05:58:03 UTC 2025

- 13.7K bytes

- Viewed (0)

Search Options