NetstringsProtocol.h

Go to the documentation of this file.

#ifndef OPENDAVINCI_CORE_IO_PROTOCOL_NETSTRINGSPROTOCOL_H_
#define OPENDAVINCI_CORE_IO_PROTOCOL_NETSTRINGSPROTOCOL_H_

#include <sstream>
#include <string>

#include "opendavinci/odcore/opendavinci.h"
#include "opendavinci/odcore/base/Mutex.h"
#include "opendavinci/odcore/io/StringObserver.h"
#include "opendavinci/odcore/io/protocol/AbstractProtocol.h"

namespace odcore { namespace io { class StringListener; } }

namespace odcore {
    namespace io {
        namespace protocol {

            using namespace std;

            class OPENDAVINCI_API NetstringsProtocol : public StringObserver, public AbstractProtocol {
                private:
                    NetstringsProtocol(const NetstringsProtocol &);

                    NetstringsProtocol& operator=(const NetstringsProtocol &);

                public:
                    NetstringsProtocol();

                    virtual ~NetstringsProtocol();

                    void send(const string& data);

                    void setStringListener(StringListener *listener);

                    virtual void nextString(const string &s);

                private:
                    void decodeNetstring();

                    void invokeStringListener(const string& data);

                    odcore::base::Mutex m_stringListenerMutex;
                    StringListener *m_stringListener;

                    odcore::base::Mutex m_partialDataMutex;
                    stringstream m_partialData;
            };

        }
    }
}

#endif /* OPENDAVINCI_CORE_IO_PROTOCOL_NETSTRINGSPROTOCOL_H_ */