*/
public class DfsReferral extends SmbException {

    /** Number of characters consumed from the path */
    public int pathConsumed;
    /** Time to live for this referral in seconds */
    public long ttl;
    /** Target server for this referral */
    public String server; // Server
    /** Target share for this referral */
    public String share; // Share
    /** The complete UNC path link */

        FwAssistantDirector assistantDirector = createMockAssistantDirector();

        // First invocation
        curtainFinallyHook.hook(assistantDirector);

        // Second invocation - should also work without issues
        curtainFinallyHook.hook(assistantDirector);

        // Third invocation
        curtainFinallyHook.hook(assistantDirector);

        jobExecutor.addShutdownListener(listener1);
        assertEquals(listener1, jobExecutor.shutdownListener);

        // Replace with second listener
        jobExecutor.addShutdownListener(listener2);
        assertEquals(listener2, jobExecutor.shutdownListener);

        // Verify only second listener is called
        jobExecutor.shutdown();
        assertEquals(10, callCount.get());
    }

    public void test_shutdown() {

       * columns in the first row, the columns in the second row, etc. If a column Comparator is
       * provided but a row Comparator isn't, cellSet() iterates across the rows in the first
       * column, the rows in the second column, etc.
       */
      Comparator<Cell<R, C, V>> comparator =
          (Cell<R, C, V> cell1, Cell<R, C, V> cell2) -> {

  }

  @Override
  V checkValue(V value) {
    return checkNotNull(value);
  }

  /**
   * @serialData the key class, value class, number of entries, first key, first value, second key,
   *     second value, and so on.
   */
  @GwtIncompatible // java.io.ObjectOutputStream
  private void writeObject(ObjectOutputStream stream) throws IOException {
    stream.defaultWriteObject();

        assertEquals(16L, response.getOffset(), "First read should set offset to 16");

        response.readParameterWordsWireFormat(buffer2, 0);
        assertEquals(32L, response.getOffset(), "Second read should update offset to 32");
    }

    @Test
    @DisplayName("getOffset returns same value on multiple calls")
    void testGetOffsetConsistency() {

  private void assertNoExpectedFailures() {
    assertWithMessage("executor was shut down")
        .that(shutdownAndAwaitTermination(executor, 10, SECONDS))
        .isTrue();
    assertWithMessage("closingExecutor was shut down")
        .that(shutdownAndAwaitTermination(closingExecutor, 10, SECONDS))
        .isTrue();
    if (!failures.isEmpty()) {
      StringWriter message = new StringWriter();

        c.acquire();
        verify(tree, times(1)).acquire();

        // Act: second acquire does not call tree.acquire again
        c.acquire();
        verify(tree, times(1)).acquire();

        // Act: first release does not release yet (usage -> 1)
        c.release();
        verify(tree, never()).release();

        // Act: second release (usage -> 0) releases the tree
        c.release();

        // Then
        assertNotNull(resource1, "First resource should be created");
        assertNotNull(resource2, "Second resource should be created");
        assertNotNull(pipe1, "First pipe should be created");
        assertNotNull(pipe2, "Second pipe should be created");

        assertNotSame(resource1, resource2, "Different resources should be different instances");

        try {
            Future<List<FileNotifyInformation>> future = executor.submit((Callable<List<FileNotifyInformation>>) realHandle);
            List<FileNotifyInformation> result = future.get(1, TimeUnit.SECONDS);

            // Verify
            assertNotNull(result);
            assertEquals(1, result.size());
            assertEquals(fileNotifyInfo1, result.get(0));
        } finally {