CServerSocket Class Reference

#include <socket.h>

Inheritance diagram for CServerSocket:

Collaboration diagram for CServerSocket:

Public Member Functions
	CServerSocket ()
virtual	~CServerSocket ()
virtual VOID	SetPort (UINT nPort)
virtual VOID	Open ()
virtual VOID	Close ()
virtual LPCServerClientSocket	OnGetSocket (LPCServerSocket lpServerSocket)
virtual LPCServerClientThread	OnGetThread (LPCServerClientSocket lpSocket)
virtual VOID	OnAccept (LPCServerClientThread lpThread)
virtual VOID	MessageLoop ()
VOID	InsertClient (LPCServerClientThread lpClient)
VOID	RemoveClient (LPCServerClientThread lpClient)
Public Member Functions inherited from CSocket
	CSocket ()
virtual	~CSocket ()
virtual SOCKET	GetSocket ()
virtual VOID	SetSocket (SOCKET socket)
virtual SOCKADDR_IN	GetSockAddrIn ()
virtual VOID	SetSockAddrIn (SOCKADDR_IN sockaddrin)
virtual VOID	SetEvents (LONG lEvents)
virtual LONG	GetEvents ()
virtual VOID	SetPort (UINT nPort)
virtual VOID	Open ()
virtual VOID	Close ()
virtual INT	Transmit (LPCSTR lpsBuffer, UINT nLength)
virtual INT	Receive (LPSTR lpsBuffer, UINT nLength)
virtual INT	SendText (LPCSTR lpsStr)

Protected Attributes
CList< LPCServerClientThread >	Connections
Protected Attributes inherited from CSocket
SOCKET	Socket
SOCKADDR_IN	SockAddrIn
WSAEVENT	Event
UINT	Port
BOOL	Active

Detailed Description

Definition at line 123 of file socket.h.

Constructor & Destructor Documentation

CServerSocket()

CServerSocket::CServerSocket

(

)

Definition at line 171 of file socket.cpp.

{
}

~CServerSocket()

CServerSocket::~CServerSocket ( )

virtual

Definition at line 176 of file socket.cpp.

{
    if (Active)
        Close();
}

Member Function Documentation

Close()

VOID CServerSocket::Close ( )

virtual

Reimplemented from CSocket.

Definition at line 212 of file socket.cpp.

{
    assert(Active);
 
    if (Event != WSA_INVALID_EVENT) {
        // Tell winsock not to notify us about any events
        if (WSAEventSelect(Socket, Event, 0) == SOCKET_ERROR)
            throw ESocketClose(TS("Unable to select socket events."));
 
        if (!WSACloseEvent(Event))
            throw ESocketClose(TS("Unable to close socket event."));
        Event = WSA_INVALID_EVENT;
    }
 
    CIterator<LPCServerClientThread> *i = Connections.CreateIterator();
 
    // Terminate and free all client threads
    for (i->First(); !i->IsDone(); i->Next()) {
        //i->CurrentItem()->Terminate();
        delete i->CurrentItem();
    }
    delete i;
    Connections.RemoveAll();
 
    closesocket(Socket);
    Socket = INVALID_SOCKET;
 
    Active = FALSE;
}

Referenced by CHttpDaemon::Stop(), and ~CServerSocket().

InsertClient()

VOID CServerSocket::InsertClient

(

LPCServerClientThread

lpClient

)

Definition at line 294 of file socket.cpp.

{
    Connections.Insert(lpClient);
}

Referenced by MessageLoop().

MessageLoop()

VOID CServerSocket::MessageLoop ( )

virtual

Definition at line 251 of file socket.cpp.

