CHttpClient Class Reference

#include <httpd.h>

Inheritance diagram for CHttpClient:

Collaboration diagram for CHttpClient:

Public Member Functions
	CHttpClient ()
	CHttpClient (LPCServerSocket lpServerSocket)
virtual void	OnRead ()
virtual void	OnClose ()
void	SplitUri (const LPSTR lpsUri, LPSTR lpsHost, LPSTR lpsResource, LPSTR lpsParams)
void	SplitResource (const LPSTR lpsResource, LPSTR lpsPath, LPSTR lpsFilename, LPSTR lpsExtension)
void	ProcessRequest ()
void	SendFile (const LPSTR lpsFilename)
void	Report (LPCSTR lpsCode, const LPSTR lpsStr)
Public Member Functions inherited from CServerClientSocket
	CServerClientSocket ()
	CServerClientSocket (LPCServerSocket lpServerSocket)
CServerSocket *	GetServerSocket ()
virtual INT	Transmit (LPCSTR lpsBuffer, UINT nLength)
virtual INT	Receive (LPSTR lpsBuffer, UINT nLength)
virtual INT	SendText (LPCSTR lpsText)
virtual VOID	MessageLoop ()
virtual VOID	OnRead ()
virtual VOID	OnClose ()
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)

Public Attributes
HANDLE	ThreadHandle
DWORD	ThreadId
CHttpParser	Parser

Private Attributes
BOOL	bStop
LPSTR	lpsBuffer
LONG	nBufferSize
unsigned long long	nTotalRead
unsigned long long	nFileSize
HANDLE	hFile

Additional Inherited Members
Protected Attributes inherited from CServerClientSocket
LPCServerSocket	ServerSocket
Protected Attributes inherited from CSocket
SOCKET	Socket
SOCKADDR_IN	SockAddrIn
WSAEVENT	Event
UINT	Port
BOOL	Active

Detailed Description

Definition at line 26 of file httpd.h.

Constructor & Destructor Documentation

CHttpClient() [1/2]

CHttpClient::CHttpClient

(

)

Definition at line 30 of file httpd.cpp.

{
}

CHttpClient() [2/2]

CHttpClient::CHttpClient

(

LPCServerSocket

lpServerSocket

)

Member Function Documentation

OnClose()

VOID CHttpClient::OnClose ( )

virtual

Reimplemented from CServerClientSocket.

Definition at line 334 of file httpd.cpp.

{
    // Stop sending file if we are doing that now
    bStop = TRUE;
}

OnRead()

VOID CHttpClient::OnRead ( )

virtual

Reimplemented from CServerClientSocket.

Definition at line 289 of file httpd.cpp.

{
    LONG nCount;
 
    nCount = Receive((LPSTR) &Parser.sBuffer[Parser.nHead],
        sizeof(Parser.sBuffer) - Parser.nHead);
 
    Parser.nHead += nCount;
    if (Parser.nHead >= sizeof(Parser.sBuffer))
        Parser.nHead = 0;
 
    if (Parser.Complete()) {
        ProcessRequest();
    }
 
    if (Parser.bUnknownMethod) {
        // Method Not Allowed
        Report("405 Method Not Allowed", HttpMsg405);
        // Terminate connection
        Close();
    }
}

ProcessRequest()

VOID CHttpClient::ProcessRequest

(

)

Definition at line 118 of file httpd.cpp.

{
    CHAR sStr[255];
    CHAR sHost[255];
    CHAR sResource[255];
    CHAR sParams[255];
 
    // Which method?
    switch (Parser.nMethodNo) {
        case hmGET: {
            SplitUri(Parser.sUri, sHost, sResource, sParams);
 
            // Default resource?
            if (strlen(sResource) == 0) {
                CIterator<LPSTR> *i = pConfiguration->GetDefaultResources()->CreateIterator();
 
                // FIXME: All default resources should be tried
                // Iterate through all strings
                //for (i->First(); !i->IsDone(); i->Next())
                i->First();
                if (!i->IsDone()) {
                    strcat(sResource, i->CurrentItem());
                    delete i;
                } else {
                    // File not found
                    Report("404 Not Found", HttpMsg404);
                    break;
                }
            }
            strcpy(sStr, pConfiguration->GetHttpBase());
            strcat(sStr, sResource);
            SendFile(sStr);
            break;
        }
        default: {
            // Method is not implemented
            Report("501 Not Implemented", HttpMsg501);
        }
    }
}

