final Queue<OldExecutionList.RunnableExecutorPair> runnables = new LinkedList<>();
    boolean executed = false;

    void add(Runnable runnable, Executor executor) {
      Preconditions.checkNotNull(runnable, "Runnable was null.");
      Preconditions.checkNotNull(executor, "Executor was null.");

      boolean executeImmediate = false;

      synchronized (runnables) {
        if (!executed) {

        assertEquals("\\server\\share\\folder", normalized);
    }

    @Test
    public void testUncPathNotAllowed() throws Exception {
        PathValidator noUncValidator = new PathValidator(260, 255, false, false);
        // Due to normalization bug, UNC paths are not properly detected
        // The normalization removes all duplicate backslashes, so \\\\server becomes \server

    private static class TestExecJob extends ExecJob {
        private String executeType = "test";
        private String executeResult = "success";
        private boolean throwException = false;

        @Override
        public String execute() {
            if (throwException) {
                throw new RuntimeException("Test exception");
            }
            return executeResult;
        }

        return this.connection.getResponseMessage();
    }

    @Override
    public void disconnect() {
        this.connection.disconnect();
        this.handshakeComplete = false;
        this.connected = false;
    }

    @Override
    public boolean usingProxy() {
        return this.connection.usingProxy();
    }

    @Override
    public InputStream getErrorStream() {

    @BeforeEach
    void setUp() throws Exception {
        MockitoAnnotations.openMocks(this);
        // Use real configuration for most tests
        mockConfig = new BaseConfiguration(false);
        response = new NetServerEnum2Response(mockConfig);
    }

    @Test
    @DisplayName("Test constructor with configuration")
    void testConstructor() {
        assertNotNull(response);

            factory.setFeature(Constants.FEATURE_SECURE_PROCESSING, true);
            factory.setFeature(Constants.FEATURE_EXTERNAL_GENERAL_ENTITIES, false);
            factory.setFeature(Constants.FEATURE_EXTERNAL_PARAMETER_ENTITIES, false);
            factory.setAttribute(XMLConstants.ACCESS_EXTERNAL_DTD, StringUtil.EMPTY);
            factory.setAttribute(XMLConstants.ACCESS_EXTERNAL_SCHEMA, StringUtil.EMPTY);

      private val delegate: MutableIterator<DiskLruCache.Snapshot> = cache.snapshots()
      private var nextUrl: String? = null
      private var canRemove = false

      override fun hasNext(): Boolean {
        if (nextUrl != null) return true

        canRemove = false // Prevent delegate.remove() on the wrong item!
        while (delegate.hasNext()) {
          try {
            delegate.next().use { snapshot ->

                    } else {
                        makeKey(req);
                    }

                    synchronized (this) {
                        response.received = false;
                        resp.isReceived = false;
                        try {
                            response_map.put(req, resp);

                            /*
                             * Send multiple fragments

        CharArrayAsList that = (CharArrayAsList) object;
        int size = size();
        if (that.size() != size) {
          return false;
        }
        for (int i = 0; i < size; i++) {
          if (array[start + i] != that.array[that.start + i]) {
            return false;
          }
        }
        return true;
      }
      return super.equals(object);
    }

    @Override

    try (Socket socket = new Socket()) {
        socket.connect(new InetSocketAddress(address, 135), 5000);  // RPC endpoint
        return true;
    } catch (IOException e) {
        return false;
    }
}

public void registerForWitnessNotifications(String shareName) {
    if (!witnessEnabled || witnessClient == null) {
        return;
    }
    
    try {