#ifndef INCLUDED_SYNC_MAIL_MANAGER
#define INCLUDED_SYNC_MAIL_MANAGER

#include <pthread.h>
#include "MailManager.h"
#include "types.h"
#include "Sem.h"

class SynchronizedMailManager : public MailManager {
public:
    /* constructor */
    SynchronizedMailManager(unsigned int qsize = 32);

    ~SynchronizedMailManager();

    /* functions */
    void send(memaddr data);
    memaddr recv();
    int count();
    virtual void set_waiter(SemPtr w);

private:
    /* variables */
    memaddr *queue;
    SemPtr queue_remain;
    SemPtr queue_count;
    SemPtr ppe_waiter;  // shared among all synchronizedMailManager
    unsigned int size;
    unsigned int read;
    unsigned int write;
    unsigned int mask;

    void calc_mask(unsigned int qsize);
    void extend();
}  ;

typedef SynchronizedMailManager *SynchronizedMailManagerPtr;

#endif