//CYCLONE MATRIX HOST NODE APPLICATION
//Hermann L. Johnson, 2019
//Free for unmodified distribution and non-commercial use.

import java.io.*;
import java.net.*;
import java.util.*;
import java.util.zip.*;

public class ServerConnectionThread extends Thread
{

    private ServerSocket serverSocket;

    private int PORT;
    private int MAX_CONNECTIONS;
    private Vector<ServerThread> openSockets;
    private DataManager data_manager;

    private boolean intakeServer, zipped;

    private boolean running;

    public ServerConnectionThread(int port, int max_connections,
				  DataManager data_manager, boolean intake,
				  boolean zipped)
    {

	super("ServerConnectionThread-Upload:"+Integer.valueOf(port));
	running = false;
	PORT = port;
	MAX_CONNECTIONS = max_connections;
	intakeServer = intake;
	this.data_manager = data_manager;
	this.zipped = zipped;
	openSockets = new Vector<ServerThread>();

    }

    public synchronized boolean running() {
	return running;
    }

    public synchronized void setRunning(boolean newValue) {
	running = newValue;
    }

    public void killThread() {

	setRunning(false);
     
    }

    public synchronized int getNumActiveConnections() {
	return openSockets.size();
    }

    private synchronized void checkSockets() {
	for(int count=0;count<openSockets.size();count++) {
	    if(openSockets.elementAt(count).isClosed()) {
		openSockets.removeElementAt(count);
		count--;
	    }
	}
    }

    public void run()
    {

	running = true;

	try {
	    while(running) {

		if(openSockets.size()<MAX_CONNECTIONS) {

		    serverSocket = new ServerSocket(PORT,0);
		    synchronized(this) {
		    openSockets.addElement(new ServerThread(
		               serverSocket.accept(), data_manager,
			       intakeServer, zipped));
		    openSockets.elementAt(openSockets.size()-1).start();
		    }
		    serverSocket.close();

		}
		Thread.sleep(200);
		checkSockets();
//HEALTH REPORT?
	    }
	} catch(Exception e) {
	    System.err.println("Problem operating server socket: "+
			       String.valueOf(PORT));
	}
    }

}