try {
      val result = block(header)

      // The object processed bytes beyond its range.
      if (newLimit != -1L && byteCount > newLimit) {
        throw ProtocolException("unexpected byte count at $this")
      }

      return result
    } finally {
      peekedHeader = null
      limit = pushedLimit
      constructed = pushedConstructed
      if (name != null) path.removeAt(path.size - 1)

            assertEquals(0, result);
            assertNotNull(testResponse.getData());
            assertEquals(0, testResponse.getData().length);
        }

        @Test
        @DisplayName("Should count decode calls correctly")
        void testDecodeCallCount() throws SMBProtocolDecodingException {
            assertEquals(0, testResponse.getDecodeCallCount());

            testResponse.decode(testBuffer, 0, 10);

        response = new Trans2QueryPathInformationResponse(mockConfig, FileInformation.FILE_BASIC_INFO);

        byte[] buffer = createMockFileBasicInfoBuffer();
        response.setDataCount(buffer.length / 2); // Set data count to half the buffer

        int bytesRead = response.readDataWireFormat(buffer, 0, buffer.length);

        assertTrue(bytesRead > 0);
        assertNotNull(response.getInfo());
    }

    @Test

			}, nil},
			testWrite{"", 0, nil},

			testClose{nil},
		},
	}, {
		// The truncated test file was produced using these commands:
		//   dd if=/dev/zero bs=1048576 count=16384 > /tmp/16gig.txt
		//   tar -b 1 -c -f- /tmp/16gig.txt | dd bs=512 count=8 > writer-big.tar
		file: "testdata/writer-big.tar",
		tests: []testFnc{
			testHeader{Header{
				Typeflag: TypeReg,
				Name:     "tmp/16gig.txt",
				Size:     16 << 30,

        long count = client.prepareSearch(TEST_INDEX)
                .setQuery(QueryBuilders.termQuery("field", "value1"))
                .execute()
                .actionGet()
                .getHits()
                .getTotalHits()
                .value();
        assertEquals(0, count);
    }

    @Test
    public void testDeleteByQueryWithNoMatches() {

			st.Status = s.Status
			return nil
		}
		sm.resyncStatus[s.ResyncID] = st
		return saveSiteResyncMetadata(GlobalContext, st, newObjectLayerFn())
	}
	return nil
}

// increment SyncedBuckets count
func (sm *siteResyncMetrics) incBucket(o resyncOpts, bktStatus ResyncStatusType) {
	if !globalSiteReplicationSys.isEnabled() {
		return
	}
	sm.Lock()
	defer sm.Unlock()
	st, ok := sm.resyncStatus[o.resyncID]

        requestBody.put("included_urls", includedUrls);
        requestBody.put("user_agent", "Mozilla/5.0");
        requestBody.put("depth", 0);
        requestBody.put("max_access_count", 1L); // Minimal access count
        requestBody.put("num_of_thread", 1);
        requestBody.put("interval_time", 0); // No delay
        requestBody.put("boost", 100);
        requestBody.put("available", true);

```

For example:

```
minio server http://host{1...4}/export{1...16} http://host{5...12}/export{1...16}
```

            // Verify we still have only one process for this session
            Set<String> sessionIds = processHelper.getRunningSessionIdSet();
            assertEquals(1, sessionIds.stream().filter(id -> id.equals(sessionId)).count());

            // Clean up
            processHelper.destroyProcess(sessionId);
        } catch (Exception e) {
            fail("Unexpected exception: " + e.getMessage());
        }
    }

    @Test

   *
   * <p><b>Java 8+ users:</b> In most cases, the {@code Stream} equivalent of this method is {@code
   * stream.filter(element::equals).count()}. If {@code element} might be null, use {@code
   * stream.filter(Predicate.isEqual(element)).count()} instead.
   *
   * @see java.util.Collections#frequency(Collection, Object) Collections.frequency(Collection,
   *     Object)
   */