* Verify that all methods can be called with null buffers without
     * throwing exceptions. This test ensures robustness of the implementation.
     */
    @Test
    void methodsHandleNullBuffersGracefully() {
        // Arrange
        TransWaitNamedPipeResponse resp = new TransWaitNamedPipeResponse();
        // Act & Assert - no exceptions should be thrown
        assertDoesNotThrow(() -> resp.writeSetupWireFormat(null, 0));

        void testReadOperationsWithNullBuffer() {
            // Read operations return 0 when given null buffer - no exceptions thrown
            assertEquals(0, response.readSetupWireFormat(null, 0, 0));
            assertEquals(0, response.readParametersWireFormat(null, 0, 0));

            // readDataWireFormat will throw when accessing null buffer
            assertThrows(NullPointerException.class, () -> {

        // When/Then: Should throw last exception
        IOException thrown = assertThrows(IOException.class, () -> poolSpy.getSmbTransport(ctx, "failing.server", 445, false, false));
        assertSame(secondException, thrown);

        // Verify fail counts incremented
        assertEquals(1, pool.failCounts.get("10.0.0.1"));

 */
package org.codelibs.core.exception;

import static org.codelibs.core.collection.ArrayUtil.asArray;

import java.lang.reflect.Constructor;

/**
 * Exception thrown when a {@link Constructor} cannot be found.
 *
 * @author higa
 */
public class ConstructorNotFoundRuntimeException extends ClRuntimeException {

    private static final long serialVersionUID = 8584662068396978822L;

  public void writeShort(int v) throws IOException {
    out.write(0xFF & v);
    out.write(0xFF & (v >> 8));
  }

  @Override
  public void writeUTF(String str) throws IOException {
    ((DataOutputStream) out).writeUTF(str);
  }

  // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior:
  // it silently ignores any exception thrown by flush(). Instead, just close the delegate stream.

        } catch (final IOException e) {
            throw new IORuntimeException(e);
        }
    }

    /**
     * Reads the contents of a file into a byte array and returns it.
     * <p>
     * <strong>Note:</strong> This method loads the entire file into memory.
     * For files larger than {@value #MAX_BUF_SIZE} bytes (10MB), an
     * {@link IORuntimeException} will be thrown to prevent OutOfMemoryError.

          public Integer computeNext() {
            if (haveBeenCalled) {
              throw new AssertionError("Should not have been called again");
            } else {
              haveBeenCalled = true;
              throw sneakyThrow(new SomeCheckedException());
            }
          }
        };

    // The first time, the sneakily-thrown exception comes out
    assertThrows(SomeCheckedException.class, iter::hasNext);

 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.crawler.exception;

/**
 * Exception thrown during the extraction process in the crawler.
 * This exception indicates a failure or error that occurred while extracting content from a crawled resource.

    assertThrows(TimeoutException.class, () -> manager.awaitHealthy(1, MILLISECONDS));
    manager.awaitHealthy(5, SECONDS); // no exception thrown

    manager.stopAsync();
    assertThrows(TimeoutException.class, () -> manager.awaitStopped(1, MILLISECONDS));
    manager.awaitStopped(5, SECONDS); // no exception thrown
  }

  /**
   * This covers a case where if the last service to stop failed then the stopped callback would

 * It extends CrawlerSystemException and provides functionality to set and check the log level for the exception.
 *
 * <p>
 * This exception can be thrown when there are problems accessing URLs, files, or any other resources needed for crawling.
 * It includes constructors to handle messages, causes, or both.
 * </p>
 *
 * <p>