shared_buffer.h

Go to the documentation of this file.

#ifndef SHARED_BUFFER_H
#define SHARED_BUFFER_H

#include <string>
#include <utility>
#include <list>
#include <pthread.h>

#include "threading_error.h"

class SharedBuffer {
        public:
                typedef unsigned long MessageId;

                typedef std::pair<std::string, MessageId> MessageWithId;

        private:
                typedef std::list<MessageWithId> Buffer;

        public:
                SharedBuffer();

                ~SharedBuffer();

                SharedBuffer(const SharedBuffer &other);

                SharedBuffer & operator=(const SharedBuffer &other);

                bool operator==(const SharedBuffer &other);

                bool operator==(const SharedBuffer &other) const;

                bool operator!=(const SharedBuffer &other);

                bool operator!=(const SharedBuffer &other) const;

                Buffer::size_type size();

                Buffer::size_type size() const;

                MessageWithId getMessage();

                void addMessage(const std::string &message);

                void removeMessage(MessageId messageId);

                void changeMessage(MessageId messageId, const std::string &newMessage);

        public:
                static const MessageWithId INVALID_MESSAGE;

        private:
                void lockBufferMutex();

                void unlockBufferMutex();

                MessageId generateNewMessageId();

                void initializeBufferMutex();

                void swap(SharedBuffer &other);

        private:
                Buffer _buffer;
                MessageId _lastMessageId;
                pthread_mutex_t _bufferMutex;
};

#endif // #ifndef SHARED_BUFFER_H

// End of file shared_buffer.h