NtTransNotifyChange notify3 = new NtTransNotifyChange(mockConfig, 0x3333, FILE_NOTIFY_CHANGE_ATTRIBUTES, false);

        // Verify each instance maintains its own state
        byte[] dst1 = new byte[8];
        byte[] dst2 = new byte[8];
        byte[] dst3 = new byte[8];

        notify1.writeSetupWireFormat(dst1, 0);
        notify2.writeSetupWireFormat(dst2, 0);

    try {
      t.join(timeoutMillis);
    } catch (InterruptedException ie) {
      threadUnexpectedException(ie);
    } finally {
      if (t.getState() != Thread.State.TERMINATED) {
        t.interrupt();
        fail("Test timed out");
      }
    }
  }

  /**
   * Waits for LONG_DELAY_MS milliseconds for the thread to terminate (using {@link

    void testInitialGetterValues() {
        // Create fresh instance
        SrvPipePeekResponse freshResponse = new SrvPipePeekResponse();

        // Verify initial state
        assertEquals(0, freshResponse.getNamedPipeState());
        assertEquals(0, freshResponse.getReadDataAvailable());
        assertEquals(0, freshResponse.getNumberOfMessages());

        String actualFilename = readString(buffer, 12, written - 12);
        assertEquals(filename, actualFilename);
    }

    @Test
    void testResetMultipleTimes() {
        // Test multiple resets to ensure state is properly maintained
        trans2FindNext2 = new Trans2FindNext2(config, TEST_SID, TEST_RESUME_KEY, TEST_FILENAME, TEST_BATCH_COUNT, TEST_BATCH_SIZE);

        for (int i = 1; i <= 5; i++) {

        byte[] dst = new byte[100];
        int originalHexCode = 0xFF;
        mockName.hexCode = originalHexCode;

        // Create a spy to capture the state during writeQuestionSectionWireFormat
        NodeStatusRequest spyRequest = spy(nodeStatusRequest);
        doAnswer(invocation -> {
            // Verify hexCode is 0 during the call

 * under the License.
 */

/**
 * <h2>Maven Core API</h2>
 *
 * <h3>Session</h3>
 *
 * <p>The {@link org.apache.maven.api.Session} interface is the main entry point for Maven operations.
 * It maintains the state of a Maven execution and provides access to all core services and components.
 * Sessions are thread-safe and can be obtained in session-scoped components using the
 * {@link org.apache.maven.api.di.SessionScoped} annotation.</p>
 *

            }
            return false;
        }

        // Document already exists - check if it's stale
        return tryCleanupAndRetry(operationName, data, remainingRetries);
    }

    /**
     * Checks if the existing operation lock is stale (expired or owner inactive) and retries acquisition.
     *
     * @param operationName the operation name.

        break;
      }
      index++;
    }
    return index;
  }

  /**
   * Escapes a code point that has no direct explicit value in the replacement array and lies
   * outside the stated safe range. Subclasses should override this method to provide generalized
   * escaping for code points if required.
   *
   * <p>Note that arrays returned by this method must not be modified once they have been returned.

		(*z)[zb0001], bts, err = msgp.ReadStringBytes(bts)
		if err != nil {
			err = msgp.WrapError(err, zb0001)
			return
		}
	}
	o = bts
	return
}

// Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (z BatchJobPrefix) Msgsize() (s int) {
	s = msgp.ArrayHeaderSize
	for zb0003 := range z {
		s += msgp.StringPrefixSize + len(z[zb0003])
	}
	return
}

        // CIFS context returns same config to build responses during initResponse
        lenient().when(cifsContext.getConfig()).thenReturn(config);
    }

    @AfterEach
    void teardown() {
        // No global state to reset beyond mocks
    }

    static Stream<String> wildcardProvider() {
        return Stream.of(null, "", "*");
    }

    @ParameterizedTest
    @MethodSource("wildcardProvider")