web::http::server::SocketContext Class Reference

#include <SocketContext.h>

Inheritance diagram for web::http::server::SocketContext:

Collaboration diagram for web::http::server::SocketContext:

Public Member Functions
	SocketContext (core::socket::stream::SocketConnection *socketConnection, const std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)> &onRequestReady)
Public Member Functions inherited from core::socket::stream::SocketContext
	SocketContext (core::socket::stream::SocketConnection *socketConnection)
void	sendToPeer (const char *chunk, std::size_t chunkLen) const final
bool	streamToPeer (core::pipe::Source *source) const
void	streamEof ()
std::size_t	readFromPeer (char *chunk, std::size_t chunklen) const final
void	setTimeout (const utils::Timeval &timeout) final
void	shutdownRead ()
void	shutdownWrite (bool forceClose=false)
void	close () override
SocketConnection *	getSocketConnection () const
virtual void	switchSocketContext (SocketContext *newSocketContext)
void	sendToPeer (const std::string &data) const
Public Member Functions inherited from core::socket::SocketContext
	SocketContext (const SocketContext &)=delete
	SocketContext (SocketContext &&)=delete
SocketContext &	operator= (const SocketContext &)=delete
SocketContext &	operator= (SocketContext &&)=delete
void	sendToPeer (const std::string &data) const

Private Types
using	Super = core::socket::stream::SocketContext
using	Request = web::http::server::Request
using	Response = web::http::server::Response

Private Member Functions
void	deliverRequest ()
void	responseStarted ()
void	responseCompleted (bool success)
void	requestCompleted ()
void	onConnected () override
std::size_t	onReceivedFromPeer () override
void	onDisconnected () override
bool	onSignal (int signum) override
void	onWriteError (int errnum) override

Private Attributes
std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)>	onRequestReady
std::list< std::shared_ptr< Request > >	pendingRequests
std::shared_ptr< Response >	masterResponse
RequestParser	parser
bool	httpClose = false
friend	Response

Additional Inherited Members
Protected Member Functions inherited from core::socket::stream::SocketContext
void	onReadError (int errnum) override
Protected Member Functions inherited from core::socket::SocketContext
	SocketContext ()=default
virtual	~SocketContext ()

Detailed Description

Definition at line 45 of file SocketContext.h.

Member Typedef Documentation

Request

using web::http::server::SocketContext::Request = web::http::server::Request

private

Definition at line 49 of file SocketContext.h.

Response

using web::http::server::SocketContext::Response = web::http::server::Response

private

Definition at line 50 of file SocketContext.h.

Super

using web::http::server::SocketContext::Super = core::socket::stream::SocketContext

private

Definition at line 47 of file SocketContext.h.

Constructor & Destructor Documentation

SocketContext()

web::http::server::SocketContext::SocketContext	(	core::socket::stream::SocketConnection *	socketConnection,
		const std::function< void(const std::shared_ptr< Request > &, const std::shared_ptr< Response > &)> &	onRequestReady )

Definition at line 37 of file SocketContext.cpp.

        : Super(socketConnection)
        , onRequestReady(onRequestReady)
        , masterResponse(std::make_shared<Response>(this))
        , parser(
              this,
              [this]() {
                  LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Request started";
              },
              [this](web::http::server::Request&& request) {
                  LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Request parsed: " << request.method << " "
                            << request.url << " HTTP/" << request.httpMajor << "." << request.httpMinor;
 
                  pendingRequests.emplace_back(std::make_shared<Request>(std::move(request)));
 
                  if (pendingRequests.size() == 1) {
                      deliverRequest();
                  }
              },
              [this](int status, const std::string& reason) {
                  LOG(ERROR) << getSocketConnection()->getConnectionName() << " HTTP Request parse error: " << reason << " (" << status
                             << ") ";
 
                  shutdownWrite(true);
              }) {
    }

References SocketContext().

Referenced by SocketContext().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

deliverRequest()

void web::http::server::SocketContext::deliverRequest ( )

private

Definition at line 66 of file SocketContext.cpp.

                                       {
        if (!pendingRequests.empty()) {
            const std::shared_ptr<Request>& pendingRequest = pendingRequests.front();
 
            LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Request ready: " << pendingRequest->method << " "
                      << pendingRequest->url << " HTTP/" << pendingRequest->httpMajor << "." << pendingRequest->httpMinor;
 
            masterResponse->init();
            masterResponse->httpMajor = pendingRequest->httpMajor;
            masterResponse->httpMinor = pendingRequest->httpMinor;
 
            const std::string connection = pendingRequest->get("Connection");
            if (!connection.empty()) {
                masterResponse->set("Connection", connection);
            }
 
            onRequestReady(pendingRequest, masterResponse);
        } else {
            LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Request: No more pending";
        }
    }

Referenced by requestCompleted().

Here is the caller graph for this function:

onConnected()

void web::http::server::SocketContext::onConnected ( )

overrideprivatevirtual

Implements core::socket::stream::SocketContext.

