assertTrue(awaitLatchUninterruptibly(timeoutMillis, MILLISECONDS));
      completed.assertCompletionExpected();
    }

    /**
     * Awaits the latch with a timeout and asserts that the wait returned within the expected
     * timeout.
     */
    final void awaitUnsuccessfully(long timeoutMillis) {
      assertFalse(awaitLatchUninterruptibly(timeoutMillis, MILLISECONDS));

  return curr_version


# Disable clang extension that rejects type definitions within offsetof.
# This was added in clang-16 by https://reviews.llvm.org/D133574.
# Still required for clang-17.
# Can be removed once upb is updated, since a type definition is used within
# offset of in the current version of ubp. See

                        managedPluginsElement, context, sectionName + "/" + PLUGIN_MANAGEMENT + "/" + PLUGINS);
            }
        }

        return fixed;
    }

    /**
     * Fixes duplicate plugins within a specific plugins section.
     */
    private boolean fixDuplicatePluginsInSection(Element pluginsElement, UpgradeContext context, String sectionName) {
        List<Element> plugins = pluginsElement.children(PLUGIN).toList();

         */
        public void setMessages(List<WitnessNotificationMessage> messages) {
            this.messages = messages;
        }
    }

    /**
     * Individual notification message within a notification response.
     */
    public static class WitnessNotificationMessage {

        /**
         * Creates a new witness notification message
         */
        public WitnessNotificationMessage() {

      if (array[i] == target) {
        return i;
      }
    }
    return -1;
  }

  /**
   * Returns the start position of the first occurrence of the specified {@code target} within
   * {@code array}, or {@code -1} if there is no such occurrence.
   *
   * <p>More formally, returns the lowest index {@code i} such that {@code Arrays.copyOfRange(array,

    any liability that these contractual assumptions directly impose on
    those licensors and authors.

  All other non-permissive additional terms are considered "further
restrictions" within the meaning of section 10.  If the Program as you
received it, or any part of it, contains a notice stating that it is
governed by this License along with a term that is a further

    }
  }

  /*
   * We've split testFuzzyCompare() into multiple tests so that our internal Android test runner has
   * a better chance of completing each within its per-test-method timeout.
   */

  public void testFuzzyCompare0() {
    runTestFuzzyCompare(0);
  }

  public void testFuzzyCompare1() {
    runTestFuzzyCompare(1);
  }

     *         </p>
     *         <p>
     *         The recommended version of the returned version range will be the recommended version of
     *         this version range, provided that ranges falls within the intersected restrictions. If
     *         the restrictions are empty, this version range's recommended version is used if it is not

   * confirms the fast fallback implements these invariants:
   *
   *  * if there's no TCP connect in flight, start one.
   *  * don't start a new TCP connect within 250 ms of the previous TCP connect.
   */
  @Test
  fun minimumDelayEnforcedBetweenConnects() {
    val plan0 = routePlanner.addPlan()
    plan0.tcpConnectDelayNanos = 510.ms

            this.handle.decode(_src);
            this.retval = _src.dec_ndr_long();
        }
    }

    /**
     * SAMR OpenDomain operation for opening a domain within the SAM database.
     * This operation obtains a handle to a specific domain.
     */
    public static class SamrOpenDomain extends DcerpcMessage {

        @Override
        public int getOpnum() {