libtasks Documentation
1.6
|
The base class for the uwsgi protocol implementation. More...
#include <uwsgi_task.h>
Public Member Functions | |
uwsgi_task (net::socket &sock) | |
virtual | ~uwsgi_task () |
bool | handle_event (tasks::worker *worker, int revents) |
virtual bool | handle_request ()=0 |
uwsgi_request & | request () |
const uwsgi_request & | request () const |
uwsgi_request * | request_p () |
const uwsgi_request * | request_p () const |
http_response & | response () |
const http_response & | response () const |
http_response * | response_p () |
const http_response * | response_p () const |
void | send_response () |
Send the resonse back. More... | |
![]() | |
net_io_task (int events) | |
net_io_task (net::socket &socket, int events) | |
virtual | ~net_io_task () |
std::string | get_string () const |
A debug helper. More... | |
net::socket & | socket () |
Provide access to the underlying socket object. More... | |
const net::socket & | socket () const |
Provide const access to the underlying socket object. More... | |
![]() | |
io_task_base (int events) | |
virtual | ~io_task_base () |
std::string | get_string () const |
int | events () const |
Return the monitored events. More... | |
ev_io * | watcher () const |
Return the io watcher object. More... | |
virtual void | init_watcher () |
Initialize the watcher. More... | |
virtual void | start_watcher (worker *worker) |
Start a watcher in the context of the given worker. More... | |
virtual void | stop_watcher (worker *worker) |
Stop a watcher in the context of the given worker. More... | |
virtual void | update_watcher (worker *worker) |
Udate a watcher in the context of the given worker. More... | |
virtual void | dispose (worker *worker) |
Stop the watcher before being deleted. More... | |
![]() | |
virtual | ~event_task () |
worker * | assigned_worker () const |
Returns a pointer to the assigned worker. More... | |
void | assign_worker (worker *worker) |
void | notify_error (worker *worker=nullptr) |
void | on_error (error_func_worker_t f) |
void | on_error (error_func_void_t f) |
Install an error callback. More... | |
![]() | |
virtual | ~task () |
bool | auto_delete () const |
Returns true if auto deletion is active. More... | |
void | disable_auto_delete () |
Call this to deactivate auto deletion. More... | |
void | finish (worker *worker=nullptr) |
Called by a worker when a task has auto_deletion enabled. More... | |
void | on_finish (finish_func_worker_t f) |
void | on_finish (finish_func_void_t f) |
![]() | |
error_base () | |
virtual | ~error_base () |
bool | error () const |
Return true if an error occured. More... | |
tasks_error | error_code () const |
Return the error code. More... | |
const std::string & | error_message () const |
Return the error message. More... | |
int | sys_errno () const |
Return the errno if available. More... | |
std::string | sys_errno_str () const |
Return the errno description if available. More... | |
const tasks_exception & | exception () const |
Return the underlying exception object. More... | |
void | set_exception (tasks_exception &e) |
Set an exception to report an error. More... | |
void | reset_error () |
Reset the error state. More... | |
![]() | |
disposable () | |
virtual | ~disposable () |
bool | can_dispose () const |
Check if a task can be disposed or not. More... | |
void | disable_dispose () |
Mark a task for being not disposable. More... | |
void | enable_dispose () |
Mark a task for being disposable. More... | |
Protected Member Functions | |
void | finish_request () |
Called after a request has been responded. More... | |
![]() | |
void | add_task (worker *worker, net_io_task *task) |
io_base & | iob () |
Grant socket access to the io_task_base. More... | |
const io_base & | iob () const |
Grant const socket access to the io_task_base. More... | |
void | disable_auto_close () |
Disable automatic closing of the socket in the desctructor. More... | |
![]() | |
void | set_events (int events) |
Update the events the object monitors. More... | |
Protected Attributes | |
uwsgi_request | m_request |
http_response | m_response |
Additional Inherited Members | |
![]() | |
typedef std::function< void(worker *worker, const tasks_exception &e)> | error_func_worker_t |
typedef std::function< void(const tasks_exception &e)> | error_func_void_t |
![]() | |
typedef std::function< void(worker *worker)> | finish_func_worker_t |
typedef std::function< void()> | finish_func_void_t |
![]() | |
static void | add_task (net_io_task *task) |
The base class for the uwsgi protocol implementation.
Definition at line 30 of file uwsgi_task.h.
|
inline |
Definition at line 32 of file uwsgi_task.h.
|
inlinevirtual |
Definition at line 33 of file uwsgi_task.h.
|
inlineprotected |
Called after a request has been responded.
Definition at line 79 of file uwsgi_task.h.
|
virtual |
Will be called for each I/O or timer event.
Each task needs to implement the handle_event method. Returns true if the task stays active and false otherwise. The task will be deleted if false is returned and auto_delete() returns true.
worker | The worker thread executing the task. |
events | The events bitmask. |
Implements tasks::event_task.
Definition at line 16 of file uwsgi_task.cpp.
|
pure virtual |
A uwsgi request handler needs to implement this. This method gets called after a uwsgi request has been deserialized successfully.
Implemented in tasks::net::uwsgi_thrift_async_processor< handler_type >, tasks::net::uwsgi_thrift_processor< processor_type, handler_type >, uwsgi_handler, and uwsgi_handler.
|
inline |
Definition at line 43 of file uwsgi_task.h.
|
inline |
Definition at line 46 of file uwsgi_task.h.
|
inline |
Definition at line 49 of file uwsgi_task.h.
|
inline |
Definition at line 52 of file uwsgi_task.h.
|
inline |
Definition at line 55 of file uwsgi_task.h.
|
inline |
Definition at line 58 of file uwsgi_task.h.
|
inline |
Definition at line 61 of file uwsgi_task.h.
|
inline |
Definition at line 64 of file uwsgi_task.h.
|
inline |
Send the resonse back.
Definition at line 67 of file uwsgi_task.h.
|
protected |
Definition at line 75 of file uwsgi_task.h.
|
protected |
Definition at line 76 of file uwsgi_task.h.