urls.add(new URL("file", null, new File(entry).getAbsolutePath()));
        }
      } catch (MalformedURLException e) {
        throw new AssertionError("malformed class path entry: " + entry, e);
      }
    }
    return urls.build();
  }

        byte[] buffer = new byte[100];

        // Should work with zero length
        int result = emptyBufferResponse.readDataWireFormat(buffer, 0, 0);
        assertEquals(0, result);

        // Should throw exception with non-zero length
        assertThrows(SMBProtocolDecodingException.class, () -> emptyBufferResponse.readDataWireFormat(buffer, 0, 1));
    }

    largeElementSplitFunction: (T, Int) -> List<R>,
    smallElementAggregateFunction: (List<T>) -> R,
    expectedBucketNumber: Int,
    maxNumberInBucket: Int,
    noElementSplitFunction: (Int) -> List<R> = { throw IllegalArgumentException("More buckets than things to split") },
    canRunTogether: (T, T) -> Boolean = { _, _ -> true },
): List<R> {
    if (list.isEmpty()) {
        return noElementSplitFunction(expectedBucketNumber)

  private final ListenableFutureTask<Integer> task =
      ListenableFutureTask.create(
          () -> {
            runLatch.countDown();
            taskLatch.await();
            if (throwException) {
              throw new IllegalStateException("Fail");
            }
            return 25;
          });

  @Override
  protected void setUp() throws Exception {
    super.setUp();

    exec = newCachedThreadPool();

    try {
      for (int i = axes.size() - 1; i >= 0; i--) {
        axesSizeProduct[i] = Math.multiplyExact(axesSizeProduct[i + 1], axes.get(i).size());
      }
    } catch (ArithmeticException e) {
      throw new IllegalArgumentException(
          "Cartesian product too large; must have size at most Integer.MAX_VALUE");
    }
    this.axesSizeProduct = axesSizeProduct;
  }

                endpoint = new Object();

                initialized = true;
                log.info("DiSNI RDMA provider initialized");

            } catch (Exception e) {
                throw new IOException("Failed to initialize DiSNI", e);
            }
        }
    }

    @Override
    public String getProviderName() {
        return "DiSNI (InfiniBand/RoCE)";
    }

    @Override

        // Assert throwing/catching behavior with assertThrows
        SMBProtocolDecodingException thrown = assertThrows(SMBProtocolDecodingException.class, () -> {
            throw new SMBProtocolDecodingException();
        }, "Should be throwable via assertThrows");
        assertTrue(thrown instanceof CIFSException, "Thrown instance should also be CIFSException subtype");
    }

    @ParameterizedTest

            bufferIndex += 2;
            final int numAces = ServerMessageBlock.readInt4(buffer, bufferIndex);
            bufferIndex += 4;

            if (numAces > 4096) {
                throw new IOException("Invalid SecurityDescriptor");
            }

            aces = new ACE[numAces];
            for (int i = 0; i < numAces; i++) {
                aces[i] = new ACE();

            final int start = bufferIndex;

            version = readInt2(buffer, bufferIndex);
            if (version != 3 && version != 1) {
                throw new RuntimeException("Version " + version + " referral not supported. Please report this to jcifs at samba dot org.");
            }
            bufferIndex += 2;
            size = readInt2(buffer, bufferIndex);

   */
  @VisibleForTesting transient @Nullable Object @Nullable [] values;

  /**
   * Keeps track of metadata like the number of hash table bits and modifications of this data
   * structure (to make it possible to throw ConcurrentModificationException in the iterator). Note
   * that we choose not to make this volatile, so we do less of a "best effort" to track such
   * errors, for better performance.
   *