|
|
DSN_API | network (rpc_engine *srv, network *inner_provider) |
| |
|
virtual error_code | start (rpc_channel channel, int port, bool client_only, io_modifer &ctx)=0 |
| |
|
virtual ::dsn::rpc_address | address ()=0 |
| |
|
virtual void | send_message (message_ex *request)=0 |
| |
|
virtual void | inject_drop_message (message_ex *msg, bool is_send)=0 |
| |
|
DSN_API service_node * | node () const |
| |
|
DSN_API void | on_recv_request (message_ex *msg, int delay_ms) |
| |
|
DSN_API void | on_recv_reply (uint64_t id, message_ex *msg, int delay_ms) |
| |
|
DSN_API message_parser * | new_message_parser (network_header_format hdr_format) |
| |
|
DSN_API std::pair< message_parser::factory2, size_t > | get_message_parser_info (network_header_format hdr_format) |
| |
|
rpc_engine * | engine () const |
| |
|
int | max_buffer_block_count_per_send () const |
| |
|
network_header_format | client_hdr_format () const |
| |
|
network_header_format | unknown_msg_hdr_format () const |
| |
|
int | message_buffer_block_size () const |
| |
|
|
template<typename T > |
| static network * | create (rpc_engine *srv, network *inner_provider) |
| |
|
|
static DSN_API uint32_t | get_local_ipv4 () |
| |
|
|
rpc_engine * | _engine |
| |
|
network_header_format | _client_hdr_format |
| |
|
network_header_format | _unknown_msg_header_format |
| |
|
int | _message_buffer_block_size |
| |
|
int | _max_buffer_block_count_per_send |
| |
|
int | _send_queue_threshold |
| |
The documentation for this class was generated from the following file:
