public void run() {
            throw new BadRunnableException();
          }
        };

    future.set(1);
    future.addListener(bad, directExecutor()); // BadRunnableException must not propagate.
  }

  public void testMisbehavingListenerLaterDone() {
    class BadRunnableException extends RuntimeException {}

    CountingRunnable before = new CountingRunnable();
    Runnable bad =

        assertTrue(filter.accept(smbFile), "Positive size should be accepted");
        verify(smbFile, times(1)).length();
        verifyNoMoreInteractions(smbFile);
    }

    @Test
    @DisplayName("accept: propagates SmbException thrown by dependency")
    void accept_propagatesSmbException() throws Exception {
        // Arrange: filter delegates to isDirectory which may throw SmbException

            // Then: Should call sendrecv with bind message
            verify(spyHandle).sendrecv(any(DcerpcMessage.class));
        }

        @Test
        @DisplayName("Should propagate IOException during bind")
        void testBindIOException() throws DcerpcException, IOException {
            // Given: Spy that throws IOException on sendrecv

            when(mockSmbPipeHandleInternal.getSessionKey()).thenReturn(expectedKey);
            assertArrayEquals(expectedKey, handle.getSessionKey());
        }

        @Test
        @DisplayName("Should propagate CIFSException when getting session key")
        void testGetSessionKey_ThrowsCIFSException() throws Exception {
            DcerpcPipeHandle handle = createMockedDcerpcPipeHandle();

  private static final LazyLogger logger = new LazyLogger(AggregateFuture.class);

  /**
   * The input futures. After {@link #init}, this field is read only by {@link #afterDone()} (to
   * propagate cancellation) and {@link #toString()}. To access the futures' <i>values</i>, {@code
   * AggregateFuture} attaches listeners that hold references to one or more inputs. And in the case

        // Then it should be rejected because the ARCHIVE attribute is not present
        assertFalse(dosFileFilter.accept(mockFile));
    }

    /**
     * Tests that the accept method correctly propagates SmbException when
     * {@link SmbFile#getAttributes()} throws it.
     * @throws SmbException if an SMB error occurs.
     */
    @Test
    void testAccept_ThrowsSmbException() throws SmbException {

        boolean result = filter.accept(null, "anything");

        assertTrue(result, "Filter should accept when dir is null as defined");
    }

    /**
     * Exception flow: filter throws SmbException and it propagates to caller.
     */
    @Test
    @DisplayName("throws SmbException as declared by contract")
    void throwsSmbExceptionFromFilter() {
        SmbFilenameFilter filter = (dir, name) -> {

            assertEquals(0, testMessage.getTreeId());
            testMessage.setTreeId(123);
            assertEquals(123, testMessage.getTreeId());
        }

        @Test
        @DisplayName("Should propagate tree ID to chained message")
        void testTreeIdPropagation() {
            TestServerMessageBlock2 nextMessage = new TestServerMessageBlock2(mockConfig);
            testMessage.chain(nextMessage);

    * Note: for this change, the other allocators still exist and are the default.
    * It supports two modes:
        * CIDR range allocations done within the cluster that are then propagated out to the cloud provider.
        * Cloud provider managed IPAM that is then reflected into the cluster.

		// CRI-O, Containerd etc..
		// Fallback to our container specific ENVs if they are set.
		return env.IsSet("MINIO_ACCESS_KEY_FILE")
	}

	// Log error, as we will not propagate it to caller
	internalLogIf(GlobalContext, err)

	return err == nil
}

// IsDCOS returns true if minio is running in DCOS.
func IsDCOS() bool {