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

Public Member Functions

DSN_API task_spec (int code, const char *name, dsn_task_type_t type, dsn_task_priority_t pri, dsn_threadpool_code_t pool)
 
DSN_API void init_profiling (bool profile)
 

Static Public Member Functions

static DSN_API task_specget (int ec)
 
static DSN_API void register_task_code (dsn_task_code_t code, dsn_task_type_t type, dsn_task_priority_t pri, dsn_threadpool_code_t pool)
 
static DSN_API bool init ()
 

Public Attributes

dsn_task_code_t code
 
dsn_task_type_t type
 
std::string name
 
dsn_task_code_t rpc_paired_code
 
shared_exp_delay rpc_request_delayer
 
dsn_task_priority_t priority
 
grpc_mode_t grpc_mode
 
dsn_threadpool_code_t pool_code
 
bool allow_inline
 
bool randomize_timer_delay_if_zero
 
network_header_format rpc_call_header_format
 
dsn_msg_serialize_format rpc_msg_payload_serialize_default_format
 
rpc_channel rpc_call_channel
 
bool rpc_message_crc_required
 
int32_t rpc_timeout_milliseconds
 
int32_t rpc_request_resend_timeout_milliseconds
 
throttling_mode_t rpc_request_throttling_mode
 
std::vector< int > rpc_request_delays_milliseconds
 
bool rpc_request_dropped_before_execution_when_timeout
 
bool rpc_request_layer2_handler_required
 
bool rpc_request_is_write_operation
 
task_rejection_handler rejection_handler
 
join_point< void, task *, task * > on_task_create
 
join_point< void, task *, task * > on_task_enqueue
 
join_point< void, task * > on_task_begin
 
join_point< void, task * > on_task_end
 
join_point< void, task * > on_task_cancelled
 
join_point< void, task *, task *, uint32_t > on_task_wait_pre
 
join_point< void, task * > on_task_wait_notified
 
join_point< void, task *, task *, bool > on_task_wait_post
 
join_point< void, task *, task *, bool > on_task_cancel_post
 
join_point< bool, task *, aio_task * > on_aio_call
 
join_point< void, aio_task * > on_aio_enqueue
 
join_point< bool, task *, message_ex *, rpc_response_task * > on_rpc_call
 
join_point< bool, rpc_request_task * > on_rpc_request_enqueue
 
join_point< bool, task *, message_ex * > on_rpc_reply
 
join_point< bool, rpc_response_task * > on_rpc_response_enqueue
 
join_point< void, message_ex *, message_ex * > on_rpc_create_response
 

The documentation for this class was generated from the following file: