mirror of
https://github.com/modelec/TCPSocketServer.git
synced 2026-01-18 16:37:29 +01:00
cin
This commit is contained in:
26
main.cpp
26
main.cpp
@@ -1,30 +1,26 @@
|
||||
#include <atomic>
|
||||
#include <csignal>
|
||||
|
||||
#include "TCPServer.h"
|
||||
|
||||
std::atomic<bool> keepRunning(true);
|
||||
|
||||
void signalHandler(int signum) {
|
||||
std::cout << "Interrupt signal (" << signum << ") received.\n";
|
||||
keepRunning = false;
|
||||
}
|
||||
|
||||
int main() {
|
||||
signal(SIGTERM, signalHandler);
|
||||
signal(SIGINT, signalHandler);
|
||||
|
||||
TCPServer server(8080);
|
||||
|
||||
try {
|
||||
server.start();
|
||||
|
||||
while (keepRunning) {
|
||||
while (true) {
|
||||
sleep(1);
|
||||
|
||||
server.broadcastMessage("request aruco");
|
||||
std::string message;
|
||||
std::cout << "Enter message ('quit' to exit): ";
|
||||
std::getline(std::cin, message);
|
||||
|
||||
if (message == "quit") {
|
||||
server.stop();
|
||||
break;
|
||||
}
|
||||
|
||||
server.broadcastMessage(message.c_str());
|
||||
|
||||
std::cout << "Main thread communicating with server..." << std::endl;
|
||||
}
|
||||
|
||||
server.stop();
|
||||
|
||||
Reference in New Issue
Block a user