return metacache{
			id:     o.ID,
			bucket: o.Bucket,
			status: scanStateNone,
		}
	}

	// Create new and add.
	best := o.newMetacache()
	b.caches[o.ID] = best
	b.cachesRoot[best.root] = append(b.cachesRoot[best.root], best.id)
	b.updated = true
	b.debugf("returning new cache %s, bucket: %v", best.id, best.bucket)
	return best
}

// cleanup removes redundant and outdated entries.

    }

    @Test
    public void test_multipleInstancesHaveIndependentSettings() {
        final SuppressErrorReportValve valve1 = new SuppressErrorReportValve();
        final SuppressErrorReportValve valve2 = new SuppressErrorReportValve();

        valve1.setShowReport(true);
        valve1.setShowServerInfo(true);

        // valve2 should still have default values

                    addRule(KotlinModifiersBreakingChangeRule, ruleParams)
                    addRule(JApiChangeStatus.NEW, IncubatingMissingRule, ruleParams)
                    addRule(JApiChangeStatus.NEW, SinceAnnotationRule, ruleParams)
                    addRule(JApiChangeStatus.NEW, NewIncubatingAPIRule, ruleParams)

                    addSetupRule(AcceptedRegressionsRuleSetup, [acceptedApiChanges: acceptedChanges])

        byte[] dst = new byte[1024];
        int result = response.writeParameterWordsWireFormat(dst, 0);

        // The method should write parameter words
        assertTrue(result >= 0, "writeParameterWordsWireFormat should return non-negative value");
    }

    @Test
    void testReadParameterWordsWireFormat() {
        byte[] buffer = new byte[1024];

            throw new IllegalArgumentException(msg);
        }
        if (!input.startsWith("/")) {
            final String msg = "The argument 'input' should start with slash '/': " + input;
            throw new IllegalArgumentException(msg);
        }
        final StringBuilder sb = new StringBuilder();

    checkArgument(capacity > 0);
    this.items = newEArray(capacity);
    monitor = new Monitor(fair);
    notEmpty =
        new Monitor.Guard(monitor) {
          @Override
          public boolean isSatisfied() {
            return count > 0;
          }
        };
    notFull =
        new Monitor.Guard(monitor) {
          @Override
          public boolean isSatisfied() {

 * @author Hayward Chan
 */
@NullUnmarked
public class ForwardingMultimapTest extends TestCase {

  @SuppressWarnings("rawtypes")
  public void testForwarding() {
    new ForwardingWrapperTester()
        .testForwarding(
            Multimap.class,
            new Function<Multimap, Multimap<?, ?>>() {
              @Override
              public Multimap<?, ?> apply(Multimap delegate) {
                return wrap((Multimap<?, ?>) delegate);

 * @author Gregory Kick
 */
@NullUnmarked
public class ForwardingTableTest extends TestCase {

  @SuppressWarnings("rawtypes")
  public void testForwarding() {
    new ForwardingWrapperTester()
        .testForwarding(
            Table.class,
            new Function<Table, Table<?, ?, ?>>() {
              @Override
              public Table<?, ?, ?> apply(Table delegate) {
                return wrap((Table<?, ?, ?>) delegate);

        final Tokenizer tokenizer = new Tokenizer("");
        assertThat(tokenizer.nextToken(), is(Tokenizer.TT_EOF));
        assertThat(tokenizer.nextToken(), is(Tokenizer.TT_EOF));
    }

    /**
     * @throws Exception
     */
    @Test
    public void testWhitespace() throws Exception {
        final Tokenizer tokenizer = new Tokenizer("\t       \n");

   * the same way.
   */
  public CharSource asCharSource(Charset charset) {
    return new AsCharSource(charset);
  }

  /**
   * Opens a new {@link InputStream} for reading from this source. This method returns a new,
   * independent stream each time it is called.
   *
   * <p>The caller is responsible for ensuring that the returned stream is closed.
   *