version 1.1.2.3, 2013/08/13 09:30:00
|
version 1.2.2.2, 2014/03/12 22:35:06
|
|
|
#include <Pegasus/Common/Tracer.h> | #include <Pegasus/Common/Tracer.h> |
| |
#include <Pegasus/WebServer/WebServer.h> | #include <Pegasus/WebServer/WebServer.h> |
#include <Pegasus/WebServer/WebProcessor.h> |
|
#include <Pegasus/WebServer/WebRequest.h> |
|
| |
| |
PEGASUS_USING_STD; | PEGASUS_USING_STD; |
|
|
| |
void WebServer::handleEnqueue(Message* message) | void WebServer::handleEnqueue(Message* message) |
{ | { |
PEG_METHOD_ENTER(TRC_WEBSERVER, |
PEG_METHOD_ENTER(TRC_WEBSERVER, "WebServer::handleEnqueue()"); |
"WebServer::handleEnqueue(Message* message)"); |
|
| |
if ( !message ) | if ( !message ) |
{ | { |
|
PEG_METHOD_EXIT(); |
return; | return; |
} | } |
| |
|
|
handleHTTPMessage((HTTPMessage*)message); | handleHTTPMessage((HTTPMessage*)message); |
break; | break; |
| |
|
//Handles only the HTTP_MESSAGE, So this is unrechable |
default: | default: |
// Unexpected message type |
|
PEGASUS_UNREACHABLE( PEGASUS_ASSERT(0);) | PEGASUS_UNREACHABLE( PEGASUS_ASSERT(0);) |
break; | break; |
} | } |
|
|
| |
void WebServer::handleHTTPMessage(HTTPMessage* httpMessage) | void WebServer::handleHTTPMessage(HTTPMessage* httpMessage) |
{ | { |
PEG_METHOD_ENTER(TRC_WEBSERVER, |
PEG_METHOD_ENTER(TRC_WEBSERVER, "WebServer::handleHTTPMessage()"); |
"WebServer::handleHTTPMessage(HTTPMessage* httpMessage)"); |
|
| |
if (!httpMessage) | if (!httpMessage) |
{ | { |
|
|
headers, "Accept-Charset", charSetHeader, false); | headers, "Accept-Charset", charSetHeader, false); |
| |
//ex.: 'Accept-Encoding: gzip,deflate' | //ex.: 'Accept-Encoding: gzip,deflate' |
|
//Not supported yet |
const char* encHeader = NULL; | const char* encHeader = NULL; |
Boolean encHeaderFound = HTTPMessage::lookupHeader( | Boolean encHeaderFound = HTTPMessage::lookupHeader( |
headers, "Accept-Encoding", encHeader, false); | headers, "Accept-Encoding", encHeader, false); |
|
|
void WebServer::handleResponse(HTTPMessage* response) | void WebServer::handleResponse(HTTPMessage* response) |
{ | { |
| |
PEG_METHOD_ENTER(TRC_WEBSERVER, |
PEG_METHOD_ENTER(TRC_WEBSERVER, "WebServer::handleResponse()"); |
"WebServer::handleResponse(HTTPMessage* response)"); |
|
| |
Uint32 queueId = response->queueId; | Uint32 queueId = response->queueId; |
MessageQueue* queue = MessageQueue::lookup(queueId); | MessageQueue* queue = MessageQueue::lookup(queueId); |