Home

nevrax.com

Nevrax.org News Mailing-list Documentation CVS Bugs License

Documentation                       Search   buf_net_base.h Go to the documentation of this file. /* Copyright, 2001 Nevrax Ltd. * * This file is part of NEVRAX NEL. * NEVRAX NEL is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2, or (at your option) * any later version. * NEVRAX NEL 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 General Public License * along with NEVRAX NEL; see the file COPYING. If not, write to the * Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, * MA 02111-1307, USA. */ #ifndef NL_BUF_NET_BASE_H #define NL_BUF_NET_BASE_H #include "nel/misc/types_nl.h" #include "nel/misc/mutex.h" #include "nel/misc/buf_fifo.h" #include "nel/misc/thread.h" #include "nel/misc/debug.h" #include "nel/misc/common.h" namespace NLNET { class CBufSock; typedef CBufSock *TSockId; static const TSockId InvalidSockId = (TSockId) NULL; typedef void (*TNetCallback) ( TSockId from, void *arg ); typedef std::pair<TNetCallback,TSockId> TStoredNetCallback; typedef NLMISC::CSynchronized<NLMISC::CBufFIFO> CSynchronizedFIFO; typedef CSynchronizedFIFO::CAccessor CFifoAccessor; typedef uint32 TBlockSize; class CBufNetBase { public: enum TEventType { User = 'U', Connection = 'C', Disconnection = 'D' }; virtual ~CBufNetBase() {}; void setDisconnectionCallback( TNetCallback cb, void* arg ) { _DisconnectionCallback = cb; _DisconnectionCbArg = arg; } uint32 getReceiveQueueSize() { CFifoAccessor syncfifo( &_RecvFifo ); return syncfifo.value().size(); } void setMaxExpectedBlockSize( sint32 limit ) { if ( limit < 0 ) _MaxExpectedBlockSize = 0x7FFFFFF; else _MaxExpectedBlockSize = (uint32)limit; } void setMaxSentBlockSize( sint32 limit ) { if ( limit < 0 ) _MaxSentBlockSize = 0x7FFFFFF; else _MaxSentBlockSize = (uint32)limit; } uint32 maxExpectedBlockSize() const { return _MaxExpectedBlockSize; } uint32 maxSentBlockSize() const { return _MaxSentBlockSize; } protected: friend class NLNET::CBufSock; CBufNetBase(); CSynchronizedFIFO& receiveQueue() { return _RecvFifo; } TNetCallback disconnectionCallback() const { return _DisconnectionCallback; } void* argOfDisconnectionCallback() const { return _DisconnectionCbArg; } // TODO OPTIM never use this function void pushMessageIntoReceiveQueue( const std::vector<uint8>& buffer ) { //sint32 mbsize; { //nldebug( "BNB: Acquiring the receive queue... "); CFifoAccessor recvfifo( &_RecvFifo ); //nldebug( "BNB: Acquired, pushing the received buffer... "); recvfifo.value().push( buffer ); //nldebug( "BNB: Pushed, releasing the receive queue..." ); //mbsize = recvfifo.value().size() / 1048576; setDataAvailableFlag( true ); } //nldebug( "BNB: Released." ); //if ( mbsize > 1 ) //{ // nlwarning( "The receive queue size exceeds %d MB", mbsize ); //} } void pushMessageIntoReceiveQueue( const uint8 *buffer, uint32 size) { //sint32 mbsize; { //nldebug( "BNB: Acquiring the receive queue... "); CFifoAccessor recvfifo( &_RecvFifo ); //nldebug( "BNB: Acquired, pushing the received buffer... "); recvfifo.value().push( buffer, size ); //nldebug( "BNB: Pushed, releasing the receive queue..." ); //mbsize = recvfifo.value().size() / 1048576; setDataAvailableFlag( true ); } //nldebug( "BNB: Released." ); /*if ( mbsize > 1 ) { nlwarning( "The receive queue size exceeds %d MB", mbsize ); }*/ } void setDataAvailableFlag( bool da ) { _DataAvailable = da; } volatile bool dataAvailableFlag() const { return _DataAvailable; } private: CSynchronizedFIFO _RecvFifo; volatile bool _DataAvailable; TNetCallback _DisconnectionCallback; void* _DisconnectionCbArg; uint32 _MaxExpectedBlockSize; uint32 _MaxSentBlockSize; }; } // NLNET #endif // NL_BUF_NET_BASE_H /* End of buf_net_base.h */