1 files changed, 59 insertions, 0 deletions
diff --git a/ychat-0.1/sock.h b/ychat-0.1/sock.h
new file mode 100644
index 0000000..9893007
--- /dev/null
+++ b/ychat-0.1/sock.h
@@ -0,0 +1,59 @@
+// class sock declaration.
+
+#ifndef SOCK_H
+#define SOCK_H
+
+#include <queue>
+#include <arpa/inet.h>
+#include <errno.h>
+#include <netdb.h>
+#include <netinet/in.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <unistd.h>
+
+#include "incl.h"
+#include "reqp.h"
+#include "thrd.h"
+
+using namespace std;
+
+class sock 
+{
+private:
+ // total number of server requests. 
+ unsigned long long int i_req; 
+ queue<pthread_t> thrd_pool;
+
+ int i_thrd_pool_size;
+
+ bool  b_run;      // true while socket manager is running.
+ reqp* req_parser; // parses the http requests from clients.
+
+ // the chat stream there all the chat messages will sent through.
+#ifdef THRDMOD
+ static void chat_stream( int i_sock, map_string &map_params );
+#else
+ static void chat_stream( int i_sock, map_string &map_params, queue<pthread_t> &thrd_pool );
+#endif
+ virtual int make_socket( uint16_t port );
+
+ static void *posix_thread_func ( void *v_pointer );
+ static void *posix_thread_func_( void *v_pointer );
+
+public:
+ // small inline methods:
+ bool get_run() const { return b_run; }
+ bool set_run( bool b_run ) { this->b_run = b_run; }
+
+ // public methods.
+ explicit sock( ); // simple constructor.
+ virtual int  read_write( int filedes   );
+ virtual int  start();
+
+ virtual void refill_thrd_pool( ); // refills the thread pool with new thewads.
+};
+
+#endif