Home

nevrax.com

Nevrax.org News Mailing-list Documentation CVS Bugs License

Documentation                       Search   callback_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_CALLBACK_NET_BASE_H #define NL_CALLBACK_NET_BASE_H #undef USE_MESSAGE_RECORDER #include "nel/misc/types_nl.h" #include "nel/misc/time_nl.h" #include "nel/net/buf_net_base.h" #include "nel/net/message.h" #include "nel/net/inet_address.h" #ifdef USE_MESSAGE_RECORDER #include "nel/net/message_recorder.h" #include <queue> #endif #include <vector> namespace NLNET { class CCallbackNetBase; typedef void (*TMsgCallback) (CMessage &msgin, TSockId from, CCallbackNetBase &netbase); typedef struct { char *Key; TMsgCallback Callback; } TCallbackItem; class CCallbackNetBase { public: virtual ~CCallbackNetBase() {} virtual void send (const CMessage &buffer, TSockId hostid = InvalidSockId, bool log = true) = 0; uint64 getBytesSent () { return _BytesSent; } uint64 getBytesReceived () { return _BytesReceived; } virtual uint64 getReceiveQueueSize () = 0; virtual uint64 getSendQueueSize () = 0; virtual bool flush (TSockId hostid = InvalidSockId) = 0; void addCallbackArray (const TCallbackItem *callbackarray, NLMISC::CStringIdArray::TStringId arraysize); void setDefaultCallback(TMsgCallback defaultCallback) { _DefaultCallback = defaultCallback; } void setDisconnectionCallback (TNetCallback cb, void *arg) { checkThreadId (); _DisconnectionCallback = cb; _DisconnectionCbArg = arg; } virtual TSockId getSockId (TSockId hostid = InvalidSockId) = 0; void authorizeOnly (const char *callbackName, TSockId hostid = InvalidSockId); bool isAServer () const { checkThreadId (); return _IsAServer; } NLMISC::CStringIdArray &getSIDA () { return _InputSIDA; } virtual bool dataAvailable () { nlstop; return false; } virtual void update ( sint32 timeout=0 ) { nlstop; } virtual bool connected () const { nlstop; return false; } virtual void disconnect (TSockId hostid = InvalidSockId) { nlstop; } virtual const CInetAddress& hostAddress (TSockId hostid); void sendAllMyAssociations (TSockId to); void setOtherSideAssociations (const char **associationarray, NLMISC::CStringIdArray::TStringId arraysize); void displayAllMyAssociations (); void ignoreAllUnknownId(bool b) { _InputSIDA.ignoreAllUnknownId (b); } // Defined even when USE_MESSAGE_RECORDER is not defined enum TRecordingState { Off, Record, Replay }; protected: uint64 _BytesSent, _BytesReceived; TNetCallback _NewDisconnectionCallback; CCallbackNetBase( TRecordingState rec=Off, const std::string& recfilename="", bool recordall=true ); void baseUpdate ( sint32 timeout=0 ); void processOneMessage (); virtual void receive (CMessage &buffer, TSockId *hostid) = 0; /* It's the layer4 that full the buffer association because it's based on callback system * this is message association used when received a message number from the socket to know the * associated message name */ NLMISC::CStringIdArray _InputSIDA; /* It's the layer4 that full the buffer association because it's based on callback system * this is message association used when you want to send a message to a socket */ NLMISC::CStringIdArray _OutputSIDA; // contains callbacks std::vector<TCallbackItem> _CallbackArray; // called if the received message is not found in the callback array TMsgCallback _DefaultCallback; bool _IsAServer; bool _FirstUpdate; // --------------------------------------- #ifdef USE_MESSAGE_RECORDER bool replayDataAvailable(); virtual bool replaySystemCallbacks() = 0; void noticeDisconnection( TSockId hostid ); TRecordingState _MR_RecordingState; sint64 _MR_UpdateCounter; CMessageRecorder _MR_Recorder; #endif // --------------------------------------- private: NLMISC::TTime _LastUpdateTime; NLMISC::TTime _LastMovedStringArray; TNetCallback _DisconnectionCallback; void *_DisconnectionCbArg; friend void cbnbMessageAskAssociations (CMessage &msgin, TSockId from, CCallbackNetBase &netbase); friend void cbnbMessageRecvAssociations (CMessage &msgin, TSockId from, CCallbackNetBase &netbase); friend void cbnbNewDisconnection (TSockId from, void *data); protected: uint _ThreadId; void checkThreadId () const; }; } // NLNET #endif // NL_CALLBACK_NET_BASE_H /* End of callback_net_base.h */