Robust Distributed System Nucleus (rDSN)  ver 1.0.0
Public Member Functions | Public Attributes | Protected Attributes | List of all members
dsn::aio_task Class Reference
Inheritance diagram for dsn::aio_task:
dsn::task

Public Member Functions

DSN_API aio_task (dsn_task_code_t code, dsn_aio_handler_t cb, void *context, dsn_task_cancelled_handler_t on_cancel, int hash=0, service_node *node=nullptr)
 
DSN_API void enqueue (error_code err, size_t transferred_size)
 
size_t get_transferred_size () const
 
disk_aioaio ()
 
void copy_to (char *dest)
 
void collapse ()
 
virtual void exec () override
 
- Public Member Functions inherited from dsn::task
DSN_API task (dsn_task_code_t code, void *context, dsn_task_cancelled_handler_t on_cancel, int hash=0, service_node *node=nullptr)
 
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_specspec () const
 
int hash () const
 
int delay_milliseconds () const
 
error_code error () const
 
service_node * node () const
 
task_tracker * tracker () const
 
bool is_empty () const
 

Public Attributes

std::vector< dsn_file_buffer_t_unmerged_write_buffers
 
blob _merged_write_buffer_holder
 
- Public Attributes inherited from dsn::task
tasknext
 

Protected Attributes

disk_aio_aio
 
size_t _transferred_size
 
dsn_aio_handler_t _cb
 
- Protected Attributes inherited from dsn::task
bool _is_null
 
error_code _error
 
void * _context
 
dsn_task_cancelled_handler_t _on_cancel
 

Additional Inherited Members

- Static Public Member Functions inherited from dsn::task
static DSN_API taskget_current_task ()
 
static DSN_API uint64_t get_current_task_id ()
 
static DSN_API task_workerget_current_worker ()
 
static DSN_API task_workerget_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_providerget_current_env ()
 
static DSN_API nfs_nodeget_current_nfs ()
 
static DSN_API timer_serviceget_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)
 
- Protected Member Functions inherited from dsn::task
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: