// allocated to size `ninputs`. The caller should build `cond_graph` and
// `body_graph` starting from the inputs, and store the final outputs in
// `cond_output` and `body_outputs`.
//
// If `status` is OK, the caller must call either TF_FinishWhile or
// TF_AbortWhile on the returned TF_WhileParams. If `status` isn't OK, the
// returned TF_WhileParams is not valid, and the caller should not call

    assertThat(call2Connect.exchangeIndex).isEqualTo(0)
    val call2Get = server.takeRequest()
    assertThat(call2Get.method).isEqualTo("GET")
    assertThat(call2Get.url.encodedPath).isEqualTo("/call2")
    assertThat(call2Get.exchangeIndex).isEqualTo(0)
    val call1Get = server.takeRequest()
    assertThat(call1Get.method).isEqualTo("GET")
    assertThat(call1Get.url.encodedPath).isEqualTo("/call1")

  //    visible to done(). This is because there is no happens before edge between the write and a
  //    (hypothetical) unsafe read by our caller. Note: adding 'volatile' does not fix this issue,
  //    it would just add an edge such that if done() observed non-null, then it would also

   * @return this {@code CacheBuilder} instance (for chaining)
   * @throws IllegalStateException if a weigher was already set or {@link #maximumSize(long)} was
   *     previously called
   * @since 11.0
   */
  @GwtIncompatible // To be supported
  @CanIgnoreReturnValue // TODO(b/27479612): consider removing this
  public <K1 extends K, V1 extends V> CacheBuilder<K1, V1> weigher(

    public void test_addEventHandler_singleHandler() {
        final AtomicBoolean called = new AtomicBoolean(false);
        coordinatorHelper.addEventHandler("config_updated", event -> called.set(true));

        final EventInfo event = new EventInfo();
        event.name = "config_updated";
        coordinatorHelper.dispatchEvent(event);

        assertTrue(called.get());
    }

    @Test

// Assumes that c.Lock is held by caller.
func (c *iamCache) buildUserGroupMemberships() {
	for group, gi := range c.iamGroupsMap {
		c.updateGroupMembershipsMap(group, &gi)
	}
}

// updateGroupMembershipsMap - updates the memberships map for a
// group. IMPORTANT: Assumes c.Lock() is held by caller.
func (c *iamCache) updateGroupMembershipsMap(group string, gi *GroupInfo) {

        objAttr.encode(mockNdrBuffer);

        verify(mockNdrBuffer).align(4);
        verify(mockNdrBuffer).enc_ndr_long(objAttr.length);
        verify(mockNdrBuffer, times(3)).enc_ndr_referent(null, 1); // Called 3 times for null root_directory, object_name, and security_quality_of_service
        verify(mockNdrBuffer).enc_ndr_long(objAttr.attributes);
        verify(mockNdrBuffer).enc_ndr_long(objAttr.security_descriptor);

            """
        ),
    ] = None,
    *,
    use_cache: Annotated[
        bool,
        Doc(
            """
            By default, after a dependency is called the first time in a request, if
            the dependency is declared again for the rest of the request (for example
            if the dependency is needed by several dependencies), the value will be

// ``legacyObject``: This is the legacy object in xlV1 format, preserved until its overwritten
//
// The most recently updated element in the array is considered the latest version.

// In addition to these we have a special kind called free-version. This is represented
// using a delete-marker and MetaSys entries. It's used to track tiered content of a
// deleted/overwritten version. This version is visible _only_to the scanner routine, for subsequent deletion.

    assertThat(stats.loadSuccessCount()).isEqualTo(3);
    assertThat(stats.loadExceptionCount()).isEqualTo(0);
    assertThat(stats.hitCount()).isEqualTo(1);

    Object value = new Object();
    // callable is not called
    assertThat(cache.get(key, throwing(new Exception()))).isSameInstanceAs(key);
    stats = cache.stats();
    assertThat(stats.missCount()).isEqualTo(2);
    assertThat(stats.loadSuccessCount()).isEqualTo(3);