Referenced by OnRead().

Report()

VOID CHttpClient::Report	(	LPCSTR	lpsCode,
		const LPSTR	lpsStr
	)

Definition at line 263 of file httpd.cpp.

{
    CHAR sTmp[128];
    CHAR sTmp2[16];
 
    strcpy(sTmp, "HTTP/1.1 ");
    strcat(sTmp, lpsCode);
    SendText(sTmp);
    SendText("Server: ROSHTTPD");
    SendText("MIME-version: 1.0");
    SendText("Content-Type: text/html");
    SendText("Accept-Ranges: bytes");
    strcpy(sTmp, "Content-Length: ");
    if (lpsStr != NULL) {
        _itoa(strlen(lpsStr), sTmp2, 10);
        strcat(sTmp,  sTmp2);
    } else
        strcat(sTmp, "0");
    SendText(sTmp);
    SendText("");
    if (lpsStr != NULL)
        SendText(lpsStr);
    SendText("");
}

Referenced by OnRead(), ProcessRequest(), and SendFile().

SendFile()

VOID CHttpClient::SendFile

(

const LPSTR

lpsFilename

)

Definition at line 160 of file httpd.cpp.

{
    CHAR str[255];
    CHAR str2[32];
    union BigNum {
      //        unsigned __int64 Big;
      unsigned long long Big;
        struct {
            DWORD Low;
            DWORD High;
        } u;
    } nTotalBytes;
    DWORD nBytesToRead;
    DWORD nBytesRead;
    BOOL bStatus;
 
    // Try to open file
    hFile = CreateFileA(lpsFilename,
        GENERIC_READ,               // Open for reading
        FILE_SHARE_READ,            // Share for reading
        NULL,                       // No security
        OPEN_EXISTING,              // Existing file only
        FILE_ATTRIBUTE_NORMAL,      // Normal file
        NULL);                      // No attr. template
    if (hFile == INVALID_HANDLE_VALUE) {
        // File not found
        Report("404 Not Found", HttpMsg404);
        return;
    }
    // Get file size
    nTotalBytes.u.Low = GetFileSize(hFile, &nTotalBytes.u.High);
    if ((nTotalBytes.u.Low == 0xFFFFFFFF) && ((GetLastError()) != NO_ERROR)) {
        // Internal server error
        Report("500 Internal Server Error", HttpMsg500);
        // Close file
        CloseHandle(hFile);
        return;
    }
 
    // Determine buffer size
    if (nTotalBytes.Big < 65536)
        nBufferSize = 1024;
    else
        nBufferSize = 32768;
    // Allocate memory on heap
    lpsBuffer = (PCHAR) malloc(nBufferSize);
 
    if (lpsBuffer == NULL) {
        // Internal server error
        Report("500 Internal Server Error", HttpMsg500);
        // Close file
        CloseHandle(hFile);
        return;
    }
 
    SendText("HTTP/1.1 200 OK");
    SendText("Server: ROSHTTPD");
    SendText("MIME-version: 1.0");
    SendText("Content-Type: text/plain");
    SendText("Accept-Ranges: bytes");
    strcpy(str, "Content-Length: ");
    _itoa(nTotalBytes.u.Low, str2, 10);
    strcat(str, str2);
    SendText(str);
    SendText("");
    // Read and transmit file
    nTotalRead = 0;
    nFileSize = nTotalBytes.Big;
    bStop = FALSE;
 
    fd_set wfds;
    FD_ZERO(&wfds);
    FD_SET(Socket, &wfds);
    do {
        MessageLoop();
 
        if (nTotalRead + nBufferSize < nFileSize)
            nBytesToRead = nBufferSize;
        else nBytesToRead = nFileSize - nTotalRead;
 
        bStatus = ReadFile(hFile, lpsBuffer, nBytesToRead, &nBytesRead, NULL);
        if (bStatus) {
            select(0, NULL, &wfds, NULL, NULL);
            bStatus = (Transmit(lpsBuffer, nBytesRead) == (INT)nBytesRead);
            nTotalRead += nBytesRead;
        }
    } while ((!bStop) && (bStatus) && (nTotalRead < nFileSize));
 
    if (bStatus)
        SendText("");
    else
        // We can't send an error message here as we are in the process of sending a file.
        // We have to terminate the connection instead
        Close();
 
    // Free allocated memory
    free(lpsBuffer);
 
    // Close file
    CloseHandle(hFile);
}

