From 0ea5fc66924303d1bf73ba283a383e2aadee02f2 Mon Sep 17 00:00:00 2001 From: neodarz Date: Sat, 11 Aug 2018 20:21:34 +0200 Subject: Initial commit --- docs/doxygen/nel/a02770.html | 575 +++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 575 insertions(+) create mode 100644 docs/doxygen/nel/a02770.html (limited to 'docs/doxygen/nel/a02770.html') diff --git a/docs/doxygen/nel/a02770.html b/docs/doxygen/nel/a02770.html new file mode 100644 index 00000000..3184ff11 --- /dev/null +++ b/docs/doxygen/nel/a02770.html @@ -0,0 +1,575 @@ + + +NeL: NLNET::CListenTask class Reference + + + +
+Main Page | Namespace List | Class Hierarchy | Alphabetical List | Data Structures | File List | Namespace Members | Data Fields | Globals | Related Pages | Search for 
+

NLNET::CListenTask Class Reference

#include <buf_server.h> +

+

Inheritance diagram for NLNET::CListenTask: +

+ +NLMISC::IRunnable +NLNET::CServerTask + +

Detailed Description

+Code of listening thread +

+ +

+Definition at line 87 of file buf_server.h. + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +

Public Member Functions

 CListenTask (CBufServer *server)
 Constructor.

void close ()
 Close listening socket.

virtual void getName (std::string &result) const
void init (uint16 port, sint32 maxExpectedBlockSize)
 Begins to listen on the specified port (call before running thread).

const CInetAddress & localAddr ()
 Returns the listening address.

void requireExit ()
 Tells the task to exit.

virtual void run ()
 Run (exits when the listening socket disconnects).


Data Fields

uint32 NbLoop

Protected Member Functions

bool exitRequired () const
 Returns true if the requireExit() has been called.


Private Attributes

CListenSock _ListenSock
uint32 _MaxExpectedBlockSize
CBufServer * _Server
+

Constructor & Destructor Documentation

+

+ + + + +
+ + + + + + + + + + +
NLNET::CListenTask::CListenTask ( CBufServer *  server  )  [inline]
+
+ + + + + +
+   + + +

+Constructor. +

+ +

+Definition at line 92 of file buf_server.h. +

+References _Server. +

+

00092 : CServerTask(), _Server(server) {}
+
+

Member Function Documentation

+

+ + + + +
+ + + + + + + + + +
void NLNET::CListenTask::close (   )  [inline]
+
+ + + + + +
+   + + +

+Close listening socket. +

+ +

+Definition at line 101 of file buf_server.h. +

+References _ListenSock, and NLNET::CSock::close(). +

+

00101 { _ListenSock.close(); }
+
+

+ + + + +
+ + + + + + + + + +
bool NLNET::CServerTask::exitRequired (   )  const [inline, protected, inherited]
+
+ + + + + +
+   + + +

+Returns true if the requireExit() has been called. +

+ +

+Definition at line 71 of file buf_server.h. +

+References NLNET::CServerTask::_ExitRequired. +

+Referenced by NLNET::CServerReceiveTask::run(), and run(). +

+

00071 { return _ExitRequired; }
+
+

+ + + + +
+ + + + + + + + + + +
virtual void NLMISC::IRunnable::getName ( std::string &  result  )  const [inline, virtual, inherited]
+
+ + + + + +
+   + + +

+ +

+Reimplemented in NL3D::CAsyncFileManager3D::CMeshLoad, NL3D::CAsyncFileManager3D::CIGLoad, NL3D::CAsyncFileManager3D::CIGLoadUser, NL3D::CAsyncFileManager3D::CTextureLoad, NL3D::CZoneLoadingTask, NLPACS::CGlobalRetriever::CLrLoader, NLMISC::CAsyncFileManager::CFileLoad, NLMISC::CAsyncFileManager::CMultipleFileLoad, and NLMISC::CAsyncFileManager::CSignal. +

