* any one time. If this method throws an exception or the connect timeout
     * expires an encapsulating TransportException will be thrown from connect
     * and the transport will be in error.
     */

    /**
     * Establish the transport connection
     *
     * @throws Exception if the connection fails
     */
    protected abstract void doConnect() throws Exception;

    /*

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

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

import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;

/**
 * Exception that wraps {@link NoSuchAlgorithmException}.
 *
 * @author shinsuke
 */

 * under the License.
 */
package org.apache.maven.execution;

/**
 * This exception will be thrown when something fails while persisting build resumption data.
 * @see BuildResumptionDataRepository#persistResumptionData
 */
public class BuildResumptionPersistenceException extends Exception {
    public BuildResumptionPersistenceException(String message, Throwable cause) {

    @Mock
    private CIFSContext ctx;
    @Mock
    private Configuration cfg;
    @Mock
    private Address address;

    private SmbTransportImpl transport;

    @BeforeEach
    void setUp() throws Exception {
        when(ctx.getConfig()).thenReturn(cfg);
        when(cfg.isSigningEnforced()).thenReturn(false);
        when(cfg.getSessionTimeout()).thenReturn(30_000);
        when(cfg.getResponseTimeout()).thenReturn(5_000);

      builder.addInterceptor(interceptor)
    }
    client = builder.build()
  }

  /** Catches exceptions that are otherwise headed for the uncaught exception handler.  */
  private class ExceptionCatchingExecutor : ThreadPoolExecutor(1, 1, 0, TimeUnit.SECONDS, SynchronousQueue()) {
    private val exceptions: BlockingQueue<Exception> = LinkedBlockingQueue()

    override fun execute(runnable: Runnable) {
      super.execute {

  protected ListenableFuture<Boolean> future;

  @Override
  protected void setUp() throws Exception {

    // Create a latch and a future that waits on the latch.
    latch = new CountDownLatch(1);
    future = createListenableFuture(Boolean.TRUE, null, latch);
  }

  @Override
  protected void tearDown() throws Exception {

    // Make sure we have no waiting threads.
    latch.countDown();
  }

        // Assert: "bad" was skipped due to filter exception, "good" returned
        assertNotNull(next);
        assertEquals("good", next.getName());
        assertFalse(it.hasNext());
        verify(tree, times(1)).release();
    }

    @Test
    @DisplayName("advance() path handles fetchMore throwing CIFSException in next()")
    void advanceFetchMoreThrows() throws Exception {
        // Arrange

        assertTrue((long) stats.get("totalAllocated") > 0);
    }

    @Test
    @DisplayName("Test resource close tracking")
    void testResourceCloseTracking() throws Exception {
        TestResource resource = new TestResource("test2");
        String resourceId = resourceManager.registerResource(resource);

        resource.close();
        resourceManager.markClosed(resourceId);

      public CacheResponse(File cacheDirectory) throws Exception {
        int cacheSize = 10 * 1024 * 1024; // 10 MiB
        Cache cache = new Cache(cacheDirectory, cacheSize);

        client = new OkHttpClient.Builder()
            .cache(cache)
            .build();
      }

      public void run() throws Exception {
        Request request = new Request.Builder()

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

/**
 * Exception thrown when command execution fails.
 * This exception indicates that an external command or process execution encountered an error.
 */
public class CommandExecutionException extends FessSystemException {

    private static final long serialVersionUID = 1L;