From 7a0155ba2ccf24098cea2c62e8cabeecad95f657 Mon Sep 17 00:00:00 2001 From: Brad Arant Date: Tue, 15 Mar 2022 20:09:11 -0700 Subject: [PATCH] ServerCore modifications. --- html/Socket_8h_source.html | 178 ++++++++++---------- html/SubscriptionManager_8h_source.html | 2 +- html/Subscription_8h_source.html | 29 ++-- html/TCPSession_8h_source.html | 20 +-- html/ThreadScope_8h_source.html | 92 ++++++++++ html/Thread_8h_source.html | 76 +++++---- html/annotated.html | 11 +- html/classcore_1_1Socket.html | 5 +- html/classcore_1_1Subscription-members.html | 6 +- html/classcore_1_1Subscription.html | 18 +- html/classcore_1_1Thread-members.html | 3 +- html/classcore_1_1Thread.html | 3 + html/classcore_1_1ThreadScope-members.html | 84 +++++++++ html/classcore_1_1ThreadScope.html | 85 ++++++++++ html/classes.html | 24 +-- html/files.html | 11 +- html/hierarchy.html | 1 + html/inherit_graph_2.md5 | 2 +- html/inherit_graph_4.map | 3 + html/inherit_graph_4.md5 | 1 + html/inherit_graph_4.png | Bin 0 -> 1697 bytes html/inherits.html | 5 + html/search/all_b.js | 7 +- html/search/all_c.js | 6 +- html/search/all_d.js | 4 +- html/search/all_e.js | 8 +- html/search/classes_0.js | 8 +- html/search/classes_1.js | 2 +- html/search/classes_2.js | 6 +- html/search/classes_3.js | 2 +- html/search/classes_4.js | 8 +- html/search/classes_5.js | 17 +- 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 | 14 +- html/search/functions_4.js | 2 +- html/search/functions_5.js | 18 +- html/search/functions_6.js | 6 +- html/search/functions_7.js | 6 +- html/search/functions_8.js | 20 +-- html/search/functions_9.js | 6 +- html/search/functions_a.js | 2 +- html/search/functions_b.js | 2 +- html/search/functions_c.js | 8 +- html/search/variables_0.js | 2 +- html/search/variables_1.js | 2 +- html/search/variables_2.js | 2 +- html/search/variables_3.js | 2 +- html/search/variables_4.js | 4 +- html/search/variables_5.js | 2 +- latex/annotated.tex | 1 + latex/classcore_1_1Socket.tex | 6 +- latex/classcore_1_1Subscription.tex | 14 +- latex/classcore_1_1Thread.tex | 3 + latex/classcore_1_1ThreadScope.tex | 7 + latex/hierarchy.tex | 1 + latex/refman.tex | 1 + 59 files changed, 595 insertions(+), 279 deletions(-) create mode 100644 html/ThreadScope_8h_source.html create mode 100644 html/classcore_1_1ThreadScope-members.html create mode 100644 html/classcore_1_1ThreadScope.html create mode 100644 html/inherit_graph_4.map create mode 100644 html/inherit_graph_4.md5 create mode 100644 html/inherit_graph_4.png create mode 100644 latex/classcore_1_1ThreadScope.tex 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 
Definition: Socket.h:34
-
int write(std::string data)
Definition: Socket.cpp:154
+
int write(std::string data)
Definition: Socket.cpp:149
Definition: EPoll.h:31
virtual void onRegistered()
Called after the socket has been registered with epoll processing.
Definition: Socket.cpp:57
-
virtual void receiveData(coreutils::ZString &buffer)
Definition: Socket.cpp:103
-
virtual void onDataReceived(std::string data)
Called when data is received from the socket.
Definition: Socket.cpp:95
+
virtual void receiveData(coreutils::ZString &buffer)
Definition: Socket.cpp:98
+
virtual void onDataReceived(std::string data)
Called when data is received from the socket.
Definition: Socket.cpp:90
Socket(EPoll &ePoll, std::string text="")
Definition: Socket.cpp:9
-
void shutdown(std::string text="unknown")
Definition: Socket.cpp:170
+
void shutdown(std::string text="unknown")
Definition: Socket.cpp:165
virtual void onRegister()
Called before the socket has registered with the epoll processing.
Definition: Socket.cpp:55
bool eventReceived(struct epoll_event event)
Parse epoll event and call specified callbacks.
Definition: Socket.cpp:63
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() {
Definition: TCPSession.h:24
Definition: SubscriptionManager.h:13
Definition: Subscription.h:12
-
int processCommand(coreutils::ZString &request, TCPSession &session) override
Definition: SubscriptionManager.cpp:31
+
int processCommand(coreutils::ZString &request, TCPSession &session) override
Definition: SubscriptionManager.cpp:40
Definition: Command.h:22