+Definition at line 74 of file thread.h. +

+Referenced by NLMISC::CTaskManager::run(). +

+

00075         {
+00076                 result = "NoName";
+00077         }
+
+

+ + + + +
+ + + + + + + + + + + + + + + + + + + +
void NLNET::CListenTask::init ( uint16  port,
sint32  maxExpectedBlockSize
) 
+
+ + + + + +
+   + + +

+Begins to listen on the specified port (call before running thread). +

+ +

+Definition at line 111 of file buf_server.cpp. +

+References _ListenSock, NLNET::CListenSock::init(), nlnettrace, sint32, and uint16. +

+Referenced by NLNET::CBufServer::init(). +

+

00112 {
+00113         nlnettrace( "CListenTask::init" );
+00114         _ListenSock.init( port );
+00115         _MaxExpectedBlockSize = maxExpectedBlockSize;
+00116 }
+
+

+ + + + +
+ + + + + + + + + +
const CInetAddress& NLNET::CListenTask::localAddr (   )  [inline]
+
+ + + + + +
+   + + +

+Returns the listening address. +

+ +

+Definition at line 104 of file buf_server.h. +

+References _ListenSock, and NLNET::CSock::localAddr(). +

+Referenced by NLNET::CBufServer::listenAddress(). +

+

00104 { return _ListenSock.localAddr(); }
+
+

+ + + + +
+ + + + + + + + + +
void NLNET::CServerTask::requireExit (   )  [inline, inherited]
+
+ + + + + +
+   + + +

+Tells the task to exit. +

+ +

+Definition at line 56 of file buf_server.h. +

+References NLNET::CServerTask::_ExitRequired. +

+Referenced by NLNET::CBufServer::~CBufServer(). +

+

00056 { _ExitRequired = true; }
+
+

+ + + + +
+ + + + + + + + + +
void NLNET::CListenTask::run (   )  [virtual]
+
+ + + + + +
+   + + +

+Run (exits when the listening socket disconnects). +

+ +

+Implements NLMISC::IRunnable. +

+Definition at line 779 of file buf_server.cpp. +

+References _ListenSock, _Server, NLNET::CListenSock::accept(), NLNET::CServerBufSock::advertiseConnection(), NLNET::CBufSock::asString(), NLNET::CSock::descriptor(), NLNET::CBufServer::dispatchNewSocket(), NLNET::CServerTask::exitRequired(), NLNET::NbNetworkTask, NLNET::NbServerListenTask, nldebug, nlerror, nlinfo, nlnettrace, NLNET::CBufServer::noDelay(), res, NLNET::CNonBlockingBufSock::setMaxExpectedBlockSize(), NLNET::CTcpSock::setNoDelay(), NLNET::CNonBlockingBufSock::setNonBlocking(), NLNET::CBufSock::Sock, and uint8. +

+

