Class cubconn::connection::worker¶

ClassList > cubconn > connection > worker

#include <connection_worker.hpp>

Classes¶

Type	Name
struct	message

Public Types¶

Type	Name
enum	message_type
enum uint8_t	queue_type

Public Functions¶

Type	Name
void	attach ()
void	enqueue (queue_type type, message && item)
bool	enqueue_and_notify (queue_type type, message && item, std::function< void()> func=nullptr, int wait_time=0)
void	finalize ()
void	initialize ()
bool	notify ()
bool	run ()
	worker (pool * pool, std::shared_ptr< coordinator > coord, std::shared_ptr< thread_watcher > watcher, std::size_t core, std::size_t index)
	~worker ()

Public Types Documentation¶

enum message_type¶

enum cubconn::connection::worker::message_type {
    START,
    HIBERNATE,
    AWAKEN,
    SHUTDOWN,
    NEW_CLIENT,
    HANDOFF_CLIENT,
    TAKEOVER_CLIENT,
    SHUTDOWN_CLIENT,
    SEND_PACKET,
    RELEASE_PACKET,
    TYPE_COUNT
};

enum queue_type¶

enum cubconn::connection::worker::queue_type {
    IMMEDIATE,
    LAZY,
    TYPE_COUNT
};

Public Functions Documentation¶

function attach¶

void cubconn::connection::worker::attach ()

function enqueue¶

void cubconn::connection::worker::enqueue (
    queue_type type,
    message && item
)

function enqueue_and_notify¶

bool cubconn::connection::worker::enqueue_and_notify (
    queue_type type,
    message && item,
    std::function< void ()> func=nullptr,
    int wait_time=0
)

function finalize¶

void cubconn::connection::worker::finalize ()

function initialize¶

void cubconn::connection::worker::initialize ()

function notify¶

bool cubconn::connection::worker::notify ()

function run¶

bool cubconn::connection::worker::run ()

function worker¶

cubconn::connection::worker::worker (
    pool * pool,
    std::shared_ptr< coordinator > coord,
    std::shared_ptr< thread_watcher > watcher,
    std::size_t core,
    std::size_t index
)

function ~worker¶

cubconn::connection::worker::~worker ()

The documentation for this class was generated from the following file cubrid/src/connection/connection_worker.hpp