nevrax.org : docs

00001 
00007 /* Copyright, 2001 Nevrax Ltd.
00008  *
00009  * This file is part of NEVRAX NEL.
00010  * NEVRAX NEL is free software; you can redistribute it and/or modify
00011  * it under the terms of the GNU General Public License as published by
00012  * the Free Software Foundation; either version 2, or (at your option)
00013  * any later version.
00014 
00015  * NEVRAX NEL is distributed in the hope that it will be useful, but
00016  * WITHOUT ANY WARRANTY; without even the implied warranty of
00017  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
00018  * General Public License for more details.
00019 
00020  * You should have received a copy of the GNU General Public License
00021  * along with NEVRAX NEL; see the file COPYING. If not, write to the
00022  * Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
00023  * MA 02111-1307, USA.
00024  */
00025 
00026 #ifndef NL_CALLBACK_SERVER_H
00027 #define NL_CALLBACK_SERVER_H
00028 
00029 #include "nel/misc/types_nl.h"
00030 
00031 #include "nel/net/callback_net_base.h"
00032 #include "nel/net/buf_server.h"
00033 
00034 
00035 namespace NLNET {
00036 
00037 
00044 class CCallbackServer : public CCallbackNetBase, public CBufServer
00045 {
00046 public:
00047 
00049         CCallbackServer( TRecordingState rec=Off, const std::string& recfilename="", bool recordall=true );
00050 
00052         void    send (const CMessage &buffer, TSockId hostid, bool log = true);
00053 
00055         bool    flush (TSockId destid) { checkThreadId (); nlassert( destid != InvalidSockId ); return CBufServer::flush(destid); }
00056 
00058         void    update (sint32 timeout=0);
00059 
00061         void    setConnectionCallback (TNetCallback cb, void *arg) { checkThreadId (); _ConnectionCallback = cb; _ConnectionCbArg = arg; }
00062 
00064         void    setDisconnectionCallback (TNetCallback cb, void *arg) { checkThreadId (); CCallbackNetBase::setDisconnectionCallback (cb, arg); }
00065 
00067         bool    connected () const { checkThreadId (); return true; } 
00068 
00074         void    disconnect (TSockId hostid);
00075 
00077         const CInetAddress& hostAddress (TSockId hostid) { nlassert(hostid!=InvalidSockId); checkThreadId(); return CBufServer::hostAddress (hostid); }
00078 
00080         virtual TSockId getSockId (TSockId hostid = InvalidSockId);
00081 
00082         uint64  getReceiveQueueSize () { return CBufServer::getReceiveQueueSize(); }
00083         uint64  getSendQueueSize () { return CBufServer::getSendQueueSize(0); }
00084 
00085 private:
00086 
00088         void                    send (const NLMISC::CMemStream &buffer, TSockId hostid) { nlstop; }
00089 
00090         bool                    dataAvailable ();
00091         void                    receive (CMessage &buffer, TSockId *hostid);
00092 
00093         void                    sendAllMyAssociations (TSockId to);
00094 
00095         TNetCallback    _ConnectionCallback;
00096         void                    *_ConnectionCbArg;
00097 
00098         friend void             cbsNewConnection (TSockId from, void *data);
00099 
00100         // ---------------------------------------
00101 #ifdef USE_MESSAGE_RECORDER
00102         void                                            noticeConnection( TSockId hostid );
00103         virtual                                         bool replaySystemCallbacks();
00104         std::vector<CBufSock*>          _MR_Connections;
00105         std::map<TSockId,TSockId>       _MR_SockIds; // first=sockid in file; second=CBufSock*
00106 #endif
00107         // ---------------------------------------
00108         
00109 };
00110 
00111 
00112 } // NLNET
00113 
00114 
00115 #endif // NL_CALLBACK_SERVER_H
00116 
00117 /* End of callback_server.h */