c1 - Code Search

okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

    val poolApi = ConnectionPool(pool)
    val c1 = factory.newConnection(pool, routeA1, 0L)
    allocateAndLeakAllocation(poolApi, c1)
    awaitGarbageCollection()
    assertThat(pool.closeConnections(100L)).isEqualTo(0L)
    assertThat(c1.calls).isEmpty()

    // Can't allocate once a leak has been detected.
    assertThat(c1.noNewExchanges).isTrue()
  }

  @Test fun interruptStopsThread() {

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Wed Apr 24 04:40:49 GMT 2024

- 12.7K bytes

- Viewed (0)

github.com/go-gorm/gorm

tests/callbacks_test.go

	}{
		{
			callbacks: []callback{{h: c1}, {h: c2}, {h: c3}, {h: c4}, {h: c5}},
			results:   []string{"c1", "c2", "c3", "c4", "c5"},
		},
		{
			callbacks: []callback{{h: c1}, {h: c2}, {h: c3}, {h: c4}, {h: c5, before: "c4"}},
			results:   []string{"c1", "c2", "c3", "c5", "c4"},
		},
		{
			callbacks: []callback{{h: c1}, {h: c2}, {h: c3}, {h: c4, after: "c5"}, {h: c5}},
			results:   []string{"c1", "c2", "c3", "c5", "c4"},
		},
		{

Go

- Registered: Sun May 05 09:35:13 GMT 2024

- Last Modified: Tue Mar 26 03:33:36 GMT 2024

- 7.2K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/io/CloserTest.java

    Closer closer = new Closer(suppressor);

    TestCloseable c1 = closer.register(TestCloseable.normal());
    TestCloseable c2 = closer.register(TestCloseable.normal());
    TestCloseable c3 = closer.register(TestCloseable.normal());

    assertFalse(c1.isClosed());
    assertFalse(c2.isClosed());
    assertFalse(c3.isClosed());

    closer.close();

    assertTrue(c1.isClosed());
    assertTrue(c2.isClosed());

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Wed Mar 06 15:15:46 GMT 2024

- 13.6K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/io/CloserTest.java

    Closer closer = new Closer(suppressor);

    TestCloseable c1 = closer.register(TestCloseable.normal());
    TestCloseable c2 = closer.register(TestCloseable.normal());
    TestCloseable c3 = closer.register(TestCloseable.normal());

    assertFalse(c1.isClosed());
    assertFalse(c2.isClosed());
    assertFalse(c3.isClosed());

    closer.close();

    assertTrue(c1.isClosed());
    assertTrue(c2.isClosed());

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Wed Mar 06 15:15:46 GMT 2024

- 13.6K bytes

- Viewed (0)

github.com/istio/istio

common/scripts/kind_provisioner.sh

      fi
    done
  done
}

function connect_kind_clusters() {
  C1="${1}"
  C1_KUBECONFIG="${2}"
  C2="${3}"
  C2_KUBECONFIG="${4}"
  POD_TO_POD_AND_SERVICE_CONNECTIVITY="${5}"

  C1_NODE="${C1}-control-plane"
  C2_NODE="${C2}-control-plane"
  C1_DOCKER_IP=$(docker inspect -f "{{ .NetworkSettings.Networks.kind.IPAddress }}" "${C1_NODE}")

Shell Script

- Registered: Wed May 08 22:53:08 GMT 2024

- Last Modified: Mon Apr 08 19:12:55 GMT 2024

- 17.3K bytes

- Viewed (1)

github.com/square/okhttp

okhttp/src/test/java/okhttp3/DispatcherTest.kt

  }

  @Test
  fun cancelingRunningJobTakesNoEffectUntilJobFinishes() {
    dispatcher.maxRequests = 1
    val c1 = client.newCall(newRequest("http://a/1", "tag1"))
    val c2 = client.newCall(newRequest("http://a/2"))
    c1.enqueue(callback)
    c2.enqueue(callback)
    c1.cancel()
    executor.assertJobs("http://a/1")
    executor.finishJob("http://a/1")
    executor.assertJobs("http://a/2")
  }

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Fri Apr 05 03:30:42 GMT 2024

- 12.7K bytes

- Viewed (0)

github.com/square/okhttp

samples/simple-client/src/main/java/okhttp3/sample/OkHttpContributors.java

      ResponseBody body = response.body();
      List<Contributor> contributors = CONTRIBUTORS_JSON_ADAPTER.fromJson(body.source());

      // Sort list by the most contributions.
      Collections.sort(contributors, (c1, c2) -> c2.contributions - c1.contributions);

      // Output list of contributors.
      for (Contributor contributor : contributors) {
        System.out.println(contributor.login + ": " + contributor.contributions);
      }
    }

Java

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Fri Apr 05 03:30:42 GMT 2024

- 2.2K bytes

- Viewed (0)

github.com/apache/maven

maven-compat/src/test/java/org/apache/maven/repository/legacy/resolver/DefaultArtifactCollectorTest.java

        ArtifactSpec e = createArtifactSpec("e", "1.0");
        ArtifactSpec c1 = e.addDependency("c", "1.0");
        ArtifactSpec f = c1.addDependency("f", "1.0");

        ArtifactResolutionResult res = collect(createSet(new Object[] {a.artifact, e.artifact}));
        assertEquals(
                createSet(new Object[] {a.artifact, b.artifact, e.artifact, c1.artifact, f.artifact}),
                res.getArtifacts(),

Java

- Registered: Sun May 05 03:35:11 GMT 2024

- Last Modified: Thu Apr 25 05:46:50 GMT 2024

- 42.5K bytes

- Viewed (0)

github.com/google/guava

guava-tests/test/com/google/common/collect/HashBasedTableTest.java

      table.put("r" + i, "c" + i, "v" + i);
    }
    assertThat(table.rowKeySet()).containsExactly("r0", "r1", "r2", "r3", "r4").inOrder();
    assertThat(table.columnKeySet()).containsExactly("c0", "c1", "c2", "c3", "c4").inOrder();
    assertThat(table.values()).containsExactly("v0", "v1", "v2", "v3", "v4").inOrder();
  }

  public void testCreateWithValidSizes() {

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Mon Mar 04 16:54:11 GMT 2024

- 3.6K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/collect/HashBasedTableTest.java

      table.put("r" + i, "c" + i, "v" + i);
    }
    assertThat(table.rowKeySet()).containsExactly("r0", "r1", "r2", "r3", "r4").inOrder();
    assertThat(table.columnKeySet()).containsExactly("c0", "c1", "c2", "c3", "c4").inOrder();
    assertThat(table.values()).containsExactly("v0", "v1", "v2", "v3", "v4").inOrder();
  }

  public void testCreateWithValidSizes() {

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Mon Mar 04 16:54:11 GMT 2024

- 3.6K bytes

- Viewed (0)

Search Options