Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| e111d4ab5c |
@@ -12,8 +12,13 @@
|
|||||||
#include <tuple>
|
#include <tuple>
|
||||||
#include <utility>
|
#include <utility>
|
||||||
#include <complex>
|
#include <complex>
|
||||||
|
#include <csignal>
|
||||||
#include <common/callback.hpp>
|
#include <common/callback.hpp>
|
||||||
|
|
||||||
|
|
||||||
|
bool registerSignalHandler(void); // registers a Control-c handler
|
||||||
|
void signalHandler(int signal); // The Control-C handler
|
||||||
|
|
||||||
class Info
|
class Info
|
||||||
{
|
{
|
||||||
public:
|
public:
|
||||||
@@ -104,6 +109,11 @@ void Monitor::doCallback(CallbackData<Info> &callbackData)
|
|||||||
|
|
||||||
int main(int argc, char ** argv)
|
int main(int argc, char ** argv)
|
||||||
{
|
{
|
||||||
|
registerSignalHandler();
|
||||||
|
while(true)
|
||||||
|
{
|
||||||
|
// do stuff
|
||||||
|
}
|
||||||
// std::vector<int> myBigVec(10000000, 2011);
|
// std::vector<int> myBigVec(10000000, 2011);
|
||||||
// std::vector<std::string> s1;
|
// std::vector<std::string> s1;
|
||||||
// std::vector<std::string> s2;
|
// std::vector<std::string> s2;
|
||||||
@@ -114,21 +124,42 @@ int main(int argc, char ** argv)
|
|||||||
// s2 = std::move(s1);
|
// s2 = std::move(s1);
|
||||||
|
|
||||||
|
|
||||||
Monitor monitor;
|
// Monitor monitor;
|
||||||
// SmartPointer<B> b(::new B(),PointerDisposition::Delete);
|
// SmartPointer<B> b(true);
|
||||||
SmartPointer<B> b(true);
|
// Callback<B,Info> callback(&(*b),&B::callback);
|
||||||
Callback<B,Info> callback(&(*b),&B::callback);
|
// monitor.setCallback(callback);
|
||||||
monitor.setCallback(callback);
|
|
||||||
|
|
||||||
Info info;
|
// Info info;
|
||||||
info.setMessage("Hello");
|
// info.setMessage("Hello");
|
||||||
|
|
||||||
CallbackData<Info> callbackData(info);
|
// CallbackData<Info> callbackData(info);
|
||||||
monitor.doCallback(callbackData);
|
// monitor.doCallback(callbackData);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// @brief The signal handler
|
||||||
|
void signalHandler(int signal)
|
||||||
|
{
|
||||||
|
std::cout << "Received signal " << signal << std::endl;
|
||||||
|
exit(signal);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// @brief Method that registers the signal handler
|
||||||
|
/// @param
|
||||||
|
bool registerSignalHandler(void)
|
||||||
|
{
|
||||||
|
struct sigaction sa;
|
||||||
|
sa.sa_handler = signalHandler;
|
||||||
|
sigemptyset(&sa.sa_mask); // Clear the mask of blocked signals
|
||||||
|
sa.sa_flags = 0; // No special flags
|
||||||
|
|
||||||
|
if (-1==sigaction(SIGINT, &sa, nullptr))
|
||||||
|
{
|
||||||
|
std::cerr << "Error registering SIGINT handler." << std::endl;
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -4,6 +4,7 @@
|
|||||||
#include <sys/socket.h>
|
#include <sys/socket.h>
|
||||||
#include <netinet/in.h>
|
#include <netinet/in.h>
|
||||||
#include <unistd.h>
|
#include <unistd.h>
|
||||||
|
#include <csignal>
|
||||||
#include <arpa/inet.h>
|
#include <arpa/inet.h>
|
||||||
#include <thread>
|
#include <thread>
|
||||||
#include <vector>
|
#include <vector>
|
||||||
@@ -15,22 +16,27 @@
|
|||||||
#include <sstp/socketserver.hpp>
|
#include <sstp/socketserver.hpp>
|
||||||
#include <sstp/clientsocketsender.hpp>
|
#include <sstp/clientsocketsender.hpp>
|
||||||
|
|
||||||
// https://www.man7.org/linux/man-pages/man2/accept.2.html
|
void handleServer(Block<String> &commands); // handler for server mode
|
||||||
|
void handleClient(Block<String> &commands); // handler for client mode
|
||||||
void handleServer(Block<String> &commands);
|
bool registerSignalHandler(void); // registers a Control-c handler
|
||||||
void handleClient(Block<String> &commands);
|
void signalHandler(int signal); // The Control-C handler
|
||||||
|
|
||||||
/// @brief
|
/// @brief
|
||||||
/// @param argc
|
/// @param argc
|
||||||
/// @param argv [0] program. [1] SERVERMODE {port} [2] CLIENTMODE {serveripaddress} {serverport} SEND {FileName}
|
/// @param argv [0] program. [1] SERVERMODE {port} [2] CLIENTMODE {serveripaddress} {serverport} SEND {FileName}
|
||||||
/// @return
|
/// @return -1:Error 1:Success
|
||||||
int main(int argc, char **argv)
|
int main(int argc, char **argv)
|
||||||
{
|
{
|
||||||
int returnCode(0);
|
int returnCode(0);
|
||||||
Profiler profiler;
|
Profiler profiler;
|
||||||
String version = "0.1.0.1"; // major version, minor version, patch, build
|
String version = "0.1.0.3"; // major version, minor version, patch, build
|
||||||
|
|
||||||
std::cout << "sstp version " << version.str() << std::endl;
|
std::cout << "sstp version " << version.str() << std::endl;
|
||||||
|
if(!registerSignalHandler())
|
||||||
|
{
|
||||||
|
std::cout << "Unable to register CTRL-C handler" << std::endl;
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
if(argc<2)
|
if(argc<2)
|
||||||
@@ -77,6 +83,33 @@ int main(int argc, char **argv)
|
|||||||
return returnCode;
|
return returnCode;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// @brief The signal handler
|
||||||
|
/// TODO: If we are sending then we need to destroy the sender, if we are listening then we need to destroy the listener
|
||||||
|
/// Currently we exit the app without cleaning anything up.
|
||||||
|
void signalHandler(int signal)
|
||||||
|
{
|
||||||
|
std::cout << "SSTP Received signal " << signal << std::endl;
|
||||||
|
exit(signal);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// @brief Method that registers the signal handler
|
||||||
|
/// @param
|
||||||
|
bool registerSignalHandler(void)
|
||||||
|
{
|
||||||
|
struct sigaction sa;
|
||||||
|
sa.sa_handler = signalHandler;
|
||||||
|
sigemptyset(&sa.sa_mask); // Clear the mask of blocked signals
|
||||||
|
sa.sa_flags = 0; // No special flags
|
||||||
|
|
||||||
|
if (-1==sigaction(SIGINT, &sa, nullptr))
|
||||||
|
{
|
||||||
|
std::cerr << "Error registering SIGINT handler." << std::endl;
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
/// @brief [0]=program [1]=SERVERMODE [2]={port}
|
/// @brief [0]=program [1]=SERVERMODE [2]={port}
|
||||||
/// @Note Currently this method will never return. The application is terminate with CTRL-C. Ideally, we would exit is some cleaner fashion
|
/// @Note Currently this method will never return. The application is terminate with CTRL-C. Ideally, we would exit is some cleaner fashion
|
||||||
/// perhaps by implementing a CTRL-C hook and then destroying the SocketServer properly by calling it's destructor. See SocketServer::~SocketServer()
|
/// perhaps by implementing a CTRL-C hook and then destroying the SocketServer properly by calling it's destructor. See SocketServer::~SocketServer()
|
||||||
|
|||||||
Reference in New Issue
Block a user