commandQueue.h

/* Copyright (c) 2005-2008, Stefan Eilemann <eile@equalizergraphics.com> 
   All rights reserved. */

#ifndef EQNET_COMMANDQUEUE_H
#define EQNET_COMMANDQUEUE_H

#include <eq/net/commandCache.h>

#include <eq/base/lock.h>
#include <eq/base/mtQueue.h>
#include <eq/base/nonCopyable.h>
#include <eq/base/thread.h>

namespace eq
{
namespace net
{
    class Command;

    class EQ_EXPORT CommandQueue : public base::NonCopyable
    {
    public:
        CommandQueue();
        virtual ~CommandQueue();

        virtual void push( Command& packet );

        virtual void pushFront( Command& packet );

        virtual void wakeup() { _commands.push( static_cast< Command* >( 0 )); }

        virtual Command* pop();

        virtual Command* tryPop();

        void release( Command* command );

        Command* back() const;

        bool empty() const { return _commands.empty(); }

        virtual void flush();

        size_t size() const { return _commands.size(); }

        CHECK_THREAD_DECLARE( _thread );
    private:
        base::MTQueue< Command* >  _commands;
        
        CommandCache              _commandCache;
        base::Lock                _commandCacheLock;
    };
}
}

#endif //EQNET_COMMANDQUEUE_H