diff options
Diffstat (limited to '')
| -rw-r--r-- | docs/doxygen/nel/buf__sock_8cpp-source.html | 496 |
1 files changed, 496 insertions, 0 deletions
diff --git a/docs/doxygen/nel/buf__sock_8cpp-source.html b/docs/doxygen/nel/buf__sock_8cpp-source.html new file mode 100644 index 00000000..4e5f67e1 --- /dev/null +++ b/docs/doxygen/nel/buf__sock_8cpp-source.html @@ -0,0 +1,496 @@ +<!doctype html public "-//W3C//DTD HTML 4.0 Transitional//EN" "http://www.w3.org/TR/REC-html40/loose.dtd"> +<HTML> +<HEAD> + <TITLE>nevrax.org : docs</TITLE> + <LINK REL=stylesheet TYPE="text/css" HREF="http://www.nevrax.org/inc/css/nevrax.css"> + <link href="doxygen.css" rel="stylesheet" type="text/css"> +</HEAD> +<BODY MARGINHEIGHT="0" MARGINWIDTH="0"> + +<!-- uplinks --> +<TABLE CELLSPACING=0 CELLPADDING=0 BORDER=0> + <TR> + <TD WIDTH=16><IMG SRC="http://www.nevrax.org/inc/img/pixel.gif" WIDTH="16" HEIGHT="16" BORDER=0 ALT=""></TD> + <TD WIDTH=140 BGCOLOR=#dddddd><IMG SRC="http://www.nevrax.org/inc/img/pixel.gif" WIDTH="140" HEIGHT="16" BORDER=0 ALT=""></TD> + <TD WIDTH=16><IMG SRC="http://www.nevrax.org/inc/img/pixel.gif" WIDTH="16" HEIGHT="16" BORDER=0 ALT=""></TD> + <TD><IMG width=6 height=14 SRC="http://www.nevrax.org/inc/img/reddots.gif" ALT="#" VSPACE=2 HSPACE=2 BORDER=0 ></TD><TD VALIGN=middle> <A CLASS=uplinks HREF=http://www.nevrax.org><b>Home</B></FONT></A> </TD> + <TD><IMG width=6 height=14 SRC="http://www.nevrax.org/inc/img/reddots.gif" ALT="#" VSPACE=2 HSPACE=2 BORDER=0 ></TD><TD VALIGN=middle> <A CLASS=uplinks HREF=http://www.nevrax.com><b>nevrax.com</B></FONT></A> </TD> + </TR> +</TABLE> + +<!-- banner Nevrax --> +<TABLE CELLSPACING=0 CELLPADDING=0 BORDER=0 WIDTH=100%> + <TR><TD BGCOLOR="#000000" BACKGROUND="http://www.nevrax.org/inc/img/black_banner.jpg"><A HREF="http://www.nevrax.org"><IMG SRC="http://www.nevrax.org/inc/img/nevrax.gif" WIDTH="170" HEIGHT="45" BORDER=0 ALT="Nevrax" ></A></TD></TR> +</TABLE> + +<!-- main table --> +<TABLE CELLSPACING=0 CELLPADDING=0 BORDER=0 height=100%> + <TR> + <TD WIDTH=16><IMG SRC="http://www.nevrax.org/inc/img/pixel.gif" WIDTH="16" HEIGHT="10" BORDER=0 ALT=""></TD> + <TD WIDTH=140 BGCOLOR=#dddddd VALIGN=TOP ALIGN=middle><IMG SRC="http://www.nevrax.org/inc/img/pixel.gif" WIDTH="140" HEIGHT="10" BORDER=0 ALT=""> + + <!------ Begin Box ------> + <TABLE BORDER=0 CELLSPACING=0 CELLPADDING=0 BGCOLOR=black><TR><TD><TABLE border=0 cellspacing=2 cellpadding=0 width=120><tr><TD ALIGN=middle bgcolor=black> + <FONT COLOR=white FACE="sans-serif"><B>Nevrax.org</B></FONT></TD></TR><tr><td colspan=2 bgcolor=#FFFFFF> + <TABLE cellspacing=0 cellpadding=1 border=0> + <tr><td ALIGN=middle><a class='linkbox' href="http://www.nevrax.org/news/" TITLE="Rubrique news"><img width=13 height=15 hspace=5 border=0 src=http://www.nevrax.org/inc/img/picto-news.gif ALT=#></A></td><td><a class='linkbox' href="http://www.nevrax.org/news/" TITLE="News">News</a></td></tr> + <tr><td ALIGN=middle><a class='linkbox' href="http://www.nevrax.org/mail/" TITLE="Rubrique mail"><img width=15 height=11 hspace=5 border=0 src=http://www.nevrax.org/inc/img/picto-mail.gif ALT=#></A></td><td><a class='linkbox' href="http://www.nevrax.org/mail/" TITLE="Mailing list archive">Mailing-list</a></td></tr> + <tr><td ALIGN=middle><a class='linkbox' href="http://www.nevrax.org/docs/" TITLE="Rubrique docs"><img width=14 height=16 hspace=5 border=0 src=http://www.nevrax.org/inc/img/picto-docs.gif ALT=#></A></td><td><a class='linkbox' href="http://www.nevrax.org/docs/" TITLE="Documentation">Documentation</a></td></tr> + <tr><td ALIGN=middle><a class='linkbox' href="http://www.nevrax.org/cvs/" TITLE="Rubrique cvs"><img width=13 height=17 hspace=5 border=0 src=http://www.nevrax.org/inc/img/picto-cvs.gif ALT=#></A></td><td><a class='linkbox' href="http://www.nevrax.org/cvs/" TITLE="CVS Web">CVS</a></td></tr> + <tr><td ALIGN=middle><a class='linkbox' href="http://www.nevrax.org/bugs/" TITLE="Rubrique bugs"><img width=20 height=16 hspace=5 border=0 src=http://www.nevrax.org/inc/img/picto-bugs.gif ALT=#></A></td><td><a class='linkbox' href="http://www.nevrax.org/bugs/" TITLE="Bugtracking">Bugs</a></td></tr> + <tr><td ALIGN=middle><a class='linkbox' href="http://www.nevrax.org/GPL.php3" TITLE="Rubrique license"><img width=18 height=12 hspace=5 border=0 src=http://www.nevrax.org/inc/img/picto-gpl.gif ALT=#></A></td><td><a class='linkbox' href="http://www.nevrax.org/GPL.php3" TITLE="License">License</a></td></tr> + </TABLE> + </TD></TR></TABLE></TD></TR></TABLE> + <!------ End Box ------> + + </TD> + <TD WIDTH=15><IMG SRC="http://www.nevrax.org/inc/img/pixel.gif" WIDTH="16" HEIGHT="16" BORDER=0 ALT=""></TD> + <TD ALIGN=left valign=top><IMG SRC="http://www.nevrax.org/inc/img/pixel.gif" WIDTH="140" HEIGHT="10" BORDER=0 ALT=""> + +<!-- title --> +<TABLE background="http://www.nevrax.org/inc/img/redline.gif" CELLSPACING=0 CELLPADDING=0 BORDER=0 width=100%><tr><td> +<A HREF="http://www.nevrax.org/docs/"><img src="http://www.nevrax.org/inc/img/t_docs.gif" ALT="Docs" HEIGHT=20 BORDER=0></A> +</td><td><IMG SRC="http://www.nevrax.org/inc/img/pixel.gif" WIDTH="1" HEIGHT="1" BORDER=0 ALT=""> +</td></tr></table> + + +<!-- block --> +<TABLE bgcolor="#dddddd" CELLSPACING=0 CELLPADDING=0 BORDER=0 width=100%><tr><td width=1% valign=middle><img width=6 height=14 hspace=2 vspace=2 src="http://www.nevrax.org/inc/img/reddots.gif"></TD> + <TD><B>Documentation</B></TD> + <TD ALIGN=RIGHT> </td> +</tr></table> +<!-- Generated by Doxygen 1.2.14 --> +<center> +<a class="qindex" href="index.html">Main Page</a> <a class="qindex" href="namespaces.html">Namespace List</a> <a class="qindex" href="hierarchy.html">Class Hierarchy</a> <a class="qindex" href="classes.html">Alphabetical List</a> <a class="qindex" href="annotated.html">Compound List</a> <a class="qindex" href="files.html">File List</a> <a class="qindex" href="namespacemembers.html">Namespace Members</a> <a class="qindex" href="functions.html">Compound Members</a> <a class="qindex" href="globals.html">File Members</a> <a class="qindex" href="pages.html">Related Pages</a> <a class="qindexRef" doxygen="_cgi:http://www.nevrax.org/cgi-bin/nel-search.cgi" href="http://www.nevrax.org/cgi-bin/nel-search.cgi">Search</a> </center> +<hr><h1>buf_sock.cpp</h1><a href="buf__sock_8cpp.html">Go to the documentation of this file.</a><div class="fragment"><pre>00001 +00007 <font class="comment">/* Copyright, 2001 Nevrax Ltd.</font> +00008 <font class="comment"> *</font> +00009 <font class="comment"> * This file is part of NEVRAX NEL.</font> +00010 <font class="comment"> * NEVRAX NEL is free software; you can redistribute it and/or modify</font> +00011 <font class="comment"> * it under the terms of the GNU General Public License as published by</font> +00012 <font class="comment"> * the Free Software Foundation; either version 2, or (at your option)</font> +00013 <font class="comment"> * any later version.</font> +00014 <font class="comment"></font> +00015 <font class="comment"> * NEVRAX NEL is distributed in the hope that it will be useful, but</font> +00016 <font class="comment"> * WITHOUT ANY WARRANTY; without even the implied warranty of</font> +00017 <font class="comment"> * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU</font> +00018 <font class="comment"> * General Public License for more details.</font> +00019 <font class="comment"></font> +00020 <font class="comment"> * You should have received a copy of the GNU General Public License</font> +00021 <font class="comment"> * along with NEVRAX NEL; see the file COPYING. If not, write to the</font> +00022 <font class="comment"> * Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,</font> +00023 <font class="comment"> * MA 02111-1307, USA.</font> +00024 <font class="comment"> */</font> +00025 +00026 <font class="preprocessor">#include "<a class="code" href="stdnet_8h.html">stdnet.h</a>"</font> +00027 +00028 <font class="preprocessor">#include "<a class="code" href="hierarchical__timer_8h.html">nel/misc/hierarchical_timer.h</a>"</font> +00029 +00030 <font class="preprocessor">#include "<a class="code" href="buf__sock_8h.html">nel/net/buf_sock.h</a>"</font> +00031 <font class="preprocessor">#include "<a class="code" href="buf__server_8h.html">nel/net/buf_server.h</a>"</font> +00032 +00033 <font class="preprocessor">#ifdef NL_OS_WINDOWS</font> +00034 <font class="preprocessor"></font><font class="preprocessor">#include <winsock2.h></font> +00035 <font class="preprocessor">#elif defined NL_OS_UNIX</font> +00036 <font class="preprocessor"></font><font class="preprocessor">#include <netinet/in.h></font> +00037 <font class="preprocessor">#endif</font> +00038 <font class="preprocessor"></font> +00039 <font class="keyword">using</font> <font class="keyword">namespace </font>NLMISC; +00040 <font class="keyword">using</font> <font class="keyword">namespace </font>std; +00041 +00042 +00043 <font class="keyword">namespace </font>NLNET { +00044 +00045 +00046 NLMISC::CMutex <a class="code" href="namespaceNLNET.html#a87">nettrace_mutex</a>(<font class="stringliteral">"nettrace_mutex"</font>); +00047 +00048 +00049 <font class="comment">/*</font> +00050 <font class="comment"> * Constructor</font> +00051 <font class="comment"> */</font> +<a name="l00052"></a><a class="code" href="classNLNET_1_1CBufSock.html#b0">00052</a> CBufSock::CBufSock( CTcpSock *sock ) : +00053 SendNextValue(0), +00054 ReceiveNextValue(0), +00055 Sock( sock ), +00056 _KnowConnected( false ), +00057 _LastFlushTime( 0 ), +00058 _TriggerTime( 20 ), +00059 _TriggerSize( -1 ), +00060 _RTSBIndex( 0 ), +00061 _AppId( 0 ), +00062 _ConnectedState( false ) +00063 { +00064 <a class="code" href="buf__sock_8h.html#a0">nlnettrace</a>( <font class="stringliteral">"CBufSock::CBufSock"</font> ); <font class="comment">// don't define a global object</font> +00065 +00066 <font class="keywordflow">if</font> ( <a class="code" href="classNLNET_1_1CBufSock.html#n1">Sock</a> == NULL ) +00067 { +00068 <a class="code" href="classNLNET_1_1CBufSock.html#n1">Sock</a> = <font class="keyword">new</font> CTcpSock(); +00069 } +00070 +00071 <font class="preprocessor">#ifdef NL_DEBUG</font> +00072 <font class="preprocessor"></font> _FlushTrigger = FTManual; +00073 <font class="preprocessor">#endif</font> +00074 <font class="preprocessor"></font> <a class="code" href="classNLNET_1_1CBufSock.html#o0">_LastFlushTime</a> = CTime::getLocalTime(); +00075 } +00076 +00077 +00078 <font class="comment">/*</font> +00079 <font class="comment"> * Destructor</font> +00080 <font class="comment"> */</font> +<a name="l00081"></a><a class="code" href="classNLNET_1_1CBufSock.html#a0">00081</a> CBufSock::~CBufSock() +00082 { +00083 <a class="code" href="debug_8h.html#a6">nlassert</a> (<font class="keyword">this</font> != InvalidSockId); <font class="comment">// invalid bufsock</font> +00084 +00085 <a class="code" href="buf__sock_8h.html#a0">nlnettrace</a>( <font class="stringliteral">"CBufSock::~CBufSock"</font> ); +00086 +00087 <font class="keyword">delete</font> <a class="code" href="classNLNET_1_1CBufSock.html#n1">Sock</a>; <font class="comment">// the socket disconnects automatically if needed</font> +00088 +00089 <font class="comment">// destroy the structur to be sure that other people will not access to this anymore</font> +00090 <a class="code" href="classNLNET_1_1CBufSock.html#m0">AuthorizedCallback</a> = <font class="stringliteral">""</font>; +00091 <a class="code" href="classNLNET_1_1CBufSock.html#n1">Sock</a> = NULL; +00092 <a class="code" href="classNLNET_1_1CBufSock.html#n2">_KnowConnected</a> = <font class="keyword">false</font>; +00093 <a class="code" href="classNLNET_1_1CBufSock.html#o0">_LastFlushTime</a> = 0; +00094 <a class="code" href="classNLNET_1_1CBufSock.html#o1">_TriggerTime</a> = 0; +00095 <a class="code" href="classNLNET_1_1CBufSock.html#o2">_TriggerSize</a> = 0; +00096 <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z301_0">clear</a> (); +00097 <a class="code" href="classNLNET_1_1CBufSock.html#o4">_RTSBIndex</a> = 0; +00098 <a class="code" href="classNLNET_1_1CBufSock.html#o5">_AppId</a> = 0; +00099 <a class="code" href="classNLNET_1_1CBufSock.html#o6">_ConnectedState</a> = <font class="keyword">false</font>; +00100 } +00101 +00102 +00103 <font class="comment">/*</font> +00104 <font class="comment"> * Returns a readable string from a vector of bytes, beginning from pos, limited to 'len' characters. '\0' are replaced by ' '</font> +00105 <font class="comment"> */</font> +00106 string <a class="code" href="namespaceNLNET.html#a88">stringFromVectorPart</a>( <font class="keyword">const</font> vector<uint8>& <a class="code" href="driver__opengl__extension__def_8h.html#a368">v</a>, uint32 pos, uint32 len ) +00107 { +00108 <a class="code" href="debug_8h.html#a8">nlassertex</a>( pos+len <= <a class="code" href="driver__opengl__extension__def_8h.html#a368">v</a>.size(), (<font class="stringliteral">"pos=%u len=%u size=%u"</font>, pos, len, <a class="code" href="driver__opengl__extension__def_8h.html#a368">v</a>.size()) ); +00109 +00110 string <a class="code" href="driver__opengl__extension__def_8h.html#a383">s</a>; +00111 <font class="keywordflow">if</font> ( (! <a class="code" href="driver__opengl__extension__def_8h.html#a368">v</a>.empty()) && (len!=0) ) +00112 { +00113 <font class="comment">// Copy contents</font> +00114 <a class="code" href="driver__opengl__extension__def_8h.html#a383">s</a>.resize( len ); +00115 memcpy( &*<a class="code" href="driver__opengl__extension__def_8h.html#a383">s</a>.begin(), &*<a class="code" href="driver__opengl__extension__def_8h.html#a368">v</a>.begin()+pos, len ); +00116 +00117 <font class="comment">// Replace '\0' characters</font> +00118 string::iterator is; +00119 <font class="keywordflow">for</font> ( is=<a class="code" href="driver__opengl__extension__def_8h.html#a383">s</a>.begin(); is!=<a class="code" href="driver__opengl__extension__def_8h.html#a383">s</a>.end(); ++is ) +00120 { +00121 <font class="keywordflow">if</font> ( ! isprint((uint8)(*is)) || (*is) == <font class="charliteral">'%'</font> ) +00122 { +00123 (*is) = <font class="charliteral">'?'</font>; +00124 } +00125 } +00126 } +00127 +00128 <font class="keywordflow">return</font> <a class="code" href="driver__opengl__extension__def_8h.html#a383">s</a>; +00129 } +00130 +00131 +00132 <font class="comment">/*</font> +00133 <font class="comment"> * Force to send all data pending in the send queue</font> +00134 <font class="comment"> * Note: this method is used by clients (blocking sockets) and servers (non-blocking sockets)</font> +00135 <font class="comment"> * so it works in both cases.</font> +00136 <font class="comment"> * Precond: the send queue should not contain an empty block</font> +00137 <font class="comment"> */</font> +<a name="l00138"></a><a class="code" href="classNLNET_1_1CBufSock.html#z347_3">00138</a> <font class="keywordtype">bool</font> CBufSock::flush() +00139 { +00140 <a class="code" href="debug_8h.html#a6">nlassert</a> (<font class="keyword">this</font> != InvalidSockId); <font class="comment">// invalid bufsock</font> +00141 <font class="comment">//nlnettrace( "CBufSock::flush" );</font> +00142 +00143 <font class="comment">// Copy data from the send queue to _ReadyToSendBuffer</font> +00144 <a class="code" href="namespaceNLNET.html#a6">TBlockSize</a> netlen; +00145 <font class="comment">// vector<uint8> tmpbuffer;</font> +00146 +00147 <font class="comment">// Process each element in the send queue</font> +00148 <font class="keywordflow">while</font> ( ! <a class="code" href="classNLNET_1_1CBufSock.html#n0">SendFifo</a>.<a class="code" href="classNLMISC_1_1CBufFIFO.html#a12">empty</a>() ) +00149 { +00150 uint8 *tmpbuffer; +00151 uint32 size; +00152 <a class="code" href="classNLNET_1_1CBufSock.html#n0">SendFifo</a>.<a class="code" href="classNLMISC_1_1CBufFIFO.html#a6">front</a>( tmpbuffer, size ); +00153 +00154 <font class="comment">// Compute the size and add it into the beginning of the buffer</font> +00155 netlen = htonl( (<a class="code" href="namespaceNLNET.html#a6">TBlockSize</a>)size ); +00156 uint32 oldBufferSize = <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z302_0">size</a>(); +00157 <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z301_1">resize</a> (oldBufferSize+<font class="keyword">sizeof</font>(<a class="code" href="namespaceNLNET.html#a6">TBlockSize</a>)+size); +00158 *(<a class="code" href="namespaceNLNET.html#a6">TBlockSize</a>*)&(<a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>[oldBufferSize])=netlen; +00159 +00160 <font class="comment">// Append the temporary buffer to the global buffer</font> +00161 CFastMem::memcpy (&<a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>[oldBufferSize+<font class="keyword">sizeof</font>(<a class="code" href="namespaceNLNET.html#a6">TBlockSize</a>)], tmpbuffer, size); +00162 <a class="code" href="classNLNET_1_1CBufSock.html#n0">SendFifo</a>.<a class="code" href="classNLMISC_1_1CBufFIFO.html#a10">pop</a>(); +00163 } +00164 +00165 <font class="comment">// Actual sending of _ReadyToSendBuffer</font> +00166 <font class="comment">//if ( ! _ReadyToSendBuffer.empty() )</font> +00167 <font class="keywordflow">if</font> ( <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z302_0">size</a>() != 0 ) +00168 { +00169 <font class="comment">// Send</font> +00170 CSock::TSockResult <a class="code" href="driver__opengl__extension__def_8h.html#a400">res</a>; +00171 <a class="code" href="namespaceNLNET.html#a6">TBlockSize</a> len = <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z302_0">size</a>() - <a class="code" href="classNLNET_1_1CBufSock.html#o4">_RTSBIndex</a>; +00172 +00173 <a class="code" href="driver__opengl__extension__def_8h.html#a400">res</a> = <a class="code" href="classNLNET_1_1CBufSock.html#n1">Sock</a>->send( <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z302_2">getPtr</a>()+<a class="code" href="classNLNET_1_1CBufSock.html#o4">_RTSBIndex</a>, len, <font class="keyword">false</font> ); +00174 +00175 <font class="keywordflow">if</font> ( <a class="code" href="driver__opengl__extension__def_8h.html#a400">res</a> == CSock::Ok ) +00176 { +00177 <font class="comment">/* // Debug display</font> +00178 <font class="comment"> switch ( _FlushTrigger )</font> +00179 <font class="comment"> {</font> +00180 <font class="comment"> case FTTime : nldebug( "LNETL1: Time triggered flush for %s:", asString().c_str() ); break;</font> +00181 <font class="comment"> case FTSize : nldebug( "LNETL1: Size triggered flush for %s:", asString().c_str() ); break;</font> +00182 <font class="comment"> default: nldebug( "LNETL1: Manual flush for %s:", asString().c_str() );</font> +00183 <font class="comment"> }</font> +00184 <font class="comment"> _FlushTrigger = FTManual;</font> +00185 <font class="comment"> nldebug( "LNETL1: %s sent effectively a buffer (%d on %d B)", asString().c_str(), len, _ReadyToSendBuffer.size() );</font> +00186 <font class="comment">*/</font> +00187 +00188 <font class="comment">// TODO OPTIM remove the nldebug for speed</font> +00189 <font class="comment">//commented for optimisation nldebug( "LNETL1: %s sent effectively %u/%u bytes (pos %u wantedsend %u)", asString().c_str(), len, _ReadyToSendBuffer.size(), _RTSBIndex, realLen/*, stringFromVectorPart(_ReadyToSendBuffer,_RTSBIndex,len).c_str()*/ );</font> +00190 +00191 <font class="keywordflow">if</font> ( <a class="code" href="classNLNET_1_1CBufSock.html#o4">_RTSBIndex</a>+len == <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z302_0">size</a>() ) <font class="comment">// for non-blocking mode (server)</font> +00192 { +00193 <font class="comment">// If sending is ok, clear the global buffer</font> +00194 <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z301_0">clear</a>(); +00195 <a class="code" href="classNLNET_1_1CBufSock.html#o4">_RTSBIndex</a> = 0; +00196 } +00197 <font class="keywordflow">else</font> +00198 { +00199 <font class="comment">// Or clear only the data that was actually sent</font> +00200 <a class="code" href="debug_8h.html#a8">nlassertex</a>( <a class="code" href="classNLNET_1_1CBufSock.html#o4">_RTSBIndex</a>+len < <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z302_0">size</a>(), (<font class="stringliteral">"index=%u len=%u size=%u"</font>, <a class="code" href="classNLNET_1_1CBufSock.html#o4">_RTSBIndex</a>, len, <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z302_0">size</a>()) ); +00201 <a class="code" href="classNLNET_1_1CBufSock.html#o4">_RTSBIndex</a> += len; +00202 <font class="keywordflow">if</font> ( <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z302_0">size</a>() > 20480 ) <font class="comment">// if big, clear data already sent</font> +00203 { +00204 uint nbcpy = <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z302_0">size</a>() - len; +00205 <font class="keywordflow">for</font> (uint i = 0; i < nbcpy; i++) +00206 { +00207 <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>[i] = <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>[i+len]; +00208 } +00209 <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z301_1">resize</a>(nbcpy); +00210 <font class="comment">//_ReadyToSendBuffer.erase( _ReadyToSendBuffer.begin(), _ReadyToSendBuffer.begin()+len );</font> +00211 <a class="code" href="classNLNET_1_1CBufSock.html#o4">_RTSBIndex</a> = 0; +00212 } +00213 } +00214 } +00215 <font class="keywordflow">else</font> +00216 { +00217 <font class="preprocessor">#ifdef NL_DEBUG</font> +00218 <font class="preprocessor"></font> <font class="comment">// can happen in a normal behavior if, for example, the other side is not connect anymore</font> +00219 <a class="code" href="debug_8h.html#a0">nldebug</a>( <font class="stringliteral">"LNETL1: %s failed to send effectively a buffer of %d bytes"</font>, <a class="code" href="classNLNET_1_1CBufSock.html#a3">asString</a>().c_str(), <a class="code" href="classNLNET_1_1CBufSock.html#o3">_ReadyToSendBuffer</a>.<a class="code" href="classNLMISC_1_1CObjectVector.html#z302_0">size</a>() ); +00220 <font class="preprocessor">#endif</font> +00221 <font class="preprocessor"></font> <font class="keywordflow">return</font> <font class="keyword">false</font>; +00222 } +00223 } +00224 +00225 <font class="keywordflow">return</font> <font class="keyword">true</font>; +00226 } +00227 +00228 +00229 <font class="comment">/* Sets the time flush trigger (in millisecond). When this time is elapsed,</font> +00230 <font class="comment"> * all data in the send queue is automatically sent (-1 to disable this trigger)</font> +00231 <font class="comment"> */</font> +<a name="l00232"></a><a class="code" href="classNLNET_1_1CBufSock.html#z347_1">00232</a> <font class="keywordtype">void</font> CBufSock::setTimeFlushTrigger( sint32 ms ) +00233 { +00234 <a class="code" href="debug_8h.html#a6">nlassert</a> (<font class="keyword">this</font> != InvalidSockId); <font class="comment">// invalid bufsock</font> +00235 <a class="code" href="classNLNET_1_1CBufSock.html#o1">_TriggerTime</a> = ms; +00236 <a class="code" href="classNLNET_1_1CBufSock.html#o0">_LastFlushTime</a> = CTime::getLocalTime(); +00237 } +00238 +00239 +00240 <font class="comment">/*</font> +00241 <font class="comment"> * Update the network sending (call this method evenly). Returns false if an error occured.</font> +00242 <font class="comment"> */</font> +<a name="l00243"></a><a class="code" href="classNLNET_1_1CBufSock.html#z347_0">00243</a> <font class="keywordtype">bool</font> CBufSock::update() +00244 { +00245 <a class="code" href="debug_8h.html#a6">nlassert</a> (<font class="keyword">this</font> != InvalidSockId); <font class="comment">// invalid bufsock</font> +00246 <font class="comment">// nlnettrace( "CBufSock::update-BEGIN" );</font> +00247 <font class="comment">// Time trigger</font> +00248 +00249 <font class="keywordflow">if</font> ( <a class="code" href="classNLNET_1_1CBufSock.html#o1">_TriggerTime</a> != -1 ) +00250 { +00251 <a class="code" href="namespaceNLMISC.html#a183">TTime</a> now = CTime::getLocalTime(); +00252 <font class="keywordflow">if</font> ( (sint32)(now-<a class="code" href="classNLNET_1_1CBufSock.html#o0">_LastFlushTime</a>) >= <a class="code" href="classNLNET_1_1CBufSock.html#o1">_TriggerTime</a> ) +00253 { +00254 <font class="preprocessor">#ifdef NL_DEBUG</font> +00255 <font class="preprocessor"></font> _FlushTrigger = FTTime; +00256 <font class="preprocessor">#endif</font> +00257 <font class="preprocessor"></font> <font class="keywordflow">if</font> ( <a class="code" href="classNLNET_1_1CBufSock.html#z347_3">flush</a>() ) +00258 { +00259 <a class="code" href="classNLNET_1_1CBufSock.html#o0">_LastFlushTime</a> = now; +00260 <font class="comment">// nlnettrace ( "CBufSock::update-END time 1" );</font> +00261 <font class="keywordflow">return</font> <font class="keyword">true</font>; +00262 } +00263 <font class="keywordflow">else</font> +00264 { +00265 <font class="comment">// nlnettrace ( "CBufSock::update-END time 0" );</font> +00266 <font class="keywordflow">return</font> <font class="keyword">false</font>; +00267 } +00268 } +00269 } +00270 <font class="comment">// Size trigger</font> +00271 <font class="keywordflow">if</font> ( <a class="code" href="classNLNET_1_1CBufSock.html#o2">_TriggerSize</a> != -1 ) +00272 { +00273 <font class="keywordflow">if</font> ( (sint32)<a class="code" href="classNLNET_1_1CBufSock.html#n0">SendFifo</a>.<a class="code" href="classNLMISC_1_1CBufFIFO.html#a14">size</a>() > <a class="code" href="classNLNET_1_1CBufSock.html#o2">_TriggerSize</a> ) +00274 { +00275 <font class="preprocessor">#ifdef NL_DEBUG</font> +00276 <font class="preprocessor"></font> _FlushTrigger = FTSize; +00277 <font class="preprocessor">#endif</font> +00278 <font class="preprocessor"></font><font class="comment">// nlnettrace( "CBufSock::update-END size" );</font> +00279 <font class="keywordflow">return</font> <a class="code" href="classNLNET_1_1CBufSock.html#z347_3">flush</a>(); +00280 } +00281 } +00282 <font class="comment">// nlnettrace( "CBufSock::update-END nosend" );</font> +00283 <font class="keywordflow">return</font> <font class="keyword">true</font>; +00284 } +00285 +00286 +00287 <font class="comment">/*</font> +00288 <font class="comment"> * Connects to the specified addr; set connectedstate to true if no connection advertising is needed</font> +00289 <font class="comment"> * Precond: not connected</font> +00290 <font class="comment"> */</font> +<a name="l00291"></a><a class="code" href="classNLNET_1_1CBufSock.html#b5">00291</a> <font class="keywordtype">void</font> CBufSock::connect( <font class="keyword">const</font> CInetAddress& <a class="code" href="driver__opengl__extension__def_8h.html#a414">addr</a>, <font class="keywordtype">bool</font> nodelay, <font class="keywordtype">bool</font> connectedstate ) +00292 { +00293 <a class="code" href="debug_8h.html#a6">nlassert</a> (<font class="keyword">this</font> != InvalidSockId); <font class="comment">// invalid bufsock</font> +00294 <a class="code" href="debug_8h.html#a6">nlassert</a>( ! <a class="code" href="classNLNET_1_1CBufSock.html#n1">Sock</a>->connected() ); +00295 +00296 <a class="code" href="classNLNET_1_1CBufSock.html#m1">SendNextValue</a> = <a class="code" href="classNLNET_1_1CBufSock.html#m2">ReceiveNextValue</a> = 0; +00297 +00298 <a class="code" href="classNLNET_1_1CBufSock.html#n1">Sock</a>->connect( <a class="code" href="driver__opengl__extension__def_8h.html#a414">addr</a> ); +00299 <a class="code" href="classNLNET_1_1CBufSock.html#o6">_ConnectedState</a> = connectedstate; +00300 <a class="code" href="classNLNET_1_1CBufSock.html#n2">_KnowConnected</a> = connectedstate; +00301 <font class="keywordflow">if</font> ( nodelay ) +00302 { +00303 <a class="code" href="classNLNET_1_1CBufSock.html#n1">Sock</a>->setNoDelay( <font class="keyword">true</font> ); +00304 } +00305 } +00306 +00307 +00308 <font class="comment">/*</font> +00309 <font class="comment"> * Disconnects; set connectedstate to false if no disconnection advertising is needed</font> +00310 <font class="comment"> */</font> +<a name="l00311"></a><a class="code" href="classNLNET_1_1CBufSock.html#b6">00311</a> <font class="keywordtype">void</font> CBufSock::disconnect( <font class="keywordtype">bool</font> connectedstate ) +00312 { +00313 <a class="code" href="debug_8h.html#a6">nlassert</a> (<font class="keyword">this</font> != InvalidSockId); <font class="comment">// invalid bufsock</font> +00314 <a class="code" href="classNLNET_1_1CBufSock.html#n1">Sock</a>->disconnect(); +00315 <a class="code" href="classNLNET_1_1CBufSock.html#o6">_ConnectedState</a> = connectedstate; +00316 <a class="code" href="classNLNET_1_1CBufSock.html#n2">_KnowConnected</a> = connectedstate; +00317 +00318 <a class="code" href="classNLNET_1_1CBufSock.html#m1">SendNextValue</a> = <a class="code" href="classNLNET_1_1CBufSock.html#m2">ReceiveNextValue</a> = 0; +00319 } +00320 +00321 +00322 <font class="comment">/*</font> +00323 <font class="comment"> * Returns a string with the characteristics of the object</font> +00324 <font class="comment"> */</font> +<a name="l00325"></a><a class="code" href="classNLNET_1_1CBufSock.html#a3">00325</a> string CBufSock::asString()<font class="keyword"> const</font> +00326 <font class="keyword"></font>{ +00327 stringstream ss; +00328 <font class="keywordflow">if</font> (<font class="keyword">this</font> == InvalidSockId) <font class="comment">// tricky</font> +00329 ss << <font class="stringliteral">"<Null>"</font>; +00330 <font class="keywordflow">else</font> +00331 { +00332 <font class="comment">// if it crashs here, it means that the CBufSock was deleted and you try to access to the virtual table that is empty</font> +00333 <font class="comment">// because the object is destroyed.</font> +00334 ss << <a class="code" href="classNLNET_1_1CBufSock.html#b1">typeStr</a>(); +00335 ss << hex << <font class="keyword">this</font> << dec << <font class="stringliteral">" (socket "</font>; +00336 +00337 <font class="keywordflow">if</font> (<a class="code" href="classNLNET_1_1CBufSock.html#n1">Sock</a> == NULL) +00338 ss << <font class="stringliteral">"<Null>"</font>; +00339 <font class="keywordflow">else</font> +00340 ss << <a class="code" href="classNLNET_1_1CBufSock.html#n1">Sock</a>->descriptor(); +00341 +00342 ss << <font class="stringliteral">")"</font>; +00343 } +00344 <font class="keywordflow">return</font> ss.str(); +00345 } +00346 +00347 +00348 <font class="comment">/*</font> +00349 <font class="comment"> * Constructor with an existing socket (created by an accept())</font> +00350 <font class="comment"> */</font> +<a name="l00351"></a><a class="code" href="classNLNET_1_1CServerBufSock.html#b0">00351</a> CServerBufSock::CServerBufSock( CTcpSock *sock ) : +00352 CBufSock( sock ), +00353 _Advertised( false ), +00354 _NowReadingBuffer( false ), +00355 _BytesRead( 0 ), +00356 _Length( 0 ), +00357 _OwnerTask( NULL ) +00358 { +00359 <a class="code" href="debug_8h.html#a6">nlassert</a> (<font class="keyword">this</font> != InvalidSockId); <font class="comment">// invalid bufsock</font> +00360 <a class="code" href="buf__sock_8h.html#a0">nlnettrace</a>( <font class="stringliteral">"CServerBufSock::CServerBufSock"</font> ); +00361 } +00362 +00363 +00364 <font class="comment">// In Receive Threads:</font> +00365 +00366 +00367 <font class="comment">/*</font> +00368 <font class="comment"> * Receives a part of a message (nonblocking socket only)</font> +00369 <font class="comment"> */</font> +<a name="l00370"></a><a class="code" href="classNLNET_1_1CServerBufSock.html#b3">00370</a> <font class="keywordtype">bool</font> CServerBufSock::receivePart() +00371 { +00372 <a class="code" href="debug_8h.html#a6">nlassert</a> (<font class="keyword">this</font> != InvalidSockId); <font class="comment">// invalid bufsock</font> +00373 <a class="code" href="buf__sock_8h.html#a0">nlnettrace</a>( <font class="stringliteral">"CServerBufSock::receivePart"</font> ); +00374 +00375 <a class="code" href="namespaceNLNET.html#a6">TBlockSize</a> actuallen; +00376 <font class="keywordflow">if</font> ( ! <a class="code" href="classNLNET_1_1CServerBufSock.html#o1">_NowReadingBuffer</a> ) +00377 { +00378 <font class="comment">// Receiving length prefix</font> +00379 actuallen = <font class="keyword">sizeof</font>(_Length)-<a class="code" href="classNLNET_1_1CServerBufSock.html#o2">_BytesRead</a>; +00380 <a class="code" href="classNLNET_1_1CBufSock.html#n1">Sock</a>->receive( (uint8*)(&<a class="code" href="classNLNET_1_1CServerBufSock.html#o3">_Length</a>)+<a class="code" href="classNLNET_1_1CServerBufSock.html#o2">_BytesRead</a>, actuallen ); +00381 <a class="code" href="classNLNET_1_1CServerBufSock.html#o2">_BytesRead</a> += actuallen; +00382 <font class="keywordflow">if</font> ( <a class="code" href="classNLNET_1_1CServerBufSock.html#o2">_BytesRead</a> == <font class="keyword">sizeof</font>(_Length ) ) +00383 { +00384 <font class="keywordflow">if</font> ( <a class="code" href="classNLNET_1_1CServerBufSock.html#o3">_Length</a> != 0 ) +00385 { +00386 <a class="code" href="classNLNET_1_1CServerBufSock.html#o3">_Length</a> = ntohl( <a class="code" href="classNLNET_1_1CServerBufSock.html#o3">_Length</a> ); +00387 +00388 <font class="comment">// Test size limit</font> +00389 <font class="keywordflow">if</font> ( <a class="code" href="classNLNET_1_1CServerBufSock.html#o3">_Length</a> > <a class="code" href="classNLNET_1_1CServerBufSock.html#o5">_OwnerTask</a>->server()->maxExpectedBlockSize() ) +00390 { +00391 <a class="code" href="debug_8h.html#a2">nlwarning</a>( <font class="stringliteral">"LNETL1: Socket %s received length exceeding max expected, in block header... Disconnecting"</font>, <a class="code" href="classNLNET_1_1CBufSock.html#a3">asString</a>().c_str() ); +00392 <font class="keywordflow">throw</font> ESocket( <font class="stringliteral">"Received length exceeding max expected"</font>, <font class="keyword">false</font> ); +00393 } +00394 +00395 <a class="code" href="classNLNET_1_1CServerBufSock.html#o1">_NowReadingBuffer</a> = <font class="keyword">true</font>; +00396 <a class="code" href="classNLNET_1_1CServerBufSock.html#o4">_ReceiveBuffer</a>.resize( <a class="code" href="classNLNET_1_1CServerBufSock.html#o3">_Length</a> ); +00397 } +00398 <font class="keywordflow">else</font> +00399 { +00400 <a class="code" href="debug_8h.html#a2">nlwarning</a>( <font class="stringliteral">"LNETL1: Socket %s received null length in block header"</font>, <a class="code" href="classNLNET_1_1CBufSock.html#a3">asString</a>().c_str() ); +00401 } +00402 <a class="code" href="classNLNET_1_1CServerBufSock.html#o2">_BytesRead</a> = 0; +00403 } +00404 } +00405 +00406 <font class="keywordflow">if</font> ( _NowReadingBuffer ) +00407 { +00408 <font class="comment">// Receiving payload buffer</font> +00409 actuallen = <a class="code" href="classNLNET_1_1CServerBufSock.html#o3">_Length</a>-<a class="code" href="classNLNET_1_1CServerBufSock.html#o2">_BytesRead</a>; +00410 <a class="code" href="classNLNET_1_1CBufSock.html#n1">Sock</a>->receive( &*<a class="code" href="classNLNET_1_1CServerBufSock.html#o4">_ReceiveBuffer</a>.begin()+<a class="code" href="classNLNET_1_1CServerBufSock.html#o2">_BytesRead</a>, actuallen ); +00411 <a class="code" href="classNLNET_1_1CServerBufSock.html#o2">_BytesRead</a> += actuallen; +00412 +00413 <font class="keywordflow">if</font> ( <a class="code" href="classNLNET_1_1CServerBufSock.html#o2">_BytesRead</a> == <a class="code" href="classNLNET_1_1CServerBufSock.html#o3">_Length</a> ) +00414 { +00415 <font class="preprocessor">#ifdef NL_DEBUG</font> +00416 <font class="preprocessor"></font> <a class="code" href="debug_8h.html#a0">nldebug</a>( <font class="stringliteral">"LNETL1: %s received buffer (%u bytes): [%s]"</font>, <a class="code" href="classNLNET_1_1CBufSock.html#a3">asString</a>().c_str(), <a class="code" href="classNLNET_1_1CServerBufSock.html#o4">_ReceiveBuffer</a>.size(), stringFromVector(_ReceiveBuffer).c_str() ); +00417 <font class="preprocessor">#endif</font> +00418 <font class="preprocessor"></font> <a class="code" href="classNLNET_1_1CServerBufSock.html#o1">_NowReadingBuffer</a> = <font class="keyword">false</font>; +00419 <a class="code" href="classNLNET_1_1CServerBufSock.html#o2">_BytesRead</a> = 0; +00420 <font class="keywordflow">return</font> <font class="keyword">true</font>; +00421 } +00422 } +00423 +00424 <font class="keywordflow">return</font> <font class="keyword">false</font>; +00425 } +00426 +00427 } <font class="comment">// NLNET</font> +</pre></div> + +<!-- footer --> +<BR><FONT Size=+5> </FONT> +</TD> +<TD WIDTH=15><IMG SRC=http://www.nevrax.org/inc/img/pixel.gif WIDTH=15 HEIGHT=15 BORDER=0 ALT=""></TD> +</TR> +</TABLE> +</BODY> +</HTML> |