// ============================================================================ // Copyright (C) 2001-2016 by Jozef Starosczyk // ixen@copyhandler.com // // This program is free software; you can redistribute it and/or modify // it under the terms of the GNU Library General Public License // (version 2) as published by the Free Software Foundation; // // This program is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License for more details. // // You should have received a copy of the GNU Library General Public // License along with this program; if not, write to the // Free Software Foundation, Inc., // 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. // ============================================================================ #ifndef __TWRITEBUFFERQUEUEWRAPPERWRAPPER_H__ #define __TWRITEBUFFERQUEUEWRAPPERWRAPPER_H__ #include "TEvent.h" #include "TOrderedBufferQueue.h" #include "TBufferList.h" #include "TSimpleOrderedBufferQueue.h" namespace chengine { class TOverlappedDataBuffer; class TWriteBufferQueueWrapper { public: TWriteBufferQueueWrapper(const TOrderedBufferQueuePtr& spQueue, size_t stMaxOtfBuffers, TSharedCountPtr spOtfBuffersCount); ~TWriteBufferQueueWrapper(); void Push(TOverlappedDataBuffer* pBuffer); TOverlappedDataBuffer* Pop(); size_t GetCount() const; HANDLE GetHasBuffersEvent() const; void ClearBuffers(const TBufferListPtr& spEmptyBuffers); private: void UpdateHasBuffers(); private: // input buffers TOrderedBufferQueuePtr m_spDataQueue; // external queue of buffers to use boost::signals2::connection m_dataQueueConnector; // retry buffers TSimpleOrderedBufferQueue m_tRetryBuffers; // internal queue of claimed buffers boost::signals2::connection m_retryBuffersConnector; // config size_t m_stMaxOtfBuffers = 0; // external state TSharedCountPtr m_spOtfBuffersCount; boost::signals2::connection m_otfBuffersConnector; // event TEvent m_eventHasBuffers; }; } #endif