diff --git a/html/Socket_8h_source.html b/html/Socket_8h_source.html index d051b50..b298065 100644 --- a/html/Socket_8h_source.html +++ b/html/Socket_8h_source.html @@ -95,101 +95,101 @@ $(function() {
67 
68  int getDescriptor();
69 
-
79 
-
80  bool eventReceived(struct epoll_event event);
-
81 
-
85 
-
86  int write(std::string data);
-
87  void write(char *buffer, int length);
-
88 
-
89  void output(std::stringstream &out);
-
90 
-
97 
-
98  virtual void onRegister();
-
99  virtual void onRegistered();
-
100 
-
101  virtual void onUnregister();
-
102 
-
109 
-
110  virtual void onUnregistered();
-
111 
-
112  bool needsToWrite();
-
113 
-
114  bool reset = false;
-
115 
-
116  protected:
-
117 
-
118  EPoll &ePoll; // The EPoll control object.
-
119 
-
120  bool shutDown = false;
-
121 
-
122  void setBufferSize(int length);
-
123 
-
124  int getBufferSize();
-
125 
-
131 
-
132 // virtual void onConnected(); ///< Called when socket is open and ready to communicate.
-
133 
-
137 
-
138 // virtual void onDisconnected(); ///< Called when socket is closing and no longer ready to communicate.
-
139 
-
147 
-
148  virtual void onDataReceived(std::string data);
-
149 
-
153 
-
154  virtual void onDataReceived(coreutils::ZString &data);
-
155 
-
160 
-
161  virtual void receiveData(coreutils::ZString &buffer);
-
162 
-
163  private:
-
164 
-
165  std::string text;
-
166  int descriptor = -1;
-
167  std::mutex lock;
-
168  std::mutex outlock;
-
169  bool readHangup = false;
-
170 
-
171 // struct epoll_event event; // Event selection construction structure.
-
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.
+
82 
+
83  bool eventReceived(struct epoll_event event);
+
84 
+
88 
+
89  int write(std::string data);
+
90  void write(char *buffer, int length);
+
91 
+
92  void output(std::stringstream &out);
+
93 
+
100 
+
101  virtual void onRegister();
+
102  virtual void onRegistered();
+
103 
+
104  virtual void onUnregister();
+
105 
+
112 
+
113  virtual void onUnregistered();
+
114 
+
115  bool needsToWrite();
+
116 
+
117  bool reset = false;
+
118 
+
119  protected:
+
120 
+
121  EPoll &ePoll; // The EPoll control object.
+
122 
+
123  bool shutDown = false;
+
124 
+
125  void setBufferSize(int length);
+
126 
+
127  int getBufferSize();
+
128 
+
134 
+
135 // virtual void onConnected(); ///< Called when socket is open and ready to communicate.
+
136 
+
140 
+
141 // virtual void onDisconnected(); ///< Called when socket is closing and no longer ready to communicate.
+
142 
+
150 
+
151  virtual void onDataReceived(std::string data);
+
152 
+
156 
+
157  virtual void onDataReceived(coreutils::ZString &data);
+
158 
+
163 
+
164  virtual void receiveData(coreutils::ZString &buffer);
+
165 
+
166  private:
+
167 
+
168  std::string text;
+
169  int descriptor = -1;
+
170  std::mutex lock;
+
171  std::mutex outlock;
+
172  bool readHangup = false;
+
173 
+
174 // struct epoll_event event; // Event selection construction structure.
+
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 // const char * const begin_;
-
191 // const char * const end_;
-
192 // const char * const current_;
-
193 
-
194  std::queue<std::string> fifo;
-
195 
-
196  };
-
197 
-
198 }
-
199 
-
200 #endif
-
201 
+
190  char *buffer; // This is a pointer to the managed buffer space.
+
191  int length; // This is the length of the buffer.
+
192 
+
193 // const char * const begin_;
+
194 // const char * const end_;
+
195 // const char * const current_;
+
196 
+
197  std::queue<std::string> fifo;
+
198 
+
199  };
+
200 
+
201 }
+
202 
+
203 #endif
+
204 
core::Socket
Definition: Socket.h:34
-
core::Socket::write
int write(std::string data)
Definition: Socket.cpp:154
+
core::Socket::write
int write(std::string data)
Definition: Socket.cpp:149
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:57
-
core::Socket::receiveData
virtual void receiveData(coreutils::ZString &buffer)
Definition: Socket.cpp:103
-
core::Socket::onDataReceived
virtual void onDataReceived(std::string data)
Called when data is received from the socket.
Definition: Socket.cpp:95
+
core::Socket::receiveData
virtual void receiveData(coreutils::ZString &buffer)
Definition: Socket.cpp:98
+
core::Socket::onDataReceived
virtual void onDataReceived(std::string data)
Called when data is received from the socket.
Definition: Socket.cpp:90
core::Socket::Socket
Socket(EPoll &ePoll, std::string text="")
Definition: Socket.cpp:9
-
core::Socket::shutdown
void shutdown(std::string text="unknown")
Definition: Socket.cpp:170
+
core::Socket::shutdown
void shutdown(std::string text="unknown")
Definition: Socket.cpp:165
core::Socket::onRegister
virtual void onRegister()
Called before the socket has registered with the epoll processing.
Definition: Socket.cpp:55
core::Socket::eventReceived
bool eventReceived(struct epoll_event event)
Parse epoll event and call specified callbacks.
Definition: Socket.cpp:63
core::Socket::onUnregistered
virtual void onUnregistered()
Called when the socket has finished unregistering for the epoll processing.
Definition: Socket.cpp:61
diff --git a/html/SubscriptionManager_8h_source.html b/html/SubscriptionManager_8h_source.html index 1f5d32c..baaaf08 100644 --- a/html/SubscriptionManager_8h_source.html +++ b/html/SubscriptionManager_8h_source.html @@ -99,7 +99,7 @@ $(function() {
core::TCPSession
Definition: TCPSession.h:24
core::SubscriptionManager
Definition: SubscriptionManager.h:13
core::Subscription
Definition: Subscription.h:12
-
core::SubscriptionManager::processCommand
int processCommand(coreutils::ZString &request, TCPSession &session) override
Definition: SubscriptionManager.cpp:31
+
core::SubscriptionManager::processCommand
int processCommand(coreutils::ZString &request, TCPSession &session) override
Definition: SubscriptionManager.cpp:40
core::Command
Definition: Command.h:22