1 files changed, 37 insertions, 43 deletions
diff --git a/src/sock/sock.h b/src/sock/sock.h
index 0d93543..079dfd8 100755
--- a/src/sock/sock.h
+++ b/src/sock/sock.h
@@ -3,71 +3,65 @@
 #ifndef SOCK_H
 #define SOCK_H
 
+
 #include <queue>
 #include <stdio.h>
 #include <stdlib.h>
 #include <sys/socket.h>
 #include <netinet/in.h>
 #include <netdb.h>
-
 #include "../thrd/pool.h"
+#include "../thrd/thrd.h"
 #include "../reqp.h"
-#include "../chat/user.h"
-
-#ifdef LOGGING
 #include "../logd.h"
-#endif
-
-#include "../maps/hashmap.h"
 
 using namespace std;
 
 class sock
 {
 private:
-  // total number of server requests.
-  unsigned long long i_req;
-
-  bool  b_run;      // true while socket manager is running.
-  reqp *req_parser; // parses the http requests from clients.
-  pool *thrd_pool;  // the thread pool.
-#ifdef LOGGING
+    // total number of server requests.
+    unsigned long long int i_req;
 
-  logd *log_daemon; // the log daemon
-#endif
+    bool  b_run;      // true while socket manager is running.
+    reqp* req_parser; // parses the http requests from clients.
+    pool* thrd_pool;  // the thread pool.
+    logd* log_daemon; // the log daemon
+    char* c_buffer;   // char buffer!
 
-  char *c_buffer;   // char buffer!
-  int   i_threads;  // total amount of threads inside the thread pool.
+    int   i_threads;     // total amount of threads inside the thread pool.
+    pthread_mutex_t mut_threads;
+    pthread_mutex_t mut_hits;
 
-  pthread_mutex_t mut_hits;
 
 public:
-  // creates a server socket.
-  int make_server_socket( int i_port );
-
-  // small inline methods:
-  bool get_run() const
-  {
-    return b_run;
-  }
-
-  bool set_run( bool b_run )
-  {
-    this->b_run = b_run;
-  }
-
-  sock( );
-  ~sock( );
-
-  int read_write( int* p_sock );
-  int start();
-
-  // the chat stream there all the chat messages will sent through.
-  static void chat_stream( int i_sock, user* p_user, hashmap<string> &map_params ); //<<
-
+    // creates a server socket.
+    int make_server_socket( int port );
+
+    // 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.
+    ~sock( );
+    virtual int  read_write( thrd* p_thrd, int filedes   );
+    virtual int  start();
+
+    // the chat stream there all the chat messages will sent through.
+
+    void increase_num_threads();
+    void decrease_num_threads();
 #ifdef NCURSES
 
-  void print_hits();
+    void print_threads();
+    void print_hits();
 #endif
 
 };