{
    UINT nStatus;
    INT nAddrLen;
    SOCKET ClientSocket;
    SOCKADDR_IN SockAddrIn;
    WSANETWORKEVENTS NetworkEvents;
    LPCServerClientSocket lpClient;
    LPCServerClientThread lpThread;
 
    nStatus = WSAWaitForMultipleEvents(1, &Event, FALSE, 0, FALSE);
    if ((nStatus == 0) && (WSAEnumNetworkEvents(Socket, Event, &NetworkEvents) != SOCKET_ERROR)) {
        if ((NetworkEvents.lNetworkEvents & FD_ACCEPT) != 0) {
            lpClient = OnGetSocket(this);
            nAddrLen = sizeof(SockAddrIn);
            ClientSocket = accept(Socket, (SOCKADDR *) &SockAddrIn, &nAddrLen);
            if (ClientSocket != INVALID_SOCKET) {
                // Set socket handle
                lpClient->SetSocket(ClientSocket);
                // Set socket address
                lpClient->SetSockAddrIn(SockAddrIn);
                // Set winsock events
                lpClient->SetEvents(FD_READ | FD_CLOSE);
                // Create client connection thread
                lpThread = OnGetThread(lpClient);
                // Add client thread to connection list
                InsertClient(lpThread);
                // Call OnAccept event handler
                OnAccept(lpThread);
            } else {
                delete lpClient;
                lpClient = NULL;
                throw ESocketOpen(TS("No more sockets available."));
            }
        }
        /*if ((NetworkEvents.lNetworkEvents & FD_CONNECT) != 0) {
        }
        if ((NetworkEvents.lNetworkEvents & FD_CLOSE) != 0) {
        }*/
    }
}

Referenced by CHttpDaemonThread::Execute().

OnAccept()

virtual VOID CServerSocket::OnAccept ( LPCServerClientThread  lpThread )

inlinevirtual

Reimplemented in CHttpDaemon.

Definition at line 132 of file socket.h.

{};

Referenced by MessageLoop().

OnGetSocket()

LPCServerClientSocket CServerSocket::OnGetSocket ( LPCServerSocket  lpServerSocket )

virtual

Reimplemented in CHttpDaemon.

Definition at line 306 of file socket.cpp.

{
    return NULL;
}

Referenced by MessageLoop().

OnGetThread()

LPCServerClientThread CServerSocket::OnGetThread ( LPCServerClientSocket  lpSocket )

virtual

Reimplemented in CHttpDaemon.

Definition at line 312 of file socket.cpp.

{
    return NULL;
}

Referenced by MessageLoop().

Open()

VOID CServerSocket::Open ( )

virtual

Reimplemented from CSocket.

Definition at line 183 of file socket.cpp.

{
    assert(!Active);
 
    // Convert to network ordering
    SockAddrIn.sin_port = htons(Port);
 
    if (Socket == INVALID_SOCKET) {
        // Create socket
        Socket = socket(AF_INET, SOCK_STREAM, 0);
        if (Socket == INVALID_SOCKET)
            throw ESocketOpen(TS("Unable to allocate a socket."));
    }
 
    // Associate an address with server socket
    if (bind(Socket, (struct sockaddr FAR *) &SockAddrIn, sizeof(SockAddrIn)) == SOCKET_ERROR)
        throw ESocketOpen(TS("Unable to associate address with socket."));
 
    // Listen for incoming connections
    if (listen(Socket, MAX_PENDING_CONNECTS) != 0)
        throw ESocketOpen(TS("Unable to listen on socket."));
 
    // Associate network events with socket
    SetEvents(FD_ACCEPT | FD_CONNECT | FD_CLOSE);
 
    Active = TRUE;
}

Referenced by CHttpDaemon::Start().

RemoveClient()

VOID CServerSocket::RemoveClient

(

LPCServerClientThread

lpClient

)

Definition at line 300 of file socket.cpp.

{
    Connections.Remove(lpClient);
}

Referenced by CServerClientThread::~CServerClientThread().

SetPort()

VOID CServerSocket::SetPort ( UINT  nPort )

virtual

Reimplemented from CSocket.

Definition at line 243 of file socket.cpp.

{
    assert(!Active);
 
    Port = nPort;
}

Member Data Documentation

Connections

CList<LPCServerClientThread> CServerSocket::Connections

protected

Definition at line 137 of file socket.h.

Referenced by Close(), InsertClient(), and RemoveClient().

---

The documentation for this class was generated from the following files:

• modules/rosapps/applications/net/roshttpd/include/socket.h
• modules/rosapps/applications/net/roshttpd/common/socket.cpp