server.h

Go to the documentation of this file.

 
#ifndef C_CHAT_CLIENT_H
#define C_CHAT_CLIENT_H
 
#include "../common/sockets.h"
#include "../common/constants.h"
#include "../common/threads.h"
#include "../common/packets.h"
#include "../common/synchronization.h"
 
#define NUMBER_CLIENT_MAX 10
 
struct Room;
 
typedef struct Client {
    Socket socket;
    char username[USERNAME_MAX_LENGTH + 1];
    short joined;
    Thread thread;
 
    // TODO: Implement in a better way
    /* Upload */
    struct {
        unsigned int fileId;
        long long fileSize;
        long long received;
        char* fileContent;
    } uploadData[MAX_CONCURRENT_FILE_TRANSFER];
    /* Download */
    struct {
        Thread downloadThread;
        unsigned int downloadedFileId;
    } downloadData[MAX_CONCURRENT_FILE_TRANSFER];
 
    struct Room* room;
} Client;
 
typedef struct Room {
    char name[ROOM_NAME_MAX_LENGTH + 1];
    char description[ROOM_DESC_MAX_LENGTH + 1];
    Client* clients[MAX_USERS_PER_ROOM];
    Client* owner;
    ReadWriteLock lock;
} Room;
 
extern ReadWriteLock clientsLock;
extern ReadWriteLock roomsLock;
extern Client* clients[NUMBER_CLIENT_MAX];
extern Room* rooms[NUMBER_ROOM_MAX];
 
#define SYNC_CLIENT_READ(op)     \
acquireRead(clientsLock);        \
op;                              \
releaseRead(clientsLock);
 
#define SYNC_CLIENT_WRITE(op)     \
acquireWrite(clientsLock);        \
op;                               \
releaseWrite(clientsLock);
 
#define SYNC_ROOMS_READ(op)       \
acquireRead(roomsLock);           \
op;                               \
releaseRead(roomsLock);
 
#define SYNC_ROOMS_WRITE(op)      \
acquireWrite(roomsLock);          \
op;                               \
releaseWrite(roomsLock);
 
#define SYNC_ROOM_READ(room, op)  \
acquireRead(room->lock);          \
op;                               \
releaseRead(room->lock);
 
#define SYNC_ROOM_READ(room, op)  \
acquireRead(room->lock);          \
op;                               \
releaseRead(room->lock);
 
void handleServerClose(int signal);
 
void handleClientsPackets(Client* client);
 
#endif //C_CHAT_CLIENT_H