ntv2caption608messagequeue.h

Go to the documentation of this file.

 
#ifndef __NTV2_CAPTION608MESSAGEQUEUE__
#define __NTV2_CAPTION608MESSAGEQUEUE__
 
#include "ntv2caption608message.h"
#include <deque>
 
 
class AJAExport CNTV2Caption608MessageQueue : public CNTV2CaptionLogConfig
{
    //  Instance Methods
    public:
                                        CNTV2Caption608MessageQueue ();
        virtual                         ~CNTV2Caption608MessageQueue ();
 
        virtual CNTV2Caption608MessagePtr   GetNextCaptionMessage (void);
 
        virtual bool                    EnqueueCaptionMessage (CNTV2Caption608MessagePtr inMsg);
 
        virtual size_t                  Flush (void);
 
        virtual size_t                  Flush (const NTV2Line21Channel inChannel);
 
        virtual std::ostream &          Print (std::ostream & inOutStream, const bool inDumpMessages = true) const;
 
 
        virtual size_t                  GetQueuedMessageCount (void) const;
 
        virtual size_t                  GetQueuedMessageCount (const NTV2Line21Channel inChannel) const;
 
        virtual size_t                  GetQueuedByteCount (void) const;
 
        virtual size_t                  GetQueuedByteCount (const NTV2Line21Channel inChannel) const;
 
        virtual size_t                  GetEnqueueByteTally (void) const;
 
        virtual size_t                  GetDequeueByteTally (void) const;
 
        virtual size_t                  GetEnqueueMessageTally (void) const;
 
        virtual size_t                  GetDequeueMessageTally (void) const;
 
 
        virtual size_t                  GetEnqueueByteTally (const NTV2Line21Channel inChannel) const;
 
        virtual size_t                  GetDequeueByteTally (const NTV2Line21Channel inChannel) const;
 
        virtual size_t                  GetEnqueueMessageTally (const NTV2Line21Channel inChannel) const;
 
        virtual size_t                  GetDequeueMessageTally (const NTV2Line21Channel inChannel) const;
 
 
        virtual inline size_t           GetHighestQueueDepth (void) const               {return mMaxMsgTally;}
 
    private:
        CNTV2Caption608MessageQueue (const CNTV2Caption608MessageQueue & inObjToCopy);
        virtual CNTV2Caption608MessageQueue & operator = (const CNTV2Caption608MessageQueue & inRHS);
 
 
    //  Instance Data
    private:
        typedef std::deque <CNTV2Caption608MessagePtr>  MyQueueType;
        typedef MyQueueType::const_iterator             MyQueueTypeConstIter;
 
        MyQueueType         mHiPriorityQueue;                           
        MyQueueType         mLoPriorityQueue;                           
        mutable void *      mpQueueLock;                                
        size_t              mEnqueueByteTally [NTV2_CC608_ChannelMax];  
        size_t              mDequeueByteTally [NTV2_CC608_ChannelMax];  
        size_t              mEnqueueMsgTally [NTV2_CC608_ChannelMax];   
        size_t              mDequeueMsgTally [NTV2_CC608_ChannelMax];   
        size_t              mMaxMsgTally;                               
 
};  //  CNTV2Caption608MessageQueue
 
 
//  Output stream operators:
inline std::ostream & operator << (std::ostream & inOutStream, const CNTV2Caption608MessageQueue & inObj)   {return inObj.Print (inOutStream);}
 
 
 
#endif  //  __NTV2_CAPTION608MESSAGEQUEUE__