00780 {
+00781         NbNetworkTask++;
+00782         NbServerListenTask++;
+00783 
+00784         nlnettrace( "CListenTask::run" );
+00785 
+00786 #ifdef NL_OS_UNIX
+00787         SOCKET descmax;
+00788         fd_set readers;
+00789         timeval tv;
+00790         descmax = _ListenSock.descriptor()>_WakeUpPipeHandle[PipeRead]?_ListenSock.descriptor():_WakeUpPipeHandle[PipeRead];
+00791 #endif
+00792 
+00793         // Accept connections
+00794         while ( ! exitRequired() )
+00795         {
+00796                 try
+00797                 {
+00798                         // Get and setup the new socket
+00799 #ifdef NL_OS_UNIX
+00800                         FD_ZERO( &readers );
+00801                         FD_SET( _ListenSock.descriptor(), &readers );
+00802                         FD_SET( _WakeUpPipeHandle[PipeRead], &readers );
+00803                         tv.tv_sec = 60; 
+00804                         tv.tv_usec = 0;
+00805                         int res = ::select( descmax+1, &readers, NULL, NULL, &tv );
+00806 
+00807                         switch ( res )
+00808                         {
+00809                         case  0 : continue; // time-out expired, no results
+00810                         case -1 :
+00811                                 // we'll ignore message (Interrupted system call) caused by a CTRL-C
+00812                                 if (CSock::getLastError() == 4)
+00813                                 {
+00814                                         nldebug ("LNETL1: Select failed (in listen thread): %s (code %u) but IGNORED", CSock::errorString( CSock::getLastError() ).c_str(), CSock::getLastError());
+00815                                         continue;
+00816                                 }
+00817                                 nlerror( "LNETL1: Select failed (in listen thread): %s (code %u)", CSock::errorString( CSock::getLastError() ).c_str(), CSock::getLastError() );
+00818                         }
+00819 
+00820                         if ( FD_ISSET( _WakeUpPipeHandle[PipeRead], &readers ) )
+00821                         {
+00822                                 uint8 b;
+00823                                 if ( read( _WakeUpPipeHandle[PipeRead], &b, 1 ) == -1 ) // we were woken-up by the wake-up pipe
+00824                                 {
+00825                                         nldebug( "LNETL1: In CListenTask::run(): read() failed" );
+00826                                 }
+00827                                 nldebug( "LNETL1: listen thread select woken-up" );
+00828                                 continue;
+00829                         }
+00830 #endif
+00831                         nldebug( "LNETL1: Waiting incoming connection..." );
+00832                         CServerBufSock *bufsock = new CServerBufSock( _ListenSock.accept() );
+00833                         nldebug( "LNETL1: New connection : %s", bufsock->asString().c_str() );
+00834                         bufsock->setNonBlocking();
+00835                         bufsock->setMaxExpectedBlockSize( _MaxExpectedBlockSize );
+00836                         if ( _Server->noDelay() )
+00837                         {
+00838                                 bufsock->Sock->setNoDelay( true );
+00839                         }
+00840 
+00841                         // Notify the new connection
+00842                         bufsock->advertiseConnection( _Server );
+00843 
+00844                         // Dispatch the socket into the thread pool
+00845                         _Server->dispatchNewSocket( bufsock );
+00846 
+00847                         NbLoop++;
+00848                 }
+00849                 catch ( ESocket& e )
+00850                 {
+00851                         nlinfo( "LNETL1: Exception in listen thread: %s", e.what() ); // It can occur in normal behavior (e.g. when exiting)
+00852                         // It can also occur when too many sockets are open (e.g. 885 connections)
+00853                 }
+00854         }
+00855 
+00856         nlnettrace( "Exiting CListenTask::run" );
+00857         NbServerListenTask--;
+00858         NbNetworkTask--;
+00859 }
+
+

Field Documentation

+

+ + + + +
+ + +
CListenSock NLNET::CListenTask::_ListenSock [private] +
+
+ + + + + +
+   + + +

+ +

+Definition at line 109 of file buf_server.h. +

+Referenced by close(), init(), localAddr(), and run().

+

+ + + + +
+ + +
uint32 NLNET::CListenTask::_MaxExpectedBlockSize [private] +
+
+ + + + + +
+   + + +

+ +

+Definition at line 110 of file buf_server.h.

+

+ + + + +
+ + +
CBufServer* NLNET::CListenTask::_Server [private] +
+
+ + + + + +
+   + + +

+ +

+Definition at line 108 of file buf_server.h. +

+Referenced by CListenTask(), and run().

+

+ + + + +
+ + +
uint32 NLNET::CServerTask::NbLoop [inherited] +
+
+ + + + + +
+   + + +

+ +

+Definition at line 63 of file buf_server.h. +

+Referenced by NLNET::CBufServer::displayThreadStat().

+

The documentation for this class was generated from the following files: +
Generated on Tue Mar 16 13:58:21 2004 for NeL by + +doxygen +1.3.6
+ + -- cgit v1.2.1