From cfa70c58632a367d40a6220c0c265a858bc1ce62 Mon Sep 17 00:00:00 2001 From: Brad Arant Date: Sat, 11 Mar 2023 21:55:33 -0800 Subject: [PATCH] Fixed multithread sync issue and duplicate thread on termination. --- EPoll.cpp | 33 ----- EPoll.h | 23 +--- Socket.cpp | 70 +++++++--- Socket.h | 7 + Subscription.cpp | 2 +- Thread.cpp | 2 +- UDPServerSocket.cpp | 2 +- html/EPoll_8h_source.html | 71 ++++------ html/Socket_8h_source.html | 125 +++++++++--------- html/classcore_1_1ConsoleServer-members.html | 6 +- html/classcore_1_1ConsoleServer.html | 6 + html/classcore_1_1ConsoleSession-members.html | 2 + html/classcore_1_1ConsoleSession.html | 6 + html/classcore_1_1EPoll-members.html | 5 +- html/classcore_1_1EPoll.html | 58 -------- html/classcore_1_1Socket-members.html | 6 +- html/classcore_1_1Socket.html | 6 + html/classcore_1_1TCPServer-members.html | 6 +- html/classcore_1_1TCPServer.html | 6 + html/classcore_1_1TCPSession-members.html | 6 +- html/classcore_1_1TCPSession.html | 6 + html/classcore_1_1TCPSession2-members.html | 6 +- html/classcore_1_1TCPSession2.html | 6 + html/classcore_1_1TCPSocket-members.html | 6 +- html/classcore_1_1TCPSocket.html | 6 + html/classcore_1_1TLSServer-members.html | 2 + html/classcore_1_1TLSServer.html | 6 + html/classcore_1_1TLSSession-members.html | 2 + html/classcore_1_1TLSSession.html | 6 + .../classcore_1_1TerminalSession-members.html | 2 + html/classcore_1_1TerminalSession.html | 6 + .../classcore_1_1UDPServerSocket-members.html | 6 +- html/classcore_1_1UDPServerSocket.html | 6 + html/classcore_1_1UDPSocket-members.html | 2 + html/classcore_1_1UDPSocket.html | 6 + html/functions.html | 6 - html/functions_func.html | 10 -- html/menudata.js | 1 - html/search/all_9.js | 3 +- html/search/all_a.js | 32 ++--- html/search/all_b.js | 22 +-- html/search/all_c.js | 7 +- 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 | 10 +- html/search/classes_5.js | 20 +-- html/search/classes_6.js | 4 +- html/search/functions_0.js | 2 +- html/search/functions_1.js | 6 +- html/search/functions_2.js | 4 +- html/search/functions_3.js | 16 +-- html/search/functions_4.js | 2 +- html/search/functions_5.js | 18 +-- html/search/functions_6.js | 6 +- html/search/functions_7.js | 5 +- html/search/functions_8.js | 20 +-- html/search/functions_9.js | 6 +- html/search/functions_a.js | 2 +- html/search/functions_b.js | 5 +- html/search/searchdata.js | 2 +- 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 | 4 +- latex/classcore_1_1EPoll.tex | 41 +----- latex/classcore_1_1Socket.tex | 6 + 72 files changed, 395 insertions(+), 427 deletions(-) diff --git a/EPoll.cpp b/EPoll.cpp index 9a6420a..15c57b9 100644 --- a/EPoll.cpp +++ b/EPoll.cpp @@ -67,16 +67,6 @@ namespace core { return terminateThreads; } - bool EPoll::registerSocket(Socket *socket) { - enableSocket(socket); - return true; - } - - bool EPoll::unregisterSocket(Socket *socket) { - disableSocket(socket); - return true; - } - int EPoll::getDescriptor() { return epfd; } @@ -91,27 +81,4 @@ namespace core { return 1; } - void EPoll::enableSocket(Socket *socket) { - struct epoll_event event; - event.data.ptr = socket; - event.events = EPOLLIN | EPOLLONESHOT | EPOLLRDHUP | EPOLLET; - epoll_ctl(epfd, EPOLL_CTL_ADD, socket->getDescriptor(), &event); -// coreutils::Log(coreutils::LOG_DEBUG_4) << "BMAXenable: " << socket->getDescriptor(); - } - - void EPoll::disableSocket(Socket *socket) { - epoll_ctl(epfd, EPOLL_CTL_DEL, socket->getDescriptor(), NULL); -// coreutils::Log(coreutils::LOG_DEBUG_4) << "BMAXdisable: " << socket->getDescriptor(); - } - - void EPoll::resetSocket(Socket *socket) { - struct epoll_event event; - event.data.ptr = socket; - event.events = EPOLLIN | EPOLLONESHOT | EPOLLRDHUP | EPOLLET; - if(socket->needsToWrite() && !socket->shutDown) - event.events |= EPOLLWRNORM; - epoll_ctl(epfd, EPOLL_CTL_MOD, socket->getDescriptor(), &event); -// coreutils::Log(coreutils::LOG_DEBUG_4) << "BMAXreset: " << socket->getDescriptor(); - } - } diff --git a/EPoll.h b/EPoll.h index 3db2031..d1440e3 100644 --- a/EPoll.h +++ b/EPoll.h @@ -69,24 +69,7 @@ namespace core { /// bool isStopping(); ///< Returns a true if the stop command has been requested. - - /// - /// Use registerSocket to add a new socket to the ePoll event watch list. This enables - /// a new BMASocket object to receive events when data is received as well as to write - /// data output to the socket. - /// - /// @param socket a pointer to a BMASocket object. - /// @return a booelean that indicates the socket was registered or not. - /// - - bool registerSocket(Socket *socket); ///< Register a BMASocket for monitoring by BMAEPoll. - - /// - /// Use this method to remove a socket from receiving events from the epoll system. - /// - - bool unregisterSocket(Socket *socket); ///< Unregister a BMASocket from monitoring by BMAEPoll. - + /// /// Use this method to obtain the current descriptor socket number for the epoll function call. /// @@ -114,16 +97,12 @@ namespace core { int processCommand(coreutils::ZString &request, TCPSession &session) override; /// threads; volatile bool terminateThreads; - void enableSocket(Socket *socket); - void disableSocket(Socket *socket); }; diff --git a/Socket.cpp b/Socket.cpp index 02dcf9d..f6ecab7 100644 --- a/Socket.cpp +++ b/Socket.cpp @@ -18,7 +18,7 @@ namespace core Socket::~Socket() { shutDown = true; onUnregister(); - ePoll.unregisterSocket(this); + disableSocket(); coreutils::Log(coreutils::LOG_DEBUG_4) << "Free on socket " << descriptor; free(buffer); if(descriptor == -1) @@ -39,7 +39,7 @@ namespace core throw coreutils::Exception("Descriptor out of range", __FILE__, __LINE__); this->descriptor = descriptor; onRegister(); - ePoll.registerSocket(this); + enableSocket(); onRegistered(); } @@ -68,29 +68,39 @@ namespace core void Socket::onUnregistered() {} bool Socket::eventReceived(struct epoll_event event, long long eventId) { -// lock.lock(); +// coreutils::Log(coreutils::LOG_DEBUG_1) << "Event process beginning for socket " << getDescriptor(); + if(inHandler) + // coreutils::Log(coreutils::LOG_DEBUG_2) << "inHandler was already true."; inHandler = true; if(event.events & EPOLLRDHUP) { +// coreutils::Log(coreutils::LOG_DEBUG_2) << "EPOLLRDHUP"; readHangup = true; shutdown("hangup received"); } if(event.events & EPOLLIN) { +// coreutils::Log(coreutils::LOG_DEBUG_2) << "EPOLLIN"; coreutils::ZString zbuffer(buffer, length); + lock.lock(); receiveData(zbuffer); + if(!shutDown) { + inHandler = false; + lock.unlock(); + resetSocket(); + } } if(event.events & EPOLLWRNORM) { - writeSocket(); +// coreutils::Log(coreutils::LOG_DEBUG_2) << "EPOLLWRNORM"; + writeSocket(); + inHandler = false; + resetSocket(); } - if(event.events & EPOLLHUP) { - shutdown(); - } - inHandler = false; -// lock.unlock(); + inHandler = false; +// coreutils::Log(coreutils::LOG_DEBUG_1) << "Event process ending for socket " << getDescriptor(); return !shutDown; } - + void Socket::onDataReceived(std::string data) - { + { throw coreutils::Exception("Need to override onDataReceived.", __FILE__, __LINE__, -1); } @@ -107,7 +117,7 @@ namespace core int error = -1; if((len = ::read(getDescriptor(), buffer.getData(), buffer.getLength())) >= 0) { coreutils::ZString zbuffer(buffer.getData(), len); - coreutils::Log(coreutils::LOG_DEBUG_1) << zbuffer; +// coreutils::Log(coreutils::LOG_DEBUG_1) << zbuffer; onDataReceived(zbuffer); } else @@ -135,21 +145,23 @@ namespace core } void Socket::writeSocket() { + outlock.lock(); +// coreutils::Log(coreutils::LOG_DEBUG_3) << "writing data to socket " << getDescriptor(); if(fifo.size() > 0) { - outlock.lock(); - if(!shutDown) - int rc = ::write(descriptor, fifo.front().c_str(), fifo.front().length()); + if(!shutDown) + int rc = ::write(descriptor, fifo.front().c_str(), fifo.front().length()); fifo.pop(); - outlock.unlock(); } + outlock.unlock(); } int Socket::write(std::string data) { outlock.lock(); fifo.emplace(data); outlock.unlock(); - if(!inHandler) { - ePoll.resetSocket(this); + if(lock.try_lock()) { + resetSocket(); + lock.unlock(); } return 1; } @@ -170,4 +182,26 @@ namespace core reset = false; } + void Socket::enableSocket() { + struct epoll_event event; + event.data.ptr = this; + event.events = EPOLLIN | EPOLLRDHUP | EPOLLONESHOT | EPOLLET; + epoll_ctl(ePoll.getDescriptor(), EPOLL_CTL_ADD, getDescriptor(), &event); + } + + void Socket::disableSocket() { + epoll_ctl(ePoll.getDescriptor(), EPOLL_CTL_DEL, getDescriptor(), NULL); + } + + void Socket::resetSocket() { + struct epoll_event event; + event.data.ptr = this; + event.events = EPOLLIN | EPOLLRDHUP | EPOLLONESHOT | EPOLLET; + if(fifo.size() > 0) + event.events |= EPOLLWRNORM; + if(!shutDown) + epoll_ctl(ePoll.getDescriptor(), EPOLL_CTL_MOD, getDescriptor(), &event); + } + + } diff --git a/Socket.h b/Socket.h index bf70108..fbd6395 100644 --- a/Socket.h +++ b/Socket.h @@ -117,6 +117,9 @@ namespace core { volatile bool shutDown = false; + void enableSocket(); + void disableSocket(); + protected: EPoll &ePoll; // The EPoll control object. @@ -189,6 +192,10 @@ namespace core { std::queue fifo; + void resetSocket(); + + std::mutex lock; + }; } diff --git a/Subscription.cpp b/Subscription.cpp index 006a37c..65152ad 100644 --- a/Subscription.cpp +++ b/Subscription.cpp @@ -51,7 +51,7 @@ namespace core int Subscription::process(coreutils::ZString &request, std::stringstream &out, TCPSession &session) { - std::cout << "(" << handler << ")" << std::endl; +// std::cout << "(" << handler << ")" << std::endl; if (handler) handler->process(request, out, session); else diff --git a/Thread.cpp b/Thread.cpp index cea1074..2a7628b 100644 --- a/Thread.cpp +++ b/Thread.cpp @@ -62,7 +62,7 @@ namespace core { ++count; if(((Socket *)events[ix].data.ptr)->eventReceived(events[ix], ++ePoll.eventId)) { // coreutils::Log(coreutils::LOG_DEBUG_4) << "return true"; - ePoll.resetSocket((Socket *)events[ix].data.ptr); +// ePoll.resetSocket((Socket *)events[ix].data.ptr); } else { ((Socket *)events[ix].data.ptr)->shutDown = true; // coreutils::Log(coreutils::LOG_DEBUG_4) << "return false"; diff --git a/UDPServerSocket.cpp b/UDPServerSocket.cpp index efc9b47..9458698 100644 --- a/UDPServerSocket.cpp +++ b/UDPServerSocket.cpp @@ -24,7 +24,7 @@ namespace core { listen(getDescriptor(), 10); - ePoll.registerSocket(this); +// ePoll.registerSocket(this); } diff --git a/html/EPoll_8h_source.html b/html/EPoll_8h_source.html index 5f25571..e75c626 100644 --- a/html/EPoll_8h_source.html +++ b/html/EPoll_8h_source.html @@ -97,56 +97,43 @@ $(function() {
65 
70 
71  bool isStopping();
-
72 
-
81 
-
82  bool registerSocket(Socket *socket);
-
83 
-
87 
-
88  bool unregisterSocket(Socket *socket);
-
89 
-
93 
-
94  int getDescriptor();
-
95 
-
99 
-
100  int maxSockets;
-
101 
-
105 
-
106  void eventReceived(struct epoll_event event);
-
107 
-
114 
-
115  int processCommand(coreutils::ZString &request, TCPSession &session) override;
-
116 
-
117  void resetSocket(Socket *socket);
-
118 
-
119  private:
-
120 
-
121  int epfd;
-
122  int numberOfThreads;
-
123  std::vector<Thread> threads;
-
124  volatile bool terminateThreads;
-
125  void enableSocket(Socket *socket);
-
126  void disableSocket(Socket *socket);
-
127 
-
128  };
-
129 
-
130 }
-
131 
-
132 #endif
-
133 
+
72 
+
76 
+
77  int getDescriptor();
+
78 
+
82 
+
83  int maxSockets;
+
84 
+
88 
+
89  void eventReceived(struct epoll_event event);
+
90 
+
97 
+
98  int processCommand(coreutils::ZString &request, TCPSession &session) override;
+
99 
+
100  private:
+
101 
+
102  int epfd;
+
103  int numberOfThreads;
+
104  std::vector<Thread> threads;
+
105  volatile bool terminateThreads;
+
106 
+
107  };
+
108 
+
109 }
+
110 
+
111 #endif
+
112 
core::Command
Definition: Command.h:22
core::EPoll
Definition: EPoll.h:31
core::EPoll::stop
bool stop()
Stop and shut down the BMAEPoll processing.
Definition: EPoll.cpp:46
-
core::EPoll::getDescriptor
int getDescriptor()
Return the descriptor for the ePoll socket.
Definition: EPoll.cpp:80
-
core::EPoll::processCommand
int processCommand(coreutils::ZString &request, TCPSession &session) override
Output the threads array to the console.
Definition: EPoll.cpp:84
+
core::EPoll::getDescriptor
int getDescriptor()
Return the descriptor for the ePoll socket.
Definition: EPoll.cpp:70
+
core::EPoll::processCommand
int processCommand(coreutils::ZString &request, TCPSession &session) override
Output the threads array to the console.
Definition: EPoll.cpp:74
core::EPoll::EPoll
EPoll()
Definition: EPoll.cpp:9
core::EPoll::isStopping
bool isStopping()
Returns a true if the stop command has been requested.
Definition: EPoll.cpp:66
core::EPoll::eventReceived
void eventReceived(struct epoll_event event)
Dispatch event to appropriate socket.
-
core::EPoll::registerSocket
bool registerSocket(Socket *socket)
Register a BMASocket for monitoring by BMAEPoll.
Definition: EPoll.cpp:70
-
core::EPoll::unregisterSocket
bool unregisterSocket(Socket *socket)
Unregister a BMASocket from monitoring by BMAEPoll.
Definition: EPoll.cpp:75
core::EPoll::~EPoll
~EPoll()
Definition: EPoll.cpp:18
core::EPoll::start
bool start(int numberOfThreads, int maxSockets)
Start the BMAEPoll processing.
Definition: EPoll.cpp:20
-
core::EPoll::maxSockets
int maxSockets
The maximum number of socket allowed.
Definition: EPoll.h:100
-
core::Socket
Definition: Socket.h:34
+
core::EPoll::maxSockets
int maxSockets
The maximum number of socket allowed.
Definition: EPoll.h:83
core::TCPSession
Definition: TCPSession.h:26
diff --git a/html/Socket_8h_source.html b/html/Socket_8h_source.html index 5ccd101..1d5babe 100644 --- a/html/Socket_8h_source.html +++ b/html/Socket_8h_source.html @@ -119,76 +119,83 @@ $(function() {
117 
118  volatile bool shutDown = false;
119 
-
120  protected:
-
121 
-
122  EPoll &ePoll; // The EPoll control object.
-
123 
-
124  void setBufferSize(int length);
-
125 
-
126  int getBufferSize();
-
127 
-
133 
-
134 // virtual void onConnected(); ///< Called when socket is open and ready to communicate.
-
135 
-
139 
-
140 // virtual void onDisconnected(); ///< Called when socket is closing and no longer ready to communicate.
-
141 
-
149 
-
150  virtual void onDataReceived(std::string data);
-
151 
-
155 
-
156  virtual void onDataReceived(coreutils::ZString &data);
-
157 
-
162 
-
163  virtual void receiveData(coreutils::ZString &buffer);
-
164 
-
165  private:
-
166 
-
167  std::string text;
-
168  int descriptor = -1;
-
169  std::mutex outlock;
-
170  bool readHangup = false;
-
171  volatile bool inHandler = false;
-
172 
-
173  //-------------------------------------------------------------------------------------
-
174  // the writeSocket is called when epoll has received a write request for a socket.
-
175  // Writing data to this socket is queued in the streambuf and permission is requested
-
176  // to write to the socket. This routine handles the writing of the streambuf data
-
177  // buffer to the socket.
-
178  //-------------------------------------------------------------------------------------
-
179 
-
180  void writeSocket();
-
181 
-
182  // int_type underflow();
-
183 // int_type uflow();
-
184 // int_type pbackfail(int_type ch);
-
185 // streamsize showmanyc();
-
186 
-
187  char *buffer; // This is a pointer to the managed buffer space.
-
188  int length; // This is the length of the buffer.
+
120  void enableSocket();
+
121  void disableSocket();
+
122 
+
123  protected:
+
124 
+
125  EPoll &ePoll; // The EPoll control object.
+
126 
+
127  void setBufferSize(int length);
+
128 
+
129  int getBufferSize();
+
130 
+
136 
+
137 // virtual void onConnected(); ///< Called when socket is open and ready to communicate.
+
138 
+
142 
+
143 // virtual void onDisconnected(); ///< Called when socket is closing and no longer ready to communicate.
+
144 
+
152 
+
153  virtual void onDataReceived(std::string data);
+
154 
+
158 
+
159  virtual void onDataReceived(coreutils::ZString &data);
+
160 
+
165 
+
166  virtual void receiveData(coreutils::ZString &buffer);
+
167 
+
168  private:
+
169 
+
170  std::string text;
+
171  int descriptor = -1;
+
172  std::mutex outlock;
+
173  bool readHangup = false;
+
174  volatile bool inHandler = false;
+
175 
+
176  //-------------------------------------------------------------------------------------
+
177  // the writeSocket is called when epoll has received a write request for a socket.
+
178  // Writing data to this socket is queued in the streambuf and permission is requested
+
179  // to write to the socket. This routine handles the writing of the streambuf data
+
180  // buffer to the socket.
+
181  //-------------------------------------------------------------------------------------
+
182 
+
183  void writeSocket();
+
184 
+
185  // int_type underflow();
+
186 // int_type uflow();
+
187 // int_type pbackfail(int_type ch);
+
188 // streamsize showmanyc();
189 
-
190  std::queue<std::string> fifo;
-
191 
-
192  };
-
193 
-
194 }
-
195 
-
196 #endif
-
197 
+
190  char *buffer; // This is a pointer to the managed buffer space.
+
191  int length; // This is the length of the buffer.
+
192 
+
193  std::queue<std::string> fifo;
+
194 
+
195  void resetSocket();
+
196 
+
197  std::mutex lock;
+
198 
+
199  };
+
200 
+
201 }
+
202 
+
203 #endif
+
204 
core::EPoll
Definition: EPoll.h:31
core::Socket
Definition: Socket.h:34
core::Socket::getDescriptor
int getDescriptor()
Get the descriptor for the socket.
Definition: Socket.cpp:46
-
core::Socket::write
int write(std::string data)
Definition: Socket.cpp:147
+
core::Socket::write
int write(std::string data)
Definition: Socket.cpp:158
core::Socket::eventReceived
bool eventReceived(struct epoll_event event, long long eventId)
Parse epoll event and call specified callbacks.
Definition: Socket.cpp:70
core::Socket::onRegistered
virtual void onRegistered()
Called after the socket has been registered with epoll processing.
Definition: Socket.cpp:64
-
core::Socket::receiveData
virtual void receiveData(coreutils::ZString &buffer)
Definition: Socket.cpp:102
+
core::Socket::receiveData
virtual void receiveData(coreutils::ZString &buffer)
Definition: Socket.cpp:112
core::Socket::Socket
Socket(EPoll &ePoll, std::string text="")
Definition: Socket.cpp:12
core::Socket::onRegister
virtual void onRegister()
Called before the socket has registered with the epoll processing.
Definition: Socket.cpp:62
core::Socket::~Socket
virtual ~Socket()
Definition: Socket.cpp:18
core::Socket::setDescriptor
void setDescriptor(int descriptor)
Set the descriptor for the socket.
Definition: Socket.cpp:30
-
core::Socket::onDataReceived
virtual void onDataReceived(std::string data)
Called when data is received from the socket.
Definition: Socket.cpp:92
+
core::Socket::onDataReceived
virtual void onDataReceived(std::string data)
Called when data is received from the socket.
Definition: Socket.cpp:102
core::Socket::onUnregistered
virtual void onUnregistered()
Called when the socket has finished unregistering for the epoll processing.
Definition: Socket.cpp:68
-
core::Socket::shutdown
void shutdown(std::string text="unknown")
Definition: Socket.cpp:167
+
core::Socket::shutdown
void shutdown(std::string text="unknown")
Definition: Socket.cpp:179
diff --git a/html/classcore_1_1ConsoleServer-members.html b/html/classcore_1_1ConsoleServer-members.html index af95ebe..7af721a 100644 --- a/html/classcore_1_1ConsoleServer-members.html +++ b/html/classcore_1_1ConsoleServer-members.html @@ -76,6 +76,8 @@ $(function() { commandscore::TCPServer connect(IPAddress &address) (defined in core::TCPSocket)core::TCPSocket ConsoleServer(EPoll &ePoll, IPAddress address) (defined in core::ConsoleServer)core::ConsoleServer + disableSocket() (defined in core::Socket)core::Socket + enableSocket() (defined in core::Socket)core::Socket ePoll (defined in core::Socket)core::Socketprotected eventReceived(struct epoll_event event, long long eventId)core::Socket getBufferSize() (defined in core::Socket)core::Socketprotected @@ -103,8 +105,8 @@ $(function() { sessionscore::TCPServer 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::Socket + shutDown (defined in core::Socket)core::Socket + shutdown(std::string text="unknown")core::Socket Socket(EPoll &ePoll, std::string text="")core::Socket subscriptionscore::TCPServer TCPServer(EPoll &ePoll, IPAddress address, std::string delimiter=" ", int depth=10, std::string text="")core::TCPServer diff --git a/html/classcore_1_1ConsoleServer.html b/html/classcore_1_1ConsoleServer.html index 328968e..6567f9d 100644 --- a/html/classcore_1_1ConsoleServer.html +++ b/html/classcore_1_1ConsoleServer.html @@ -190,6 +190,12 @@ virtual void onUnregister< bool needsToWrite ()   + +void enableSocket () +  + +void disableSocket () +  diff --git a/html/classcore_1_1ConsoleSession-members.html b/html/classcore_1_1ConsoleSession-members.html index c5431c3..a78300d 100644 --- a/html/classcore_1_1ConsoleSession-members.html +++ b/html/classcore_1_1ConsoleSession-members.html @@ -78,6 +78,8 @@ $(function() { + + diff --git a/html/classcore_1_1ConsoleSession.html b/html/classcore_1_1ConsoleSession.html index c7b5d4c..90bd282 100644 --- a/html/classcore_1_1ConsoleSession.html +++ b/html/classcore_1_1ConsoleSession.html @@ -213,6 +213,12 @@ virtual void  + + + +

Additional Inherited Members

compareAlias(void *alias) (defined in core::TCPSession)core::TCPSessionvirtual
connect(IPAddress &address) (defined in core::TCPSocket)core::TCPSocket
ConsoleSession(EPoll &ePoll, TCPServer &server) (defined in core::ConsoleSession)core::ConsoleSession
disableSocket() (defined in core::Socket)core::Socket
enableSocket() (defined in core::Socket)core::Socket
ePoll (defined in core::Socket)core::Socketprotected
eventReceived(struct epoll_event event, long long eventId)core::Socket
getBufferSize() (defined in core::Socket)core::Socketprotected
onUnregister<
bool needsToWrite ()
 
+void enableSocket ()
 
+void disableSocket ()
 
diff --git a/html/classcore_1_1EPoll-members.html b/html/classcore_1_1EPoll-members.html index e57383f..b7069e4 100644 --- a/html/classcore_1_1EPoll-members.html +++ b/html/classcore_1_1EPoll-members.html @@ -80,12 +80,9 @@ $(function() { - - - - +

Protected Member Functions

maxSocketscore::EPoll
output(std::stringstream &out)core::Commandvirtual
processCommand(coreutils::ZString &request, TCPSession &session) overridecore::EPollvirtual
registerSocket(Socket *socket)core::EPoll
resetSocket(Socket *socket) (defined in core::EPoll)core::EPoll
start(int numberOfThreads, int maxSockets)core::EPoll
stop()core::EPoll
unregisterSocket(Socket *socket)core::EPoll
~EPoll()core::EPoll
~EPoll()core::EPoll
diff --git a/html/classcore_1_1EPoll.html b/html/classcore_1_1EPoll.html index 874b17a..eacbe7e 100644 --- a/html/classcore_1_1EPoll.html +++ b/html/classcore_1_1EPoll.html @@ -109,12 +109,6 @@ Public Member Functions bool isStopping ()  Returns a true if the stop command has been requested. More...
  -bool registerSocket (Socket *socket) - Register a BMASocket for monitoring by BMAEPoll. More...
-  -bool unregisterSocket (Socket *socket) - Unregister a BMASocket from monitoring by BMAEPoll. More...
-  int getDescriptor ()  Return the descriptor for the ePoll socket. More...
  @@ -124,9 +118,6 @@ Public Member Functions int processCommand (coreutils::ZString &request, TCPSession &session) override  Output the threads array to the console. More...
  - -void resetSocket (Socket *socket) -  - Public Member Functions inherited from core::Command virtual void output (std::stringstream &out)   @@ -291,34 +282,6 @@ volatile long long eventId

Reimplemented from core::Command.

- - - -

◆ registerSocket()

- -
-
- - - - - - - - -
bool core::EPoll::registerSocket (Socket * socket)
-
- -

Register a BMASocket for monitoring by BMAEPoll.

-

Use registerSocket to add a new socket to the ePoll event watch list. This enables a new BMASocket object to receive events when data is received as well as to write data output to the socket.

-
Parameters
- - -
socketa pointer to a BMASocket object.
-
-
-
Returns
a booelean that indicates the socket was registered or not.
-
@@ -378,27 +341,6 @@ volatile long long eventId

Use the stop() method to initiate the shutdown process for the epoll socket management.

A complete shutdown of all managed sockets will be initiated by this method call.

- - - -

◆ unregisterSocket()

- -
-
- - - - - - - - -
bool core::EPoll::unregisterSocket (Socket * socket)
-
- -

Unregister a BMASocket from monitoring by BMAEPoll.

-

Use this method to remove a socket from receiving events from the epoll system.

-

Member Data Documentation

diff --git a/html/classcore_1_1Socket-members.html b/html/classcore_1_1Socket-members.html index b64d45b..33a2674 100644 --- a/html/classcore_1_1Socket-members.html +++ b/html/classcore_1_1Socket-members.html @@ -72,6 +72,8 @@ $(function() {

This is the complete list of members for core::Socket, including all inherited members.

+ + @@ -88,8 +90,8 @@ $(function() { - - + + diff --git a/html/classcore_1_1Socket.html b/html/classcore_1_1Socket.html index 628caad..907608c 100644 --- a/html/classcore_1_1Socket.html +++ b/html/classcore_1_1Socket.html @@ -151,6 +151,12 @@ virtual void  + + + +
disableSocket() (defined in core::Socket)core::Socket
enableSocket() (defined in core::Socket)core::Socket
ePoll (defined in core::Socket)core::Socketprotected
eventReceived(struct epoll_event event, long long eventId)core::Socket
getBufferSize() (defined in core::Socket)core::Socketprotected
reset (defined in core::Socket)core::Socket
setBufferSize(int length) (defined in core::Socket)core::Socketprotected
setDescriptor(int descriptor)core::Socket
shutDown (defined in core::Socket)core::Socket
shutdown(std::string text="unknown")core::Socket
shutdown(std::string text="unknown")core::Socket
shutDown (defined in core::Socket)core::Socket
Socket(EPoll &ePoll, std::string text="")core::Socket
write(std::string data)core::Socket
write(char *buffer, int length) (defined in core::Socket)core::Socket
onUnregister<
bool needsToWrite ()
 
+void enableSocket ()
 
+void disableSocket ()
 
diff --git a/html/classcore_1_1TCPServer-members.html b/html/classcore_1_1TCPServer-members.html index 40c7afa..896d8ec 100644 --- a/html/classcore_1_1TCPServer-members.html +++ b/html/classcore_1_1TCPServer-members.html @@ -75,6 +75,8 @@ $(function() { + + @@ -101,8 +103,8 @@ $(function() { - - + + diff --git a/html/classcore_1_1TCPServer.html b/html/classcore_1_1TCPServer.html index f1d2a59..c947870 100644 --- a/html/classcore_1_1TCPServer.html +++ b/html/classcore_1_1TCPServer.html @@ -185,6 +185,12 @@ virtual void  + + + +

Public Attributes

blackListcore::TCPServer
commandscore::TCPServer
connect(IPAddress &address) (defined in core::TCPSocket)core::TCPSocket
disableSocket() (defined in core::Socket)core::Socket
enableSocket() (defined in core::Socket)core::Socket
ePoll (defined in core::Socket)core::Socketprotected
eventReceived(struct epoll_event event, long long eventId)core::Socket
getBufferSize() (defined in core::Socket)core::Socketprotected
sessionscore::TCPServer
setBufferSize(int length) (defined in core::Socket)core::Socketprotected
setDescriptor(int descriptor)core::Socket
shutDown (defined in core::Socket)core::Socket
shutdown(std::string text="unknown")core::Socket
shutdown(std::string text="unknown")core::Socket
shutDown (defined in core::Socket)core::Socket
Socket(EPoll &ePoll, std::string text="")core::Socket
subscriptionscore::TCPServer
TCPServer(EPoll &ePoll, IPAddress address, std::string delimiter=" ", int depth=10, std::string text="")core::TCPServer
onUnregister<
bool needsToWrite ()
 
+void enableSocket ()
 
+void disableSocket ()
 
diff --git a/html/classcore_1_1TCPSession-members.html b/html/classcore_1_1TCPSession-members.html index e9448ab..b22cd21 100644 --- a/html/classcore_1_1TCPSession-members.html +++ b/html/classcore_1_1TCPSession-members.html @@ -75,6 +75,8 @@ $(function() { + + @@ -102,8 +104,8 @@ $(function() { - - + + diff --git a/html/classcore_1_1TCPSession.html b/html/classcore_1_1TCPSession.html index b31e596..6c15e5e 100644 --- a/html/classcore_1_1TCPSession.html +++ b/html/classcore_1_1TCPSession.html @@ -172,6 +172,12 @@ virtual void  + + + +

Public Attributes

aliascore::TCPSession
compareAlias(void *alias) (defined in core::TCPSession)core::TCPSessionvirtual
connect(IPAddress &address) (defined in core::TCPSocket)core::TCPSocket
disableSocket() (defined in core::Socket)core::Socket
enableSocket() (defined in core::Socket)core::Socket
ePoll (defined in core::Socket)core::Socketprotected
eventReceived(struct epoll_event event, long long eventId)core::Socket
getBufferSize() (defined in core::Socket)core::Socketprotected
setBlockSize(int size=0)core::TCPSessionprotected
setBufferSize(int length) (defined in core::Socket)core::Socketprotected
setDescriptor(int descriptor)core::Socket
shutDown (defined in core::Socket)core::Socket
shutdown(std::string text="unknown")core::Socket
shutdown(std::string text="unknown")core::Socket
shutDown (defined in core::Socket)core::Socket
Socket(EPoll &ePoll, std::string text="")core::Socket
TCPSession(EPoll &ePoll, TCPServer &server, std::string text="") (defined in core::TCPSession)core::TCPSession
TCPSocket(EPoll &ePoll) (defined in core::TCPSocket)core::TCPSocket
onUnregister<
bool needsToWrite ()
 
+void enableSocket ()
 
+void disableSocket ()
 
diff --git a/html/classcore_1_1TCPSession2-members.html b/html/classcore_1_1TCPSession2-members.html index aafdbb4..7349d40 100644 --- a/html/classcore_1_1TCPSession2-members.html +++ b/html/classcore_1_1TCPSession2-members.html @@ -73,6 +73,8 @@ $(function() {

This is the complete list of members for core::TCPSession2, including all inherited members.

Public Attributes

+ + @@ -98,8 +100,8 @@ $(function() { - - + + diff --git a/html/classcore_1_1TCPSession2.html b/html/classcore_1_1TCPSession2.html index 2bf5875..7d1398a 100644 --- a/html/classcore_1_1TCPSession2.html +++ b/html/classcore_1_1TCPSession2.html @@ -159,6 +159,12 @@ virtual void  + + + +
connect(IPAddress &address) (defined in core::TCPSocket)core::TCPSocket
disableSocket() (defined in core::Socket)core::Socket
enableSocket() (defined in core::Socket)core::Socket
ePoll (defined in core::Socket)core::Socketprotected
eventReceived(struct epoll_event event, long long eventId)core::Socket
getBufferSize() (defined in core::Socket)core::Socketprotected
setBlockSize(int size=0)core::TCPSession2protected
setBufferSize(int length) (defined in core::Socket)core::Socketprotected
setDescriptor(int descriptor)core::Socket
shutDown (defined in core::Socket)core::Socket
shutdown(std::string text="unknown")core::Socket
shutdown(std::string text="unknown")core::Socket
shutDown (defined in core::Socket)core::Socket
Socket(EPoll &ePoll, std::string text="")core::Socket
TCPSession2(EPoll &ePoll, std::string text="") (defined in core::TCPSession2)core::TCPSession2
TCPSocket(EPoll &ePoll) (defined in core::TCPSocket)core::TCPSocket
onUnregister<
bool needsToWrite ()
 
+void enableSocket ()
 
+void disableSocket ()
 
diff --git a/html/classcore_1_1TCPSocket-members.html b/html/classcore_1_1TCPSocket-members.html index 1fd3007..e7c11c2 100644 --- a/html/classcore_1_1TCPSocket-members.html +++ b/html/classcore_1_1TCPSocket-members.html @@ -73,6 +73,8 @@ $(function() {

This is the complete list of members for core::TCPSocket, including all inherited members.

Public Attributes

+ + @@ -90,8 +92,8 @@ $(function() { - - + + diff --git a/html/classcore_1_1TCPSocket.html b/html/classcore_1_1TCPSocket.html index 97058ad..64eb360 100644 --- a/html/classcore_1_1TCPSocket.html +++ b/html/classcore_1_1TCPSocket.html @@ -160,6 +160,12 @@ virtual void  + + + +
connect(IPAddress &address) (defined in core::TCPSocket)core::TCPSocket
disableSocket() (defined in core::Socket)core::Socket
enableSocket() (defined in core::Socket)core::Socket
ePoll (defined in core::Socket)core::Socketprotected
eventReceived(struct epoll_event event, long long eventId)core::Socket
getBufferSize() (defined in core::Socket)core::Socketprotected
reset (defined in core::Socket)core::Socket
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::Socket
shutDown (defined in core::Socket)core::Socket
shutdown(std::string text="unknown")core::Socket
Socket(EPoll &ePoll, std::string text="")core::Socket
TCPSocket(EPoll &ePoll) (defined in core::TCPSocket)core::TCPSocket
TCPSocket(EPoll &ePoll, std::string text) (defined in core::TCPSocket)core::TCPSocket
onUnregister<
bool needsToWrite ()
 
+void enableSocket ()
 
+void disableSocket ()
 
diff --git a/html/classcore_1_1TLSServer-members.html b/html/classcore_1_1TLSServer-members.html index 69dcc75..b30f49c 100644 --- a/html/classcore_1_1TLSServer-members.html +++ b/html/classcore_1_1TLSServer-members.html @@ -76,6 +76,8 @@ $(function() { + + diff --git a/html/classcore_1_1TLSServer.html b/html/classcore_1_1TLSServer.html index 825f68d..28524f0 100644 --- a/html/classcore_1_1TLSServer.html +++ b/html/classcore_1_1TLSServer.html @@ -192,6 +192,12 @@ virtual void  + + + +

Public Attributes

commandscore::TCPServer
connect(IPAddress &address) (defined in core::TCPSocket)core::TCPSocket
ctx (defined in core::TLSServer)core::TLSServer
disableSocket() (defined in core::Socket)core::Socket
enableSocket() (defined in core::Socket)core::Socket
ePoll (defined in core::Socket)core::Socketprotected
eventReceived(struct epoll_event event, long long eventId)core::Socket
getBufferSize() (defined in core::Socket)core::Socketprotected
onUnregister<
bool needsToWrite ()
 
+void enableSocket ()
 
+void disableSocket ()
 
diff --git a/html/classcore_1_1TLSSession-members.html b/html/classcore_1_1TLSSession-members.html index 88d6b06..46e2cb6 100644 --- a/html/classcore_1_1TLSSession-members.html +++ b/html/classcore_1_1TLSSession-members.html @@ -75,6 +75,8 @@ $(function() { + + diff --git a/html/classcore_1_1TLSSession.html b/html/classcore_1_1TLSSession.html index 3ca5c7a..053730e 100644 --- a/html/classcore_1_1TLSSession.html +++ b/html/classcore_1_1TLSSession.html @@ -173,6 +173,12 @@ virtual void  + + + +

Public Attributes

aliascore::TCPSession
compareAlias(void *alias) (defined in core::TCPSession)core::TCPSessionvirtual
connect(IPAddress &address) (defined in core::TCPSocket)core::TCPSocket
disableSocket() (defined in core::Socket)core::Socket
enableSocket() (defined in core::Socket)core::Socket
ePoll (defined in core::Socket)core::Socketprotected
eventReceived(struct epoll_event event, long long eventId)core::Socket
getBufferSize() (defined in core::Socket)core::Socketprotected
onUnregister<
bool needsToWrite ()
 
+void enableSocket ()
 
+void disableSocket ()
 
diff --git a/html/classcore_1_1TerminalSession-members.html b/html/classcore_1_1TerminalSession-members.html index c4bfb99..76a807f 100644 --- a/html/classcore_1_1TerminalSession-members.html +++ b/html/classcore_1_1TerminalSession-members.html @@ -77,6 +77,8 @@ $(function() { + + diff --git a/html/classcore_1_1TerminalSession.html b/html/classcore_1_1TerminalSession.html index 4893ddf..791468d 100644 --- a/html/classcore_1_1TerminalSession.html +++ b/html/classcore_1_1TerminalSession.html @@ -202,6 +202,12 @@ virtual void  + + + +

Protected Member Functions

clearEOL()core::TerminalSession
compareAlias(void *alias) (defined in core::TCPSession)core::TCPSessionvirtual
connect(IPAddress &address) (defined in core::TCPSocket)core::TCPSocket
disableSocket() (defined in core::Socket)core::Socket
enableSocket() (defined in core::Socket)core::Socket
ePoll (defined in core::Socket)core::Socketprotected
eventReceived(struct epoll_event event, long long eventId)core::Socket
getBufferSize() (defined in core::Socket)core::Socketprotected
onUnregister<
bool needsToWrite ()
 
+void enableSocket ()
 
+void disableSocket ()
 
diff --git a/html/classcore_1_1UDPServerSocket-members.html b/html/classcore_1_1UDPServerSocket-members.html index af07dc4..e813a91 100644 --- a/html/classcore_1_1UDPServerSocket-members.html +++ b/html/classcore_1_1UDPServerSocket-members.html @@ -72,6 +72,8 @@ $(function() {

This is the complete list of members for core::UDPServerSocket, including all inherited members.

Additional Inherited Members

+ + @@ -92,8 +94,8 @@ $(function() { - - + + diff --git a/html/classcore_1_1UDPServerSocket.html b/html/classcore_1_1UDPServerSocket.html index 065a439..ab87f00 100644 --- a/html/classcore_1_1UDPServerSocket.html +++ b/html/classcore_1_1UDPServerSocket.html @@ -150,6 +150,12 @@ virtual void  + + + + diff --git a/html/classcore_1_1UDPSocket-members.html b/html/classcore_1_1UDPSocket-members.html index 3c77a6d..2a89b4e 100644 --- a/html/classcore_1_1UDPSocket-members.html +++ b/html/classcore_1_1UDPSocket-members.html @@ -72,6 +72,8 @@ $(function() {

This is the complete list of members for core::UDPSocket, including all inherited members.

disableSocket() (defined in core::Socket)core::Socket
enableSocket() (defined in core::Socket)core::Socket
ePoll (defined in core::Socket)core::Socketprotected
eventReceived(struct epoll_event event, long long eventId)core::Socket
getBufferSize() (defined in core::Socket)core::Socketprotected
sessions (defined in core::UDPServerSocket)core::UDPServerSocketprotected
setBufferSize(int length) (defined in core::Socket)core::Socketprotected
setDescriptor(int descriptor)core::Socket
shutDown (defined in core::Socket)core::Socket
shutdown(std::string text="unknown")core::Socket
shutdown(std::string text="unknown")core::Socket
shutDown (defined in core::Socket)core::Socket
Socket(EPoll &ePoll, std::string text="")core::Socket
UDPServerSocket(EPoll &ePoll, std::string url, short int port, std::string commandName) (defined in core::UDPServerSocket)core::UDPServerSocket
UDPSocket(EPoll &ePoll) (defined in core::UDPSocket)core::UDPSocket
onUnregister<
bool needsToWrite ()
 
+void enableSocket ()
 
+void disableSocket ()
 
- Public Member Functions inherited from core::Command
virtual int processCommand (coreutils::ZString &request, TCPSession &session)
 
+ + diff --git a/html/classcore_1_1UDPSocket.html b/html/classcore_1_1UDPSocket.html index 2fd01b1..649ce4f 100644 --- a/html/classcore_1_1UDPSocket.html +++ b/html/classcore_1_1UDPSocket.html @@ -140,6 +140,12 @@ virtual void  + + + +
disableSocket() (defined in core::Socket)core::Socket
enableSocket() (defined in core::Socket)core::Socket
ePoll (defined in core::Socket)core::Socketprotected
eventReceived(struct epoll_event event, long long eventId)core::Socket
getBufferSize() (defined in core::Socket)core::Socketprotected
onUnregister<
bool needsToWrite ()
 
+void enableSocket ()
 
+void disableSocket ()
 
diff --git a/html/functions.html b/html/functions.html index 62104b0..5e895f1 100644 --- a/html/functions.html +++ b/html/functions.html @@ -228,9 +228,6 @@ $(function() { : core::Socket , core::TLSSession -
  • registerSocket() -: core::EPoll -
  • remove() : core::CommandList
    • @@ -295,9 +292,6 @@ $(function() {

    - u -

    -

    - u -

    - -

    - w -

    • write() : core::Socket diff --git a/html/menudata.js b/html/menudata.js index 0b7b348..0820aeb 100644 --- a/html/menudata.js +++ b/html/menudata.js @@ -56,7 +56,6 @@ var menudata={children:[ {text:"r",url:"functions_func.html#index_r"}, {text:"s",url:"functions_func.html#index_s"}, {text:"t",url:"functions_func.html#index_t"}, -{text:"u",url:"functions_func.html#index_u"}, {text:"w",url:"functions_func.html#index_w"}, {text:"~",url:"functions_func.html#index__7E"}]}, {text:"Variables",url:"functions_vars.html"}]}]}, diff --git a/html/search/all_9.js b/html/search/all_9.js index 6306aae..ceb52cc 100644 --- a/html/search/all_9.js +++ b/html/search/all_9.js @@ -1,6 +1,5 @@ var searchData= [ ['receivedata_40',['receiveData',['../classcore_1_1Socket.html#a46ed2e240852d3fa949979ebbc4ac875',1,'core::Socket::receiveData()'],['../classcore_1_1TLSSession.html#a8507cdcd23ac4b340ce6f6d5f0b26a52',1,'core::TLSSession::receiveData()']]], - ['registersocket_41',['registerSocket',['../classcore_1_1EPoll.html#a3d813c7bbf0da70ebc8e3cb6aeeacfb4',1,'core::EPoll']]], - ['remove_42',['remove',['../classcore_1_1CommandList.html#aaac684effb9ecf5238d23ca60d3fffaa',1,'core::CommandList']]] + ['remove_41',['remove',['../classcore_1_1CommandList.html#aaac684effb9ecf5238d23ca60d3fffaa',1,'core::CommandList']]] ]; diff --git a/html/search/all_a.js b/html/search/all_a.js index 3dfb6c5..f35b438 100644 --- a/html/search/all_a.js +++ b/html/search/all_a.js @@ -1,19 +1,19 @@ var searchData= [ - ['send_43',['send',['../classcore_1_1TCPSession.html#a2b09eeafef5e44009a77d9da43e3b889',1,'core::TCPSession::send()'],['../classcore_1_1TCPSession2.html#aca2f7127b4081fa0e2d2d128083fb0f7',1,'core::TCPSession2::send()']]], - ['sendtoall_44',['sendToAll',['../classcore_1_1TCPServer.html#a7080f7d45e734087e81b83c5e1f8e676',1,'core::TCPServer::sendToAll(std::stringstream &out, TCPSession &sender, SessionFilter filter)'],['../classcore_1_1TCPServer.html#af708df59e1bc60077c16db97f9cc8ff0',1,'core::TCPServer::sendToAll(std::stringstream &out, TCPSession &sender)']]], - ['sessionfilter_45',['SessionFilter',['../classcore_1_1SessionFilter.html',1,'core']]], - ['sessions_46',['sessions',['../classcore_1_1TCPServer.html#aeed1bc55d099667ccda51cd682bfc633',1,'core::TCPServer']]], - ['setblocksize_47',['setBlockSize',['../classcore_1_1TCPSession.html#a836fb3fd5ee543ebc93262a980ae88b5',1,'core::TCPSession::setBlockSize()'],['../classcore_1_1TCPSession2.html#a6f4ed04cd2848e5b903b8331b2e951c8',1,'core::TCPSession2::setBlockSize()']]], - ['setcursorlocation_48',['setCursorLocation',['../classcore_1_1TerminalSession.html#aa9939cbe36c08e1a0b8413a96ca251fa',1,'core::TerminalSession']]], - ['setdescriptor_49',['setDescriptor',['../classcore_1_1Socket.html#ac44f6ae3196a8a3e09a6a85fcf495762',1,'core::Socket']]], - ['settimer_50',['setTimer',['../classcore_1_1Timer.html#ac0a642cdcb76b7f995137162050d3d0b',1,'core::Timer']]], - ['shutdown_51',['shutdown',['../classcore_1_1Socket.html#af2d1b6de7a64a9d446b0305b6ec47b31',1,'core::Socket']]], - ['socket_52',['Socket',['../classcore_1_1Socket.html',1,'core::Socket'],['../classcore_1_1Socket.html#a4c3f87fd1de3c9eab4bf5efbb30ce87d',1,'core::Socket::Socket()']]], - ['start_53',['start',['../classcore_1_1EPoll.html#aaefe2caef75eb538af90cb34682d277b',1,'core::EPoll::start()'],['../classcore_1_1Thread.html#ae6885df9a9b9503669e5776518b19054',1,'core::Thread::start()']]], - ['stop_54',['stop',['../classcore_1_1EPoll.html#a0c2865acd31d14fbf19dbc42cc084ddc',1,'core::EPoll']]], - ['subscription_55',['Subscription',['../classcore_1_1Subscription.html',1,'core']]], - ['subscriptionhandler_56',['SubscriptionHandler',['../classcore_1_1SubscriptionHandler.html',1,'core']]], - ['subscriptionmanager_57',['SubscriptionManager',['../classcore_1_1SubscriptionManager.html',1,'core']]], - ['subscriptions_58',['subscriptions',['../classcore_1_1TCPServer.html#a28302dd844cfc971ee41de2000d24aa0',1,'core::TCPServer']]] + ['send_42',['send',['../classcore_1_1TCPSession.html#a2b09eeafef5e44009a77d9da43e3b889',1,'core::TCPSession::send()'],['../classcore_1_1TCPSession2.html#aca2f7127b4081fa0e2d2d128083fb0f7',1,'core::TCPSession2::send()']]], + ['sendtoall_43',['sendToAll',['../classcore_1_1TCPServer.html#a7080f7d45e734087e81b83c5e1f8e676',1,'core::TCPServer::sendToAll(std::stringstream &out, TCPSession &sender, SessionFilter filter)'],['../classcore_1_1TCPServer.html#af708df59e1bc60077c16db97f9cc8ff0',1,'core::TCPServer::sendToAll(std::stringstream &out, TCPSession &sender)']]], + ['sessionfilter_44',['SessionFilter',['../classcore_1_1SessionFilter.html',1,'core']]], + ['sessions_45',['sessions',['../classcore_1_1TCPServer.html#aeed1bc55d099667ccda51cd682bfc633',1,'core::TCPServer']]], + ['setblocksize_46',['setBlockSize',['../classcore_1_1TCPSession.html#a836fb3fd5ee543ebc93262a980ae88b5',1,'core::TCPSession::setBlockSize()'],['../classcore_1_1TCPSession2.html#a6f4ed04cd2848e5b903b8331b2e951c8',1,'core::TCPSession2::setBlockSize()']]], + ['setcursorlocation_47',['setCursorLocation',['../classcore_1_1TerminalSession.html#aa9939cbe36c08e1a0b8413a96ca251fa',1,'core::TerminalSession']]], + ['setdescriptor_48',['setDescriptor',['../classcore_1_1Socket.html#ac44f6ae3196a8a3e09a6a85fcf495762',1,'core::Socket']]], + ['settimer_49',['setTimer',['../classcore_1_1Timer.html#ac0a642cdcb76b7f995137162050d3d0b',1,'core::Timer']]], + ['shutdown_50',['shutdown',['../classcore_1_1Socket.html#af2d1b6de7a64a9d446b0305b6ec47b31',1,'core::Socket']]], + ['socket_51',['Socket',['../classcore_1_1Socket.html',1,'core::Socket'],['../classcore_1_1Socket.html#a4c3f87fd1de3c9eab4bf5efbb30ce87d',1,'core::Socket::Socket()']]], + ['start_52',['start',['../classcore_1_1EPoll.html#aaefe2caef75eb538af90cb34682d277b',1,'core::EPoll::start()'],['../classcore_1_1Thread.html#ae6885df9a9b9503669e5776518b19054',1,'core::Thread::start()']]], + ['stop_53',['stop',['../classcore_1_1EPoll.html#a0c2865acd31d14fbf19dbc42cc084ddc',1,'core::EPoll']]], + ['subscription_54',['Subscription',['../classcore_1_1Subscription.html',1,'core']]], + ['subscriptionhandler_55',['SubscriptionHandler',['../classcore_1_1SubscriptionHandler.html',1,'core']]], + ['subscriptionmanager_56',['SubscriptionManager',['../classcore_1_1SubscriptionManager.html',1,'core']]], + ['subscriptions_57',['subscriptions',['../classcore_1_1TCPServer.html#a28302dd844cfc971ee41de2000d24aa0',1,'core::TCPServer']]] ]; diff --git a/html/search/all_b.js b/html/search/all_b.js index 0b22d72..9aa31e8 100644 --- a/html/search/all_b.js +++ b/html/search/all_b.js @@ -1,14 +1,14 @@ var searchData= [ - ['tcpserver_59',['TCPServer',['../classcore_1_1TCPServer.html',1,'core::TCPServer'],['../classcore_1_1TCPServer.html#abaecb97c336b757d1029d45277f9fc5b',1,'core::TCPServer::TCPServer()']]], - ['tcpsession_60',['TCPSession',['../classcore_1_1TCPSession.html',1,'core']]], - ['tcpsession2_61',['TCPSession2',['../classcore_1_1TCPSession2.html',1,'core']]], - ['tcpsocket_62',['TCPSocket',['../classcore_1_1TCPSocket.html',1,'core']]], - ['terminalsession_63',['TerminalSession',['../classcore_1_1TerminalSession.html',1,'core']]], - ['terminate_64',['terminate',['../classcore_1_1TCPSession.html#a34936745e8d7669d5400e78d353a56d3',1,'core::TCPSession::terminate()'],['../classcore_1_1TCPSession2.html#a6b999e7ea6551a1b513ee057afaa9e4a',1,'core::TCPSession2::terminate()']]], - ['thread_65',['Thread',['../classcore_1_1Thread.html',1,'core']]], - ['threadscope_66',['ThreadScope',['../classcore_1_1ThreadScope.html',1,'core']]], - ['timer_67',['Timer',['../classcore_1_1Timer.html',1,'core']]], - ['tlsserver_68',['TLSServer',['../classcore_1_1TLSServer.html',1,'core::TLSServer'],['../classcore_1_1TLSServer.html#a6460f9872936015efdfd0b8de04aa2fe',1,'core::TLSServer::TLSServer()']]], - ['tlssession_69',['TLSSession',['../classcore_1_1TLSSession.html',1,'core']]] + ['tcpserver_58',['TCPServer',['../classcore_1_1TCPServer.html',1,'core::TCPServer'],['../classcore_1_1TCPServer.html#abaecb97c336b757d1029d45277f9fc5b',1,'core::TCPServer::TCPServer()']]], + ['tcpsession_59',['TCPSession',['../classcore_1_1TCPSession.html',1,'core']]], + ['tcpsession2_60',['TCPSession2',['../classcore_1_1TCPSession2.html',1,'core']]], + ['tcpsocket_61',['TCPSocket',['../classcore_1_1TCPSocket.html',1,'core']]], + ['terminalsession_62',['TerminalSession',['../classcore_1_1TerminalSession.html',1,'core']]], + ['terminate_63',['terminate',['../classcore_1_1TCPSession.html#a34936745e8d7669d5400e78d353a56d3',1,'core::TCPSession::terminate()'],['../classcore_1_1TCPSession2.html#a6b999e7ea6551a1b513ee057afaa9e4a',1,'core::TCPSession2::terminate()']]], + ['thread_64',['Thread',['../classcore_1_1Thread.html',1,'core']]], + ['threadscope_65',['ThreadScope',['../classcore_1_1ThreadScope.html',1,'core']]], + ['timer_66',['Timer',['../classcore_1_1Timer.html',1,'core']]], + ['tlsserver_67',['TLSServer',['../classcore_1_1TLSServer.html',1,'core::TLSServer'],['../classcore_1_1TLSServer.html#a6460f9872936015efdfd0b8de04aa2fe',1,'core::TLSServer::TLSServer()']]], + ['tlssession_68',['TLSSession',['../classcore_1_1TLSSession.html',1,'core']]] ]; diff --git a/html/search/all_c.js b/html/search/all_c.js index b05e2fd..fe7874d 100644 --- a/html/search/all_c.js +++ b/html/search/all_c.js @@ -1,7 +1,6 @@ var searchData= [ - ['udpserversocket_70',['UDPServerSocket',['../classcore_1_1UDPServerSocket.html',1,'core']]], - ['udpsocket_71',['UDPSocket',['../classcore_1_1UDPSocket.html',1,'core']]], - ['unregistersocket_72',['unregisterSocket',['../classcore_1_1EPoll.html#a5ab5e82ab51e0952fc8fbcc128f52900',1,'core::EPoll']]], - ['uuid_73',['uuid',['../classcore_1_1TCPSession.html#a2ccd4968f5c53d1c16a57e04081db692',1,'core::TCPSession']]] + ['udpserversocket_69',['UDPServerSocket',['../classcore_1_1UDPServerSocket.html',1,'core']]], + ['udpsocket_70',['UDPSocket',['../classcore_1_1UDPSocket.html',1,'core']]], + ['uuid_71',['uuid',['../classcore_1_1TCPSession.html#a2ccd4968f5c53d1c16a57e04081db692',1,'core::TCPSession']]] ]; diff --git a/html/search/all_d.js b/html/search/all_d.js index bb19872..6bd4053 100644 --- a/html/search/all_d.js +++ b/html/search/all_d.js @@ -1,5 +1,5 @@ var searchData= [ - ['whitelist_74',['whiteList',['../classcore_1_1TCPServer.html#abad6300b6234ca8b69cef9128755342e',1,'core::TCPServer']]], - ['write_75',['write',['../classcore_1_1Socket.html#a1413c826307ef0f29d7457770af675e3',1,'core::Socket']]] + ['whitelist_72',['whiteList',['../classcore_1_1TCPServer.html#abad6300b6234ca8b69cef9128755342e',1,'core::TCPServer']]], + ['write_73',['write',['../classcore_1_1Socket.html#a1413c826307ef0f29d7457770af675e3',1,'core::Socket']]] ]; diff --git a/html/search/all_e.js b/html/search/all_e.js index 589c317..78ecd9a 100644 --- a/html/search/all_e.js +++ b/html/search/all_e.js @@ -1,7 +1,7 @@ var searchData= [ - ['_7eepoll_76',['~EPoll',['../classcore_1_1EPoll.html#a8e7a2496d684b745a6410f9bd3e88534',1,'core::EPoll']]], - ['_7esocket_77',['~Socket',['../classcore_1_1Socket.html#aa5003845f8ae464ad2fa206176381be0',1,'core::Socket']]], - ['_7etcpserver_78',['~TCPServer',['../classcore_1_1TCPServer.html#a7ccdc057c9eee8504fce796301f82088',1,'core::TCPServer']]], - ['_7etlsserver_79',['~TLSServer',['../classcore_1_1TLSServer.html#ac71db77c796a1bf65357409cb96054c7',1,'core::TLSServer']]] + ['_7eepoll_74',['~EPoll',['../classcore_1_1EPoll.html#a8e7a2496d684b745a6410f9bd3e88534',1,'core::EPoll']]], + ['_7esocket_75',['~Socket',['../classcore_1_1Socket.html#aa5003845f8ae464ad2fa206176381be0',1,'core::Socket']]], + ['_7etcpserver_76',['~TCPServer',['../classcore_1_1TCPServer.html#a7ccdc057c9eee8504fce796301f82088',1,'core::TCPServer']]], + ['_7etlsserver_77',['~TLSServer',['../classcore_1_1TLSServer.html#ac71db77c796a1bf65357409cb96054c7',1,'core::TLSServer']]] ]; diff --git a/html/search/classes_0.js b/html/search/classes_0.js index 8ac6ade..dd93087 100644 --- a/html/search/classes_0.js +++ b/html/search/classes_0.js @@ -1,7 +1,7 @@ var searchData= [ - ['command_80',['Command',['../classcore_1_1Command.html',1,'core']]], - ['commandlist_81',['CommandList',['../classcore_1_1CommandList.html',1,'core']]], - ['consoleserver_82',['ConsoleServer',['../classcore_1_1ConsoleServer.html',1,'core']]], - ['consolesession_83',['ConsoleSession',['../classcore_1_1ConsoleSession.html',1,'core']]] + ['command_78',['Command',['../classcore_1_1Command.html',1,'core']]], + ['commandlist_79',['CommandList',['../classcore_1_1CommandList.html',1,'core']]], + ['consoleserver_80',['ConsoleServer',['../classcore_1_1ConsoleServer.html',1,'core']]], + ['consolesession_81',['ConsoleSession',['../classcore_1_1ConsoleSession.html',1,'core']]] ]; diff --git a/html/search/classes_1.js b/html/search/classes_1.js index 3459658..2dc33c7 100644 --- a/html/search/classes_1.js +++ b/html/search/classes_1.js @@ -1,4 +1,4 @@ var searchData= [ - ['epoll_84',['EPoll',['../classcore_1_1EPoll.html',1,'core']]] + ['epoll_82',['EPoll',['../classcore_1_1EPoll.html',1,'core']]] ]; diff --git a/html/search/classes_2.js b/html/search/classes_2.js index d7e18e0..8c752e8 100644 --- a/html/search/classes_2.js +++ b/html/search/classes_2.js @@ -1,6 +1,6 @@ var searchData= [ - ['inotify_85',['INotify',['../classcore_1_1INotify.html',1,'core']]], - ['ipaddress_86',['IPAddress',['../classcore_1_1IPAddress.html',1,'core']]], - ['ipaddresslist_87',['IPAddressList',['../classcore_1_1IPAddressList.html',1,'core']]] + ['inotify_83',['INotify',['../classcore_1_1INotify.html',1,'core']]], + ['ipaddress_84',['IPAddress',['../classcore_1_1IPAddress.html',1,'core']]], + ['ipaddresslist_85',['IPAddressList',['../classcore_1_1IPAddressList.html',1,'core']]] ]; diff --git a/html/search/classes_3.js b/html/search/classes_3.js index da6e461..bc4045a 100644 --- a/html/search/classes_3.js +++ b/html/search/classes_3.js @@ -1,4 +1,4 @@ var searchData= [ - ['object_88',['Object',['../classcore_1_1Object.html',1,'core']]] + ['object_86',['Object',['../classcore_1_1Object.html',1,'core']]] ]; diff --git a/html/search/classes_4.js b/html/search/classes_4.js index 4f5480e..1516e74 100644 --- a/html/search/classes_4.js +++ b/html/search/classes_4.js @@ -1,8 +1,8 @@ var searchData= [ - ['sessionfilter_89',['SessionFilter',['../classcore_1_1SessionFilter.html',1,'core']]], - ['socket_90',['Socket',['../classcore_1_1Socket.html',1,'core']]], - ['subscription_91',['Subscription',['../classcore_1_1Subscription.html',1,'core']]], - ['subscriptionhandler_92',['SubscriptionHandler',['../classcore_1_1SubscriptionHandler.html',1,'core']]], - ['subscriptionmanager_93',['SubscriptionManager',['../classcore_1_1SubscriptionManager.html',1,'core']]] + ['sessionfilter_87',['SessionFilter',['../classcore_1_1SessionFilter.html',1,'core']]], + ['socket_88',['Socket',['../classcore_1_1Socket.html',1,'core']]], + ['subscription_89',['Subscription',['../classcore_1_1Subscription.html',1,'core']]], + ['subscriptionhandler_90',['SubscriptionHandler',['../classcore_1_1SubscriptionHandler.html',1,'core']]], + ['subscriptionmanager_91',['SubscriptionManager',['../classcore_1_1SubscriptionManager.html',1,'core']]] ]; diff --git a/html/search/classes_5.js b/html/search/classes_5.js index 8de1f07..38ca469 100644 --- a/html/search/classes_5.js +++ b/html/search/classes_5.js @@ -1,13 +1,13 @@ var searchData= [ - ['tcpserver_94',['TCPServer',['../classcore_1_1TCPServer.html',1,'core']]], - ['tcpsession_95',['TCPSession',['../classcore_1_1TCPSession.html',1,'core']]], - ['tcpsession2_96',['TCPSession2',['../classcore_1_1TCPSession2.html',1,'core']]], - ['tcpsocket_97',['TCPSocket',['../classcore_1_1TCPSocket.html',1,'core']]], - ['terminalsession_98',['TerminalSession',['../classcore_1_1TerminalSession.html',1,'core']]], - ['thread_99',['Thread',['../classcore_1_1Thread.html',1,'core']]], - ['threadscope_100',['ThreadScope',['../classcore_1_1ThreadScope.html',1,'core']]], - ['timer_101',['Timer',['../classcore_1_1Timer.html',1,'core']]], - ['tlsserver_102',['TLSServer',['../classcore_1_1TLSServer.html',1,'core']]], - ['tlssession_103',['TLSSession',['../classcore_1_1TLSSession.html',1,'core']]] + ['tcpserver_92',['TCPServer',['../classcore_1_1TCPServer.html',1,'core']]], + ['tcpsession_93',['TCPSession',['../classcore_1_1TCPSession.html',1,'core']]], + ['tcpsession2_94',['TCPSession2',['../classcore_1_1TCPSession2.html',1,'core']]], + ['tcpsocket_95',['TCPSocket',['../classcore_1_1TCPSocket.html',1,'core']]], + ['terminalsession_96',['TerminalSession',['../classcore_1_1TerminalSession.html',1,'core']]], + ['thread_97',['Thread',['../classcore_1_1Thread.html',1,'core']]], + ['threadscope_98',['ThreadScope',['../classcore_1_1ThreadScope.html',1,'core']]], + ['timer_99',['Timer',['../classcore_1_1Timer.html',1,'core']]], + ['tlsserver_100',['TLSServer',['../classcore_1_1TLSServer.html',1,'core']]], + ['tlssession_101',['TLSSession',['../classcore_1_1TLSSession.html',1,'core']]] ]; diff --git a/html/search/classes_6.js b/html/search/classes_6.js index b0a168b..ef1ebd1 100644 --- a/html/search/classes_6.js +++ b/html/search/classes_6.js @@ -1,5 +1,5 @@ var searchData= [ - ['udpserversocket_104',['UDPServerSocket',['../classcore_1_1UDPServerSocket.html',1,'core']]], - ['udpsocket_105',['UDPSocket',['../classcore_1_1UDPSocket.html',1,'core']]] + ['udpserversocket_102',['UDPServerSocket',['../classcore_1_1UDPServerSocket.html',1,'core']]], + ['udpsocket_103',['UDPSocket',['../classcore_1_1UDPSocket.html',1,'core']]] ]; diff --git a/html/search/functions_0.js b/html/search/functions_0.js index aad17b8..e040968 100644 --- a/html/search/functions_0.js +++ b/html/search/functions_0.js @@ -1,4 +1,4 @@ var searchData= [ - ['add_106',['add',['../classcore_1_1CommandList.html#a7a45e75e3d21a25fd3f7e887acf395e9',1,'core::CommandList']]] + ['add_104',['add',['../classcore_1_1CommandList.html#a7a45e75e3d21a25fd3f7e887acf395e9',1,'core::CommandList']]] ]; diff --git a/html/search/functions_1.js b/html/search/functions_1.js index 833b34f..4af4734 100644 --- a/html/search/functions_1.js +++ b/html/search/functions_1.js @@ -1,6 +1,6 @@ var searchData= [ - ['clear_107',['clear',['../classcore_1_1TerminalSession.html#a42bb06857891220a831da04248233935',1,'core::TerminalSession']]], - ['cleareol_108',['clearEOL',['../classcore_1_1TerminalSession.html#aa660768eed03b0b996a749e8a146446c',1,'core::TerminalSession']]], - ['cleartimer_109',['clearTimer',['../classcore_1_1Timer.html#a8e063f46e89dac04364871e909ab940a',1,'core::Timer']]] + ['clear_105',['clear',['../classcore_1_1TerminalSession.html#a42bb06857891220a831da04248233935',1,'core::TerminalSession']]], + ['cleareol_106',['clearEOL',['../classcore_1_1TerminalSession.html#aa660768eed03b0b996a749e8a146446c',1,'core::TerminalSession']]], + ['cleartimer_107',['clearTimer',['../classcore_1_1Timer.html#a8e063f46e89dac04364871e909ab940a',1,'core::Timer']]] ]; diff --git a/html/search/functions_2.js b/html/search/functions_2.js index e31e64d..126fc5d 100644 --- a/html/search/functions_2.js +++ b/html/search/functions_2.js @@ -1,5 +1,5 @@ var searchData= [ - ['epoll_110',['EPoll',['../classcore_1_1EPoll.html#a2fd5cc4336b5f72990ecc0e7ea3d7641',1,'core::EPoll']]], - ['eventreceived_111',['eventReceived',['../classcore_1_1EPoll.html#a3238b150b5d0a57eb2e1b17daa236d3b',1,'core::EPoll::eventReceived()'],['../classcore_1_1Socket.html#a1a045e15fb5851d666a21be05ac4c5d7',1,'core::Socket::eventReceived()']]] + ['epoll_108',['EPoll',['../classcore_1_1EPoll.html#a2fd5cc4336b5f72990ecc0e7ea3d7641',1,'core::EPoll']]], + ['eventreceived_109',['eventReceived',['../classcore_1_1EPoll.html#a3238b150b5d0a57eb2e1b17daa236d3b',1,'core::EPoll::eventReceived()'],['../classcore_1_1Socket.html#a1a045e15fb5851d666a21be05ac4c5d7',1,'core::Socket::eventReceived()']]] ]; diff --git a/html/search/functions_3.js b/html/search/functions_3.js index c3f07ba..3bbd57b 100644 --- a/html/search/functions_3.js +++ b/html/search/functions_3.js @@ -1,11 +1,11 @@ var searchData= [ - ['getclientaddress_112',['getClientAddress',['../classcore_1_1IPAddress.html#ae5e7e28589d026bbbc6c3423d418b008',1,'core::IPAddress']]], - ['getclientaddressandport_113',['getClientAddressAndPort',['../classcore_1_1IPAddress.html#abea870f1a048cb7bba1d2bad98558232',1,'core::IPAddress']]], - ['getclientport_114',['getClientPort',['../classcore_1_1IPAddress.html#a39f706f2d43d7d001296ecead4b587e8',1,'core::IPAddress']]], - ['getdescriptor_115',['getDescriptor',['../classcore_1_1EPoll.html#a1e52017e1deae15c1c87c6b6a099e1ed',1,'core::EPoll::getDescriptor()'],['../classcore_1_1Socket.html#a06ba54744530439d4131e6aba4623d08',1,'core::Socket::getDescriptor()']]], - ['getelapsed_116',['getElapsed',['../classcore_1_1Timer.html#a0df7f1ffc05529b45d6e13713bbc0209',1,'core::Timer']]], - ['getsessionbyalias_117',['getSessionByAlias',['../classcore_1_1TCPServer.html#a9042281193e227a6cd8dab3ff8b46a40',1,'core::TCPServer']]], - ['getsocketaccept_118',['getSocketAccept',['../classcore_1_1ConsoleServer.html#a80d9ea7f3fc5e07c50d5b9e0d4943ca8',1,'core::ConsoleServer::getSocketAccept()'],['../classcore_1_1TCPServer.html#a841f02799ad8529aad7cea132f4de8a9',1,'core::TCPServer::getSocketAccept()']]], - ['grabinput_119',['grabInput',['../classcore_1_1CommandList.html#a72aea93a650f148c639ba25a724da243',1,'core::CommandList']]] + ['getclientaddress_110',['getClientAddress',['../classcore_1_1IPAddress.html#ae5e7e28589d026bbbc6c3423d418b008',1,'core::IPAddress']]], + ['getclientaddressandport_111',['getClientAddressAndPort',['../classcore_1_1IPAddress.html#abea870f1a048cb7bba1d2bad98558232',1,'core::IPAddress']]], + ['getclientport_112',['getClientPort',['../classcore_1_1IPAddress.html#a39f706f2d43d7d001296ecead4b587e8',1,'core::IPAddress']]], + ['getdescriptor_113',['getDescriptor',['../classcore_1_1EPoll.html#a1e52017e1deae15c1c87c6b6a099e1ed',1,'core::EPoll::getDescriptor()'],['../classcore_1_1Socket.html#a06ba54744530439d4131e6aba4623d08',1,'core::Socket::getDescriptor()']]], + ['getelapsed_114',['getElapsed',['../classcore_1_1Timer.html#a0df7f1ffc05529b45d6e13713bbc0209',1,'core::Timer']]], + ['getsessionbyalias_115',['getSessionByAlias',['../classcore_1_1TCPServer.html#a9042281193e227a6cd8dab3ff8b46a40',1,'core::TCPServer']]], + ['getsocketaccept_116',['getSocketAccept',['../classcore_1_1ConsoleServer.html#a80d9ea7f3fc5e07c50d5b9e0d4943ca8',1,'core::ConsoleServer::getSocketAccept()'],['../classcore_1_1TCPServer.html#a841f02799ad8529aad7cea132f4de8a9',1,'core::TCPServer::getSocketAccept()']]], + ['grabinput_117',['grabInput',['../classcore_1_1CommandList.html#a72aea93a650f148c639ba25a724da243',1,'core::CommandList']]] ]; diff --git a/html/search/functions_4.js b/html/search/functions_4.js index 687dcbd..a8f113a 100644 --- a/html/search/functions_4.js +++ b/html/search/functions_4.js @@ -1,4 +1,4 @@ var searchData= [ - ['isstopping_120',['isStopping',['../classcore_1_1EPoll.html#a301b46b71ac7ac61a687ff723fe269b3',1,'core::EPoll']]] + ['isstopping_118',['isStopping',['../classcore_1_1EPoll.html#a301b46b71ac7ac61a687ff723fe269b3',1,'core::EPoll']]] ]; diff --git a/html/search/functions_5.js b/html/search/functions_5.js index 7ab8c6e..48cb3fb 100644 --- a/html/search/functions_5.js +++ b/html/search/functions_5.js @@ -1,12 +1,12 @@ var searchData= [ - ['onblockreceived_121',['onBlockReceived',['../classcore_1_1TCPSession2.html#a6c88775e81dc0074ef0832146be9f4b9',1,'core::TCPSession2::onBlockReceived()'],['../classcore_1_1TCPSession.html#a9c996cbbfa2e592c23cf67ed8b15a32a',1,'core::TCPSession::onBlockReceived(coreutils::ZString &block)']]], - ['onconnected_122',['onConnected',['../classcore_1_1TCPSession.html#a8719952f7bb00bf7239ec40aa2868626',1,'core::TCPSession::onConnected()'],['../classcore_1_1TCPSession2.html#af1913cb444a9e07c0f31a2cd8d934a62',1,'core::TCPSession2::onConnected()']]], - ['ondatareceived_123',['onDataReceived',['../classcore_1_1Socket.html#ac8d6a2c54696eb6fc2024cf6bcf6b4e5',1,'core::Socket::onDataReceived()'],['../classcore_1_1TCPServer.html#a276ccbc8cb9b4380ebd78807b97f0159',1,'core::TCPServer::onDataReceived()'],['../classcore_1_1TCPSession.html#afc2d2a92bc65e1e5122a93d120253a1d',1,'core::TCPSession::onDataReceived()'],['../classcore_1_1TCPSession2.html#a67c473e1a22b10fc100ae54206f7471b',1,'core::TCPSession2::onDataReceived()'],['../classcore_1_1UDPServerSocket.html#a41933ca153c854a800e3d047ab18313e',1,'core::UDPServerSocket::onDataReceived()']]], - ['onlinereceived_124',['onLineReceived',['../classcore_1_1TCPSession.html#a3d9e0f14e7d24357fd1950b3f9b4eaff',1,'core::TCPSession::onLineReceived()'],['../classcore_1_1TCPSession2.html#a6cd36b444d9548d1024190c6ba747e18',1,'core::TCPSession2::onLineReceived()']]], - ['onregister_125',['onRegister',['../classcore_1_1TLSSession.html#a76cec7cf4851eb27abe77a2339344c6d',1,'core::TLSSession::onRegister()'],['../classcore_1_1Socket.html#a81e5ee3e17834166d97c6e8b7dfe0da0',1,'core::Socket::onRegister()']]], - ['onregistered_126',['onRegistered',['../classcore_1_1Socket.html#a23b9824653bbe4652a716acb828665b1',1,'core::Socket::onRegistered()'],['../classcore_1_1TCPSession.html#aed4ed499b978bcea57a8efefe929fc98',1,'core::TCPSession::onRegistered()'],['../classcore_1_1TCPSession2.html#a76096659b82c5dcbf6eac1d916511e60',1,'core::TCPSession2::onRegistered()'],['../classcore_1_1TLSSession.html#a8e26fdc9e8a6c573b5a504a1f1b137a9',1,'core::TLSSession::onRegistered()']]], - ['ontimeout_127',['onTimeout',['../classcore_1_1Timer.html#ae51704ff08d985bbc30e3ff4c9b3c6ca',1,'core::Timer']]], - ['onunregistered_128',['onUnregistered',['../classcore_1_1Socket.html#ae9be59697c2b2e5efb19aaae3ba943d2',1,'core::Socket']]], - ['output_129',['output',['../classcore_1_1Command.html#ab6352ce5650e70a5c76c3d6e4eefd292',1,'core::Command::output()'],['../classcore_1_1TCPServer.html#a49e3ead1bf4e7830685780e73c4db5db',1,'core::TCPServer::output()'],['../classcore_1_1TCPSession.html#a50037cbfc515650e04054e5481785981',1,'core::TCPSession::output()'],['../classcore_1_1TCPSession2.html#ae7648a7759570a00d3d4a8c169183291',1,'core::TCPSession2::output()'],['../classcore_1_1TCPSocket.html#afacf7528ff3c9ac077d7b5a49e2116fd',1,'core::TCPSocket::output()'],['../classcore_1_1TLSSession.html#ae55de8a035d1ddc560cf619b2030af43',1,'core::TLSSession::output()']]] + ['onblockreceived_119',['onBlockReceived',['../classcore_1_1TCPSession2.html#a6c88775e81dc0074ef0832146be9f4b9',1,'core::TCPSession2::onBlockReceived()'],['../classcore_1_1TCPSession.html#a9c996cbbfa2e592c23cf67ed8b15a32a',1,'core::TCPSession::onBlockReceived(coreutils::ZString &block)']]], + ['onconnected_120',['onConnected',['../classcore_1_1TCPSession.html#a8719952f7bb00bf7239ec40aa2868626',1,'core::TCPSession::onConnected()'],['../classcore_1_1TCPSession2.html#af1913cb444a9e07c0f31a2cd8d934a62',1,'core::TCPSession2::onConnected()']]], + ['ondatareceived_121',['onDataReceived',['../classcore_1_1Socket.html#ac8d6a2c54696eb6fc2024cf6bcf6b4e5',1,'core::Socket::onDataReceived()'],['../classcore_1_1TCPServer.html#a276ccbc8cb9b4380ebd78807b97f0159',1,'core::TCPServer::onDataReceived()'],['../classcore_1_1TCPSession.html#afc2d2a92bc65e1e5122a93d120253a1d',1,'core::TCPSession::onDataReceived()'],['../classcore_1_1TCPSession2.html#a67c473e1a22b10fc100ae54206f7471b',1,'core::TCPSession2::onDataReceived()'],['../classcore_1_1UDPServerSocket.html#a41933ca153c854a800e3d047ab18313e',1,'core::UDPServerSocket::onDataReceived()']]], + ['onlinereceived_122',['onLineReceived',['../classcore_1_1TCPSession.html#a3d9e0f14e7d24357fd1950b3f9b4eaff',1,'core::TCPSession::onLineReceived()'],['../classcore_1_1TCPSession2.html#a6cd36b444d9548d1024190c6ba747e18',1,'core::TCPSession2::onLineReceived()']]], + ['onregister_123',['onRegister',['../classcore_1_1TLSSession.html#a76cec7cf4851eb27abe77a2339344c6d',1,'core::TLSSession::onRegister()'],['../classcore_1_1Socket.html#a81e5ee3e17834166d97c6e8b7dfe0da0',1,'core::Socket::onRegister()']]], + ['onregistered_124',['onRegistered',['../classcore_1_1Socket.html#a23b9824653bbe4652a716acb828665b1',1,'core::Socket::onRegistered()'],['../classcore_1_1TCPSession.html#aed4ed499b978bcea57a8efefe929fc98',1,'core::TCPSession::onRegistered()'],['../classcore_1_1TCPSession2.html#a76096659b82c5dcbf6eac1d916511e60',1,'core::TCPSession2::onRegistered()'],['../classcore_1_1TLSSession.html#a8e26fdc9e8a6c573b5a504a1f1b137a9',1,'core::TLSSession::onRegistered()']]], + ['ontimeout_125',['onTimeout',['../classcore_1_1Timer.html#ae51704ff08d985bbc30e3ff4c9b3c6ca',1,'core::Timer']]], + ['onunregistered_126',['onUnregistered',['../classcore_1_1Socket.html#ae9be59697c2b2e5efb19aaae3ba943d2',1,'core::Socket']]], + ['output_127',['output',['../classcore_1_1Command.html#ab6352ce5650e70a5c76c3d6e4eefd292',1,'core::Command::output()'],['../classcore_1_1TCPServer.html#a49e3ead1bf4e7830685780e73c4db5db',1,'core::TCPServer::output()'],['../classcore_1_1TCPSession.html#a50037cbfc515650e04054e5481785981',1,'core::TCPSession::output()'],['../classcore_1_1TCPSession2.html#ae7648a7759570a00d3d4a8c169183291',1,'core::TCPSession2::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 b39f679..7b92908 100644 --- a/html/search/functions_6.js +++ b/html/search/functions_6.js @@ -1,6 +1,6 @@ var searchData= [ - ['processcommand_130',['processCommand',['../classcore_1_1Command.html#a95176f2532c38ee14e3fee40ee28b1bd',1,'core::Command::processCommand()'],['../classcore_1_1CommandList.html#a1819e1cb377b5d8e5e00b4777e2b4aba',1,'core::CommandList::processCommand()'],['../classcore_1_1EPoll.html#a22b5f1545aff3162040844be043abcce',1,'core::EPoll::processCommand()'],['../classcore_1_1SubscriptionManager.html#aaa30bf772ad72b3f319a790662e4f8ae',1,'core::SubscriptionManager::processCommand()'],['../classcore_1_1TCPServer.html#a6b7a7e1ac4132942fcaf418ed41c1437',1,'core::TCPServer::processCommand()']]], - ['processrequest_131',['processRequest',['../classcore_1_1CommandList.html#abcfb26e37e1ee6ff5655ebc3d33b1818',1,'core::CommandList']]], - ['protocol_132',['protocol',['../classcore_1_1ConsoleSession.html#aa1818efcd33a4152d2089aa545f08833',1,'core::ConsoleSession::protocol()'],['../classcore_1_1TCPSession.html#a98a65da2346b79bee659fca6902e94c7',1,'core::TCPSession::protocol()'],['../classcore_1_1TCPSession2.html#a45df5db21355bf7d3585d68789b371ce',1,'core::TCPSession2::protocol()'],['../classcore_1_1TLSSession.html#a208145cc1fcdc14054602aacc2c51d91',1,'core::TLSSession::protocol()']]] + ['processcommand_128',['processCommand',['../classcore_1_1Command.html#a95176f2532c38ee14e3fee40ee28b1bd',1,'core::Command::processCommand()'],['../classcore_1_1CommandList.html#a1819e1cb377b5d8e5e00b4777e2b4aba',1,'core::CommandList::processCommand()'],['../classcore_1_1EPoll.html#a22b5f1545aff3162040844be043abcce',1,'core::EPoll::processCommand()'],['../classcore_1_1SubscriptionManager.html#aaa30bf772ad72b3f319a790662e4f8ae',1,'core::SubscriptionManager::processCommand()'],['../classcore_1_1TCPServer.html#a6b7a7e1ac4132942fcaf418ed41c1437',1,'core::TCPServer::processCommand()']]], + ['processrequest_129',['processRequest',['../classcore_1_1CommandList.html#abcfb26e37e1ee6ff5655ebc3d33b1818',1,'core::CommandList']]], + ['protocol_130',['protocol',['../classcore_1_1ConsoleSession.html#aa1818efcd33a4152d2089aa545f08833',1,'core::ConsoleSession::protocol()'],['../classcore_1_1TCPSession.html#a98a65da2346b79bee659fca6902e94c7',1,'core::TCPSession::protocol()'],['../classcore_1_1TCPSession2.html#a45df5db21355bf7d3585d68789b371ce',1,'core::TCPSession2::protocol()'],['../classcore_1_1TLSSession.html#a208145cc1fcdc14054602aacc2c51d91',1,'core::TLSSession::protocol()']]] ]; diff --git a/html/search/functions_7.js b/html/search/functions_7.js index 4f92135..d05d84e 100644 --- a/html/search/functions_7.js +++ b/html/search/functions_7.js @@ -1,6 +1,5 @@ var searchData= [ - ['receivedata_133',['receiveData',['../classcore_1_1Socket.html#a46ed2e240852d3fa949979ebbc4ac875',1,'core::Socket::receiveData()'],['../classcore_1_1TLSSession.html#a8507cdcd23ac4b340ce6f6d5f0b26a52',1,'core::TLSSession::receiveData()']]], - ['registersocket_134',['registerSocket',['../classcore_1_1EPoll.html#a3d813c7bbf0da70ebc8e3cb6aeeacfb4',1,'core::EPoll']]], - ['remove_135',['remove',['../classcore_1_1CommandList.html#aaac684effb9ecf5238d23ca60d3fffaa',1,'core::CommandList']]] + ['receivedata_131',['receiveData',['../classcore_1_1Socket.html#a46ed2e240852d3fa949979ebbc4ac875',1,'core::Socket::receiveData()'],['../classcore_1_1TLSSession.html#a8507cdcd23ac4b340ce6f6d5f0b26a52',1,'core::TLSSession::receiveData()']]], + ['remove_132',['remove',['../classcore_1_1CommandList.html#aaac684effb9ecf5238d23ca60d3fffaa',1,'core::CommandList']]] ]; diff --git a/html/search/functions_8.js b/html/search/functions_8.js index 9f95bee..42e3f68 100644 --- a/html/search/functions_8.js +++ b/html/search/functions_8.js @@ -1,13 +1,13 @@ var searchData= [ - ['send_136',['send',['../classcore_1_1TCPSession.html#a2b09eeafef5e44009a77d9da43e3b889',1,'core::TCPSession::send()'],['../classcore_1_1TCPSession2.html#aca2f7127b4081fa0e2d2d128083fb0f7',1,'core::TCPSession2::send()']]], - ['sendtoall_137',['sendToAll',['../classcore_1_1TCPServer.html#a7080f7d45e734087e81b83c5e1f8e676',1,'core::TCPServer::sendToAll(std::stringstream &out, TCPSession &sender, SessionFilter filter)'],['../classcore_1_1TCPServer.html#af708df59e1bc60077c16db97f9cc8ff0',1,'core::TCPServer::sendToAll(std::stringstream &out, TCPSession &sender)']]], - ['setblocksize_138',['setBlockSize',['../classcore_1_1TCPSession.html#a836fb3fd5ee543ebc93262a980ae88b5',1,'core::TCPSession::setBlockSize()'],['../classcore_1_1TCPSession2.html#a6f4ed04cd2848e5b903b8331b2e951c8',1,'core::TCPSession2::setBlockSize()']]], - ['setcursorlocation_139',['setCursorLocation',['../classcore_1_1TerminalSession.html#aa9939cbe36c08e1a0b8413a96ca251fa',1,'core::TerminalSession']]], - ['setdescriptor_140',['setDescriptor',['../classcore_1_1Socket.html#ac44f6ae3196a8a3e09a6a85fcf495762',1,'core::Socket']]], - ['settimer_141',['setTimer',['../classcore_1_1Timer.html#ac0a642cdcb76b7f995137162050d3d0b',1,'core::Timer']]], - ['shutdown_142',['shutdown',['../classcore_1_1Socket.html#af2d1b6de7a64a9d446b0305b6ec47b31',1,'core::Socket']]], - ['socket_143',['Socket',['../classcore_1_1Socket.html#a4c3f87fd1de3c9eab4bf5efbb30ce87d',1,'core::Socket']]], - ['start_144',['start',['../classcore_1_1EPoll.html#aaefe2caef75eb538af90cb34682d277b',1,'core::EPoll::start()'],['../classcore_1_1Thread.html#ae6885df9a9b9503669e5776518b19054',1,'core::Thread::start()']]], - ['stop_145',['stop',['../classcore_1_1EPoll.html#a0c2865acd31d14fbf19dbc42cc084ddc',1,'core::EPoll']]] + ['send_133',['send',['../classcore_1_1TCPSession.html#a2b09eeafef5e44009a77d9da43e3b889',1,'core::TCPSession::send()'],['../classcore_1_1TCPSession2.html#aca2f7127b4081fa0e2d2d128083fb0f7',1,'core::TCPSession2::send()']]], + ['sendtoall_134',['sendToAll',['../classcore_1_1TCPServer.html#a7080f7d45e734087e81b83c5e1f8e676',1,'core::TCPServer::sendToAll(std::stringstream &out, TCPSession &sender, SessionFilter filter)'],['../classcore_1_1TCPServer.html#af708df59e1bc60077c16db97f9cc8ff0',1,'core::TCPServer::sendToAll(std::stringstream &out, TCPSession &sender)']]], + ['setblocksize_135',['setBlockSize',['../classcore_1_1TCPSession.html#a836fb3fd5ee543ebc93262a980ae88b5',1,'core::TCPSession::setBlockSize()'],['../classcore_1_1TCPSession2.html#a6f4ed04cd2848e5b903b8331b2e951c8',1,'core::TCPSession2::setBlockSize()']]], + ['setcursorlocation_136',['setCursorLocation',['../classcore_1_1TerminalSession.html#aa9939cbe36c08e1a0b8413a96ca251fa',1,'core::TerminalSession']]], + ['setdescriptor_137',['setDescriptor',['../classcore_1_1Socket.html#ac44f6ae3196a8a3e09a6a85fcf495762',1,'core::Socket']]], + ['settimer_138',['setTimer',['../classcore_1_1Timer.html#ac0a642cdcb76b7f995137162050d3d0b',1,'core::Timer']]], + ['shutdown_139',['shutdown',['../classcore_1_1Socket.html#af2d1b6de7a64a9d446b0305b6ec47b31',1,'core::Socket']]], + ['socket_140',['Socket',['../classcore_1_1Socket.html#a4c3f87fd1de3c9eab4bf5efbb30ce87d',1,'core::Socket']]], + ['start_141',['start',['../classcore_1_1EPoll.html#aaefe2caef75eb538af90cb34682d277b',1,'core::EPoll::start()'],['../classcore_1_1Thread.html#ae6885df9a9b9503669e5776518b19054',1,'core::Thread::start()']]], + ['stop_142',['stop',['../classcore_1_1EPoll.html#a0c2865acd31d14fbf19dbc42cc084ddc',1,'core::EPoll']]] ]; diff --git a/html/search/functions_9.js b/html/search/functions_9.js index 8f94c53..48abaf1 100644 --- a/html/search/functions_9.js +++ b/html/search/functions_9.js @@ -1,6 +1,6 @@ var searchData= [ - ['tcpserver_146',['TCPServer',['../classcore_1_1TCPServer.html#abaecb97c336b757d1029d45277f9fc5b',1,'core::TCPServer']]], - ['terminate_147',['terminate',['../classcore_1_1TCPSession.html#a34936745e8d7669d5400e78d353a56d3',1,'core::TCPSession::terminate()'],['../classcore_1_1TCPSession2.html#a6b999e7ea6551a1b513ee057afaa9e4a',1,'core::TCPSession2::terminate()']]], - ['tlsserver_148',['TLSServer',['../classcore_1_1TLSServer.html#a6460f9872936015efdfd0b8de04aa2fe',1,'core::TLSServer']]] + ['tcpserver_143',['TCPServer',['../classcore_1_1TCPServer.html#abaecb97c336b757d1029d45277f9fc5b',1,'core::TCPServer']]], + ['terminate_144',['terminate',['../classcore_1_1TCPSession.html#a34936745e8d7669d5400e78d353a56d3',1,'core::TCPSession::terminate()'],['../classcore_1_1TCPSession2.html#a6b999e7ea6551a1b513ee057afaa9e4a',1,'core::TCPSession2::terminate()']]], + ['tlsserver_145',['TLSServer',['../classcore_1_1TLSServer.html#a6460f9872936015efdfd0b8de04aa2fe',1,'core::TLSServer']]] ]; diff --git a/html/search/functions_a.js b/html/search/functions_a.js index 6b40b01..a733b17 100644 --- a/html/search/functions_a.js +++ b/html/search/functions_a.js @@ -1,4 +1,4 @@ var searchData= [ - ['unregistersocket_149',['unregisterSocket',['../classcore_1_1EPoll.html#a5ab5e82ab51e0952fc8fbcc128f52900',1,'core::EPoll']]] + ['write_146',['write',['../classcore_1_1Socket.html#a1413c826307ef0f29d7457770af675e3',1,'core::Socket']]] ]; diff --git a/html/search/functions_b.js b/html/search/functions_b.js index f59c408..12d3f0e 100644 --- a/html/search/functions_b.js +++ b/html/search/functions_b.js @@ -1,4 +1,7 @@ var searchData= [ - ['write_150',['write',['../classcore_1_1Socket.html#a1413c826307ef0f29d7457770af675e3',1,'core::Socket']]] + ['_7eepoll_147',['~EPoll',['../classcore_1_1EPoll.html#a8e7a2496d684b745a6410f9bd3e88534',1,'core::EPoll']]], + ['_7esocket_148',['~Socket',['../classcore_1_1Socket.html#aa5003845f8ae464ad2fa206176381be0',1,'core::Socket']]], + ['_7etcpserver_149',['~TCPServer',['../classcore_1_1TCPServer.html#a7ccdc057c9eee8504fce796301f82088',1,'core::TCPServer']]], + ['_7etlsserver_150',['~TLSServer',['../classcore_1_1TLSServer.html#ac71db77c796a1bf65357409cb96054c7',1,'core::TLSServer']]] ]; diff --git a/html/search/searchdata.js b/html/search/searchdata.js index 3132f51..827e91d 100644 --- a/html/search/searchdata.js +++ b/html/search/searchdata.js @@ -2,7 +2,7 @@ var indexSectionsWithContent = { 0: "abcegimoprstuw~", 1: "ceiostu", - 2: "acegioprstuw~", + 2: "acegioprstw~", 3: "abcmosuw" }; diff --git a/html/search/variables_0.js b/html/search/variables_0.js index ba3eff7..194373d 100644 --- a/html/search/variables_0.js +++ b/html/search/variables_0.js @@ -1,4 +1,4 @@ var searchData= [ - ['alias_155',['alias',['../classcore_1_1TCPSession.html#a014ae6b1465bf36606763703aa8a930d',1,'core::TCPSession']]] + ['alias_151',['alias',['../classcore_1_1TCPSession.html#a014ae6b1465bf36606763703aa8a930d',1,'core::TCPSession']]] ]; diff --git a/html/search/variables_1.js b/html/search/variables_1.js index df050d9..c9ad44d 100644 --- a/html/search/variables_1.js +++ b/html/search/variables_1.js @@ -1,4 +1,4 @@ var searchData= [ - ['blacklist_156',['blackList',['../classcore_1_1TCPServer.html#a82f6bf16e4ab20d8b30da09e034fffff',1,'core::TCPServer']]] + ['blacklist_152',['blackList',['../classcore_1_1TCPServer.html#a82f6bf16e4ab20d8b30da09e034fffff',1,'core::TCPServer']]] ]; diff --git a/html/search/variables_2.js b/html/search/variables_2.js index 684ae64..d45db33 100644 --- a/html/search/variables_2.js +++ b/html/search/variables_2.js @@ -1,4 +1,4 @@ var searchData= [ - ['commands_157',['commands',['../classcore_1_1CommandList.html#ad0aedf95828fe743908d8423f171ff36',1,'core::CommandList::commands()'],['../classcore_1_1TCPServer.html#afcc44802b988e2f4292504e804dccf8b',1,'core::TCPServer::commands()']]] + ['commands_153',['commands',['../classcore_1_1CommandList.html#ad0aedf95828fe743908d8423f171ff36',1,'core::CommandList::commands()'],['../classcore_1_1TCPServer.html#afcc44802b988e2f4292504e804dccf8b',1,'core::TCPServer::commands()']]] ]; diff --git a/html/search/variables_3.js b/html/search/variables_3.js index a68b1d4..cad56fb 100644 --- a/html/search/variables_3.js +++ b/html/search/variables_3.js @@ -1,4 +1,4 @@ var searchData= [ - ['maxsockets_158',['maxSockets',['../classcore_1_1EPoll.html#acfcef2513d94f7b9a191fed3dc744d90',1,'core::EPoll']]] + ['maxsockets_154',['maxSockets',['../classcore_1_1EPoll.html#acfcef2513d94f7b9a191fed3dc744d90',1,'core::EPoll']]] ]; diff --git a/html/search/variables_4.js b/html/search/variables_4.js index 8739eec..0a488b2 100644 --- a/html/search/variables_4.js +++ b/html/search/variables_4.js @@ -1,4 +1,4 @@ var searchData= [ - ['out_159',['out',['../classcore_1_1TCPSession.html#abb302bbb3d7e7bc75490c736364f0d4d',1,'core::TCPSession::out()'],['../classcore_1_1TCPSession2.html#a6b8005e611b6007a00ad3288973a522d',1,'core::TCPSession2::out()']]] + ['out_155',['out',['../classcore_1_1TCPSession.html#abb302bbb3d7e7bc75490c736364f0d4d',1,'core::TCPSession::out()'],['../classcore_1_1TCPSession2.html#a6b8005e611b6007a00ad3288973a522d',1,'core::TCPSession2::out()']]] ]; diff --git a/html/search/variables_5.js b/html/search/variables_5.js index bbccafe..7a8a437 100644 --- a/html/search/variables_5.js +++ b/html/search/variables_5.js @@ -1,5 +1,5 @@ var searchData= [ - ['sessions_160',['sessions',['../classcore_1_1TCPServer.html#aeed1bc55d099667ccda51cd682bfc633',1,'core::TCPServer']]], - ['subscriptions_161',['subscriptions',['../classcore_1_1TCPServer.html#a28302dd844cfc971ee41de2000d24aa0',1,'core::TCPServer']]] + ['sessions_156',['sessions',['../classcore_1_1TCPServer.html#aeed1bc55d099667ccda51cd682bfc633',1,'core::TCPServer']]], + ['subscriptions_157',['subscriptions',['../classcore_1_1TCPServer.html#a28302dd844cfc971ee41de2000d24aa0',1,'core::TCPServer']]] ]; diff --git a/latex/classcore_1_1EPoll.tex b/latex/classcore_1_1EPoll.tex index a5d1bcd..e3d4646 100644 --- a/latex/classcore_1_1EPoll.tex +++ b/latex/classcore_1_1EPoll.tex @@ -35,19 +35,12 @@ bool \mbox{\hyperlink{classcore_1_1EPoll_a0c2865acd31d14fbf19dbc42cc084ddc}{stop \begin{DoxyCompactList}\small\item\em Stop and shut down the BMAEPoll processing. \end{DoxyCompactList}\item bool \mbox{\hyperlink{classcore_1_1EPoll_a301b46b71ac7ac61a687ff723fe269b3}{is\+Stopping}} () \begin{DoxyCompactList}\small\item\em Returns a true if the stop command has been requested. \end{DoxyCompactList}\item -bool \mbox{\hyperlink{classcore_1_1EPoll_a3d813c7bbf0da70ebc8e3cb6aeeacfb4}{register\+Socket}} (\mbox{\hyperlink{classcore_1_1Socket}{Socket}} $\ast$socket) -\begin{DoxyCompactList}\small\item\em Register a BMASocket for monitoring by BMAEPoll. \end{DoxyCompactList}\item -bool \mbox{\hyperlink{classcore_1_1EPoll_a5ab5e82ab51e0952fc8fbcc128f52900}{unregister\+Socket}} (\mbox{\hyperlink{classcore_1_1Socket}{Socket}} $\ast$socket) -\begin{DoxyCompactList}\small\item\em Unregister a BMASocket from monitoring by BMAEPoll. \end{DoxyCompactList}\item int \mbox{\hyperlink{classcore_1_1EPoll_a1e52017e1deae15c1c87c6b6a099e1ed}{get\+Descriptor}} () \begin{DoxyCompactList}\small\item\em Return the descriptor for the e\+Poll socket. \end{DoxyCompactList}\item void \mbox{\hyperlink{classcore_1_1EPoll_a3238b150b5d0a57eb2e1b17daa236d3b}{event\+Received}} (struct epoll\+\_\+event event) \begin{DoxyCompactList}\small\item\em Dispatch event to appropriate socket. \end{DoxyCompactList}\item int \mbox{\hyperlink{classcore_1_1EPoll_a22b5f1545aff3162040844be043abcce}{process\+Command}} (coreutils\+::\+ZString \&request, \mbox{\hyperlink{classcore_1_1TCPSession}{TCPSession}} \&session) override -\begin{DoxyCompactList}\small\item\em Output the threads array to the console. \end{DoxyCompactList}\item -\mbox{\Hypertarget{classcore_1_1EPoll_a033633714311f3edc4127ddd1c37f299}\label{classcore_1_1EPoll_a033633714311f3edc4127ddd1c37f299}} -void {\bfseries reset\+Socket} (\mbox{\hyperlink{classcore_1_1Socket}{Socket}} $\ast$socket) -\end{DoxyCompactItemize} +\begin{DoxyCompactList}\small\item\em Output the threads array to the console. \end{DoxyCompactList}\end{DoxyCompactItemize} \doxysubsection*{Public Attributes} \begin{DoxyCompactItemize} \item @@ -138,26 +131,6 @@ The \mbox{\hyperlink{classcore_1_1EPoll_a22b5f1545aff3162040844be043abcce}{proce Reimplemented from \mbox{\hyperlink{classcore_1_1Command_a95176f2532c38ee14e3fee40ee28b1bd}{core\+::\+Command}}. -\mbox{\Hypertarget{classcore_1_1EPoll_a3d813c7bbf0da70ebc8e3cb6aeeacfb4}\label{classcore_1_1EPoll_a3d813c7bbf0da70ebc8e3cb6aeeacfb4}} -\index{core::EPoll@{core::EPoll}!registerSocket@{registerSocket}} -\index{registerSocket@{registerSocket}!core::EPoll@{core::EPoll}} -\doxysubsubsection{\texorpdfstring{registerSocket()}{registerSocket()}} -{\footnotesize\ttfamily bool core\+::\+EPoll\+::register\+Socket (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{classcore_1_1Socket}{Socket}} $\ast$}]{socket }\end{DoxyParamCaption})} - - - -Register a BMASocket for monitoring by BMAEPoll. - -Use register\+Socket to add a new socket to the e\+Poll event watch list. This enables a new BMASocket object to receive events when data is received as well as to write data output to the socket. - - -\begin{DoxyParams}{Parameters} -{\em socket} & a pointer to a BMASocket object. \\ -\hline -\end{DoxyParams} -\begin{DoxyReturn}{Returns} -a booelean that indicates the socket was registered or not. -\end{DoxyReturn} \mbox{\Hypertarget{classcore_1_1EPoll_aaefe2caef75eb538af90cb34682d277b}\label{classcore_1_1EPoll_aaefe2caef75eb538af90cb34682d277b}} \index{core::EPoll@{core::EPoll}!start@{start}} \index{start@{start}!core::EPoll@{core::EPoll}} @@ -189,17 +162,7 @@ Stop and shut down the BMAEPoll processing. Use the \mbox{\hyperlink{classcore_1_1EPoll_a0c2865acd31d14fbf19dbc42cc084ddc}{stop()}} method to initiate the shutdown process for the epoll socket management. -A complete shutdown of all managed sockets will be initiated by this method call. \mbox{\Hypertarget{classcore_1_1EPoll_a5ab5e82ab51e0952fc8fbcc128f52900}\label{classcore_1_1EPoll_a5ab5e82ab51e0952fc8fbcc128f52900}} -\index{core::EPoll@{core::EPoll}!unregisterSocket@{unregisterSocket}} -\index{unregisterSocket@{unregisterSocket}!core::EPoll@{core::EPoll}} -\doxysubsubsection{\texorpdfstring{unregisterSocket()}{unregisterSocket()}} -{\footnotesize\ttfamily bool core\+::\+EPoll\+::unregister\+Socket (\begin{DoxyParamCaption}\item[{\mbox{\hyperlink{classcore_1_1Socket}{Socket}} $\ast$}]{socket }\end{DoxyParamCaption})} - - - -Unregister a BMASocket from monitoring by BMAEPoll. - -Use this method to remove a socket from receiving events from the epoll system. +A complete shutdown of all managed sockets will be initiated by this method call. \doxysubsection{Member Data Documentation} \mbox{\Hypertarget{classcore_1_1EPoll_acfcef2513d94f7b9a191fed3dc744d90}\label{classcore_1_1EPoll_acfcef2513d94f7b9a191fed3dc744d90}} diff --git a/latex/classcore_1_1Socket.tex b/latex/classcore_1_1Socket.tex index 8855979..683fa67 100644 --- a/latex/classcore_1_1Socket.tex +++ b/latex/classcore_1_1Socket.tex @@ -58,6 +58,12 @@ virtual void \mbox{\hyperlink{classcore_1_1Socket_ae9be59697c2b2e5efb19aaae3ba94 \begin{DoxyCompactList}\small\item\em Called when the socket has finished unregistering for the epoll processing. \end{DoxyCompactList}\item \mbox{\Hypertarget{classcore_1_1Socket_a43247bfe43c2be5ab3863d9057d46b7c}\label{classcore_1_1Socket_a43247bfe43c2be5ab3863d9057d46b7c}} bool {\bfseries needs\+To\+Write} () +\item +\mbox{\Hypertarget{classcore_1_1Socket_a04a41baed2feb95cab02d6e61d4f33ce}\label{classcore_1_1Socket_a04a41baed2feb95cab02d6e61d4f33ce}} +void {\bfseries enable\+Socket} () +\item +\mbox{\Hypertarget{classcore_1_1Socket_a2ff4d1d1240f8a51cf19d620b4f51f20}\label{classcore_1_1Socket_a2ff4d1d1240f8a51cf19d620b4f51f20}} +void {\bfseries disable\+Socket} () \end{DoxyCompactItemize} \doxysubsection*{Public Attributes} \begin{DoxyCompactItemize}

    Additional Inherited Members