private volatile boolean breaking;

        /**
         * Create a new lease entry
         *
         * @param key lease key
         * @param path file path
         * @param state initial lease state
         */
        public LeaseEntry(Smb2LeaseKey key, String path, int state) {
            this.leaseKey = key;
            this.path = path;
            this.leaseState = state;

      FakeTicker ticker,
      String keyPrefix,
      long ttl) {
    loader.setKeyPrefix(keyPrefix);

    int shift1 = 10 + VALUE_PREFIX;
    loader.setValuePrefix(shift1);
    // fill with initial data
    for (int i = 0; i < 10; i++) {
      assertThat(cache.getUnchecked(keyPrefix + i)).isEqualTo(i + shift1);
    }
    assertThat(CacheTesting.expirationQueueSize(cache)).isEqualTo(10);

        }

        dataService.delete(sessionId);
    }

    public void test_getCount_Tx() {
        final String sessionId = "count_session1";

        // Initially no data
        assertEquals(0, dataService.getCount(sessionId));

        // Insert test data
        for (int i = 1; i <= 5; i++) {
            final OpenSearchAccessResult accessResult = new OpenSearchAccessResult();

   *   may add headers like `User-Agent`.
   * * It may be the request generated in response to an HTTP redirect or authentication
   *   challenge. In this case the request URL may be different than the initial request URL.
   *
   * Use the `request` of the [networkResponse] field to get the wire-level request that was
   * transmitted. In the case of follow-ups and redirects, also look at the `request` of the

				Name:   "foo",
				Method: Deflate,
			})
			w.Write(bigBuf)
		}
		zw.Close()
	}

	b.ReportAllocs()
	// Run once and then reset the timer.
	// This effectively discards the very large initial flate setup cost,
	// as well as the initialization of bigBuf.
	runOnce(&bytes.Buffer{})
	b.ResetTimer()

	b.RunParallel(func(pb *testing.PB) {
		var buf bytes.Buffer
		for pb.Next() {
			runOnce(&buf)

        char[] plaintext = "DestroyTest".toCharArray();
        byte[] encrypted = storage.encryptCredentials(plaintext);

        assertFalse(storage.isDestroyed(), "Storage should not be destroyed initially");

        // Destroy the storage - may throw DestroyFailedException if SecretKey doesn't support destroy
        try {
            storage.destroy();
        } catch (DestroyFailedException e) {

        assertEquals("my.bucket.name", getField(gcsConn, "bucketName"));
        assertEquals("object.txt", getField(gcsConn, "objectName"));
    }

    /**
     * Test that GCS Storage client is initially null before connection.
     */
    public void test_connectionState_initiallyNotConnected() throws Exception {
        URL url = new URL("gcs://mybucket/object.txt");
        Handler handler = new Handler();

   * @throws IllegalArgumentException if {@code initialCapacity} is negative
   * @throws IllegalStateException if an initial capacity was already set
   */
  @CanIgnoreReturnValue
  public CacheBuilder<K, V> initialCapacity(int initialCapacity) {
    checkState(
        this.initialCapacity == UNSET_INT,
        "initial capacity was already set to %s",
        this.initialCapacity);
    checkArgument(initialCapacity >= 0);

	resourceMetricsMapMu sync.RWMutex
	// resourceMetricsHelpMap maps metric name to its help string
	resourceMetricsHelpMap map[MetricName]string
	resourceMetricsGroups  []*MetricsGroupV2
	// initial values for drives (at the time  of server startup)
	// used for calculating avg values for drive metrics
	latestDriveStats      map[string]madmin.DiskIOStats
	latestDriveStatsMu    sync.RWMutex
	lastDriveStatsRefresh time.Time

    void testBufDataStartInitialization() throws Exception {
        byte[] buffer = new byte[100];
        int bufferIndex = 0;

        // Set bufDataStart to 0 initially
        Field bufDataStartField = response.getClass().getSuperclass().getSuperclass().getDeclaredField("bufDataStart");
        bufDataStartField.setAccessible(true);
        bufDataStartField.set(response, 0);