|
|
DSN_API | task (dsn_task_code_t code, void *context, dsn_task_cancelled_handler_t on_cancel, int hash=0, service_node *node=nullptr) |
| |
|
virtual void | exec ()=0 |
| |
|
DSN_API void | exec_internal () |
| |
|
DSN_API bool | cancel (bool wait_until_finished, bool *finished=nullptr) |
| |
|
DSN_API bool | wait (int timeout_milliseconds=TIME_MS_MAX, bool on_cancel=false) |
| |
|
virtual DSN_API void | enqueue () |
| |
|
DSN_API bool | set_retry (bool enqueue_immediately=true) |
| |
|
DSN_API const char * | node_name () const |
| |
|
void | set_error_code (error_code err) |
| |
|
void | set_delay (int delay_milliseconds=0) |
| |
|
void | set_tracker (task_tracker *tracker) |
| |
|
uint64_t | id () const |
| |
|
task_state | state () const |
| |
|
dsn_task_code_t | code () const |
| |
|
task_spec & | spec () const |
| |
|
int | hash () const |
| |
|
int | delay_milliseconds () const |
| |
|
error_code | error () const |
| |
|
service_node * | node () const |
| |
|
task_tracker * | tracker () const |
| |
|
bool | is_empty () const |
| |
|
|
static DSN_API task * | get_current_task () |
| |
|
static DSN_API uint64_t | get_current_task_id () |
| |
|
static DSN_API task_worker * | get_current_worker () |
| |
|
static DSN_API task_worker * | get_current_worker2 () |
| |
|
static DSN_API service_node * | get_current_node () |
| |
|
static DSN_API service_node * | get_current_node2 () |
| |
|
static DSN_API int | get_current_node_id () |
| |
|
static DSN_API int | get_current_worker_index () |
| |
|
static DSN_API const char * | get_current_node_name () |
| |
|
static DSN_API rpc_engine * | get_current_rpc () |
| |
|
static DSN_API disk_engine * | get_current_disk () |
| |
|
static DSN_API env_provider * | get_current_env () |
| |
|
static DSN_API nfs_node * | get_current_nfs () |
| |
|
static DSN_API timer_service * | get_current_tsvc () |
| |
|
static DSN_API int | get_current_queue_length () |
| |
|
static DSN_API void | set_tls_dsn_context (service_node *node, task_worker *worker, task_queue *queue) |
| |
|
static DSN_API void | set_tls_dsn (const __tls_dsn__ *ctx) |
| |
|
static DSN_API void | get_tls_dsn (__tls_dsn__ *ctx) |
| |
|
|
DSN_API void | signal_waiters () |
| |
|
DSN_API void | enqueue (task_worker_pool *pool) |
| |
|
void | set_task_id (uint64_t tid) |
| |
The documentation for this class was generated from the following file:
