chatserver.h

Go to the documentation of this file.

#ifndef CHATSERVER_H
#define CHATSERVER_H

#include <pthread.h>

#define BACKLOG_SIZE 1000

typedef enum {
  LOGIN_MSG = 0x1,
  LOGOUT_MSG = 0x2,
  TEXT_MSG = 0x3,
  USERNAME_NOT_EXIST = 0x4,
  USER_ALREADY_LOGGED = 0x5,
  USERS_LOGGED_REQUEST = 0x6,
  USERS_LOGGED_RESPONSE = 0x7,
  BROADCAST_MSG = 0x8,
  UKNOWN_MSG_TYPE = 0xFE,
  GENERAL_ERROR = 0xFF
} msg_type_t;


typedef struct connection{
  int socket_discriptor; 
  char *username;        
  char *ip;              
  bool is_logged_in;  
  struct connection *previous;
  struct connection *next;
} connection_t;

typedef struct client_thread_params {
  connection_t *active_connections_list; 
  connection_t *client_connection;       
} client_thread_params_t;

typedef struct broadcast_invitation_tread_params {
  int port;                             
  char *server_ip;                      
  int refresh_rate;                     
} broadcast_invitation_tread_params_t;


class chatserver {
private:
  int d_port_number;
  connection_t *d_connections_list;
   /* 3 different global counters
    * NOTE; These counters are accessed
    * simutanously by all threads, so race conditions
    * may rise. Go to the threads lab and check
    * about race conditions and locking.
    * 
    * Some setters and getters functions may
    * need to access those counters
    */

  unsigned long int d_total_msgs_received;
  unsigned long int d_total_bytes_sent;
  unsigned long int d_total_bytes_received;
  
   /*
    * Three different mutexes that you are going to use for
    * locking in your threads.
    */
  pthread_mutex_t d_print_mutex;
  pthread_mutex_t d_counters_mutex;
  pthread_mutex_t d_active_connections_mutex;
  
public:
  chatserver(int port, bool automatic_server_discovery);
  
  int create_tcp_server_socket();
  
  void *print_stats_counters_thread(void *refresh_rate);
  
  void handle_incoming_connections(int server_socket);
  
  void *handle_client_connection_thread(void *thread_parameter);
  
  msg_type_t get_message_type(char *buffer, size_t buf_len);

  int send_to_client_online_users(connection_t *client_connection);
  
  bool handle_login_message(connection_t *client_connection,
                               char *buffer,
                               size_t buf_len);

  bool handle_logout_message( connection_t *client_connection);
  
  
  int handle_text_message(connection_t *client_connection,
                          char *buffer,
                          size_t buf_len);

  int send_back_error_message(connection_t *client_connection,
                              msg_type_t error_type,
                              char *msg_content,
                              size_t msg_content_len);
  
  void *broadcast_invitation_tread(void *broadcast_params);
  
  
};

#endif