From 28292e924a5524afe5e4d03f10597b4843915323 Mon Sep 17 00:00:00 2001 From: Brad Arant Date: Thu, 23 Apr 2020 14:25:41 -0700 Subject: [PATCH] Continued improvements to shutdown. --- CommandList.cpp | 23 +++--- Socket.cpp | 27 +++---- TCPSession.cpp | 29 ++++++- TCPSession.h | 27 ++++++- TLSSession.cpp | 6 +- html/CommandList_8h_source.html | 4 +- html/Socket_8h_source.html | 4 +- html/TCPSession_8h_source.html | 52 +++++++------ html/classcore_1_1ConsoleSession-members.html | 77 ++++++++++--------- html/classcore_1_1ConsoleSession.html | 13 ++-- html/classcore_1_1Socket.html | 2 +- html/classcore_1_1TCPSession-members.html | 57 +++++++------- html/classcore_1_1TCPSession.html | 68 +++++++++++----- html/classcore_1_1TLSSession-members.html | 61 +++++++-------- html/classcore_1_1TLSSession.html | 13 ++-- .../classcore_1_1TerminalSession-members.html | 75 +++++++++--------- html/classcore_1_1TerminalSession.html | 13 ++-- html/functions.html | 5 +- html/functions_func.html | 5 +- html/search/all_7.js | 15 ++-- html/search/all_8.js | 6 +- html/search/all_9.js | 6 +- html/search/all_a.js | 24 +++--- html/search/all_b.js | 16 ++-- html/search/all_c.js | 6 +- html/search/all_d.js | 4 +- html/search/all_e.js | 8 +- html/search/classes_0.js | 8 +- html/search/classes_1.js | 2 +- html/search/classes_2.js | 6 +- html/search/classes_3.js | 2 +- html/search/classes_4.js | 4 +- html/search/classes_5.js | 16 ++-- html/search/classes_6.js | 4 +- html/search/functions_0.js | 2 +- html/search/functions_1.js | 8 +- html/search/functions_2.js | 4 +- html/search/functions_3.js | 14 ++-- html/search/functions_4.js | 2 +- html/search/functions_5.js | 15 ++-- html/search/functions_6.js | 6 +- html/search/functions_7.js | 6 +- html/search/functions_8.js | 20 ++--- html/search/functions_9.js | 4 +- html/search/functions_a.js | 2 +- html/search/functions_b.js | 2 +- html/search/functions_c.js | 8 +- html/search/variables_0.js | 2 +- html/search/variables_1.js | 2 +- html/search/variables_2.js | 2 +- html/search/variables_3.js | 2 +- html/search/variables_4.js | 2 +- html/search/variables_5.js | 2 +- latex/classcore_1_1Socket.tex | 2 +- latex/classcore_1_1TCPSession.tex | 31 ++++---- 55 files changed, 459 insertions(+), 367 deletions(-) diff --git a/CommandList.cpp b/CommandList.cpp index 451a517..9ba6265 100644 --- a/CommandList.cpp +++ b/CommandList.cpp @@ -13,20 +13,15 @@ namespace core { } bool CommandList::processRequest(std::string request, TCPSession *session, std::stringstream &data) { - std::stringstream input = std::stringstream(request); - while(!input.eof()) { - std::string requests; - std::getline(input, requests); - if(session->grab != NULL) - session->grab->processCommand(requests, session, data); - else { - int pos = requests.find(" "); - std::string function = pos == requests.npos ? requests: requests.substr(0, pos); - for(auto *command : commands) - if(command->check(function)) - command->processCommand(requests, session, data); - } - } + if(session->grab != NULL) + session->grab->processCommand(request, session, data); + else { + int pos = request.find(" "); + std::string function = pos == request.npos ? request: request.substr(0, pos); + for(auto *command : commands) + if(command->check(function)) + command->processCommand(request, session, data); + } return true; } diff --git a/Socket.cpp b/Socket.cpp index df89c8b..403741a 100644 --- a/Socket.cpp +++ b/Socket.cpp @@ -138,30 +138,26 @@ namespace core { } } - void Socket::writeSocket() { - if(shutDown) - return; - + void Socket::writeSocket() { if(fifo.size() > 0) { outlock.lock(); + coreutils::Log(coreutils::LOG_DEBUG_3) << "Writing data to socket " << getDescriptor() << " [" << fifo.front() << "]."; ::write(descriptor, fifo.front().c_str(), fifo.front().length()); fifo.pop(); coreutils::Log(coreutils::LOG_DEBUG_4) << "resetSocket from writeSocket."; - if(active) - ePoll.resetSocket(this); + ePoll.resetSocket(this); + if(shutDown && !needsToWrite()) + delete this; outlock.unlock(); } } int Socket::write(std::string data) { - if(!active) - return -1; - + coreutils::Log(coreutils::LOG_DEBUG_3) << "Writing data to socket " << getDescriptor() << " buffer [" << data << "]."; outlock.lock(); fifo.emplace(data); - coreutils::Log(coreutils::LOG_DEBUG_4) << "resetSocket from write. active is " << active; - if(active) - ePoll.resetSocket(this); + coreutils::Log(coreutils::LOG_DEBUG_4) << "Enabling write on socket " << getDescriptor() << " with " << fifo.size() << " entries to write."; + ePoll.resetSocket(this); outlock.unlock(); return 1; } @@ -171,6 +167,7 @@ namespace core { } bool Socket::needsToWrite() { + coreutils::Log(coreutils::LOG_DEBUG_4) << "Socket " << getDescriptor() << " needs to write is " << (fifo.size() > 0) << "."; return fifo.size() > 0; } @@ -178,7 +175,11 @@ namespace core { coreutils::Log(coreutils::LOG_DEBUG_2) << "Shutdown requested on socket " << descriptor << " with reason " << text << "."; shutDown = true; active = false; - delete this; + if(!needsToWrite()) { + active = false; + delete this; + } + } } diff --git a/TCPSession.cpp b/TCPSession.cpp index 35f54cd..b984a3b 100644 --- a/TCPSession.cpp +++ b/TCPSession.cpp @@ -30,8 +30,33 @@ namespace core { void TCPSession::onConnected() {} - void TCPSession::onDataReceived(std::string data) { - protocol(data); + void TCPSession::onDataReceived(char *data, int len) { + if(len > 0) { + lineBuffer = (char *)realloc(lineBuffer, lineBufferSize + len); + memcpy(lineBuffer + lineBufferSize, data, len); + lineBufferSize += len; + while(lineBufferSize > 0) { + int lineLength = strcspn(lineBuffer, "\r\n"); + if(lineLength == lineBufferSize) + break; + onLineReceived(std::string(lineBuffer, lineLength)); + if(lineBuffer[lineLength] == '\r') + ++lineLength; + if(lineBuffer[lineLength] == '\n') + ++lineLength; + lineBufferSize -= lineLength; + if(lineBufferSize > 0) + memmove(lineBuffer, lineBuffer + lineLength, lineBufferSize); + coreutils::Log(coreutils::LOG_DEBUG_3) << "lineBufferSize=" << lineBufferSize << "; lineLength=" << lineLength << ";"; + lineBuffer = (char *)realloc(lineBuffer, lineBufferSize); +// coreutils::Log(coreutils::LOG_DEBUG_3) << "lineBuffer=" << std::string(lineBuffer, lineBufferSize); + } + } + } + + void TCPSession::onLineReceived(std::string line) { + coreutils::Log(coreutils::LOG_DEBUG_3) << "[" << line << "]"; + protocol(line); send(); } diff --git a/TCPSession.h b/TCPSession.h index 10fd19a..782f611 100644 --- a/TCPSession.h +++ b/TCPSession.h @@ -61,9 +61,29 @@ namespace core { TCPServer &server; protected: - - virtual void onDataReceived(std::string data) override; + + /// + /// + /// + virtual void onRegistered() override; + + /// + /// Override this method to receive data directly from the socket as data is + /// received. If you need data split by line termination characters then + /// override the onLineReceived method instead. + /// + + virtual void onDataReceived(char *data, int len) override; + + /// + /// Override the onLineReceived method to receive a string of characters that + /// represents a single line of data terminated by a LF or CRLF. If onDataReceived + /// was overriden this method will not be called unless the onDataReceived calls + /// this method explicitly using the class and member name. + /// + + virtual void onLineReceived(std::string line); /// /// This method is called from within the protocol method when protocol is called @@ -83,7 +103,8 @@ namespace core { virtual void protocol(std::string data); private: - + char *lineBuffer = NULL; + int lineBufferSize = 0; std::mutex mtx; }; diff --git a/TLSSession.cpp b/TLSSession.cpp index 503a24a..56ee2e3 100644 --- a/TLSSession.cpp +++ b/TLSSession.cpp @@ -50,8 +50,8 @@ namespace core { if((ret = SSL_set_fd(ssl, getDescriptor())) == 0) throw std::string("Error setting TLS socket descriptor."); - if(!SSL_set_generate_session_id(ssl, generate_session_id)) - throw std::string("Error setting session identifier callback."); +// if(!SSL_set_generate_session_id(ssl, generate_session_id)) +// throw std::string("Error setting session identifier callback."); } @@ -91,7 +91,7 @@ namespace core { if((len = ::SSL_read(ssl, buffer, bufferLength)) >= 0) { std::cout << "receiveData TLS...len=" << len << ":" << buffer << std::endl; - onDataReceived(std::string(buffer, len)); + onDataReceived(buffer, len); } else { switch (SSL_get_error(ssl, len)) { diff --git a/html/CommandList_8h_source.html b/html/CommandList_8h_source.html index 168899d..6ed2e8b 100644 --- a/html/CommandList_8h_source.html +++ b/html/CommandList_8h_source.html @@ -108,10 +108,10 @@ $(function() {
74 
75 #endif
-
core::CommandList::grabInput
bool grabInput(TCPSession *session, Command &command)
Definition: CommandList.cpp:33
+
core::CommandList::grabInput
bool grabInput(TCPSession *session, Command &command)
Definition: CommandList.cpp:28
core::TCPSession
Definition: TCPSession.h:23
core::CommandList::commands
std::vector< Command * > commands
Definition: CommandList.h:69
-
core::CommandList::processCommand
int processCommand(std::string request, TCPSession *session, std::stringstream &data)
Definition: CommandList.cpp:42
+
core::CommandList::processCommand
int processCommand(std::string request, TCPSession *session, std::stringstream &data)
Definition: CommandList.cpp:37
core::CommandList::add
void add(Command &command, std::string name="")
Definition: CommandList.cpp:6
core::CommandList::remove
void remove(Command &command)
Definition: CommandList.cpp:11
core::Command
Definition: Command.h:20
diff --git a/html/Socket_8h_source.html b/html/Socket_8h_source.html index d236f37..b302722 100644 --- a/html/Socket_8h_source.html +++ b/html/Socket_8h_source.html @@ -181,13 +181,13 @@ $(function() {
196 
core::Socket
Definition: Socket.h:33
-
core::Socket::write
int write(std::string data)
Definition: Socket.cpp:156
+
core::Socket::write
int write(std::string data)
Definition: Socket.cpp:155
core::EPoll
Definition: EPoll.h:31
core::Socket::onRegistered
virtual void onRegistered()
Called after the socket has been registered with epoll processing.
Definition: Socket.cpp:55
core::Socket::onDataReceived
virtual void onDataReceived(std::string data)
Called when data is received from the socket.
Definition: Socket.cpp:99
core::Socket::Socket
Socket(EPoll &ePoll, std::string text="")
Definition: Socket.cpp:8
core::Socket::eventReceived
bool eventReceived(struct epoll_event event, pid_t threadId)
Parse epoll event and call specified callbacks.
Definition: Socket.cpp:61
-
core::Socket::shutdown
void shutdown(std::string text="unknown")
Definition: Socket.cpp:177
+
core::Socket::shutdown
void shutdown(std::string text="unknown")
Definition: Socket.cpp:174
core::Socket::onRegister
virtual void onRegister()
Called before the socket has registered with the epoll processing.
Definition: Socket.cpp:53
core::Socket::receiveData
virtual void receiveData(char *buffer, int bufferLength)
Definition: Socket.cpp:107
core::Socket::onUnregistered
virtual void onUnregistered()
Called when the socket has finished unregistering for the epoll processing.
Definition: Socket.cpp:59
diff --git a/html/TCPSession_8h_source.html b/html/TCPSession_8h_source.html index d12dee1..39cc1b7 100644 --- a/html/TCPSession_8h_source.html +++ b/html/TCPSession_8h_source.html @@ -103,37 +103,45 @@ $(function() {
61  TCPServer &server;
62 
63  protected:
-
64 
-
65  virtual void onDataReceived(std::string data) override;
-
66  virtual void onRegistered() override;
-
67 
-
73 
-
74  virtual void onConnected();
-
75 
-
82 
-
83  virtual void protocol(std::string data);
-
84 
-
85  private:
-
86 
-
87  std::mutex mtx;
-
88 
-
89  };
-
90 
-
91 }
-
92 
-
93 #endif
+
64 
+
68 
+
69  virtual void onRegistered() override;
+
70 
+
76 
+
77  virtual void onDataReceived(char *data, int len) override;
+
78 
+
85 
+
86  virtual void onLineReceived(std::string line);
+
87 
+
93 
+
94  virtual void onConnected();
+
95 
+
102 
+
103  virtual void protocol(std::string data);
+
104 
+
105  private:
+
106  char *lineBuffer = NULL;
+
107  int lineBufferSize = 0;
+
108  std::mutex mtx;
+
109 
+
110  };
+
111 
+
112 }
+
113 
+
114 #endif
-
core::TCPSession::send
void send()
Definition: TCPSession.cpp:53
+
core::TCPSession::send
void send()
Definition: TCPSession.cpp:78
core::SessionFilter
Definition: SessionFilter.h:10
core::TCPSession
Definition: TCPSession.h:23
core::TCPSession::protocol
virtual void protocol(std::string data)
Definition: TCPSession.cpp:18
+
core::TCPSession::onDataReceived
virtual void onDataReceived(char *data, int len) override
Definition: TCPSession.cpp:33
core::EPoll
Definition: EPoll.h:31
-
core::TCPSession::sendToAll
void sendToAll()
Definition: TCPSession.cpp:38
+
core::TCPSession::sendToAll
void sendToAll()
Definition: TCPSession.cpp:63
+
core::TCPSession::onLineReceived
virtual void onLineReceived(std::string line)
Definition: TCPSession.cpp:57
core::TCPSession::out
std::stringstream out
Definition: TCPSession.h:37
core::TCPSession::onRegistered
virtual void onRegistered() override
Called after the socket has been registered with epoll processing.
Definition: TCPSession.cpp:25
core::Command
Definition: Command.h:20
core::TCPSocket
Definition: TCPSocket.h:20
-
core::TCPSession::onDataReceived
virtual void onDataReceived(std::string data) override
Called when data is received from the socket.
Definition: TCPSession.cpp:33
core::TCPSession::output
virtual void output(std::stringstream &data)
Definition: TCPSession.cpp:14
core::TCPSession::onConnected
virtual void onConnected()
Definition: TCPSession.cpp:31
core::TCPServer
Definition: TCPServer.h:24
diff --git a/html/classcore_1_1ConsoleSession-members.html b/html/classcore_1_1ConsoleSession-members.html index e1f69ff..1bb0ce6 100644 --- a/html/classcore_1_1ConsoleSession-members.html +++ b/html/classcore_1_1ConsoleSession-members.html @@ -88,45 +88,46 @@ $(function() { needsToWrite() (defined in core::Socket)core::Socket NextLine(int lines) (defined in core::TerminalSession)core::TerminalSession onConnected()core::TCPSessionprotectedvirtual - onDataReceived(std::string data) overridecore::TCPSessionprotectedvirtual - onDataReceived(char *buffer, int len) (defined in core::Socket)core::Socketprotectedvirtual - onRegister()core::Socketvirtual - onRegistered() overridecore::TCPSessionprotectedvirtual - onUnregister() (defined in core::Socket)core::Socketvirtual - onUnregistered()core::Socketvirtual - outcore::TCPSession - output(std::stringstream &data)core::TCPSessionvirtual - PreviousLine(int lines) (defined in core::TerminalSession)core::TerminalSession - protocol(std::string data) overridecore::ConsoleSessionprotectedvirtual - receiveData(char *buffer, int bufferLength)core::Socketprotectedvirtual - restoreCursor() (defined in core::TerminalSession)core::TerminalSession - saveCursor() (defined in core::TerminalSession)core::TerminalSession - scrollArea(int start, int end) (defined in core::TerminalSession)core::TerminalSession - send()core::TCPSession - sendToAll()core::TCPSession - sendToAll(SessionFilter filter)core::TCPSession - server (defined in core::TCPSession)core::TCPSession - setBackColor(int color) (defined in core::TerminalSession)core::TerminalSession - setBufferSize(int length) (defined in core::Socket)core::Socketprotected - setColor(int color) (defined in core::TerminalSession)core::TerminalSession - setCursorLocation(int x, int y)core::TerminalSession - setDescriptor(int descriptor)core::Socket - shutDown (defined in core::Socket)core::Socketprotected + onDataReceived(char *data, int len) overridecore::TCPSessionprotectedvirtual + core::TCPSocket::onDataReceived(std::string data)core::Socketprotectedvirtual + onLineReceived(std::string line)core::TCPSessionprotectedvirtual + onRegister()core::Socketvirtual + onRegistered() overridecore::TCPSessionprotectedvirtual + onUnregister() (defined in core::Socket)core::Socketvirtual + onUnregistered()core::Socketvirtual + outcore::TCPSession + output(std::stringstream &data)core::TCPSessionvirtual + PreviousLine(int lines) (defined in core::TerminalSession)core::TerminalSession + protocol(std::string data) overridecore::ConsoleSessionprotectedvirtual + receiveData(char *buffer, int bufferLength)core::Socketprotectedvirtual + restoreCursor() (defined in core::TerminalSession)core::TerminalSession + saveCursor() (defined in core::TerminalSession)core::TerminalSession + scrollArea(int start, int end) (defined in core::TerminalSession)core::TerminalSession + send()core::TCPSession + sendToAll()core::TCPSession + sendToAll(SessionFilter filter)core::TCPSession + server (defined in core::TCPSession)core::TCPSession + setBackColor(int color) (defined in core::TerminalSession)core::TerminalSession + setBufferSize(int length) (defined in core::Socket)core::Socketprotected + setColor(int color) (defined in core::TerminalSession)core::TerminalSession + setCursorLocation(int x, int y)core::TerminalSession + setDescriptor(int descriptor)core::Socket shutdown(std::string text="unknown")core::Socket - Socket(EPoll &ePoll, std::string text="")core::Socket - tag (defined in core::Object)core::Object - TCPSession(EPoll &ePoll, TCPServer &server, std::string text="") (defined in core::TCPSession)core::TCPSession - TCPSocket(EPoll &ePoll) (defined in core::TCPSocket)core::TCPSocket - TCPSocket(EPoll &ePoll, std::string text) (defined in core::TCPSocket)core::TCPSocket - TerminalSession(EPoll &ePoll, TCPServer &server) (defined in core::TerminalSession)core::TerminalSession - write(std::string data)core::Socket - write(char *buffer, int length) (defined in core::Socket)core::Socket - writeLog(std::string data) (defined in core::ConsoleSession)core::ConsoleSession - ~ConsoleSession() (defined in core::ConsoleSession)core::ConsoleSession - ~Socket()core::Socket - ~TCPSession() (defined in core::TCPSession)core::TCPSession - ~TCPSocket() (defined in core::TCPSocket)core::TCPSocket - ~TerminalSession() (defined in core::TerminalSession)core::TerminalSession + shutDown (defined in core::Socket)core::Socketprotected + Socket(EPoll &ePoll, std::string text="")core::Socket + tag (defined in core::Object)core::Object + TCPSession(EPoll &ePoll, TCPServer &server, std::string text="") (defined in core::TCPSession)core::TCPSession + TCPSocket(EPoll &ePoll) (defined in core::TCPSocket)core::TCPSocket + TCPSocket(EPoll &ePoll, std::string text) (defined in core::TCPSocket)core::TCPSocket + TerminalSession(EPoll &ePoll, TCPServer &server) (defined in core::TerminalSession)core::TerminalSession + write(std::string data)core::Socket + write(char *buffer, int length) (defined in core::Socket)core::Socket + writeLog(std::string data) (defined in core::ConsoleSession)core::ConsoleSession + ~ConsoleSession() (defined in core::ConsoleSession)core::ConsoleSession + ~Socket()core::Socket + ~TCPSession() (defined in core::TCPSession)core::TCPSession + ~TCPSocket() (defined in core::TCPSocket)core::TCPSocket + ~TerminalSession() (defined in core::TerminalSession)core::TerminalSession
diff --git a/html/classcore_1_1ConsoleSession.html b/html/classcore_1_1ConsoleSession.html index 95b187f..9cae906 100644 --- a/html/classcore_1_1ConsoleSession.html +++ b/html/classcore_1_1ConsoleSession.html @@ -216,13 +216,14 @@ Protected Member Functions void protocol (std::string data) override   - Protected Member Functions inherited from core::TCPSession -virtual void onDataReceived (std::string data) override - Called when data is received from the socket. More...
-  virtual void onRegistered () override  Called after the socket has been registered with epoll processing.
  +virtual void onDataReceived (char *data, int len) override +  +virtual void onLineReceived (std::string line) +  virtual void onConnected ()   - Protected Member Functions inherited from core::Socket @@ -232,9 +233,9 @@ void setBufferSize (in int getBufferSize ()   - -virtual void onDataReceived (char *buffer, int len) -  +virtual void onDataReceived (std::string data) + Called when data is received from the socket. More...
+  virtual void receiveData (char *buffer, int bufferLength)   diff --git a/html/classcore_1_1Socket.html b/html/classcore_1_1Socket.html index af2cf5d..52bd194 100644 --- a/html/classcore_1_1Socket.html +++ b/html/classcore_1_1Socket.html @@ -322,7 +322,7 @@ bool  - - - - - - - - - - - - - - - - - - - - - - - - - - - - + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
shutDown = false< -

Reimplemented in core::TCPServer, core::TCPSession, and core::UDPServerSocket.

+

Reimplemented in core::TCPServer, and core::UDPServerSocket.

diff --git a/html/classcore_1_1TCPSession-members.html b/html/classcore_1_1TCPSession-members.html index 6fab674..4243b4a 100644 --- a/html/classcore_1_1TCPSession-members.html +++ b/html/classcore_1_1TCPSession-members.html @@ -83,34 +83,35 @@ $(function() {
name (defined in core::Object)core::Object
needsToWrite() (defined in core::Socket)core::Socket
onConnected()core::TCPSessionprotectedvirtual
onDataReceived(std::string data) overridecore::TCPSessionprotectedvirtual
onDataReceived(char *buffer, int len) (defined in core::Socket)core::Socketprotectedvirtual
onRegister()core::Socketvirtual
onRegistered() overridecore::TCPSessionprotectedvirtual
onUnregister() (defined in core::Socket)core::Socketvirtual
onUnregistered()core::Socketvirtual
outcore::TCPSession
output(std::stringstream &data)core::TCPSessionvirtual
protocol(std::string data)core::TCPSessionprotectedvirtual
receiveData(char *buffer, int bufferLength)core::Socketprotectedvirtual
send()core::TCPSession
sendToAll()core::TCPSession
sendToAll(SessionFilter filter)core::TCPSession
server (defined in core::TCPSession)core::TCPSession
setBufferSize(int length) (defined in core::Socket)core::Socketprotected
setDescriptor(int descriptor)core::Socket
shutDown (defined in core::Socket)core::Socketprotected
shutdown(std::string text="unknown")core::Socket
Socket(EPoll &ePoll, std::string text="")core::Socket
tag (defined in core::Object)core::Object
TCPSession(EPoll &ePoll, TCPServer &server, std::string text="") (defined in core::TCPSession)core::TCPSession
TCPSocket(EPoll &ePoll) (defined in core::TCPSocket)core::TCPSocket
TCPSocket(EPoll &ePoll, std::string text) (defined in core::TCPSocket)core::TCPSocket
write(std::string data)core::Socket
write(char *buffer, int length) (defined in core::Socket)core::Socket
~Socket()core::Socket
~TCPSession() (defined in core::TCPSession)core::TCPSession
~TCPSocket() (defined in core::TCPSocket)core::TCPSocket
onDataReceived(char *data, int len) overridecore::TCPSessionprotectedvirtual
core::TCPSocket::onDataReceived(std::string data)core::Socketprotectedvirtual
onLineReceived(std::string line)core::TCPSessionprotectedvirtual
onRegister()core::Socketvirtual
onRegistered() overridecore::TCPSessionprotectedvirtual
onUnregister() (defined in core::Socket)core::Socketvirtual
onUnregistered()core::Socketvirtual
outcore::TCPSession
output(std::stringstream &data)core::TCPSessionvirtual
protocol(std::string data)core::TCPSessionprotectedvirtual
receiveData(char *buffer, int bufferLength)core::Socketprotectedvirtual
send()core::TCPSession
sendToAll()core::TCPSession
sendToAll(SessionFilter filter)core::TCPSession
server (defined in core::TCPSession)core::TCPSession
setBufferSize(int length) (defined in core::Socket)core::Socketprotected
setDescriptor(int descriptor)core::Socket
shutDown (defined in core::Socket)core::Socketprotected
shutdown(std::string text="unknown")core::Socket
Socket(EPoll &ePoll, std::string text="")core::Socket
tag (defined in core::Object)core::Object
TCPSession(EPoll &ePoll, TCPServer &server, std::string text="") (defined in core::TCPSession)core::TCPSession
TCPSocket(EPoll &ePoll) (defined in core::TCPSocket)core::TCPSocket
TCPSocket(EPoll &ePoll, std::string text) (defined in core::TCPSocket)core::TCPSocket
write(std::string data)core::Socket
write(char *buffer, int length) (defined in core::Socket)core::Socket
~Socket()core::Socket
~TCPSession() (defined in core::TCPSession)core::TCPSession
~TCPSocket() (defined in core::TCPSocket)core::TCPSocket
diff --git a/html/classcore_1_1TCPSession.html b/html/classcore_1_1TCPSession.html index bcf064c..4b1fb73 100644 --- a/html/classcore_1_1TCPSession.html +++ b/html/classcore_1_1TCPSession.html @@ -198,13 +198,14 @@ std::string tag - - - + + + + @@ -216,9 +217,9 @@ void  - - + + +

Protected Member Functions

virtual void onDataReceived (std::string data) override
 Called when data is received from the socket. More...
 
virtual void onRegistered () override
 Called after the socket has been registered with epoll processing.
 
virtual void onDataReceived (char *data, int len) override
 
virtual void onLineReceived (std::string line)
 
virtual void onConnected ()
 
virtual void protocol (std::string data)
setBufferSize (in
int getBufferSize ()
 
-virtual void onDataReceived (char *buffer, int len)
 
virtual void onDataReceived (std::string data)
 Called when data is received from the socket. More...
 
virtual void receiveData (char *buffer, int bufferLength)
 
@@ -263,8 +264,8 @@ bool  - - + + + + + + + + + + + +
shutDown = false< - -

◆ onDataReceived()

+ +

◆ onDataReceived()

@@ -275,9 +276,19 @@ bool 
shutDown = false<
void core::TCPSession::onDataReceived (std::string data)char * data,
int len 
)
@@ -286,17 +297,36 @@ bool shutDown = false<
+

Override this method to receive data directly from the socket as data is received. If you need data split by line termination characters then override the onLineReceived method instead.

-

Called when data is received from the socket.

-

The onConnected method is called when the socket is ready to communicate. Writing to the socket can begin on this call to initiate a contact with the remote device. The onDataReceived method is called when the socket has received an event from epoll and there is data ready to be read from the socket. The default handler will pull the data and put it into the streambuf for the socket. EPOLLIN

-
Parameters
- - -
datathe data that has been received from the socket.
-
-
+

Reimplemented from core::Socket.

-

Reimplemented from core::Socket.

+
+ + +

◆ onLineReceived()

+ +
+
+ + + + + +
+ + + + + + + + +
void core::TCPSession::onLineReceived (std::string line)
+ 		+protectedvirtual
+
+

Override the onLineReceived method to receive a string of characters that represents a single line of data terminated by a LF or CRLF. If onDataReceived was overriden this method will not be called unless the onDataReceived calls this method explicitly using the class and member name.

diff --git a/html/classcore_1_1TLSSession-members.html b/html/classcore_1_1TLSSession-members.html index 53662d8..89ecdc5 100644 --- a/html/classcore_1_1TLSSession-members.html +++ b/html/classcore_1_1TLSSession-members.html @@ -83,36 +83,37 @@ $(function() { name (defined in core::Object)core::Object needsToWrite() (defined in core::Socket)core::Socket onConnected()core::TCPSessionprotectedvirtual - onDataReceived(std::string data) overridecore::TCPSessionprotectedvirtual - onDataReceived(char *buffer, int len) (defined in core::Socket)core::Socketprotectedvirtual - onRegister()core::TLSSessionprotectedvirtual - onRegistered()core::TLSSessionprotectedvirtual - onUnregister() (defined in core::Socket)core::Socketvirtual - onUnregistered()core::Socketvirtual - outcore::TCPSession - output(std::stringstream &out)core::TLSSessionvirtual - protocol(std::string data) overridecore::TLSSessionvirtual - receiveData(char *buffer, int bufferLength) overridecore::TLSSessionprotectedvirtual - send()core::TCPSession - sendToAll()core::TCPSession - sendToAll(SessionFilter filter)core::TCPSession - server (defined in core::TCPSession)core::TCPSession - setBufferSize(int length) (defined in core::Socket)core::Socketprotected - setDescriptor(int descriptor)core::Socket - shutdown(std::string text="unknown")core::Socket - shutDown (defined in core::Socket)core::Socketprotected - Socket(EPoll &ePoll, std::string text="")core::Socket - tag (defined in core::Object)core::Object - TCPSession(EPoll &ePoll, TCPServer &server, std::string text="") (defined in core::TCPSession)core::TCPSession - TCPSocket(EPoll &ePoll) (defined in core::TCPSocket)core::TCPSocket - TCPSocket(EPoll &ePoll, std::string text) (defined in core::TCPSocket)core::TCPSocket - TLSSession(EPoll &ePoll, TCPServer &server) (defined in core::TLSSession)core::TLSSession - write(std::string data)core::Socket - write(char *buffer, int length) (defined in core::Socket)core::Socket - ~Socket()core::Socket - ~TCPSession() (defined in core::TCPSession)core::TCPSession - ~TCPSocket() (defined in core::TCPSocket)core::TCPSocket - ~TLSSession() (defined in core::TLSSession)core::TLSSession + onDataReceived(char *data, int len) overridecore::TCPSessionprotectedvirtual + core::TCPSocket::onDataReceived(std::string data)core::Socketprotectedvirtual + onLineReceived(std::string line)core::TCPSessionprotectedvirtual + onRegister()core::TLSSessionprotectedvirtual + onRegistered()core::TLSSessionprotectedvirtual + onUnregister() (defined in core::Socket)core::Socketvirtual + onUnregistered()core::Socketvirtual + outcore::TCPSession + output(std::stringstream &out)core::TLSSessionvirtual + protocol(std::string data) overridecore::TLSSessionvirtual + receiveData(char *buffer, int bufferLength) overridecore::TLSSessionprotectedvirtual + send()core::TCPSession + sendToAll()core::TCPSession + sendToAll(SessionFilter filter)core::TCPSession + server (defined in core::TCPSession)core::TCPSession + setBufferSize(int length) (defined in core::Socket)core::Socketprotected + setDescriptor(int descriptor)core::Socket + shutdown(std::string text="unknown")core::Socket + shutDown (defined in core::Socket)core::Socketprotected + Socket(EPoll &ePoll, std::string text="")core::Socket + tag (defined in core::Object)core::Object + TCPSession(EPoll &ePoll, TCPServer &server, std::string text="") (defined in core::TCPSession)core::TCPSession + TCPSocket(EPoll &ePoll) (defined in core::TCPSocket)core::TCPSocket + TCPSocket(EPoll &ePoll, std::string text) (defined in core::TCPSocket)core::TCPSocket + TLSSession(EPoll &ePoll, TCPServer &server) (defined in core::TLSSession)core::TLSSession + write(std::string data)core::Socket + write(char *buffer, int length) (defined in core::Socket)core::Socket + ~Socket()core::Socket + ~TCPSession() (defined in core::TCPSession)core::TCPSession + ~TCPSocket() (defined in core::TCPSocket)core::TCPSocket + ~TLSSession() (defined in core::TLSSession)core::TLSSession
diff --git a/html/classcore_1_1TLSSession.html b/html/classcore_1_1TLSSession.html index 0b75d9a..52a99d5 100644 --- a/html/classcore_1_1TLSSession.html +++ b/html/classcore_1_1TLSSession.html @@ -183,9 +183,10 @@ void  Called after the socket has been registered with epoll processing.
  - Protected Member Functions inherited from core::TCPSession -virtual void onDataReceived (std::string data) override - Called when data is received from the socket. More...
-  +virtual void onDataReceived (char *data, int len) override +  +virtual void onLineReceived (std::string line) +  virtual void onConnected ()   - Protected Member Functions inherited from core::Socket @@ -195,9 +196,9 @@ void setBufferSize (in int getBufferSize ()   - -virtual void onDataReceived (char *buffer, int len) -  +virtual void onDataReceived (std::string data) + Called when data is received from the socket. More...
+  diff --git a/html/classcore_1_1TerminalSession-members.html b/html/classcore_1_1TerminalSession-members.html index 7de2dd6..81e5299 100644 --- a/html/classcore_1_1TerminalSession-members.html +++ b/html/classcore_1_1TerminalSession-members.html @@ -87,43 +87,44 @@ $(function() { - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +

Additional Inherited Members

needsToWrite() (defined in core::Socket)core::Socket
NextLine(int lines) (defined in core::TerminalSession)core::TerminalSession
onConnected()core::TCPSessionprotectedvirtual
onDataReceived(std::string data) overridecore::TCPSessionprotectedvirtual
onDataReceived(char *buffer, int len) (defined in core::Socket)core::Socketprotectedvirtual
onRegister()core::Socketvirtual
onRegistered() overridecore::TCPSessionprotectedvirtual
onUnregister() (defined in core::Socket)core::Socketvirtual
onUnregistered()core::Socketvirtual
outcore::TCPSession
output(std::stringstream &data)core::TCPSessionvirtual
PreviousLine(int lines) (defined in core::TerminalSession)core::TerminalSession
protocol(std::string data)core::TCPSessionprotectedvirtual
receiveData(char *buffer, int bufferLength)core::Socketprotectedvirtual
restoreCursor() (defined in core::TerminalSession)core::TerminalSession
saveCursor() (defined in core::TerminalSession)core::TerminalSession
scrollArea(int start, int end) (defined in core::TerminalSession)core::TerminalSession
send()core::TCPSession
sendToAll()core::TCPSession
sendToAll(SessionFilter filter)core::TCPSession
server (defined in core::TCPSession)core::TCPSession
setBackColor(int color) (defined in core::TerminalSession)core::TerminalSession
setBufferSize(int length) (defined in core::Socket)core::Socketprotected
setColor(int color) (defined in core::TerminalSession)core::TerminalSession
setCursorLocation(int x, int y)core::TerminalSession
setDescriptor(int descriptor)core::Socket
shutDown (defined in core::Socket)core::Socketprotected
shutdown(std::string text="unknown")core::Socket
Socket(EPoll &ePoll, std::string text="")core::Socket
tag (defined in core::Object)core::Object
TCPSession(EPoll &ePoll, TCPServer &server, std::string text="") (defined in core::TCPSession)core::TCPSession
TCPSocket(EPoll &ePoll) (defined in core::TCPSocket)core::TCPSocket
TCPSocket(EPoll &ePoll, std::string text) (defined in core::TCPSocket)core::TCPSocket
TerminalSession(EPoll &ePoll, TCPServer &server) (defined in core::TerminalSession)core::TerminalSession
write(std::string data)core::Socket
write(char *buffer, int length) (defined in core::Socket)core::Socket
~Socket()core::Socket
~TCPSession() (defined in core::TCPSession)core::TCPSession
~TCPSocket() (defined in core::TCPSocket)core::TCPSocket
~TerminalSession() (defined in core::TerminalSession)core::TerminalSession
onDataReceived(char *data, int len) overridecore::TCPSessionprotectedvirtual
core::TCPSocket::onDataReceived(std::string data)core::Socketprotectedvirtual
onLineReceived(std::string line)core::TCPSessionprotectedvirtual
onRegister()core::Socketvirtual
onRegistered() overridecore::TCPSessionprotectedvirtual
onUnregister() (defined in core::Socket)core::Socketvirtual
onUnregistered()core::Socketvirtual
outcore::TCPSession
output(std::stringstream &data)core::TCPSessionvirtual
PreviousLine(int lines) (defined in core::TerminalSession)core::TerminalSession
protocol(std::string data)core::TCPSessionprotectedvirtual
receiveData(char *buffer, int bufferLength)core::Socketprotectedvirtual
restoreCursor() (defined in core::TerminalSession)core::TerminalSession
saveCursor() (defined in core::TerminalSession)core::TerminalSession
scrollArea(int start, int end) (defined in core::TerminalSession)core::TerminalSession
send()core::TCPSession
sendToAll()core::TCPSession
sendToAll(SessionFilter filter)core::TCPSession
server (defined in core::TCPSession)core::TCPSession
setBackColor(int color) (defined in core::TerminalSession)core::TerminalSession
setBufferSize(int length) (defined in core::Socket)core::Socketprotected
setColor(int color) (defined in core::TerminalSession)core::TerminalSession
setCursorLocation(int x, int y)core::TerminalSession
setDescriptor(int descriptor)core::Socket
shutDown (defined in core::Socket)core::Socketprotected
shutdown(std::string text="unknown")core::Socket
Socket(EPoll &ePoll, std::string text="")core::Socket
tag (defined in core::Object)core::Object
TCPSession(EPoll &ePoll, TCPServer &server, std::string text="") (defined in core::TCPSession)core::TCPSession
TCPSocket(EPoll &ePoll) (defined in core::TCPSocket)core::TCPSocket
TCPSocket(EPoll &ePoll, std::string text) (defined in core::TCPSocket)core::TCPSocket
TerminalSession(EPoll &ePoll, TCPServer &server) (defined in core::TerminalSession)core::TerminalSession
write(std::string data)core::Socket
write(char *buffer, int length) (defined in core::Socket)core::Socket
~Socket()core::Socket
~TCPSession() (defined in core::TCPSession)core::TCPSession
~TCPSocket() (defined in core::TCPSocket)core::TCPSocket
~TerminalSession() (defined in core::TerminalSession)core::TerminalSession
diff --git a/html/classcore_1_1TerminalSession.html b/html/classcore_1_1TerminalSession.html index 3f9eeaf..23e5f11 100644 --- a/html/classcore_1_1TerminalSession.html +++ b/html/classcore_1_1TerminalSession.html @@ -227,13 +227,14 @@ std::string name< std::string tag   - Protected Member Functions inherited from core::TCPSession -virtual void onDataReceived (std::string data) override - Called when data is received from the socket. More...
-  virtual void onRegistered () override  Called after the socket has been registered with epoll processing.
  +virtual void onDataReceived (char *data, int len) override +  +virtual void onLineReceived (std::string line) +  virtual void onConnected ()   virtual void protocol (std::string data) @@ -245,9 +246,9 @@ void setBufferSize (in int getBufferSize ()   - -virtual void onDataReceived (char *buffer, int len) -  +virtual void onDataReceived (std::string data) + Called when data is received from the socket. More...
+  virtual void receiveData (char *buffer, int bufferLength)   - Protected Attributes inherited from core::Socket diff --git a/html/functions.html b/html/functions.html index a249ce5..39cc1ea 100644 --- a/html/functions.html +++ b/html/functions.html @@ -156,9 +156,12 @@ $(function() {
  • onDataReceived() : core::Socket , core::TCPServer -, core::TCPSession +, core::TCPSession , core::UDPServerSocket
    • +
  • onLineReceived() +: core::TCPSession +
  • onRegister() : core::Socket , core::TLSSession diff --git a/html/functions_func.html b/html/functions_func.html index 15a13ec..a94d44f 100644 --- a/html/functions_func.html +++ b/html/functions_func.html @@ -138,9 +138,12 @@ $(function() {
  • onDataReceived() : core::Socket , core::TCPServer -, core::TCPSession +, core::TCPSession , core::UDPServerSocket
    • +
  • onLineReceived() +: core::TCPSession +
  • onRegister() : core::Socket , core::TLSSession diff --git a/html/search/all_7.js b/html/search/all_7.js index 86245a5..97455d5 100644 --- a/html/search/all_7.js +++ b/html/search/all_7.js @@ -2,11 +2,12 @@ var searchData= [ ['object_25',['Object',['../classcore_1_1Object.html',1,'core']]], ['onconnected_26',['onConnected',['../classcore_1_1TCPSession.html#a8719952f7bb00bf7239ec40aa2868626',1,'core::TCPSession']]], - ['ondatareceived_27',['onDataReceived',['../classcore_1_1Socket.html#ac8d6a2c54696eb6fc2024cf6bcf6b4e5',1,'core::Socket::onDataReceived()'],['../classcore_1_1TCPServer.html#a276ccbc8cb9b4380ebd78807b97f0159',1,'core::TCPServer::onDataReceived()'],['../classcore_1_1TCPSession.html#aa87aca65cece02a107e7c288a925271f',1,'core::TCPSession::onDataReceived()'],['../classcore_1_1UDPServerSocket.html#a41933ca153c854a800e3d047ab18313e',1,'core::UDPServerSocket::onDataReceived()']]], - ['onregister_28',['onRegister',['../classcore_1_1Socket.html#a81e5ee3e17834166d97c6e8b7dfe0da0',1,'core::Socket::onRegister()'],['../classcore_1_1TLSSession.html#a76cec7cf4851eb27abe77a2339344c6d',1,'core::TLSSession::onRegister()']]], - ['onregistered_29',['onRegistered',['../classcore_1_1Socket.html#a23b9824653bbe4652a716acb828665b1',1,'core::Socket::onRegistered()'],['../classcore_1_1TCPSession.html#aed4ed499b978bcea57a8efefe929fc98',1,'core::TCPSession::onRegistered()'],['../classcore_1_1TLSSession.html#a8e26fdc9e8a6c573b5a504a1f1b137a9',1,'core::TLSSession::onRegistered()']]], - ['ontimeout_30',['onTimeout',['../classcore_1_1Timer.html#ae51704ff08d985bbc30e3ff4c9b3c6ca',1,'core::Timer']]], - ['onunregistered_31',['onUnregistered',['../classcore_1_1Socket.html#ae9be59697c2b2e5efb19aaae3ba943d2',1,'core::Socket']]], - ['out_32',['out',['../classcore_1_1TCPSession.html#abb302bbb3d7e7bc75490c736364f0d4d',1,'core::TCPSession']]], - ['output_33',['output',['../classcore_1_1Command.html#a314aef05f78aacb802097f8ae0875291',1,'core::Command::output()'],['../classcore_1_1TCPServer.html#a120d5031360cc62251bdc43fa2d9813a',1,'core::TCPServer::output()'],['../classcore_1_1TCPSession.html#a50037cbfc515650e04054e5481785981',1,'core::TCPSession::output()'],['../classcore_1_1TCPSocket.html#afacf7528ff3c9ac077d7b5a49e2116fd',1,'core::TCPSocket::output()'],['../classcore_1_1TLSSession.html#ae55de8a035d1ddc560cf619b2030af43',1,'core::TLSSession::output()']]] + ['ondatareceived_27',['onDataReceived',['../classcore_1_1Socket.html#ac8d6a2c54696eb6fc2024cf6bcf6b4e5',1,'core::Socket::onDataReceived()'],['../classcore_1_1TCPServer.html#a276ccbc8cb9b4380ebd78807b97f0159',1,'core::TCPServer::onDataReceived()'],['../classcore_1_1TCPSession.html#ac2c3ffef9ded12a8867e3d27902b001a',1,'core::TCPSession::onDataReceived()'],['../classcore_1_1UDPServerSocket.html#a41933ca153c854a800e3d047ab18313e',1,'core::UDPServerSocket::onDataReceived()']]], + ['onlinereceived_28',['onLineReceived',['../classcore_1_1TCPSession.html#a0f209620e9f11e70bfde54852b5c5460',1,'core::TCPSession']]], + ['onregister_29',['onRegister',['../classcore_1_1Socket.html#a81e5ee3e17834166d97c6e8b7dfe0da0',1,'core::Socket::onRegister()'],['../classcore_1_1TLSSession.html#a76cec7cf4851eb27abe77a2339344c6d',1,'core::TLSSession::onRegister()']]], + ['onregistered_30',['onRegistered',['../classcore_1_1Socket.html#a23b9824653bbe4652a716acb828665b1',1,'core::Socket::onRegistered()'],['../classcore_1_1TCPSession.html#aed4ed499b978bcea57a8efefe929fc98',1,'core::TCPSession::onRegistered()'],['../classcore_1_1TLSSession.html#a8e26fdc9e8a6c573b5a504a1f1b137a9',1,'core::TLSSession::onRegistered()']]], + ['ontimeout_31',['onTimeout',['../classcore_1_1Timer.html#ae51704ff08d985bbc30e3ff4c9b3c6ca',1,'core::Timer']]], + ['onunregistered_32',['onUnregistered',['../classcore_1_1Socket.html#ae9be59697c2b2e5efb19aaae3ba943d2',1,'core::Socket']]], + ['out_33',['out',['../classcore_1_1TCPSession.html#abb302bbb3d7e7bc75490c736364f0d4d',1,'core::TCPSession']]], + ['output_34',['output',['../classcore_1_1Command.html#a314aef05f78aacb802097f8ae0875291',1,'core::Command::output()'],['../classcore_1_1TCPServer.html#a120d5031360cc62251bdc43fa2d9813a',1,'core::TCPServer::output()'],['../classcore_1_1TCPSession.html#a50037cbfc515650e04054e5481785981',1,'core::TCPSession::output()'],['../classcore_1_1TCPSocket.html#afacf7528ff3c9ac077d7b5a49e2116fd',1,'core::TCPSocket::output()'],['../classcore_1_1TLSSession.html#ae55de8a035d1ddc560cf619b2030af43',1,'core::TLSSession::output()']]] ]; diff --git a/html/search/all_8.js b/html/search/all_8.js index 04822fa..0cff576 100644 --- a/html/search/all_8.js +++ b/html/search/all_8.js @@ -1,6 +1,6 @@ var searchData= [ - ['processcommand_34',['processCommand',['../classcore_1_1Command.html#a068ebc22f7a067cf23ed2c17f95b06e9',1,'core::Command::processCommand()'],['../classcore_1_1CommandList.html#a98939555ca061b445019a841726e3ef6',1,'core::CommandList::processCommand()'],['../classcore_1_1EPoll.html#a0c2d7fdaec43d0a15abab0399d5727df',1,'core::EPoll::processCommand()'],['../classcore_1_1TCPServer.html#a93f64f81bc63f145799af91138a064dc',1,'core::TCPServer::processCommand()']]], - ['processrequest_35',['processRequest',['../classcore_1_1CommandList.html#a589f3eba55beebad94a5978970e0650d',1,'core::CommandList']]], - ['protocol_36',['protocol',['../classcore_1_1ConsoleSession.html#a830cc1e1e0c3fe3b066f0a9f7f469490',1,'core::ConsoleSession::protocol()'],['../classcore_1_1TCPSession.html#ae90dc64e2d3c4b3239117923145edb3f',1,'core::TCPSession::protocol()'],['../classcore_1_1TLSSession.html#a547c436ab69f75307f065eca8cfcd109',1,'core::TLSSession::protocol()']]] + ['processcommand_35',['processCommand',['../classcore_1_1Command.html#a068ebc22f7a067cf23ed2c17f95b06e9',1,'core::Command::processCommand()'],['../classcore_1_1CommandList.html#a98939555ca061b445019a841726e3ef6',1,'core::CommandList::processCommand()'],['../classcore_1_1EPoll.html#a0c2d7fdaec43d0a15abab0399d5727df',1,'core::EPoll::processCommand()'],['../classcore_1_1TCPServer.html#a93f64f81bc63f145799af91138a064dc',1,'core::TCPServer::processCommand()']]], + ['processrequest_36',['processRequest',['../classcore_1_1CommandList.html#a589f3eba55beebad94a5978970e0650d',1,'core::CommandList']]], + ['protocol_37',['protocol',['../classcore_1_1ConsoleSession.html#a830cc1e1e0c3fe3b066f0a9f7f469490',1,'core::ConsoleSession::protocol()'],['../classcore_1_1TCPSession.html#ae90dc64e2d3c4b3239117923145edb3f',1,'core::TCPSession::protocol()'],['../classcore_1_1TLSSession.html#a547c436ab69f75307f065eca8cfcd109',1,'core::TLSSession::protocol()']]] ]; diff --git a/html/search/all_9.js b/html/search/all_9.js index 4037c75..fb7e6fc 100644 --- a/html/search/all_9.js +++ b/html/search/all_9.js @@ -1,6 +1,6 @@ var searchData= [ - ['receivedata_37',['receiveData',['../classcore_1_1Socket.html#af455ec6f793473f529507af26aa54695',1,'core::Socket::receiveData()'],['../classcore_1_1TLSSession.html#a1822cb21de545dc1a183ec0bac6cc4f0',1,'core::TLSSession::receiveData()']]], - ['registersocket_38',['registerSocket',['../classcore_1_1EPoll.html#a3d813c7bbf0da70ebc8e3cb6aeeacfb4',1,'core::EPoll']]], - ['remove_39',['remove',['../classcore_1_1CommandList.html#aaac684effb9ecf5238d23ca60d3fffaa',1,'core::CommandList']]] + ['receivedata_38',['receiveData',['../classcore_1_1Socket.html#af455ec6f793473f529507af26aa54695',1,'core::Socket::receiveData()'],['../classcore_1_1TLSSession.html#a1822cb21de545dc1a183ec0bac6cc4f0',1,'core::TLSSession::receiveData()']]], + ['registersocket_39',['registerSocket',['../classcore_1_1EPoll.html#a3d813c7bbf0da70ebc8e3cb6aeeacfb4',1,'core::EPoll']]], + ['remove_40',['remove',['../classcore_1_1CommandList.html#aaac684effb9ecf5238d23ca60d3fffaa',1,'core::CommandList']]] ]; diff --git a/html/search/all_a.js b/html/search/all_a.js index 6470b3a..d2be71c 100644 --- a/html/search/all_a.js +++ b/html/search/all_a.js @@ -1,15 +1,15 @@ var searchData= [ - ['send_40',['send',['../classcore_1_1TCPSession.html#a2b09eeafef5e44009a77d9da43e3b889',1,'core::TCPSession']]], - ['sendtoall_41',['sendToAll',['../classcore_1_1TCPSession.html#afdfe135694c6689f5365fac6c090ec33',1,'core::TCPSession::sendToAll()'],['../classcore_1_1TCPSession.html#a05c489dcd2ebd74f527864759929e351',1,'core::TCPSession::sendToAll(SessionFilter filter)']]], - ['sessionfilter_42',['SessionFilter',['../classcore_1_1SessionFilter.html',1,'core']]], - ['sessions_43',['sessions',['../classcore_1_1TCPServer.html#aeed1bc55d099667ccda51cd682bfc633',1,'core::TCPServer']]], - ['setcursorlocation_44',['setCursorLocation',['../classcore_1_1TerminalSession.html#aa9939cbe36c08e1a0b8413a96ca251fa',1,'core::TerminalSession']]], - ['setdescriptor_45',['setDescriptor',['../classcore_1_1Socket.html#ac44f6ae3196a8a3e09a6a85fcf495762',1,'core::Socket']]], - ['setname_46',['setName',['../classcore_1_1Command.html#ad8b0321c64838f4d5c8f93461b97cfef',1,'core::Command']]], - ['settimer_47',['setTimer',['../classcore_1_1Timer.html#ac0a642cdcb76b7f995137162050d3d0b',1,'core::Timer']]], - ['shutdown_48',['shutdown',['../classcore_1_1Socket.html#af2d1b6de7a64a9d446b0305b6ec47b31',1,'core::Socket']]], - ['socket_49',['Socket',['../classcore_1_1Socket.html',1,'core::Socket'],['../classcore_1_1Socket.html#a4c3f87fd1de3c9eab4bf5efbb30ce87d',1,'core::Socket::Socket()']]], - ['start_50',['start',['../classcore_1_1EPoll.html#aaefe2caef75eb538af90cb34682d277b',1,'core::EPoll::start()'],['../classcore_1_1Thread.html#ae6885df9a9b9503669e5776518b19054',1,'core::Thread::start()']]], - ['stop_51',['stop',['../classcore_1_1EPoll.html#a0c2865acd31d14fbf19dbc42cc084ddc',1,'core::EPoll']]] + ['send_41',['send',['../classcore_1_1TCPSession.html#a2b09eeafef5e44009a77d9da43e3b889',1,'core::TCPSession']]], + ['sendtoall_42',['sendToAll',['../classcore_1_1TCPSession.html#afdfe135694c6689f5365fac6c090ec33',1,'core::TCPSession::sendToAll()'],['../classcore_1_1TCPSession.html#a05c489dcd2ebd74f527864759929e351',1,'core::TCPSession::sendToAll(SessionFilter filter)']]], + ['sessionfilter_43',['SessionFilter',['../classcore_1_1SessionFilter.html',1,'core']]], + ['sessions_44',['sessions',['../classcore_1_1TCPServer.html#aeed1bc55d099667ccda51cd682bfc633',1,'core::TCPServer']]], + ['setcursorlocation_45',['setCursorLocation',['../classcore_1_1TerminalSession.html#aa9939cbe36c08e1a0b8413a96ca251fa',1,'core::TerminalSession']]], + ['setdescriptor_46',['setDescriptor',['../classcore_1_1Socket.html#ac44f6ae3196a8a3e09a6a85fcf495762',1,'core::Socket']]], + ['setname_47',['setName',['../classcore_1_1Command.html#ad8b0321c64838f4d5c8f93461b97cfef',1,'core::Command']]], + ['settimer_48',['setTimer',['../classcore_1_1Timer.html#ac0a642cdcb76b7f995137162050d3d0b',1,'core::Timer']]], + ['shutdown_49',['shutdown',['../classcore_1_1Socket.html#af2d1b6de7a64a9d446b0305b6ec47b31',1,'core::Socket']]], + ['socket_50',['Socket',['../classcore_1_1Socket.html',1,'core::Socket'],['../classcore_1_1Socket.html#a4c3f87fd1de3c9eab4bf5efbb30ce87d',1,'core::Socket::Socket()']]], + ['start_51',['start',['../classcore_1_1EPoll.html#aaefe2caef75eb538af90cb34682d277b',1,'core::EPoll::start()'],['../classcore_1_1Thread.html#ae6885df9a9b9503669e5776518b19054',1,'core::Thread::start()']]], + ['stop_52',['stop',['../classcore_1_1EPoll.html#a0c2865acd31d14fbf19dbc42cc084ddc',1,'core::EPoll']]] ]; diff --git a/html/search/all_b.js b/html/search/all_b.js index 1cb7cdf..a027e29 100644 --- a/html/search/all_b.js +++ b/html/search/all_b.js @@ -1,11 +1,11 @@ var searchData= [ - ['tcpserver_52',['TCPServer',['../classcore_1_1TCPServer.html',1,'core::TCPServer'],['../classcore_1_1TCPServer.html#a418924164fd6e59800272fbd6f069bb9',1,'core::TCPServer::TCPServer()']]], - ['tcpsession_53',['TCPSession',['../classcore_1_1TCPSession.html',1,'core']]], - ['tcpsocket_54',['TCPSocket',['../classcore_1_1TCPSocket.html',1,'core']]], - ['terminalsession_55',['TerminalSession',['../classcore_1_1TerminalSession.html',1,'core']]], - ['thread_56',['Thread',['../classcore_1_1Thread.html',1,'core']]], - ['timer_57',['Timer',['../classcore_1_1Timer.html',1,'core']]], - ['tlsserver_58',['TLSServer',['../classcore_1_1TLSServer.html',1,'core::TLSServer'],['../classcore_1_1TLSServer.html#a6460f9872936015efdfd0b8de04aa2fe',1,'core::TLSServer::TLSServer()']]], - ['tlssession_59',['TLSSession',['../classcore_1_1TLSSession.html',1,'core']]] + ['tcpserver_53',['TCPServer',['../classcore_1_1TCPServer.html',1,'core::TCPServer'],['../classcore_1_1TCPServer.html#a418924164fd6e59800272fbd6f069bb9',1,'core::TCPServer::TCPServer()']]], + ['tcpsession_54',['TCPSession',['../classcore_1_1TCPSession.html',1,'core']]], + ['tcpsocket_55',['TCPSocket',['../classcore_1_1TCPSocket.html',1,'core']]], + ['terminalsession_56',['TerminalSession',['../classcore_1_1TerminalSession.html',1,'core']]], + ['thread_57',['Thread',['../classcore_1_1Thread.html',1,'core']]], + ['timer_58',['Timer',['../classcore_1_1Timer.html',1,'core']]], + ['tlsserver_59',['TLSServer',['../classcore_1_1TLSServer.html',1,'core::TLSServer'],['../classcore_1_1TLSServer.html#a6460f9872936015efdfd0b8de04aa2fe',1,'core::TLSServer::TLSServer()']]], + ['tlssession_60',['TLSSession',['../classcore_1_1TLSSession.html',1,'core']]] ]; diff --git a/html/search/all_c.js b/html/search/all_c.js index 6afc930..c6e8956 100644 --- a/html/search/all_c.js +++ b/html/search/all_c.js @@ -1,6 +1,6 @@ var searchData= [ - ['udpserversocket_60',['UDPServerSocket',['../classcore_1_1UDPServerSocket.html',1,'core']]], - ['udpsocket_61',['UDPSocket',['../classcore_1_1UDPSocket.html',1,'core']]], - ['unregistersocket_62',['unregisterSocket',['../classcore_1_1EPoll.html#a5ab5e82ab51e0952fc8fbcc128f52900',1,'core::EPoll']]] + ['udpserversocket_61',['UDPServerSocket',['../classcore_1_1UDPServerSocket.html',1,'core']]], + ['udpsocket_62',['UDPSocket',['../classcore_1_1UDPSocket.html',1,'core']]], + ['unregistersocket_63',['unregisterSocket',['../classcore_1_1EPoll.html#a5ab5e82ab51e0952fc8fbcc128f52900',1,'core::EPoll']]] ]; diff --git a/html/search/all_d.js b/html/search/all_d.js index daf9ee7..130660e 100644 --- a/html/search/all_d.js +++ b/html/search/all_d.js @@ -1,5 +1,5 @@ var searchData= [ - ['whitelist_63',['whiteList',['../classcore_1_1TCPServer.html#abad6300b6234ca8b69cef9128755342e',1,'core::TCPServer']]], - ['write_64',['write',['../classcore_1_1Socket.html#a1413c826307ef0f29d7457770af675e3',1,'core::Socket']]] + ['whitelist_64',['whiteList',['../classcore_1_1TCPServer.html#abad6300b6234ca8b69cef9128755342e',1,'core::TCPServer']]], + ['write_65',['write',['../classcore_1_1Socket.html#a1413c826307ef0f29d7457770af675e3',1,'core::Socket']]] ]; diff --git a/html/search/all_e.js b/html/search/all_e.js index 3b44555..80e9550 100644 --- a/html/search/all_e.js +++ b/html/search/all_e.js @@ -1,7 +1,7 @@ var searchData= [ - ['_7eepoll_65',['~EPoll',['../classcore_1_1EPoll.html#a8e7a2496d684b745a6410f9bd3e88534',1,'core::EPoll']]], - ['_7esocket_66',['~Socket',['../classcore_1_1Socket.html#aa5003845f8ae464ad2fa206176381be0',1,'core::Socket']]], - ['_7etcpserver_67',['~TCPServer',['../classcore_1_1TCPServer.html#a7ccdc057c9eee8504fce796301f82088',1,'core::TCPServer']]], - ['_7etlsserver_68',['~TLSServer',['../classcore_1_1TLSServer.html#ac71db77c796a1bf65357409cb96054c7',1,'core::TLSServer']]] + ['_7eepoll_66',['~EPoll',['../classcore_1_1EPoll.html#a8e7a2496d684b745a6410f9bd3e88534',1,'core::EPoll']]], + ['_7esocket_67',['~Socket',['../classcore_1_1Socket.html#aa5003845f8ae464ad2fa206176381be0',1,'core::Socket']]], + ['_7etcpserver_68',['~TCPServer',['../classcore_1_1TCPServer.html#a7ccdc057c9eee8504fce796301f82088',1,'core::TCPServer']]], + ['_7etlsserver_69',['~TLSServer',['../classcore_1_1TLSServer.html#ac71db77c796a1bf65357409cb96054c7',1,'core::TLSServer']]] ]; diff --git a/html/search/classes_0.js b/html/search/classes_0.js index b1e3f8a..b03534d 100644 --- a/html/search/classes_0.js +++ b/html/search/classes_0.js @@ -1,7 +1,7 @@ var searchData= [ - ['command_69',['Command',['../classcore_1_1Command.html',1,'core']]], - ['commandlist_70',['CommandList',['../classcore_1_1CommandList.html',1,'core']]], - ['consoleserver_71',['ConsoleServer',['../classcore_1_1ConsoleServer.html',1,'core']]], - ['consolesession_72',['ConsoleSession',['../classcore_1_1ConsoleSession.html',1,'core']]] + ['command_70',['Command',['../classcore_1_1Command.html',1,'core']]], + ['commandlist_71',['CommandList',['../classcore_1_1CommandList.html',1,'core']]], + ['consoleserver_72',['ConsoleServer',['../classcore_1_1ConsoleServer.html',1,'core']]], + ['consolesession_73',['ConsoleSession',['../classcore_1_1ConsoleSession.html',1,'core']]] ]; diff --git a/html/search/classes_1.js b/html/search/classes_1.js index db6175c..0fc114c 100644 --- a/html/search/classes_1.js +++ b/html/search/classes_1.js @@ -1,4 +1,4 @@ var searchData= [ - ['epoll_73',['EPoll',['../classcore_1_1EPoll.html',1,'core']]] + ['epoll_74',['EPoll',['../classcore_1_1EPoll.html',1,'core']]] ]; diff --git a/html/search/classes_2.js b/html/search/classes_2.js index 9db7dc5..132c719 100644 --- a/html/search/classes_2.js +++ b/html/search/classes_2.js @@ -1,6 +1,6 @@ var searchData= [ - ['inotify_74',['INotify',['../classcore_1_1INotify.html',1,'core']]], - ['ipaddress_75',['IPAddress',['../classcore_1_1IPAddress.html',1,'core']]], - ['ipaddresslist_76',['IPAddressList',['../classcore_1_1IPAddressList.html',1,'core']]] + ['inotify_75',['INotify',['../classcore_1_1INotify.html',1,'core']]], + ['ipaddress_76',['IPAddress',['../classcore_1_1IPAddress.html',1,'core']]], + ['ipaddresslist_77',['IPAddressList',['../classcore_1_1IPAddressList.html',1,'core']]] ]; diff --git a/html/search/classes_3.js b/html/search/classes_3.js index 94e0c52..7c17f10 100644 --- a/html/search/classes_3.js +++ b/html/search/classes_3.js @@ -1,4 +1,4 @@ var searchData= [ - ['object_77',['Object',['../classcore_1_1Object.html',1,'core']]] + ['object_78',['Object',['../classcore_1_1Object.html',1,'core']]] ]; diff --git a/html/search/classes_4.js b/html/search/classes_4.js index 2eea47d..5448ea7 100644 --- a/html/search/classes_4.js +++ b/html/search/classes_4.js @@ -1,5 +1,5 @@ var searchData= [ - ['sessionfilter_78',['SessionFilter',['../classcore_1_1SessionFilter.html',1,'core']]], - ['socket_79',['Socket',['../classcore_1_1Socket.html',1,'core']]] + ['sessionfilter_79',['SessionFilter',['../classcore_1_1SessionFilter.html',1,'core']]], + ['socket_80',['Socket',['../classcore_1_1Socket.html',1,'core']]] ]; diff --git a/html/search/classes_5.js b/html/search/classes_5.js index 5fed038..17ade47 100644 --- a/html/search/classes_5.js +++ b/html/search/classes_5.js @@ -1,11 +1,11 @@ var searchData= [ - ['tcpserver_80',['TCPServer',['../classcore_1_1TCPServer.html',1,'core']]], - ['tcpsession_81',['TCPSession',['../classcore_1_1TCPSession.html',1,'core']]], - ['tcpsocket_82',['TCPSocket',['../classcore_1_1TCPSocket.html',1,'core']]], - ['terminalsession_83',['TerminalSession',['../classcore_1_1TerminalSession.html',1,'core']]], - ['thread_84',['Thread',['../classcore_1_1Thread.html',1,'core']]], - ['timer_85',['Timer',['../classcore_1_1Timer.html',1,'core']]], - ['tlsserver_86',['TLSServer',['../classcore_1_1TLSServer.html',1,'core']]], - ['tlssession_87',['TLSSession',['../classcore_1_1TLSSession.html',1,'core']]] + ['tcpserver_81',['TCPServer',['../classcore_1_1TCPServer.html',1,'core']]], + ['tcpsession_82',['TCPSession',['../classcore_1_1TCPSession.html',1,'core']]], + ['tcpsocket_83',['TCPSocket',['../classcore_1_1TCPSocket.html',1,'core']]], + ['terminalsession_84',['TerminalSession',['../classcore_1_1TerminalSession.html',1,'core']]], + ['thread_85',['Thread',['../classcore_1_1Thread.html',1,'core']]], + ['timer_86',['Timer',['../classcore_1_1Timer.html',1,'core']]], + ['tlsserver_87',['TLSServer',['../classcore_1_1TLSServer.html',1,'core']]], + ['tlssession_88',['TLSSession',['../classcore_1_1TLSSession.html',1,'core']]] ]; diff --git a/html/search/classes_6.js b/html/search/classes_6.js index 3194ddb..7c5ec04 100644 --- a/html/search/classes_6.js +++ b/html/search/classes_6.js @@ -1,5 +1,5 @@ var searchData= [ - ['udpserversocket_88',['UDPServerSocket',['../classcore_1_1UDPServerSocket.html',1,'core']]], - ['udpsocket_89',['UDPSocket',['../classcore_1_1UDPSocket.html',1,'core']]] + ['udpserversocket_89',['UDPServerSocket',['../classcore_1_1UDPServerSocket.html',1,'core']]], + ['udpsocket_90',['UDPSocket',['../classcore_1_1UDPSocket.html',1,'core']]] ]; diff --git a/html/search/functions_0.js b/html/search/functions_0.js index dc96e19..3d7e490 100644 --- a/html/search/functions_0.js +++ b/html/search/functions_0.js @@ -1,4 +1,4 @@ var searchData= [ - ['add_90',['add',['../classcore_1_1CommandList.html#a7a45e75e3d21a25fd3f7e887acf395e9',1,'core::CommandList']]] + ['add_91',['add',['../classcore_1_1CommandList.html#a7a45e75e3d21a25fd3f7e887acf395e9',1,'core::CommandList']]] ]; diff --git a/html/search/functions_1.js b/html/search/functions_1.js index 9a73b98..89467ab 100644 --- a/html/search/functions_1.js +++ b/html/search/functions_1.js @@ -1,7 +1,7 @@ var searchData= [ - ['check_91',['check',['../classcore_1_1Command.html#abdc0d7a4693a7f7940bbae20c4a667c0',1,'core::Command']]], - ['clear_92',['clear',['../classcore_1_1TerminalSession.html#a42bb06857891220a831da04248233935',1,'core::TerminalSession']]], - ['cleareol_93',['clearEOL',['../classcore_1_1TerminalSession.html#aa660768eed03b0b996a749e8a146446c',1,'core::TerminalSession']]], - ['cleartimer_94',['clearTimer',['../classcore_1_1Timer.html#a8e063f46e89dac04364871e909ab940a',1,'core::Timer']]] + ['check_92',['check',['../classcore_1_1Command.html#abdc0d7a4693a7f7940bbae20c4a667c0',1,'core::Command']]], + ['clear_93',['clear',['../classcore_1_1TerminalSession.html#a42bb06857891220a831da04248233935',1,'core::TerminalSession']]], + ['cleareol_94',['clearEOL',['../classcore_1_1TerminalSession.html#aa660768eed03b0b996a749e8a146446c',1,'core::TerminalSession']]], + ['cleartimer_95',['clearTimer',['../classcore_1_1Timer.html#a8e063f46e89dac04364871e909ab940a',1,'core::Timer']]] ]; diff --git a/html/search/functions_2.js b/html/search/functions_2.js index 952bc3e..3411b3e 100644 --- a/html/search/functions_2.js +++ b/html/search/functions_2.js @@ -1,5 +1,5 @@ var searchData= [ - ['epoll_95',['EPoll',['../classcore_1_1EPoll.html#a2fd5cc4336b5f72990ecc0e7ea3d7641',1,'core::EPoll']]], - ['eventreceived_96',['eventReceived',['../classcore_1_1EPoll.html#a39b88c943190f724c963b49baaa2cfbb',1,'core::EPoll::eventReceived()'],['../classcore_1_1Socket.html#aeee3b9d24b039679f1f05820209539c5',1,'core::Socket::eventReceived()']]] + ['epoll_96',['EPoll',['../classcore_1_1EPoll.html#a2fd5cc4336b5f72990ecc0e7ea3d7641',1,'core::EPoll']]], + ['eventreceived_97',['eventReceived',['../classcore_1_1EPoll.html#a39b88c943190f724c963b49baaa2cfbb',1,'core::EPoll::eventReceived()'],['../classcore_1_1Socket.html#aeee3b9d24b039679f1f05820209539c5',1,'core::Socket::eventReceived()']]] ]; diff --git a/html/search/functions_3.js b/html/search/functions_3.js index a9f090a..43c6d6e 100644 --- a/html/search/functions_3.js +++ b/html/search/functions_3.js @@ -1,10 +1,10 @@ var searchData= [ - ['getclientaddress_97',['getClientAddress',['../classcore_1_1IPAddress.html#ae5e7e28589d026bbbc6c3423d418b008',1,'core::IPAddress']]], - ['getclientaddressandport_98',['getClientAddressAndPort',['../classcore_1_1IPAddress.html#abea870f1a048cb7bba1d2bad98558232',1,'core::IPAddress']]], - ['getclientport_99',['getClientPort',['../classcore_1_1IPAddress.html#a39f706f2d43d7d001296ecead4b587e8',1,'core::IPAddress']]], - ['getdescriptor_100',['getDescriptor',['../classcore_1_1EPoll.html#a1e52017e1deae15c1c87c6b6a099e1ed',1,'core::EPoll::getDescriptor()'],['../classcore_1_1Socket.html#a06ba54744530439d4131e6aba4623d08',1,'core::Socket::getDescriptor()']]], - ['getelapsed_101',['getElapsed',['../classcore_1_1Timer.html#a0df7f1ffc05529b45d6e13713bbc0209',1,'core::Timer']]], - ['getsocketaccept_102',['getSocketAccept',['../classcore_1_1ConsoleServer.html#a80d9ea7f3fc5e07c50d5b9e0d4943ca8',1,'core::ConsoleServer::getSocketAccept()'],['../classcore_1_1TCPServer.html#a841f02799ad8529aad7cea132f4de8a9',1,'core::TCPServer::getSocketAccept()']]], - ['grabinput_103',['grabInput',['../classcore_1_1CommandList.html#a40211d843807cd65f6614c17efcb00e4',1,'core::CommandList']]] + ['getclientaddress_98',['getClientAddress',['../classcore_1_1IPAddress.html#ae5e7e28589d026bbbc6c3423d418b008',1,'core::IPAddress']]], + ['getclientaddressandport_99',['getClientAddressAndPort',['../classcore_1_1IPAddress.html#abea870f1a048cb7bba1d2bad98558232',1,'core::IPAddress']]], + ['getclientport_100',['getClientPort',['../classcore_1_1IPAddress.html#a39f706f2d43d7d001296ecead4b587e8',1,'core::IPAddress']]], + ['getdescriptor_101',['getDescriptor',['../classcore_1_1EPoll.html#a1e52017e1deae15c1c87c6b6a099e1ed',1,'core::EPoll::getDescriptor()'],['../classcore_1_1Socket.html#a06ba54744530439d4131e6aba4623d08',1,'core::Socket::getDescriptor()']]], + ['getelapsed_102',['getElapsed',['../classcore_1_1Timer.html#a0df7f1ffc05529b45d6e13713bbc0209',1,'core::Timer']]], + ['getsocketaccept_103',['getSocketAccept',['../classcore_1_1ConsoleServer.html#a80d9ea7f3fc5e07c50d5b9e0d4943ca8',1,'core::ConsoleServer::getSocketAccept()'],['../classcore_1_1TCPServer.html#a841f02799ad8529aad7cea132f4de8a9',1,'core::TCPServer::getSocketAccept()']]], + ['grabinput_104',['grabInput',['../classcore_1_1CommandList.html#a40211d843807cd65f6614c17efcb00e4',1,'core::CommandList']]] ]; diff --git a/html/search/functions_4.js b/html/search/functions_4.js index c852a01..e36f8d2 100644 --- a/html/search/functions_4.js +++ b/html/search/functions_4.js @@ -1,4 +1,4 @@ var searchData= [ - ['isstopping_104',['isStopping',['../classcore_1_1EPoll.html#a301b46b71ac7ac61a687ff723fe269b3',1,'core::EPoll']]] + ['isstopping_105',['isStopping',['../classcore_1_1EPoll.html#a301b46b71ac7ac61a687ff723fe269b3',1,'core::EPoll']]] ]; diff --git a/html/search/functions_5.js b/html/search/functions_5.js index b580494..5a9550a 100644 --- a/html/search/functions_5.js +++ b/html/search/functions_5.js @@ -1,10 +1,11 @@ var searchData= [ - ['onconnected_105',['onConnected',['../classcore_1_1TCPSession.html#a8719952f7bb00bf7239ec40aa2868626',1,'core::TCPSession']]], - ['ondatareceived_106',['onDataReceived',['../classcore_1_1Socket.html#ac8d6a2c54696eb6fc2024cf6bcf6b4e5',1,'core::Socket::onDataReceived()'],['../classcore_1_1TCPServer.html#a276ccbc8cb9b4380ebd78807b97f0159',1,'core::TCPServer::onDataReceived()'],['../classcore_1_1TCPSession.html#aa87aca65cece02a107e7c288a925271f',1,'core::TCPSession::onDataReceived()'],['../classcore_1_1UDPServerSocket.html#a41933ca153c854a800e3d047ab18313e',1,'core::UDPServerSocket::onDataReceived()']]], - ['onregister_107',['onRegister',['../classcore_1_1Socket.html#a81e5ee3e17834166d97c6e8b7dfe0da0',1,'core::Socket::onRegister()'],['../classcore_1_1TLSSession.html#a76cec7cf4851eb27abe77a2339344c6d',1,'core::TLSSession::onRegister()']]], - ['onregistered_108',['onRegistered',['../classcore_1_1Socket.html#a23b9824653bbe4652a716acb828665b1',1,'core::Socket::onRegistered()'],['../classcore_1_1TCPSession.html#aed4ed499b978bcea57a8efefe929fc98',1,'core::TCPSession::onRegistered()'],['../classcore_1_1TLSSession.html#a8e26fdc9e8a6c573b5a504a1f1b137a9',1,'core::TLSSession::onRegistered()']]], - ['ontimeout_109',['onTimeout',['../classcore_1_1Timer.html#ae51704ff08d985bbc30e3ff4c9b3c6ca',1,'core::Timer']]], - ['onunregistered_110',['onUnregistered',['../classcore_1_1Socket.html#ae9be59697c2b2e5efb19aaae3ba943d2',1,'core::Socket']]], - ['output_111',['output',['../classcore_1_1Command.html#a314aef05f78aacb802097f8ae0875291',1,'core::Command::output()'],['../classcore_1_1TCPServer.html#a120d5031360cc62251bdc43fa2d9813a',1,'core::TCPServer::output()'],['../classcore_1_1TCPSession.html#a50037cbfc515650e04054e5481785981',1,'core::TCPSession::output()'],['../classcore_1_1TCPSocket.html#afacf7528ff3c9ac077d7b5a49e2116fd',1,'core::TCPSocket::output()'],['../classcore_1_1TLSSession.html#ae55de8a035d1ddc560cf619b2030af43',1,'core::TLSSession::output()']]] + ['onconnected_106',['onConnected',['../classcore_1_1TCPSession.html#a8719952f7bb00bf7239ec40aa2868626',1,'core::TCPSession']]], + ['ondatareceived_107',['onDataReceived',['../classcore_1_1Socket.html#ac8d6a2c54696eb6fc2024cf6bcf6b4e5',1,'core::Socket::onDataReceived()'],['../classcore_1_1TCPServer.html#a276ccbc8cb9b4380ebd78807b97f0159',1,'core::TCPServer::onDataReceived()'],['../classcore_1_1TCPSession.html#ac2c3ffef9ded12a8867e3d27902b001a',1,'core::TCPSession::onDataReceived()'],['../classcore_1_1UDPServerSocket.html#a41933ca153c854a800e3d047ab18313e',1,'core::UDPServerSocket::onDataReceived()']]], + ['onlinereceived_108',['onLineReceived',['../classcore_1_1TCPSession.html#a0f209620e9f11e70bfde54852b5c5460',1,'core::TCPSession']]], + ['onregister_109',['onRegister',['../classcore_1_1Socket.html#a81e5ee3e17834166d97c6e8b7dfe0da0',1,'core::Socket::onRegister()'],['../classcore_1_1TLSSession.html#a76cec7cf4851eb27abe77a2339344c6d',1,'core::TLSSession::onRegister()']]], + ['onregistered_110',['onRegistered',['../classcore_1_1Socket.html#a23b9824653bbe4652a716acb828665b1',1,'core::Socket::onRegistered()'],['../classcore_1_1TCPSession.html#aed4ed499b978bcea57a8efefe929fc98',1,'core::TCPSession::onRegistered()'],['../classcore_1_1TLSSession.html#a8e26fdc9e8a6c573b5a504a1f1b137a9',1,'core::TLSSession::onRegistered()']]], + ['ontimeout_111',['onTimeout',['../classcore_1_1Timer.html#ae51704ff08d985bbc30e3ff4c9b3c6ca',1,'core::Timer']]], + ['onunregistered_112',['onUnregistered',['../classcore_1_1Socket.html#ae9be59697c2b2e5efb19aaae3ba943d2',1,'core::Socket']]], + ['output_113',['output',['../classcore_1_1Command.html#a314aef05f78aacb802097f8ae0875291',1,'core::Command::output()'],['../classcore_1_1TCPServer.html#a120d5031360cc62251bdc43fa2d9813a',1,'core::TCPServer::output()'],['../classcore_1_1TCPSession.html#a50037cbfc515650e04054e5481785981',1,'core::TCPSession::output()'],['../classcore_1_1TCPSocket.html#afacf7528ff3c9ac077d7b5a49e2116fd',1,'core::TCPSocket::output()'],['../classcore_1_1TLSSession.html#ae55de8a035d1ddc560cf619b2030af43',1,'core::TLSSession::output()']]] ]; diff --git a/html/search/functions_6.js b/html/search/functions_6.js index 37c3028..2f9388a 100644 --- a/html/search/functions_6.js +++ b/html/search/functions_6.js @@ -1,6 +1,6 @@ var searchData= [ - ['processcommand_112',['processCommand',['../classcore_1_1Command.html#a068ebc22f7a067cf23ed2c17f95b06e9',1,'core::Command::processCommand()'],['../classcore_1_1CommandList.html#a98939555ca061b445019a841726e3ef6',1,'core::CommandList::processCommand()'],['../classcore_1_1EPoll.html#a0c2d7fdaec43d0a15abab0399d5727df',1,'core::EPoll::processCommand()'],['../classcore_1_1TCPServer.html#a93f64f81bc63f145799af91138a064dc',1,'core::TCPServer::processCommand()']]], - ['processrequest_113',['processRequest',['../classcore_1_1CommandList.html#a589f3eba55beebad94a5978970e0650d',1,'core::CommandList']]], - ['protocol_114',['protocol',['../classcore_1_1ConsoleSession.html#a830cc1e1e0c3fe3b066f0a9f7f469490',1,'core::ConsoleSession::protocol()'],['../classcore_1_1TCPSession.html#ae90dc64e2d3c4b3239117923145edb3f',1,'core::TCPSession::protocol()'],['../classcore_1_1TLSSession.html#a547c436ab69f75307f065eca8cfcd109',1,'core::TLSSession::protocol()']]] + ['processcommand_114',['processCommand',['../classcore_1_1Command.html#a068ebc22f7a067cf23ed2c17f95b06e9',1,'core::Command::processCommand()'],['../classcore_1_1CommandList.html#a98939555ca061b445019a841726e3ef6',1,'core::CommandList::processCommand()'],['../classcore_1_1EPoll.html#a0c2d7fdaec43d0a15abab0399d5727df',1,'core::EPoll::processCommand()'],['../classcore_1_1TCPServer.html#a93f64f81bc63f145799af91138a064dc',1,'core::TCPServer::processCommand()']]], + ['processrequest_115',['processRequest',['../classcore_1_1CommandList.html#a589f3eba55beebad94a5978970e0650d',1,'core::CommandList']]], + ['protocol_116',['protocol',['../classcore_1_1ConsoleSession.html#a830cc1e1e0c3fe3b066f0a9f7f469490',1,'core::ConsoleSession::protocol()'],['../classcore_1_1TCPSession.html#ae90dc64e2d3c4b3239117923145edb3f',1,'core::TCPSession::protocol()'],['../classcore_1_1TLSSession.html#a547c436ab69f75307f065eca8cfcd109',1,'core::TLSSession::protocol()']]] ]; diff --git a/html/search/functions_7.js b/html/search/functions_7.js index c1a175c..02b4153 100644 --- a/html/search/functions_7.js +++ b/html/search/functions_7.js @@ -1,6 +1,6 @@ var searchData= [ - ['receivedata_115',['receiveData',['../classcore_1_1Socket.html#af455ec6f793473f529507af26aa54695',1,'core::Socket::receiveData()'],['../classcore_1_1TLSSession.html#a1822cb21de545dc1a183ec0bac6cc4f0',1,'core::TLSSession::receiveData()']]], - ['registersocket_116',['registerSocket',['../classcore_1_1EPoll.html#a3d813c7bbf0da70ebc8e3cb6aeeacfb4',1,'core::EPoll']]], - ['remove_117',['remove',['../classcore_1_1CommandList.html#aaac684effb9ecf5238d23ca60d3fffaa',1,'core::CommandList']]] + ['receivedata_117',['receiveData',['../classcore_1_1Socket.html#af455ec6f793473f529507af26aa54695',1,'core::Socket::receiveData()'],['../classcore_1_1TLSSession.html#a1822cb21de545dc1a183ec0bac6cc4f0',1,'core::TLSSession::receiveData()']]], + ['registersocket_118',['registerSocket',['../classcore_1_1EPoll.html#a3d813c7bbf0da70ebc8e3cb6aeeacfb4',1,'core::EPoll']]], + ['remove_119',['remove',['../classcore_1_1CommandList.html#aaac684effb9ecf5238d23ca60d3fffaa',1,'core::CommandList']]] ]; diff --git a/html/search/functions_8.js b/html/search/functions_8.js index d9e5cb8..be013e7 100644 --- a/html/search/functions_8.js +++ b/html/search/functions_8.js @@ -1,13 +1,13 @@ var searchData= [ - ['send_118',['send',['../classcore_1_1TCPSession.html#a2b09eeafef5e44009a77d9da43e3b889',1,'core::TCPSession']]], - ['sendtoall_119',['sendToAll',['../classcore_1_1TCPSession.html#afdfe135694c6689f5365fac6c090ec33',1,'core::TCPSession::sendToAll()'],['../classcore_1_1TCPSession.html#a05c489dcd2ebd74f527864759929e351',1,'core::TCPSession::sendToAll(SessionFilter filter)']]], - ['setcursorlocation_120',['setCursorLocation',['../classcore_1_1TerminalSession.html#aa9939cbe36c08e1a0b8413a96ca251fa',1,'core::TerminalSession']]], - ['setdescriptor_121',['setDescriptor',['../classcore_1_1Socket.html#ac44f6ae3196a8a3e09a6a85fcf495762',1,'core::Socket']]], - ['setname_122',['setName',['../classcore_1_1Command.html#ad8b0321c64838f4d5c8f93461b97cfef',1,'core::Command']]], - ['settimer_123',['setTimer',['../classcore_1_1Timer.html#ac0a642cdcb76b7f995137162050d3d0b',1,'core::Timer']]], - ['shutdown_124',['shutdown',['../classcore_1_1Socket.html#af2d1b6de7a64a9d446b0305b6ec47b31',1,'core::Socket']]], - ['socket_125',['Socket',['../classcore_1_1Socket.html#a4c3f87fd1de3c9eab4bf5efbb30ce87d',1,'core::Socket']]], - ['start_126',['start',['../classcore_1_1EPoll.html#aaefe2caef75eb538af90cb34682d277b',1,'core::EPoll::start()'],['../classcore_1_1Thread.html#ae6885df9a9b9503669e5776518b19054',1,'core::Thread::start()']]], - ['stop_127',['stop',['../classcore_1_1EPoll.html#a0c2865acd31d14fbf19dbc42cc084ddc',1,'core::EPoll']]] + ['send_120',['send',['../classcore_1_1TCPSession.html#a2b09eeafef5e44009a77d9da43e3b889',1,'core::TCPSession']]], + ['sendtoall_121',['sendToAll',['../classcore_1_1TCPSession.html#afdfe135694c6689f5365fac6c090ec33',1,'core::TCPSession::sendToAll()'],['../classcore_1_1TCPSession.html#a05c489dcd2ebd74f527864759929e351',1,'core::TCPSession::sendToAll(SessionFilter filter)']]], + ['setcursorlocation_122',['setCursorLocation',['../classcore_1_1TerminalSession.html#aa9939cbe36c08e1a0b8413a96ca251fa',1,'core::TerminalSession']]], + ['setdescriptor_123',['setDescriptor',['../classcore_1_1Socket.html#ac44f6ae3196a8a3e09a6a85fcf495762',1,'core::Socket']]], + ['setname_124',['setName',['../classcore_1_1Command.html#ad8b0321c64838f4d5c8f93461b97cfef',1,'core::Command']]], + ['settimer_125',['setTimer',['../classcore_1_1Timer.html#ac0a642cdcb76b7f995137162050d3d0b',1,'core::Timer']]], + ['shutdown_126',['shutdown',['../classcore_1_1Socket.html#af2d1b6de7a64a9d446b0305b6ec47b31',1,'core::Socket']]], + ['socket_127',['Socket',['../classcore_1_1Socket.html#a4c3f87fd1de3c9eab4bf5efbb30ce87d',1,'core::Socket']]], + ['start_128',['start',['../classcore_1_1EPoll.html#aaefe2caef75eb538af90cb34682d277b',1,'core::EPoll::start()'],['../classcore_1_1Thread.html#ae6885df9a9b9503669e5776518b19054',1,'core::Thread::start()']]], + ['stop_129',['stop',['../classcore_1_1EPoll.html#a0c2865acd31d14fbf19dbc42cc084ddc',1,'core::EPoll']]] ]; diff --git a/html/search/functions_9.js b/html/search/functions_9.js index 9fbeb4f..dcaaf8c 100644 --- a/html/search/functions_9.js +++ b/html/search/functions_9.js @@ -1,5 +1,5 @@ var searchData= [ - ['tcpserver_128',['TCPServer',['../classcore_1_1TCPServer.html#a418924164fd6e59800272fbd6f069bb9',1,'core::TCPServer']]], - ['tlsserver_129',['TLSServer',['../classcore_1_1TLSServer.html#a6460f9872936015efdfd0b8de04aa2fe',1,'core::TLSServer']]] + ['tcpserver_130',['TCPServer',['../classcore_1_1TCPServer.html#a418924164fd6e59800272fbd6f069bb9',1,'core::TCPServer']]], + ['tlsserver_131',['TLSServer',['../classcore_1_1TLSServer.html#a6460f9872936015efdfd0b8de04aa2fe',1,'core::TLSServer']]] ]; diff --git a/html/search/functions_a.js b/html/search/functions_a.js index 5702f6b..47589e4 100644 --- a/html/search/functions_a.js +++ b/html/search/functions_a.js @@ -1,4 +1,4 @@ var searchData= [ - ['unregistersocket_130',['unregisterSocket',['../classcore_1_1EPoll.html#a5ab5e82ab51e0952fc8fbcc128f52900',1,'core::EPoll']]] + ['unregistersocket_132',['unregisterSocket',['../classcore_1_1EPoll.html#a5ab5e82ab51e0952fc8fbcc128f52900',1,'core::EPoll']]] ]; diff --git a/html/search/functions_b.js b/html/search/functions_b.js index 4f77c9d..243a5f2 100644 --- a/html/search/functions_b.js +++ b/html/search/functions_b.js @@ -1,4 +1,4 @@ var searchData= [ - ['write_131',['write',['../classcore_1_1Socket.html#a1413c826307ef0f29d7457770af675e3',1,'core::Socket']]] + ['write_133',['write',['../classcore_1_1Socket.html#a1413c826307ef0f29d7457770af675e3',1,'core::Socket']]] ]; diff --git a/html/search/functions_c.js b/html/search/functions_c.js index 5bfef78..1733e1b 100644 --- a/html/search/functions_c.js +++ b/html/search/functions_c.js @@ -1,7 +1,7 @@ var searchData= [ - ['_7eepoll_132',['~EPoll',['../classcore_1_1EPoll.html#a8e7a2496d684b745a6410f9bd3e88534',1,'core::EPoll']]], - ['_7esocket_133',['~Socket',['../classcore_1_1Socket.html#aa5003845f8ae464ad2fa206176381be0',1,'core::Socket']]], - ['_7etcpserver_134',['~TCPServer',['../classcore_1_1TCPServer.html#a7ccdc057c9eee8504fce796301f82088',1,'core::TCPServer']]], - ['_7etlsserver_135',['~TLSServer',['../classcore_1_1TLSServer.html#ac71db77c796a1bf65357409cb96054c7',1,'core::TLSServer']]] + ['_7eepoll_134',['~EPoll',['../classcore_1_1EPoll.html#a8e7a2496d684b745a6410f9bd3e88534',1,'core::EPoll']]], + ['_7esocket_135',['~Socket',['../classcore_1_1Socket.html#aa5003845f8ae464ad2fa206176381be0',1,'core::Socket']]], + ['_7etcpserver_136',['~TCPServer',['../classcore_1_1TCPServer.html#a7ccdc057c9eee8504fce796301f82088',1,'core::TCPServer']]], + ['_7etlsserver_137',['~TLSServer',['../classcore_1_1TLSServer.html#ac71db77c796a1bf65357409cb96054c7',1,'core::TLSServer']]] ]; diff --git a/html/search/variables_0.js b/html/search/variables_0.js index 3b7b039..101b9a8 100644 --- a/html/search/variables_0.js +++ b/html/search/variables_0.js @@ -1,4 +1,4 @@ var searchData= [ - ['blacklist_136',['blackList',['../classcore_1_1TCPServer.html#a82f6bf16e4ab20d8b30da09e034fffff',1,'core::TCPServer']]] + ['blacklist_138',['blackList',['../classcore_1_1TCPServer.html#a82f6bf16e4ab20d8b30da09e034fffff',1,'core::TCPServer']]] ]; diff --git a/html/search/variables_1.js b/html/search/variables_1.js index e6fabae..e389e1e 100644 --- a/html/search/variables_1.js +++ b/html/search/variables_1.js @@ -1,4 +1,4 @@ var searchData= [ - ['commands_137',['commands',['../classcore_1_1CommandList.html#a435f09d15c78dad43e7bca4977d6bdf1',1,'core::CommandList::commands()'],['../classcore_1_1TCPServer.html#afcc44802b988e2f4292504e804dccf8b',1,'core::TCPServer::commands()']]] + ['commands_139',['commands',['../classcore_1_1CommandList.html#a435f09d15c78dad43e7bca4977d6bdf1',1,'core::CommandList::commands()'],['../classcore_1_1TCPServer.html#afcc44802b988e2f4292504e804dccf8b',1,'core::TCPServer::commands()']]] ]; diff --git a/html/search/variables_2.js b/html/search/variables_2.js index 88b42a9..aa47ad4 100644 --- a/html/search/variables_2.js +++ b/html/search/variables_2.js @@ -1,4 +1,4 @@ var searchData= [ - ['maxsockets_138',['maxSockets',['../classcore_1_1EPoll.html#acfcef2513d94f7b9a191fed3dc744d90',1,'core::EPoll']]] + ['maxsockets_140',['maxSockets',['../classcore_1_1EPoll.html#acfcef2513d94f7b9a191fed3dc744d90',1,'core::EPoll']]] ]; diff --git a/html/search/variables_3.js b/html/search/variables_3.js index c7de56e..d8de31c 100644 --- a/html/search/variables_3.js +++ b/html/search/variables_3.js @@ -1,4 +1,4 @@ var searchData= [ - ['out_139',['out',['../classcore_1_1TCPSession.html#abb302bbb3d7e7bc75490c736364f0d4d',1,'core::TCPSession']]] + ['out_141',['out',['../classcore_1_1TCPSession.html#abb302bbb3d7e7bc75490c736364f0d4d',1,'core::TCPSession']]] ]; diff --git a/html/search/variables_4.js b/html/search/variables_4.js index 4a46efd..7fca247 100644 --- a/html/search/variables_4.js +++ b/html/search/variables_4.js @@ -1,4 +1,4 @@ var searchData= [ - ['sessions_140',['sessions',['../classcore_1_1TCPServer.html#aeed1bc55d099667ccda51cd682bfc633',1,'core::TCPServer']]] + ['sessions_142',['sessions',['../classcore_1_1TCPServer.html#aeed1bc55d099667ccda51cd682bfc633',1,'core::TCPServer']]] ]; diff --git a/html/search/variables_5.js b/html/search/variables_5.js index 89a716e..a991fd0 100644 --- a/html/search/variables_5.js +++ b/html/search/variables_5.js @@ -1,4 +1,4 @@ var searchData= [ - ['whitelist_141',['whiteList',['../classcore_1_1TCPServer.html#abad6300b6234ca8b69cef9128755342e',1,'core::TCPServer']]] + ['whitelist_143',['whiteList',['../classcore_1_1TCPServer.html#abad6300b6234ca8b69cef9128755342e',1,'core::TCPServer']]] ]; diff --git a/latex/classcore_1_1Socket.tex b/latex/classcore_1_1Socket.tex index c5be7ff..76a104b 100644 --- a/latex/classcore_1_1Socket.tex +++ b/latex/classcore_1_1Socket.tex @@ -163,7 +163,7 @@ The on\+Connected method is called when the socket is ready to communicate. Writ \end{DoxyParams} -Reimplemented in \mbox{\hyperlink{classcore_1_1TCPServer_a276ccbc8cb9b4380ebd78807b97f0159}{core\+::\+T\+C\+P\+Server}}, \mbox{\hyperlink{classcore_1_1TCPSession_aa87aca65cece02a107e7c288a925271f}{core\+::\+T\+C\+P\+Session}}, and \mbox{\hyperlink{classcore_1_1UDPServerSocket_a41933ca153c854a800e3d047ab18313e}{core\+::\+U\+D\+P\+Server\+Socket}}. +Reimplemented in \mbox{\hyperlink{classcore_1_1TCPServer_a276ccbc8cb9b4380ebd78807b97f0159}{core\+::\+T\+C\+P\+Server}}, and \mbox{\hyperlink{classcore_1_1UDPServerSocket_a41933ca153c854a800e3d047ab18313e}{core\+::\+U\+D\+P\+Server\+Socket}}. \mbox{\Hypertarget{classcore_1_1Socket_a81e5ee3e17834166d97c6e8b7dfe0da0}\label{classcore_1_1Socket_a81e5ee3e17834166d97c6e8b7dfe0da0}} \index{core::Socket@{core::Socket}!onRegister@{onRegister}} diff --git a/latex/classcore_1_1TCPSession.tex b/latex/classcore_1_1TCPSession.tex index 9ccaddd..824ebab 100644 --- a/latex/classcore_1_1TCPSession.tex +++ b/latex/classcore_1_1TCPSession.tex @@ -50,11 +50,13 @@ std\+::stringstream \mbox{\hyperlink{classcore_1_1TCPSession_abb302bbb3d7e7bc754 \doxysubsection*{Protected Member Functions} \begin{DoxyCompactItemize} \item -virtual void \mbox{\hyperlink{classcore_1_1TCPSession_aa87aca65cece02a107e7c288a925271f}{on\+Data\+Received}} (std\+::string data) override -\begin{DoxyCompactList}\small\item\em Called when data is received from the socket. \end{DoxyCompactList}\item \mbox{\Hypertarget{classcore_1_1TCPSession_aed4ed499b978bcea57a8efefe929fc98}\label{classcore_1_1TCPSession_aed4ed499b978bcea57a8efefe929fc98}} virtual void \mbox{\hyperlink{classcore_1_1TCPSession_aed4ed499b978bcea57a8efefe929fc98}{on\+Registered}} () override \begin{DoxyCompactList}\small\item\em Called after the socket has been registered with epoll processing. \end{DoxyCompactList}\item +virtual void \mbox{\hyperlink{classcore_1_1TCPSession_ac2c3ffef9ded12a8867e3d27902b001a}{on\+Data\+Received}} (char $\ast$data, int len) override +\item +virtual void \mbox{\hyperlink{classcore_1_1TCPSession_a0f209620e9f11e70bfde54852b5c5460}{on\+Line\+Received}} (std\+::string line) +\item virtual void \mbox{\hyperlink{classcore_1_1TCPSession_a8719952f7bb00bf7239ec40aa2868626}{on\+Connected}} () \item virtual void \mbox{\hyperlink{classcore_1_1TCPSession_ae90dc64e2d3c4b3239117923145edb3f}{protocol}} (std\+::string data) @@ -75,28 +77,23 @@ virtual void \mbox{\hyperlink{classcore_1_1TCPSession_ae90dc64e2d3c4b32391179231 \doxysubsubsection{\texorpdfstring{onConnected()}{onConnected()}} {\footnotesize\ttfamily void core\+::\+T\+C\+P\+Session\+::on\+Connected (\begin{DoxyParamCaption}{ }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [protected]}, {\ttfamily [virtual]}} -This method is called from within the protocol method when protocol is called on the initial connection where the data is an empty string. Use this method to deliver a message to the connection upon connection. \mbox{\Hypertarget{classcore_1_1TCPSession_aa87aca65cece02a107e7c288a925271f}\label{classcore_1_1TCPSession_aa87aca65cece02a107e7c288a925271f}} +This method is called from within the protocol method when protocol is called on the initial connection where the data is an empty string. Use this method to deliver a message to the connection upon connection. \mbox{\Hypertarget{classcore_1_1TCPSession_ac2c3ffef9ded12a8867e3d27902b001a}\label{classcore_1_1TCPSession_ac2c3ffef9ded12a8867e3d27902b001a}} \index{core::TCPSession@{core::TCPSession}!onDataReceived@{onDataReceived}} \index{onDataReceived@{onDataReceived}!core::TCPSession@{core::TCPSession}} \doxysubsubsection{\texorpdfstring{onDataReceived()}{onDataReceived()}} -{\footnotesize\ttfamily void core\+::\+T\+C\+P\+Session\+::on\+Data\+Received (\begin{DoxyParamCaption}\item[{std\+::string}]{data }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [override]}, {\ttfamily [protected]}, {\ttfamily [virtual]}} +{\footnotesize\ttfamily void core\+::\+T\+C\+P\+Session\+::on\+Data\+Received (\begin{DoxyParamCaption}\item[{char $\ast$}]{data, }\item[{int}]{len }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [override]}, {\ttfamily [protected]}, {\ttfamily [virtual]}} +Override this method to receive data directly from the socket as data is received. If you need data split by line termination characters then override the on\+Line\+Received method instead. +Reimplemented from \mbox{\hyperlink{classcore_1_1Socket}{core\+::\+Socket}}. -Called when data is received from the socket. +\mbox{\Hypertarget{classcore_1_1TCPSession_a0f209620e9f11e70bfde54852b5c5460}\label{classcore_1_1TCPSession_a0f209620e9f11e70bfde54852b5c5460}} +\index{core::TCPSession@{core::TCPSession}!onLineReceived@{onLineReceived}} +\index{onLineReceived@{onLineReceived}!core::TCPSession@{core::TCPSession}} +\doxysubsubsection{\texorpdfstring{onLineReceived()}{onLineReceived()}} +{\footnotesize\ttfamily void core\+::\+T\+C\+P\+Session\+::on\+Line\+Received (\begin{DoxyParamCaption}\item[{std\+::string}]{line }\end{DoxyParamCaption})\hspace{0.3cm}{\ttfamily [protected]}, {\ttfamily [virtual]}} -The on\+Connected method is called when the socket is ready to communicate. Writing to the socket can begin on this call to initiate a contact with the remote device. The on\+Data\+Received method is called when the socket has received an event from epoll and there is data ready to be read from the socket. The default handler will pull the data and put it into the streambuf for the socket. E\+P\+O\+L\+L\+IN - - -\begin{DoxyParams}{Parameters} -{\em data} & the data that has been received from the socket. \\ -\hline -\end{DoxyParams} - - -Reimplemented from \mbox{\hyperlink{classcore_1_1Socket_ac8d6a2c54696eb6fc2024cf6bcf6b4e5}{core\+::\+Socket}}. - -\mbox{\Hypertarget{classcore_1_1TCPSession_a50037cbfc515650e04054e5481785981}\label{classcore_1_1TCPSession_a50037cbfc515650e04054e5481785981}} +Override the on\+Line\+Received method to receive a string of characters that represents a single line of data terminated by a LF or C\+R\+LF. If on\+Data\+Received was overriden this method will not be called unless the on\+Data\+Received calls this method explicitly using the class and member name. \mbox{\Hypertarget{classcore_1_1TCPSession_a50037cbfc515650e04054e5481785981}\label{classcore_1_1TCPSession_a50037cbfc515650e04054e5481785981}} \index{core::TCPSession@{core::TCPSession}!output@{output}} \index{output@{output}!core::TCPSession@{core::TCPSession}} \doxysubsubsection{\texorpdfstring{output()}{output()}}