_chat_inet_8cpp-source.html

一个聊天的软件

<a name="l00284"></a>00284 <span class="comment">// Disconnects from the remote machine.</span>
<a name="l00285"></a>00285 <span class="comment">// ----------------------------------------------------------------------------</span>
<a name="l00286"></a>00286 <span class="comment">//</span>
<a name="l00287"></a><a class="code" href="class_c_chat_inet.html#90fa17f1549fcafa070e14c9e5e7234d">00287</a> <span class="keywordtype">void</span> <a class="code" href="class_c_chat_inet.html#90fa17f1549fcafa070e14c9e5e7234d">CChatInet::DisconnectL</a>()
<a name="l00288"></a>00288     {
<a name="l00289"></a>00289     <span class="keywordflow">if</span> ( ( <a class="code" href="class_c_chat_base.html#af77e92297a4bac4704e440284577ebe">State</a>() == EConnected )||( <a class="code" href="class_c_chat_base.html#af77e92297a4bac4704e440284577ebe">State</a>() == ESendingMessage ) )
<a name="l00290"></a>00290         {
<a name="l00291"></a>00291         <a class="code" href="class_c_chat_inet.html#e109483d24ec2fbd018840d64f6242c5">DisconnectFromServerL</a>();
<a name="l00292"></a>00292         <a class="code" href="class_c_chat_base.html#deacd9f98d0548748cf116698aea2be0">SetState</a>( EDisconnecting );
<a name="l00293"></a>00293         }
<a name="l00294"></a>00294     <span class="keywordflow">else</span>
<a name="l00295"></a>00295         {
<a name="l00296"></a>00296         HBufC* errNoConn = StringLoader::LoadLC ( R_CHAT_ERR_NO_CONN );
<a name="l00297"></a>00297         <a class="code" href="class_c_chat_inet.html#9d387bbae93f2ae894f3e1c32e6bf1c6">iLog</a>.<a class="code" href="class_m_log.html#70fb5098d98a8b349c056b46102d5de9">LogL</a>( *errNoConn );
<a name="l00298"></a>00298         CleanupStack::PopAndDestroy( errNoConn );
<a name="l00299"></a>00299         User::Leave( KErrDisconnected );
<a name="l00300"></a>00300         }
<a name="l00301"></a>00301     }
<a name="l00302"></a>00302 
<a name="l00303"></a>00303 <span class="comment">// ----------------------------------------------------------------------------</span>
<a name="l00304"></a>00304 <span class="comment">// CChatInet::DisconnectFromServerL()</span>
<a name="l00305"></a>00305 <span class="comment">// Disconnects from the service</span>
<a name="l00306"></a>00306 <span class="comment">// ----------------------------------------------------------------------------</span>
<a name="l00307"></a>00307 <span class="comment">//</span>
<a name="l00308"></a><a class="code" href="class_c_chat_inet.html#e109483d24ec2fbd018840d64f6242c5">00308</a> <span class="keywordtype">void</span> <a class="code" href="class_c_chat_inet.html#e109483d24ec2fbd018840d64f6242c5">CChatInet::DisconnectFromServerL</a>()
<a name="l00309"></a>00309     {
<a name="l00310"></a>00310     <span class="comment">// Terminate all operations</span>
<a name="l00311"></a>00311     <a class="code" href="class_c_chat_inet.html#4791a9b2a2447d2068a89acb05c8c25b">iSocket</a>.CancelAll();
<a name="l00312"></a>00312     Cancel();
<a name="l00313"></a>00313 
<a name="l00314"></a>00314     HBufC* strReleasingConn = StringLoader
<a name="l00315"></a>00315         ::LoadLC ( R_CHAT_STR_RELEASING_CONN );
<a name="l00316"></a>00316     <a class="code" href="class_c_chat_inet.html#9d387bbae93f2ae894f3e1c32e6bf1c6">iLog</a>.<a class="code" href="class_m_log.html#70fb5098d98a8b349c056b46102d5de9">LogL</a>( *strReleasingConn );
<a name="l00317"></a>00317     CleanupStack::PopAndDestroy( strReleasingConn );
<a name="l00318"></a>00318     <a class="code" href="class_c_chat_inet.html#4791a9b2a2447d2068a89acb05c8c25b">iSocket</a>.Shutdown( RSocket::ENormal, iStatus );
<a name="l00319"></a>00319     SetActive();
<a name="l00320"></a>00320     }
<a name="l00321"></a>00321 
<a name="l00322"></a>00322 <span class="comment">// ----------------------------------------------------------------------------</span>
<a name="l00323"></a>00323 <span class="comment">// CChatInet::ConnectToServerL()</span>
<a name="l00324"></a>00324 <span class="comment">// Connect to the server.</span>
<a name="l00325"></a>00325 <span class="comment">// ----------------------------------------------------------------------------</span>
<a name="l00326"></a>00326 <span class="comment">//</span>
<a name="l00327"></a><a class="code" href="class_c_chat_inet.html#b449bdd385967c4126b2611e5cb7e36f">00327</a> <span class="keywordtype">void</span> <a class="code" href="class_c_chat_inet.html#b449bdd385967c4126b2611e5cb7e36f">CChatInet::ConnectToServerL</a>( <span class="keyword">const</span> TDesC&amp; aAddress )
<a name="l00328"></a>00328     {
<a name="l00329"></a>00329     HBufC* strConnecting = StringLoader
<a name="l00330"></a>00330         ::LoadLC ( R_CHAT_STR_CONNECTING );
<a name="l00331"></a>00331     <a class="code" href="class_c_chat_inet.html#9d387bbae93f2ae894f3e1c32e6bf1c6">iLog</a>.<a class="code" href="class_m_log.html#70fb5098d98a8b349c056b46102d5de9">LogL</a>( *strConnecting );
<a name="l00332"></a>00332     CleanupStack::PopAndDestroy( strConnecting );
<a name="l00333"></a>00333     
<a name="l00334"></a>00334     TInetAddr addr;
<a name="l00335"></a>00335   <span class="keywordflow">if</span> ( addr.Input( aAddress ) == KErrNone )
<a name="l00336"></a>00336         {
<a name="l00337"></a>00337         <span class="comment">// server name is already a valid ip address</span>
<a name="l00338"></a>00338         <a class="code" href="class_c_chat_inet.html#8972dc718386d445f2d0b38cc55db1e7">ConnectL</a>( addr.Address() );
<a name="l00339"></a>00339         }
<a name="l00340"></a>00340     <span class="keywordflow">else</span> 
<a name="l00341"></a>00341         {
<a name="l00342"></a>00342         <span class="comment">// Initiate DNS</span>
<a name="l00343"></a>00343         User::LeaveIfError( <a class="code" href="class_c_chat_inet.html#b1070510689fa8b751a37a19716e2b8c">iResolver</a>.Open( <a class="code" href="class_c_chat_inet.html#56bd53f21c6818eaa0d4a1ad2c7c5a84">iSocketServer</a>,
<a name="l00344"></a>00344                                             KAfInet,
<a name="l00345"></a>00345                                             KProtocolInetTcp ) );
<a name="l00346"></a>00346         <span class="comment">// DNS request for name resolution</span>
<a name="l00347"></a>00347         <a class="code" href="class_c_chat_inet.html#b1070510689fa8b751a37a19716e2b8c">iResolver</a>.GetByName( aAddress, <a class="code" href="class_c_chat_inet.html#9d553c2bdc0685584364edb811f27f3b">iNameEntry</a>, iStatus );
<a name="l00348"></a>00348         
<a name="l00349"></a>00349         TRequestStatus waitStatus = KRequestPending;
<a name="l00350"></a>00350         RTimer timer;
<a name="l00351"></a>00351         timer.CreateLocal();
<a name="l00352"></a>00352     
<a name="l00353"></a>00353         timer.After( waitStatus, KChatTimeOut );
<a name="l00354"></a>00354      
<a name="l00355"></a>00355         User::WaitForRequest( iStatus, waitStatus );
<a name="l00356"></a>00356         
<a name="l00357"></a>00357         <span class="keywordflow">if</span> ( iStatus == KRequestPending )
<a name="l00358"></a>00358             {
<a name="l00359"></a>00359             <a class="code" href="class_c_chat_inet.html#b1070510689fa8b751a37a19716e2b8c">iResolver</a>.Cancel();
<a name="l00360"></a>00360             
<a name="l00361"></a>00361             User::WaitForRequest( iStatus );
<a name="l00362"></a>00362             <a class="code" href="class_c_chat_inet.html#b1070510689fa8b751a37a19716e2b8c">iResolver</a>.Close();
<a name="l00363"></a>00363             <span class="comment">// Operation did not complete in time.</span>
<a name="l00364"></a>00364             HBufC* strConnecting = StringLoader
<a name="l00365"></a>00365                 ::LoadLC ( R_CHAT_ERR_TIMEOUT );
<a name="l00366"></a>00366             <a class="code" href="class_c_chat_inet.html#9d387bbae93f2ae894f3e1c32e6bf1c6">iLog</a>.<a class="code" href="class_m_log.html#70fb5098d98a8b349c056b46102d5de9">LogL</a>( *strConnecting );
<a name="l00367"></a>00367             CleanupStack::PopAndDestroy( strConnecting );
<a name="l00368"></a>00368             <a class="code" href="class_c_chat_base.html#deacd9f98d0548748cf116698aea2be0">SetState</a>( EDisconnected );
<a name="l00369"></a>00369             timer.Close();
<a name="l00370"></a>00370             User::Leave( KErrTimedOut );
<a name="l00371"></a>00371 
<a name="l00372"></a>00372             }
<a name="l00373"></a>00373         <span class="keywordflow">else</span>
<a name="l00374"></a>00374             {
<a name="l00375"></a>00375             <span class="comment">// DNS look up successful</span>
<a name="l00376"></a>00376                 <a class="code" href="class_c_chat_inet.html#7df2f02c93aa57d69fa421a0c9648b9b">iNameRecord</a> = <a class="code" href="class_c_chat_inet.html#9d553c2bdc0685584364edb811f27f3b">iNameEntry</a>();
<a name="l00377"></a>00377                 TBuf&lt;KIpAddressLen&gt; ipAddr;
<a name="l00378"></a>00378                 TInetAddr::Cast( <a class="code" href="class_c_chat_inet.html#7df2f02c93aa57d69fa421a0c9648b9b">iNameRecord</a>.iAddr ).Output( ipAddr );
<a name="l00379"></a>00379                 <a class="code" href="class_c_chat_inet.html#8972dc718386d445f2d0b38cc55db1e7">ConnectL</a>( TInetAddr::Cast( <a class="code" href="class_c_chat_inet.html#7df2f02c93aa57d69fa421a0c9648b9b">iNameRecord</a>.iAddr ).Address() );
<a name="l00380"></a>00380                 
<a name="l00381"></a>00381             timer.Cancel();
<a name="l00382"></a>00382             User::WaitForRequest( waitStatus );
<a name="l00383"></a>00383             timer.Close();
<a name="l00384"></a>00384             <a class="code" href="class_c_chat_inet.html#b1070510689fa8b751a37a19716e2b8c">iResolver</a>.Close();
<a name="l00385"></a>00385             }
<a name="l00386"></a>00386 
<a name="l00387"></a>00387       }
<a name="l00388"></a>00388 
<a name="l00389"></a>00389 <span class="preprocessor">  #ifdef __WINS__</span>
<a name="l00390"></a>00390 <span class="preprocessor"></span>      User::After( 1 );     <span class="comment">// Fix to allow emulator client to connect to server</span>
<a name="l00391"></a>00391 <span class="preprocessor">  #endif</span>
<a name="l00392"></a>00392 <span class="preprocessor"></span>  
<a name="l00393"></a>00393     SetState( EGettingConnection );
<a name="l00394"></a>00394 
<a name="l00395"></a>00395     SetActive();
<a name="l00396"></a>00396     }
<a name="l00397"></a>00397 
<a name="l00398"></a>00398 
<a name="l00399"></a>00399 <span class="comment">// -----------------------------------------------------------------------------</span>
<a name="l00400"></a>00400 <span class="comment">// CChatInet::ConnectL()</span>
<a name="l00401"></a>00401 <span class="comment">// Initiates a connect operation on a socket.</span>
<a name="l00402"></a>00402 <span class="comment">// -----------------------------------------------------------------------------</span>
<a name="l00403"></a>00403 <span class="comment">//</span>
<a name="l00404"></a><a class="code" href="class_c_chat_inet.html#345d0d754ebc6b15fd182f42d46a1310">00404</a> <span class="keywordtype">void</span> <a class="code" href="class_c_chat_inet.html#8972dc718386d445f2d0b38cc55db1e7">CChatInet::ConnectL</a>( TUint32 aAddr )
<a name="l00405"></a>00405     {
<a name="l00406"></a>00406     <a class="code" href="class_c_chat_inet.html#42435def2f80909f7700ad684c625f0f">iActiveSocket</a> = &amp;<a class="code" href="class_c_chat_inet.html#4791a9b2a2447d2068a89acb05c8c25b">iSocket</a>;
<a name="l00407"></a>00407     <a class="code" href="class_c_chat_inet.html#5d2af0e4e421312918bddbe0e0861f28">iAddress</a>.SetPort( <a class="code" href="class_c_chat_inet.html#ca13b175f9849e6ff5ce23ea58682739">iPort</a> );
<a name="l00408"></a>00408     <a class="code" href="class_c_chat_inet.html#5d2af0e4e421312918bddbe0e0861f28">iAddress</a>.SetAddress( aAddr );
<a name="l00409"></a>00409     <a class="code" href="class_c_chat_inet.html#5d2af0e4e421312918bddbe0e0861f28">iAddress</a>.SetFamily( KAfInet );
<a name="l00410"></a>00410         
<a name="l00411"></a>00411     <span class="comment">// Open a TCP socket</span>
<a name="l00412"></a>00412     User::LeaveIfError( <a class="code" href="class_c_chat_inet.html#4791a9b2a2447d2068a89acb05c8c25b">iSocket</a>.Open( <a class="code" href="class_c_chat_inet.html#56bd53f21c6818eaa0d4a1ad2c7c5a84">iSocketServer</a>,
<a name="l00413"></a>00413         KAfInet,
<a name="l00414"></a>00414         KSockStream,
<a name="l00415"></a>00415         KProtocolInetTcp ) );
<a name="l00416"></a>00416 
<a name="l00417"></a>00417     <span class="comment">// Initiate socket connection</span>
<a name="l00418"></a>00418     <a class="code" href="class_c_chat_inet.html#4791a9b2a2447d2068a89acb05c8c25b">iSocket</a>.Connect( <a class="code" href="class_c_chat_inet.html#5d2af0e4e421312918bddbe0e0861f28">iAddress</a>, iStatus );
<a name="l00419"></a>00419     }
<a name="l00420"></a>00420 
<a name="l00421"></a>00421 
<a name="l00422"></a>00422 <span class="comment">// ----------------------------------------------------------------------------</span>
<a name="l00423"></a>00423 <span class="comment">// CChatInet::SendMessageL()</span>
<a name="l00424"></a>00424 <span class="comment">// Send a message to a service on a remote machine.</span>
<a name="l00425"></a>00425 <span class="comment">// ----------------------------------------------------------------------------</span>
<a name="l00426"></a>00426 <span class="comment">//</span>
<a name="l00427"></a><a class="code" href="class_c_chat_inet.html#2ba04add62f4a2053e7628aea8d821af">00427</a> <span class="keywordtype">void</span> <a class="code" href="class_c_chat_inet.html#2ba04add62f4a2053e7628aea8d821af">CChatInet::SendMessageL</a>( <span class="keyword">const</span> TDesC&amp; aText )
<a name="l00428"></a>00428     {
<a name="l00429"></a>00429     <span class="keywordflow">if</span> ( <a class="code" href="class_c_chat_base.html#af77e92297a4bac4704e440284577ebe">State</a>() != EConnected )
<a name="l00430"></a>00430         {
<a name="l00431"></a>00431         User::Leave( KErrDisconnected );
<a name="l00432"></a>00432         }
<a name="l00433"></a>00433 
<a name="l00434"></a>00434     <span class="comment">// stop reading socket</span>