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_BUF_CLIENT_H
+00027 #define NL_BUF_CLIENT_H
+00028 
+00029 #include "nel/misc/types_nl.h"
+00030 #include "nel/net/buf_net_base.h"
+00031 #include "nel/net/tcp_sock.h"
+00032 #include "nel/net/buf_sock.h"
+00033 
+00034 
+00035 namespace NLNET {
+00036 
+00037 
+00038 class CInetAddress;
+00039 class CBufClient;
+00040 
+00041 
+00045 class CClientReceiveTask : public NLMISC::IRunnable
+00046 {
+00047 public:
+00048 
+00050         CClientReceiveTask( CBufClient *client, TSockId sockid ) : _Client(client), _SockId(sockid) {}  
+00051 
+00053         virtual void run();
+00054 
+00056         CTcpSock                *sock() { return _SockId->Sock; }
+00057 
+00059         TSockId                 sockId() { return _SockId; }
+00060 
+00061 private:
+00062 
+00063         CBufClient              *_Client;
+00064 
+00065         TSockId                 _SockId;
+00066 };
+00067 
+00068 
+00069 
+00091 class CBufClient : public CBufNetBase
+00092 {
+00093 public:
+00094 
+00096         CBufClient( bool nodelay=true, bool replaymode=false );
+00097 
+00099         virtual ~CBufClient();
+00100         
+00102         void    connect( const CInetAddress& addr );
+00103                 
+00109         void    disconnect( bool quick=false );
+00110 
+00113         //void  send( const std::vector<uint8>& buffer );
+00114         void    send( const NLMISC::CMemStream& buffer );
+00115 
+00119         bool    dataAvailable();
+00120 
+00124         //void  receive( std::vector<uint8>& buffer );
+00125         void    receive( NLMISC::CMemStream& buffer );
+00126 
+00128         void    update();
+00129 
+00130 
+00131 
+00132         // Returns the size in bytes of the data stored in the send queue.
+00133         uint32  getSendQueueSize() const { return _BufSock->SendFifo.size(); }
+00134 
+00138         void    setTimeFlushTrigger( sint32 ms ) { _BufSock->setTimeFlushTrigger( ms ); }
+00139 
+00143         void    setSizeFlushTrigger( sint32 size ) { _BufSock->setSizeFlushTrigger( size ); }
+00144 
+00149         bool    flush() { return _BufSock->flush(); }
+00150 
+00151 
+00152         
+00157         bool    connected() const { return _BufSock->connectedState(); } 
+00158 
+00160         const CInetAddress&     remoteAddress() const { return _BufSock->Sock->remoteAddr(); }
+00161 
+00163         uint64  bytesDownloaded() const { return _BufSock->Sock->bytesReceived(); }
+00164 
+00166         uint64  bytesUploaded() const { return _BufSock->Sock->bytesSent(); }
+00167 
+00169         uint64  newBytesDownloaded();
+00170 
+00172         uint64  newBytesUploaded();
+00173 
+00174         /*//Not right because we add callbacks in the receive queue
+00176         uint64  bytesReceived() {  }
+00177         
+00179         uint64  bytesSent() { return bytesUploaded() + getSendQueueSize(); }
+00180 
+00182         uint64  newBytesReceived();
+00183 
+00185         uint64  newBytesSent();
+00186         */
+00187 
+00189         TSockId id() const { return _BufSock; /*_RecvTask->sockId();*/ }
+00190 
+00191 
+00192 protected:
+00193 
+00194         friend class CClientReceiveTask;
+00195 
+00197         CBufSock                        *_BufSock;
+00198 
+00200         bool                            _NoDelay;
+00201 
+00203         uint64                          _PrevBytesDownloaded;
+00204 
+00206         uint64                          _PrevBytesUploaded;
+00207 
+00208         /*
+00210         uint32                          _PrevBytesReceived;
+00211 
+00213         uint32                          _PrevBytesSent;
+00214         */
+00215 
+00216 private:
+00217 
+00219         CClientReceiveTask      *_RecvTask;
+00220 
+00222         NLMISC::IThread         *_RecvThread;
+00223 
+00224 };
+00225 
+00226 
+00227 
+00228 } // NLNET
+00229 
+00230 
+00231 #endif // NL_BUF_CLIENT_H
+00232 
+00233 /* End of buf_client.h */
+