if (size > maxSize) {
            failedValidations.incrementAndGet();
            log.warn("Message size exceeds maximum: {} > {}", size, maxSize);
            throw new SmbException("Message size exceeds maximum: " + size + " > " + maxSize);
        }
    }

    /**
     * Validate string from server response
     *
     * @param str string to validate

            throw new IllegalArgumentException(
                    "Source array bounds exceeded: offset=" + srcOffset + ", length=" + length + ", array.length=" + src.length);
        }
        if (dstOffset + length > dst.length) {
            throw new IllegalArgumentException(
                    "Destination array bounds exceeded: offset=" + dstOffset + ", length=" + length + ", array.length=" + dst.length);
        }
    }

        // Test when data length exceeds outputBuffer size
        byte[] buffer = new byte[2000];
        int dataLen = outputBuffer.length + 100; // Exceeds outputBuffer size

        SMBProtocolDecodingException exception =
                assertThrows(SMBProtocolDecodingException.class, () -> response.readDataWireFormat(buffer, 0, dataLen));

        assertEquals("Payload exceeds buffer size", exception.getMessage());
    }

        }
        if (offset + length > data.length) {
            throw new IllegalArgumentException("Offset + length exceeds data buffer size");
        }
        if (offset + SIGNATURE_OFFSET + SIGNATURE_LENGTH > data.length) {
            throw new IllegalArgumentException("Signature field exceeds data buffer size");
        }

        // Use fine-grained locking for better concurrency
        this.signingLock.lock();

        assertThrows(IndexOutOfBoundsException.class, () -> {
            encodable.encode(dest, 0);
        }, "Should throw IndexOutOfBoundsException if source offset + length exceeds source array bounds");
    }

    @Test
    void testEncodeDestinationTooSmall() {
        // Test when destination array is too small
        byte[] data = { 0x01, 0x02, 0x03 };

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.exception;

/**
 * This exception is thrown when the requested result offset exceeds the limit.
 */
public class ResultOffsetExceededException extends FessSystemException {
    private static final long serialVersionUID = 1L;

    /**
     * Constructor.
     * @param message The exception message.
     */

	MaxUploads int

	// Indicates whether the returned list of multipart uploads is truncated. A
	// value of true indicates that the list was truncated. The list can be truncated
	// if the number of multipart uploads exceeds the limit allowed or specified
	// by max uploads.
	IsTruncated bool

	// List of all pending uploads.
	Uploads []MultipartInfo

	// When a prefix is provided in the request, The result contains only keys

 */
package org.codelibs.fess.crawler.exception;

/**
 * MaxLengthExceededException is thrown when the content length exceeds the maximum allowed length.
 * It extends CrawlingAccessException, indicating a crawling-related access issue.
 *
 */
public class MaxLengthExceededException extends CrawlingAccessException {

    private static final long serialVersionUID = 1L;

    /**

    }

    /**
     * Extracts data from the input stream using the configured parameters.
     *
     * @return the extracted data
     * @throws MaxLengthExceededException if content length exceeds maximum allowed
     * @throws ExtractException if extraction fails
     */
    public ExtractData extract() {
        final ExtractorFactory extractorFactory = crawlerContainer.getComponent("extractorFactory");

        if (len > this.outputBuffer.length) {
            throw new SMBProtocolDecodingException("Payload exceeds buffer size");
        }
        System.arraycopy(buffer, bufferIndex, this.outputBuffer, 0, len);
        return len;
    }

    @Override
    public String toString() {