import org.dbflute.optional.OptionalEntity;

/**
 * @author FreeGen
 */
public class SearchLog extends BsSearchLog implements SearchLogEvent {

    private static final long serialVersionUID = 1L;

    private final List<Pair<String, String>> searchFieldLogList = new ArrayList<>();

    private final List<Pair<String, String>> headerList = new ArrayList<>();

    private OptionalEntity<UserInfo> userInfo;

 * - File handle leaks
 * - Connection pool exhaustion
 * - Memory allocation failures
 * - Quota exceeded
 */
public class SmbResourceException extends SmbException {

    private static final long serialVersionUID = 1L;

    /**
     * Resource type that caused the error
     */
    public enum ResourceType {
        FILE_HANDLE, CONNECTION, MEMORY, DISK_SPACE, QUOTA, LOCK, BUFFER, THREAD_POOL
    }

        // Arrange: filter that accepts only strictly positive length
        SmbFileFilter filter = f -> f.length() > 0;

        // negative size -> reject
        when(smbFile.length()).thenReturn(-1L);
        assertFalse(filter.accept(smbFile), "Negative size should be rejected");
        verify(smbFile, times(1)).length();

        // zero size -> reject
        reset(smbFile);

/**
 * @param <ENTITY> The type of entity.
 * @author ESFlute (using FreeGen)
 */
public class EsPagingResultBean<ENTITY> extends PagingResultBean<ENTITY> {

    private static final long serialVersionUID = 1L;

    protected long took;
    private int totalShards;
    private int successfulShards;
    private int failedShards;
    private TotalHits totalHits;
    private Aggregations aggregations;

    }

    /**
     * Parameterised test of capacity values, including edge cases such as
     * zero and negative capacities.
     */
    @ParameterizedTest
    @ValueSource(longs = { 0L, -1L, Long.MAX_VALUE })
    @DisplayName("capacity may be any long value")
    void testCapacityEdgeValues(long capacity) {
        when(mockAllocInfo.getCapacity()).thenReturn(capacity);

    @Test
    @DisplayName("Test setSessionId with boundary values")
    void testSetSessionIdWithBoundaryValues() {
        // Test with various session ID values
        long[] sessionIds = { 0L, 1L, Long.MAX_VALUE, Long.MIN_VALUE, -1L };

        for (long sessionId : sessionIds) {
            doNothing().when(messageBlock).setSessionId(sessionId);
            messageBlock.setSessionId(sessionId);

  fun bytesThrowsMoreThanIntMaxValue() {
    val body: ResponseBody =
      object : ResponseBody() {
        override fun contentType(): MediaType? = null

        override fun contentLength(): Long = Int.MAX_VALUE + 1L

        override fun source(): BufferedSource = throw AssertionError()
      }
    assertFailsWith<IOException> {
      body.bytes()
    }.also { expected ->
      assertThat(expected.message).isEqualTo(

    public void testConvertValue_propertyConverter_asObject() throws Exception {
        assertThat(new CopyOptions().converter(new NumberConverter("##0"), BeanNames.aaa()).convertValue("1", "aaa", null),
                is((Object) 1L));
    }

    /**
     * @throws Exception
     */
    @Test
    public void testConvertValue_typeConverter_asString() throws Exception {

        SMBUtil.writeInt4(overflowSize, buffer, 6);

        response.readParameterWordsWireFormat(buffer, 0);

        // 0xFFFFFFFF becomes -1 when interpreted as signed int
        assertEquals(-1L, response.getSize());
    }

    @Test
    void testReadBytesWireFormat() {
        // Test readBytesWireFormat - should always return 0
        response = new SmbComQueryInformationResponse(mockConfig, 0L);

    connectionIndex: Int,
    exchangeIndex: Int,
  ): RecordedRequest {
    var request: RequestLine = DEFAULT_REQUEST_LINE_HTTP_1
    val headers = Headers.Builder()
    var contentLength = -1L
    var chunked = false
    var hasBody = false
    val requestBody = TruncatingBuffer(bodyLimit)
    var chunkSizes: List<Int>? = null
    var failure: IOException? = null

    try {