Upp::String command;
LOG("Command line interface ready");
while(command != "exit" && !secureStop){
	command	= ToLower(ReadStdIn());
	Cout() << ProcessCommandLine(command);
}

#include <Core/Core.h>
#include <signal.h>

using namespace Upp;

static std::atomic<bool> done(false);
static void SecureStop(int) {  done = true; }

CONSOLE_APP_MAIN
{
    String s;
    struct sigaction sa;
    Zero(sa);
    sa.sa_handler = &SecureStop;
    sigaction(SIGINT, &sa, nullptr);
	
	while(s != "exit" && !done) {
		s = ReadStdIn();
	}
 	if(done) {
		Cout() << "SIGINT!" << "\n";
	}
}

CV2DServer* serverPtr;

CONSOLE_APP_MAIN
{
	StdLogSetup(LOG_COUT | LOG_FILE | LOG_TIMESTAMP);
	CV2DServer server(LISTENING_PORT, TICK_RATE);
	serverPtr = &server;
	std::signal(SIGINT,static_cast<__p_sig_fn_t>([](int s)->void{serverPtr->StopServer();}));
	server.StartServer();
}

void CV2DServer::StartServer(){
	serverThread.Start(THISBACK(ServerRoutine));
	Upp::String command;
	LOG("Command line interface ready");
	while(command != "exit" && !secureStop){
		command	= ToLower(ReadStdIn());
		Cout() << ProcessCommandLine(command);
	}
	server.Close();
	client.Close();
	serverThread.ShutdownThreads();
	serverThread.Wait();
}

std::signal(SIGINT,static_cast<__p_sig_fn_t>([](int s)->void{serverPtr->StopServer();}));

static void SecureStop(int)
{
        // Cleanup the app here...

	 signal(SIGINT, SIG_DFL); // unsintall your hook.
	 raise(SIGINT);           // Let OS handle it.
}

static std::atomic<bool> done(false);
static void SecureStop(int)
{
        // Do app cleanup here..
	done = true;
	signal(SIGINT, SIG_DFL); // unsintall the hook.
	raise(SIGINT);
}

CONSOLE_APP_MAIN
{
	StdLogSetup(LOG_COUT|LOG_FILE);
	
	auto worker = Async([] { // Simulate the signal request...
		int timeout = 5000;
		int t = msecs();
		while(msecs(t) < timeout) {
			if(CoWork::IsCanceled())
				return;
			Sleep(10);
		}
		if(!done) {
			RLOG("rasigin SIGINT with custom hook...");
			raise(SIGINT);
		}
		
	});
	signal(SIGINT, &SecureStop);
	String s;
	while(s != "exit") {
		s = ReadStdIn();
	}
	worker.Cancel();
	
}

void SetNonBlocking()
{
	fcntl(STDIN_FILENO, F_SETFL, fcntl(STDIN_FILENO, F_GETFL) | O_NONBLOCK);
}

void SetBlocking()
{
	fcntl(STDIN_FILENO, F_SETFL, fcntl(STDIN_FILENO, F_GETFL) & ~O_NONBLOCK);
}

String ReadStdIn2(int timeout)
{
	String r;
	SetNonBlocking();
	int t = msecs();
	do {
		SocketWaitEvent we;
		we.Add(STDIN_FILENO, WAIT_READ);
		if(we.Wait(10) && (we[0] & WAIT_READ)) {
			int c = 0;
			int n = read(STDIN_FILENO, (char*) &c, 1);
			if(c == '\n')
				break;
			if(n > 0) {
				r.Cat(c);
				t = msecs();
			}
		}
	}
	while(msecs(t) < timeout && !done);
	SetBlocking();
	return r.GetCount() ? r : String::GetVoid();
}

String ReadCmd(int timeout)
{
	String r;
	int time = msecs();
	
	while(msecs(time) < timeout){
		int c = 0;
		int n = read(STDIN_FILENO, (char*) &c, 1);
		if(c == '\n')
			break;
		if(n > 0) {
			r.Cat(c);
			time = msecs();
		}
	}
	return r.GetCount() ? r : String::GetVoid();
}