ndrShort1.encode(encodeBuffer);

            NdrShort ndrShort2 = new NdrShort(0);
            ndrShort2.decode(decodeBuffer);

            // Then: Values should match
            verify(encodeBuffer).enc_ndr_short(originalValue);
            verify(decodeBuffer).dec_ndr_short();
            assertEquals(ndrShort1.value, ndrShort2.value);
        }

        @Test

        byte[] buf = impl.getBuffer();
        assertNotNull(buf, "getBuffer should never return null");
        assertEquals(5, buf.length, "Newly allocated buffer length should match config maximum size");
    }

    // Happy path: get -> release -> get returns same instance, zeroed on release
    @Test
    @DisplayName("Release stores buffer for reuse and zeroes its contents")

        return (GetCheckedTypeValidator) theClass.getEnumConstants()[0];
      } catch (ClassNotFoundException
          | RuntimeException
          | Error t) { // ensure we really catch *everything*
        return weakSetValidator();
      }
    }
  }

  // TODO(cpovirk): change parameter order to match other helper methods (Class, Throwable)?

        dataStoreMap.put(dataStore.getClass().getSimpleName().toLowerCase(Locale.ROOT), dataStore);
    }

    /**
     * Retrieves a data store instance by name.
     * The lookup is case-insensitive and will match both registered names
     * and class simple names.
     *
     * @param name the name of the data store to retrieve, may be null
     * @return the data store instance if found, null if not found or name is null
     */

        factory.addClient(regexList, client);
    }

    /**
     * Retrieves a client from the wrapped factory that matches the given URL.
     * @param url The URL to match.
     * @return The matching CrawlerClient instance.
     */
    @Override
    public CrawlerClient getClient(final String url) {
        return factory.getClient(url);
    }

    /**

* `allow_origins` - A list of origins that should be permitted to make cross-origin requests. E.g. `['https://example.org', 'https://www.example.org']`. You can use `['*']` to allow any origin.
* `allow_origin_regex` - A regex string to match against origins that should be permitted to make cross-origin requests. e.g. `'https://.*\.example\.org'`.

        assertTrue(result.contains("secretkey={cipher}"));
        assertFalse(result.contains("secretkey=unencrypted"));

        // Test with keys that don't match pattern
        value = "normalfield=value\npassword=secret";
        result = ParameterUtil.encrypt(value);
        assertTrue("Result should contain normalfield=value, but was: " + result, result.contains("normalfield=value"));

  /** The HTTP {@code If-Match} header field name. */
  public static final String IF_MATCH = "If-Match";

  /** The HTTP {@code If-Modified-Since} header field name. */
  public static final String IF_MODIFIED_SINCE = "If-Modified-Since";

  /** The HTTP {@code If-None-Match} header field name. */
  public static final String IF_NONE_MATCH = "If-None-Match";

                            successCount.incrementAndGet();
                        } catch (Exception e) {
                            failureCount.incrementAndGet();
                        }
                    }
                } finally {
                    latch.countDown();
                }
            });
        }

        assertTrue(latch.await(10, TimeUnit.SECONDS), "Concurrent operations should complete");

	if b == nil {
		logger.Info("bucketMetacache.findCache: nil cache for bucket %s", o.Bucket)
		return metacache{}
	}

	if o.Bucket != b.bucket {
		logger.Info("bucketMetacache.findCache: bucket %s does not match this bucket %s", o.Bucket, b.bucket)
		debug.PrintStack()
		return metacache{}
	}

	// Grab a write lock, since we create one if we cannot find one.
	b.mu.Lock()
	defer b.mu.Unlock()