#include <libworker.h>
Data Fields | |
int | thread_num |
every worker has a unique thread_num. | |
struct ub_ctx * | ctx |
context we are operating under | |
int | is_bg |
is this the bg worker? | |
int | is_bg_thread |
is this a bg worker that is threaded (not forked)? | |
struct module_env * | env |
copy of the module environment with worker local entries. | |
struct comm_base * | base |
the event base this worker works with | |
struct outside_network * | back |
the backside outside network interface to the auth servers | |
struct ub_randstate * | rndstate |
random() table for this worker. | |
struct comm_point * | cmd_com |
commpoint to listen to commands | |
size_t | cmd_read |
are we currently reading a command, 0 if not, else bytecount | |
uint32_t | cmd_len |
size of current read command, may be partially read | |
uint8_t * | cmd_msg |
the current read command content, malloced, can be partially read | |
struct comm_point * | res_com |
commpoint to write results back | |
size_t | res_write |
are we curently writing a result, 0 if not, else bytecount into the res_list first entry. | |
struct libworker_res_list * | res_list |
list of outstanding results to be written back | |
struct libworker_res_list * | res_last |
last in list |
every worker has a unique thread_num.
(first in struct)
Referenced by libworker_bg(), libworker_dobg(), and libworker_setup().
struct module_env* libworker::env [read] |
copy of the module environment with worker local entries.
Referenced by handle_newq(), libworker_alloc_cleanup(), libworker_delete(), libworker_fg(), libworker_fillup_fg(), libworker_handle_reply(), libworker_handle_service_reply(), and libworker_setup().
struct ub_randstate* libworker::rndstate [read] |
random() table for this worker.
size_t libworker::res_write |
are we curently writing a result, 0 if not, else bytecount into the res_list first entry.
Referenced by libworker_handle_result_write().