package de.mickare.xserver;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.net.SocketTimeoutException;
import java.util.concurrent.Future;
import java.util.concurrent.atomic.AtomicReference;
import java.util.logging.Level;

import de.mickare.xserver.net.ConnectionObj;

public class MainServer implements Runnable {

  private final ServerSocket server;
  private final AbstractXServerManagerObj manager;
  private final AtomicReference<Future<?>> task = new AtomicReference<Future<?>>(null);

  private volatile boolean open = false;

  protected MainServer(ServerSocket server, AbstractXServerManagerObj manager) {
    // super( "XServer Main Server Thread" );
    this.server = server;
    this.manager = manager;
  }

  public synchronized void close() throws IOException {
    open = false;
    try {
      if (!this.server.isClosed()) {
        this.manager.debugInfo("Closing MainServer...");
        this.server.close();
        this.manager.debugInfo("MainServer closed");
      }
    } finally {
      if (this.task.get() != null) {
        this.task.get().cancel(true);
        this.task.set(null);
      }
    }
  }

  public boolean isClosed() {
    return !open && this.server.isClosed();
  }

  @Override
  public void run() {
    while (!isClosed()) {
      try {
        Socket socket = server.accept();
        if (!isClosed()) {
          socket.close();
        } else {
          new ConnectionObj(socket, manager);
        }
      } catch (SocketTimeoutException ste) {
        // ignore
      } catch (SocketException e) {
        if (!"socket closed".equals(e.getMessage()) || !isClosed()) {
          manager.getLogger().log(Level.WARNING, "Exception while client connects: " + e.getMessage(), e);
        }
      } catch (IOException e) {
        // Only log if not shutdown. This prevents misleading issue reports on github.
        manager.getLogger().log(Level.WARNING, "Exception while client connects: " + e.getMessage(), e);
      }
    }
  }

  public synchronized void start(ServerThreadPoolExecutor stpool) {
    if (task.get() == null) {
      this.manager.debugInfo("Starting MainServer...");
      open = true;
      task.set(stpool.runServerTask(this));
      this.manager.debugInfo("MainServer closed");
    }
  }

}

@@ -1407,17 +1407,16 @@
     if (
-!
 isClosed

fix small mishap