@Override
    protected <T> Callable<T> wrapTask(Callable<T> callable) {
      return new WrappedCallable<T>(callable);
    }

    @Override
    protected Runnable wrapTask(Runnable command) {
      return new WrappedRunnable(command);
    }
  }

  private static final class MockExecutor implements ScheduledExecutorService {
    String lastMethodCalled = "";
    long lastInitialDelay;
    long lastDelay;

    void testConstructor() {
        assertEquals(testDomain, netServerEnum2.domain);
        assertEquals(testServerTypes, netServerEnum2.serverTypes);
        assertEquals(ServerMessageBlock.SMB_COM_TRANSACTION, netServerEnum2.command);
        assertEquals(SmbComTransaction.NET_SERVER_ENUM2, netServerEnum2.subCommand);
        assertEquals("\\PIPE\\LANMAN", netServerEnum2.name);
        assertEquals(8, netServerEnum2.maxParameterCount);

    void testToStringUnknownCommand() {
        smb.command = (byte) 0xFF; // Unknown command
        smb.errorCode = 0;
        smb.mid = 1;
        String str = smb.toString();
        assertTrue(str.contains("command=UNKNOWN"));
    }

    }

    @Test
    public void testConstructor() {
        // Test if the constructor sets the file name and command correctly
        assertEquals(TEST_FILE_NAME, smbComQueryInformation.path);
        assertEquals(ServerMessageBlock.SMB_COM_QUERY_INFORMATION, smbComQueryInformation.command);
    }

    @Test
    public void testWriteParameterWordsWireFormat() {

    }

    @Test
    @DisplayName("constructor sets correct command value")
    void constructorSetsCorrectCommand() {
        SmbComLogoffAndX msg = new SmbComLogoffAndX(null);
        assertNotNull(msg, "Message should not be null");
        // SMB_COM_LOGOFF_ANDX = 0x74
        assertEquals((byte) 0x74, msg.command, "Command should be SMB_COM_LOGOFF_ANDX");
    }

    @Test

 */

package com.google.common.util.concurrent.testing;

import static java.util.concurrent.TimeUnit.NANOSECONDS;

import com.google.common.annotations.GwtIncompatible;
import com.google.common.collect.ImmutableList;
import com.google.common.util.concurrent.AbstractFuture;
import com.google.common.util.concurrent.AbstractListeningExecutorService;
import com.google.common.util.concurrent.ListenableScheduledFuture;

        // Scenario 1: Command not found
        CommandExecutionException cmdNotFound = new CommandExecutionException("Command 'xyz' not found");
        assertTrue(cmdNotFound.getMessage().contains("not found"));

        // Scenario 2: Command timeout
        CommandExecutionException timeout =

                "Command should change to SMB_COM_TRANSACTION_SECONDARY");
    }

    @Test
    @DisplayName("Test NT transaction command handling")
    void testNtTransactionCommand() {
        transaction.command = ServerMessageBlock.SMB_COM_NT_TRANSACT;

        // First call
        transaction.nextElement();

        // Second call should change to NT_TRANSACT_SECONDARY

Started: 1 minute ago
```

Once it is **Complete**

```
λ mc admin decommission status alias/ http://minio{1...2}/data{1...4}
Decommission of pool http://minio{1...2}/data{1...4} is complete, you may now remove it from server command line
```

### A pool not under decommissioning will throw an error

```
λ mc admin decommission status alias/ http://minio{1...2}/data{1...4}
ERROR: This pool is not scheduled for decommissioning currently.
```

    }

    @Test
    @DisplayName("Should verify command constant in constructor")
    void testCommandConstant() throws Exception {
        // When
        Field commandField = ServerMessageBlock2.class.getDeclaredField("command");
        commandField.setAccessible(true);
        int command = commandField.getInt(request);

        // Then
        assertEquals(0x000F, command); // SMB2_CHANGE_NOTIFY
    }

    @Test