AaronCameron.net

Not Left, nor right. Just correct.

• 
• 
• 
• 
• 

Not a Member? - Login or Create an Account

Wednesday the 23rd of May 2012 @ 06:18pm

Front Page Journal Projects Your Profile About

LibN2L N2L Home Older News Downloads Documentation (n2l5) Class Hierarchy Compound List File List n2l:: Members Functions Whole n2l:: Ref Documentation (libN2L-4) Class Hierarchy Compound List File List n2l:: Members Functions Whole n2l:: Ref Bugtracker Project Page Report a Bug Bug List Related Things Life 2130 Devel Game Journal

LibN2L-4 Library Code Reference Classes Compounds Files Members Method Index Full Reference cTSUniStreamImp.h Go to the documentation of this file. /************************************************************************ Nova-2 Library (libN2L, or simply n2l) Game development C++ Library Copyright (C) 2002 Aaron Cameron This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation; either version 2.1 of the License, or (at your option) any later version. This library 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 Lesser General Public License for more details. You should have received a copy of the GNU Lesser General Public License along with this library; if not, write to the Free Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA A copy of the GNU Lesser General Public License has been provided with this library in the file 'COPYING'. Contact information for the author of this library has been provided with this library in the file 'AUTHOR'. ************************************************************************/ #ifndef _n2l4_cUniStreamImp_H #define _n2l4_cUniStreamImp_H #include "n2l/n2l.h" #include "n2l/threads.h" #include "cStreamFilterInterface.h" #include "cInsertionStreamInterface.h" #include "cStreamConverterInterface.h" #include <vector> namespace n2l { template < class TIValue, class TOValue, class TVContainer > class cUniStreamImp { public: typedef cUniStreamImp<TIValue,TOValue,TVContainer> tThis; typedef TIValue tInValue; typedef TOValue tOutValue; typedef cAutoPtr<cStreamConverterInterface<tInValue,tOutValue> > tConverter; typedef cAutoPtr<cInsertionStreamInterface<tInValue> > tPreConvJoiner; typedef cAutoPtr<cInsertionStreamInterface<tInValue> > tPostConvJoiner; typedef TVContainer tValueContainer; typedef typename tValueContainer::size_type tSize; typedef cAutoPtr<cStreamFilterInterface<tInValue> > tPreFilter; typedef cAutoPtr<cStreamFilterInterface<tOutValue> > tPostFilter; typedef std::vector<tPreFilter> tPreFilterContainer; typedef std::vector<tPostFilter> tPostFilterContainer; typedef typename tPreFilterContainer::iterator tPreFilterIterator; typedef typename tPostFilterContainer::iterator tPostFilterIterator; typedef std::vector<tPreConvJoiner> tPreConvJoinContainer; typedef std::vector<tPostConvJoiner> tPostConvJoinContainer; typedef typename tPreConvJoinContainer::iterator tPreConvJoinIterator; typedef typename tPostConvJoinContainer::iterator tPostConvJoinIterator; /* ************************************************************ */ cUniStreamImp( const tConverter & i_converter ) : m_converter(i_converter), m_connected(true) { } /* ************************************************************ */ void push( const tInValue & i_value ) { const cMutexLocker MutexLock(&m_mutex); if (!isConnected()) return; const tPreFilterIterator EndPreFilterIt = m_preFilters.end(); for ( tPreFilterIterator filterIt = m_preFilters.begin(); EndPreFilterIt!=filterIt; ++filterIt ) if (!(*filterIt)->allow(i_value)) return; const tPreConvJoinIterator EndPreStreamIt = m_preConvJoiners.end(); for ( tPreConvJoinIterator streamIt = m_preConvJoiners.begin(); EndPreStreamIt!=streamIt; ++streamIt ) (*streamIt)->push(i_value); tOutValue temp; m_converter->convert(temp,i_value); const tPostFilterIterator EndPostFilterIt = m_postFilters.end(); for ( tPostFilterIterator filterIt = m_postFilters.begin(); EndPostFilterIt!=filterIt; ++filterIt ) if (!(*filterIt)->allow(temp)) return; const tPostConvJoinIterator EndPostStreamIt = m_postConvJoiners.end(); for ( tPostConvJoinIterator streamIt = m_postConvJoiners.begin(); EndPostStreamIt!=streamIt; ++streamIt ) (*streamIt)->push(temp); m_values.push(temp); } /* ************************************************************ */ const bool pop( tOutValue & o_value ) { const cMutexLocker MutexLock(&m_mutex); if (m_values.empty()) return false; o_value = m_values.front(); m_values.pop(); return true; } /* ************************************************************ */ const tSize size() const { const cMutexLocker MutexLock(&m_mutex); return m_values.size(); } /* ************************************************************ */ const bool empty() const { const cMutexLocker MutexLock(&m_mutex); return m_values.empty(); } /* ************************************************************ */ void attachInsertionFilter( tPreFilter io_filter ) { const cMutexLocker MutexLock(&m_mutex); m_preFilters.push_back( io_filter ); } /* ************************************************************ */ void attachExtractionFilter( tPostFilter io_filter ) { const cMutexLocker MutexLock(&m_mutex); m_postFilters.push_back( io_filter ); } /* ************************************************************ */ void attachPreConversionStream( const tPreConvJoiner io_stream ) { const cMutexLocker MutexLock(&m_mutex); m_preConvJoiners.push_back(io_stream); } /* ************************************************************ */ void attachPostConversionStream( const tPostConvJoiner io_stream ) { const cMutexLocker MutexLock(&m_mutex); m_postConvJoiners.push_back(io_stream); } /* ************************************************************ */ const bool isConnected() const { const cMutexLocker MutexLock(&m_mutex); return m_connected; } /* ************************************************************ */ void disconnect() { const cMutexLocker MutexLock(&m_mutex); m_connected = false; } private: tValueContainer m_values; tPreFilterContainer m_preFilters; tPostFilterContainer m_postFilters; tPreConvJoinContainer m_preConvJoiners; tPostConvJoinContainer m_postConvJoiners; tConverter m_converter; bool m_connected; cMutex m_mutex; }; // class } // namespace n2l #endif

©2012 Aaron Cameron