Referenced by ProcessRequest().

SplitResource()

VOID CHttpClient::SplitResource	(	const LPSTR	lpsResource,
		LPSTR	lpsPath,
		LPSTR	lpsFilename,
		LPSTR	lpsExtension
	)

Definition at line 80 of file httpd.cpp.

{
    INT i,len,fileptr,extptr;
 
    strcpy(lpsPath, "");
    strcpy(lpsFilename, "");
    strcpy(lpsExtension, "");
 
    len = strlen(lpsResource);
    if (len != 0) {
        if (lpsResource[len - 1] == '/') {
            // There is only a path
            strcpy(lpsPath, lpsResource);
        } else {
            // Find extension
            i = len - 1;
            while ((i >= 0) && (lpsResource[i] != '.')) i--;
            extptr = i;
            while ((i >= 0) && (lpsResource[i] != '/')) i--;
            if (i > 0) {
                // There is at least one directory in the path (besides root directory)
                fileptr = i + 1;
                strncat(lpsPath, lpsResource, fileptr);
            } else
                fileptr = 1;
 
            // Get filename and possibly extension
            if (extptr != 0) {
                strncat(lpsFilename, &lpsResource[fileptr], extptr - fileptr);
                // Get extension
                strncat(lpsExtension, &lpsResource[extptr + 1], len - extptr - 1);
            } else
                strncat(lpsFilename, &lpsResource[fileptr], len - fileptr);
        }
    }
}

SplitUri()

VOID CHttpClient::SplitUri	(	const LPSTR	lpsUri,
		LPSTR	lpsHost,
		LPSTR	lpsResource,
		LPSTR	lpsParams
	)

Definition at line 41 of file httpd.cpp.

{
    LPSTR lpsPos;
    LPSTR lpsStr;
    UINT i;
 
    strcpy(lpsHost, "");
    strcpy(lpsResource, "");
    strcpy(lpsParams, "");
 
    lpsPos = strstr(lpsUri, "://");
    if (lpsPos != NULL)
        lpsStr = &lpsPos[3];
    else
        lpsStr = lpsUri;
 
    lpsPos = strstr(lpsStr, "/");
    if (lpsPos != NULL) {
        strncat(lpsHost, lpsPos, lpsPos - lpsStr);
        lpsStr = &lpsPos[1];
 
        lpsPos = strstr(lpsStr, "?");
        if (lpsPos != NULL) {
            strncat(lpsResource, lpsStr, lpsPos - lpsStr);
            strcpy(lpsParams, &lpsPos[1]);
        } else {
            strcpy(lpsResource, lpsStr);
            strcpy(lpsParams, "");
        }
 
        // Replace "/" with "\"
        for (i = 0; i < strlen(lpsResource); i++) {
            if (lpsResource[i] == '/')
                lpsResource[i] = '\\';
        }
    }
}

Referenced by ProcessRequest().

Member Data Documentation

bStop

BOOL CHttpClient::bStop

private

Definition at line 42 of file httpd.h.

Referenced by OnClose(), and SendFile().

hFile

HANDLE CHttpClient::hFile

private

Definition at line 49 of file httpd.h.

lpsBuffer

LPSTR CHttpClient::lpsBuffer

private

Definition at line 43 of file httpd.h.

Referenced by SendFile().

nBufferSize

LONG CHttpClient::nBufferSize

private

Definition at line 44 of file httpd.h.

Referenced by SendFile().

nFileSize

unsigned long long CHttpClient::nFileSize

private

Definition at line 48 of file httpd.h.

Referenced by SendFile().

nTotalRead

unsigned long long CHttpClient::nTotalRead

private

Definition at line 46 of file httpd.h.

Referenced by SendFile().

Parser

CHttpParser CHttpClient::Parser

Definition at line 35 of file httpd.h.

Referenced by OnRead(), and ProcessRequest().

ThreadHandle

HANDLE CHttpClient::ThreadHandle

Definition at line 33 of file httpd.h.

ThreadId

DWORD CHttpClient::ThreadId

Definition at line 34 of file httpd.h.

---

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

• modules/rosapps/applications/net/roshttpd/include/httpd.h
• modules/rosapps/applications/net/roshttpd/httpd.cpp