| 1 | /************************************************************************* | 
|---|
| 2 | * libjson-rpc-cpp | 
|---|
| 3 | ************************************************************************* | 
|---|
| 4 | * @file    tcpsocketserver.h | 
|---|
| 5 | * @date    17.07.2015 | 
|---|
| 6 | * @author  Alexandre Poirot <alexandre.poirot@legrand.fr> | 
|---|
| 7 | * @license See attached LICENSE.txt | 
|---|
| 8 | ************************************************************************/ | 
|---|
| 9 |  | 
|---|
| 10 | #ifndef JSONRPC_CPP_TCPSOCKETSERVERCONNECTOR_H_ | 
|---|
| 11 | #define JSONRPC_CPP_TCPSOCKETSERVERCONNECTOR_H_ | 
|---|
| 12 |  | 
|---|
| 13 | #include "../abstractserverconnector.h" | 
|---|
| 14 |  | 
|---|
| 15 | namespace jsonrpc { | 
|---|
| 16 | /** | 
|---|
| 17 | * This class provides an embedded TCP Socket Server that handle incoming | 
|---|
| 18 | * Requests and send result over same socket. | 
|---|
| 19 | * It uses the delimiter character to distinct a full RPC Message over the | 
|---|
| 20 | * tcp flow. This character is parametered on | 
|---|
| 21 | * compilation time in implementation files. The default value for this | 
|---|
| 22 | * delimiter is 0x0A a.k.a. "new line". | 
|---|
| 23 | * This class hides OS specific features in real implementation of this | 
|---|
| 24 | * server. Currently it has implementation for | 
|---|
| 25 | * both Linux and Windows. | 
|---|
| 26 | */ | 
|---|
| 27 | class TcpSocketServer : public AbstractServerConnector { | 
|---|
| 28 | public: | 
|---|
| 29 | /** | 
|---|
| 30 | * @brief TcpSocketServer, constructor for the included | 
|---|
| 31 | * TcpSocketServer | 
|---|
| 32 | * | 
|---|
| 33 | * Instanciates the real implementation of TcpSocketServerPrivate | 
|---|
| 34 | * depending on running OS. | 
|---|
| 35 | * | 
|---|
| 36 | * @param ipToBind The ipv4 address on which the server should | 
|---|
| 37 | * bind and listen | 
|---|
| 38 | * @param port The port on which the server should bind and listen | 
|---|
| 39 | */ | 
|---|
| 40 | TcpSocketServer(const std::string &ipToBind, const unsigned int &port); | 
|---|
| 41 |  | 
|---|
| 42 | ~TcpSocketServer(); | 
|---|
| 43 | /** | 
|---|
| 44 | * @brief The AbstractServerConnector::StartListening method overload. | 
|---|
| 45 | * | 
|---|
| 46 | * This method launches the listening loop that will handle client | 
|---|
| 47 | * connections. | 
|---|
| 48 | * The return value depends on the current listening states : | 
|---|
| 49 | *  - not listening and no error come up while bind and listen returns true | 
|---|
| 50 | *  - not listening but error happen on bind or listen returns false | 
|---|
| 51 | *  - is called while listening returns false | 
|---|
| 52 | * | 
|---|
| 53 | * @return A boolean that indicates the success or the failure of the | 
|---|
| 54 | * operation. | 
|---|
| 55 | */ | 
|---|
| 56 | bool StartListening(); | 
|---|
| 57 | /** | 
|---|
| 58 | * @brief The AbstractServerConnector::StopListening method overload. | 
|---|
| 59 | * | 
|---|
| 60 | * This method stops the listening loop that will handle client connections. | 
|---|
| 61 | * The return value depends on the current listening states : | 
|---|
| 62 | *  - listening and successfully stops the listen loop returns true | 
|---|
| 63 | *  - is called while not listening returns false | 
|---|
| 64 | * | 
|---|
| 65 | * @return A boolean that indicates the success or the failure of the | 
|---|
| 66 | * operation. | 
|---|
| 67 | */ | 
|---|
| 68 | bool StopListening(); | 
|---|
| 69 |  | 
|---|
| 70 | protected: | 
|---|
| 71 | AbstractServerConnector *realSocket; | 
|---|
| 72 | }; | 
|---|
| 73 |  | 
|---|
| 74 | } /* namespace jsonrpc */ | 
|---|
| 75 | #endif /* JSONRPC_CPP_TCPSOCKETSERVERCONNECTOR_H_ */ | 
|---|
| 76 |  | 
|---|