Definition at line 137 of file SocketContext.cpp.

                                    {
        LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP: Connected";
 
        masterResponse->init();
    }

onDisconnected()

void web::http::server::SocketContext::onDisconnected ( )

overrideprivatevirtual

Implements core::socket::stream::SocketContext.

Definition at line 153 of file SocketContext.cpp.

                                       {
        if (masterResponse != nullptr) {
            masterResponse->stopResponse();
        }
 
        LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP: Disconnected";
    }

onReceivedFromPeer()

std::size_t web::http::server::SocketContext::onReceivedFromPeer ( )

overrideprivatevirtual

Implements core::socket::SocketContext.

Definition at line 143 of file SocketContext.cpp.

                                                {
        std::size_t consumed = 0;
 
        if (!httpClose) {
            consumed = parser.parse();
        }
 
        return consumed;
    }

References httpClose.

onSignal()

bool web::http::server::SocketContext::onSignal ( int signum )

overrideprivatevirtual

Implements core::socket::SocketContext.

Definition at line 161 of file SocketContext.cpp.

                                           {
        LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP: Received signal " << signum;
 
        return true;
    }

onWriteError()

void web::http::server::SocketContext::onWriteError ( int errnum )

overrideprivatevirtual

Reimplemented from core::socket::stream::SocketContext.

Definition at line 167 of file SocketContext.cpp.

                                                                {
        // Do nothing in case of an write error
    }

requestCompleted()

void web::http::server::SocketContext::requestCompleted ( )

private

Definition at line 115 of file SocketContext.cpp.

                                         {
        const std::shared_ptr<Request>& pendingRequest = pendingRequests.front();
 
        LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Request completed: " << pendingRequest->method << " "
                  << pendingRequest->url << " HTTP/" << pendingRequest->httpMajor << "." << pendingRequest->httpMinor;
 
        if (httpClose) {
            LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP: Connection = Close";
 
            shutdownWrite();
        } else {
            LOG(DEBUG) << getSocketConnection()->getConnectionName() << " HTTP: Connection = Keep-Alive";
 
            core::EventReceiver::atNextTick([this, response = static_cast<std::weak_ptr<Response>>(this->masterResponse)]() {
                if (!response.expired()) {
                    pendingRequests.pop_front();
                    deliverRequest();
                }
            });
        }
    }

References deliverRequest(), and httpClose.

Referenced by responseCompleted().

Here is the call graph for this function:

Here is the caller graph for this function:

responseCompleted()

void web::http::server::SocketContext::responseCompleted ( bool success )

private

Definition at line 95 of file SocketContext.cpp.

                                                      {
        if (success) {
            const std::shared_ptr<Request>& pendingRequest = pendingRequests.front();
 
            LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Response completed: " << pendingRequest->method << " "
                      << pendingRequest->url << " HTTP/" << pendingRequest->httpMajor << "." << pendingRequest->httpMinor;
 
            httpClose = masterResponse->connectionState == ConnectionState::Close ||
                        (masterResponse->connectionState == ConnectionState::Default &&
                         ((masterResponse->httpMajor == 0 && masterResponse->httpMinor == 9) ||
                          (masterResponse->httpMajor == 1 && masterResponse->httpMinor == 0)));
 
            requestCompleted();
        } else {
            LOG(WARNING) << getSocketConnection()->getConnectionName() << " HTTP Response wrong content length";
 
            shutdownWrite(true);
        }
    }

References requestCompleted().

Here is the call graph for this function:

responseStarted()

void web::http::server::SocketContext::responseStarted ( )

private

Definition at line 88 of file SocketContext.cpp.

                                        {
        const std::shared_ptr<Request>& pendingRequest = pendingRequests.front();
 
        LOG(INFO) << getSocketConnection()->getConnectionName() << " HTTP Response started: " << pendingRequest->method << " "
                  << pendingRequest->url << " HTTP/" << pendingRequest->httpMajor << "." << pendingRequest->httpMinor;
    }

Member Data Documentation

httpClose

bool web::http::server::SocketContext::httpClose = false

private

Definition at line 75 of file SocketContext.h.

Referenced by onReceivedFromPeer(), and requestCompleted().

masterResponse

std::shared_ptr<Response> web::http::server::SocketContext::masterResponse

private

Definition at line 71 of file SocketContext.h.

onRequestReady

std::function<void(const std::shared_ptr<Request>&, const std::shared_ptr<Response>&)> web::http::server::SocketContext::onRequestReady

private

Definition at line 62 of file SocketContext.h.

parser

RequestParser web::http::server::SocketContext::parser

private

Definition at line 73 of file SocketContext.h.

pendingRequests

std::list<std::shared_ptr<Request> > web::http::server::SocketContext::pendingRequests

private

Definition at line 70 of file SocketContext.h.

Response

friend web::http::server::SocketContext::Response

private

Definition at line 77 of file SocketContext.h.

---

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

• web/http/server/SocketContext.h
• web/http/server/SocketContext.cpp