public final void readFully(final byte b[], final int off, final int len) throws SmbException {
        int n = 0, count;

        do {
            count = this.read(b, off + n, len - n);
            if (count < 0) {
                throw new SmbException("EOF");
            }
            n += count;
            fp += count;
        } while (n < len);
    }

    @Override

@ExtendWith(MockitoExtension.class)
class SrvCopychunkCopyTest {

    private static final int SOURCE_KEY_SIZE = 24;
    private static final int HEADER_SIZE = 32; // 24 bytes source key + 4 bytes chunk count + 4 bytes reserved
    private static final int CHUNK_SIZE = 24;

    @Mock
    private SrvCopychunk mockChunk;

    @BeforeEach
    void setUp() {
    }

    @Nested

}

func TestCountNearPageBoundary(t *testing.T) {
	t.Parallel()
	b := dangerousSlice(t)
	for i := range b {
		c := Count(b[i:], []byte{1})
		if c != 0 {
			t.Fatalf("Count(b[%d:], {1})=%d, want 0\n", i, c)
		}
		c = Count(b[:i], []byte{0})
		if c != i {
			t.Fatalf("Count(b[:%d], {0})=%d, want %d\n", i, c, i)
		}
	}

   * support concurrent multisets whose content may change while the method is running.
   *
   * <p>The serialized output consists of the number of distinct elements, the first element, its
   * count, the second element, its count, and so on.
   */
  static <E extends @Nullable Object> void writeMultiset(
      Multiset<E> multiset, ObjectOutputStream stream) throws IOException {
    int entryCount = multiset.entrySet().size();

        when(mockNdrBuffer.dec_ndr_long()).thenReturn(2, 1); // count, array pointer
        when(mockDeferredBuffer.dec_ndr_long()).thenReturn(2); // array size
        mockDeferredBuffer.index = 0; // Set field directly
        mockDeferredBuffer.deferred = mockDeferredBuffer;

        ctr0.decode(mockNdrBuffer);

        assertEquals(2, ctr0.count);
        assertNotNull(ctr0.array);

        assertEquals(8, next.maxParameterCount, "Max parameter count should be 8");
        assertEquals(Trans2FindFirst2.LIST_SIZE, next.maxDataCount, "Max data count should use LIST_SIZE");
        assertEquals((byte) 0x00, next.maxSetupCount, "Max setup count must be 0");

        // Information level defaults to BOTH_DIRECTORY_INFO (0x104) — check via parameters encoding

      ensureRoomFor(values.length());
      System.arraycopy(values.array, values.start, array, count, values.length());
      count += values.length();
      return this;
    }

    private void ensureRoomFor(int numberToAdd) {
      int newCount = count + numberToAdd; // TODO(kevinb): check overflow now?
      if (newCount > array.length) {

      ensureRoomFor(values.length());
      System.arraycopy(values.array, values.start, array, count, values.length());
      count += values.length();
      return this;
    }

    private void ensureRoomFor(int numberToAdd) {
      int newCount = count + numberToAdd; // TODO(kevinb): check overflow now?
      if (newCount > array.length) {

            }
        }

        int totalCount = 0;
        int count = 1;
        final ExecutorService executorService = Executors.newFixedThreadPool(options.numOfThreads);
        try {
            while (count != 0) {
                count = ComponentUtil.getThumbnailManager().generate(executorService, options.cleanup);
                totalCount += count;
            }
            executorService.shutdown();

		"Drive health (0 = offline, 1 = healthy, 2 = healing)", allDriveLabels...)

	driveOfflineCountMD = NewGaugeMD(driveOfflineCount,
		"Count of offline drives")
	driveOnlineCountMD = NewGaugeMD(driveOnlineCount,
		"Count of online drives")
	driveCountMD = NewGaugeMD(driveCount,
		"Count of all drives")

	// iostat related
	driveReadsPerSecMD = NewGaugeMD(driveReadsPerSec,
		"Reads per second on a drive",