UP_FUNC_CLIENT_DISCONNECT, //! up_thread_client_disconnect function
UP_FUNC_CLIENT_DISCONNECT_EVENT, //! up_thread_client_disconnect_event function
UP_FUNC_CLIENT_RECEIVE, //! up_thread_client_receive function
- UP_FUNC_CLIENT_ARECEIVE_HANDLE_EVENT, //! up_thread_client_asnc_read_some_handler function
UP_FUNC_CLIENT_HANDLE_ARECIEVE, //! up_thread_client_handle_async_read_some function
UP_FUNC_CLIENT_RESPOND_SEND, //! up_thread_client_respond function
UP_FUNC_CLIENT_RESPOND_SEND_EVENT, //! up_thread_client_respond_event function
UP_FUNC_REALSERVER_CONNECT_EVENT, //! up_thread_realserver_connect_event function
UP_FUNC_REALSERVER_CONNECT_FAIL_EVENT, //! up_thread_realserver_connection_fail_event function
UP_FUNC_REALSERVER_SEND, //! up_thread_realserver_send function
- UP_FUNC_REALSERVER_ASEND_HANDLE_EVENT, //! up_thread_realserver_async_write_some_handler function
- UP_FUNC_REALSERVER_HANDLE_ASEND, //! up_thread_realserver_handle_async_write_some function
+ UP_FUNC_REALSERVER_HANDLE_ASYNC_SEND, //! up_thread_realserver_handle_async_write_some function
UP_FUNC_REALSERVER_DISCONNECT, //! up_thread_realserver_disconnect function
UP_FUNC_REALSERVER_DISCONNECT_EVENT, //! up_thread_realserver_disconnect_event function
UP_FUNC_REALSERVER_ALL_DISCONNECT, //! up_thread_realserver_asll_disconnect function
UP_FUNC_SORRYSERVER_CONNECT_EVENT, //! up_thread_sorryserver_connect_event function
UP_FUNC_SORRYSERVER_CONNECT_FAIL_EVENT, //! up_thread_sorryserver_connection_fail_event function
UP_FUNC_SORRYSERVER_SEND, //! up_thread_sorryserver_send function
- UP_FUNC_SORRYSERVER_ASEND_HANDLE_EVENT, //! up_thread_sorryserver_async_read_some_handler function
- UP_FUNC_SORRYSERVER_HANDLE_ASEND, //! up_thread_sorryserver_handle_async_read_some function
+ UP_FUNC_SORRYSERVER_HANDLE_ASYNC_SEND, //! up_thread_sorryserver_handle_async_read_some function
UP_FUNC_SORRYSERVER_DISCONNECT, //! up_thread_sorryserver_disconnect function
UP_FUNC_SORRYSERVER_MOD_DISCONNECT, //! up_thread_sorryserver_mod_disconnect function
UP_FUNC_SORRYSERVER_DISCONNECT_EVENT, //! up_thread_sorryserver_disconnect_event function
DOWN_FUNC_CLIENT_DISCONNECT_EVENT, //! down_thread_client_disconnect_event function
DOWN_FUNC_CLIENT_CONNECTION_CHK, //! down_thread_client_connection_chk_event function
DOWN_FUNC_CLIENT_SEND, //! down_thread_client_send function
- DOWN_FUNC_CLIENT_ASEND_HANDLE_EVENT, //! down_thread_client_async_write_some_handler function
- DOWN_FUNC_CLIENT_HANDLE_ASEND, //! down_thread_client_handle_async_write_some function
+ DOWN_FUNC_CLIENT_HANDLE_ASYNC_SEND, //! down_thread_client_handle_async_write_some function
DOWN_FUNC_CLIENT_RESPOND_SEND_EVENT, //! down_thread_client_respond_event function
DOWN_FUNC_REALSERVER_RECEIVE, //! down_thread_realserver_receive function
- DOWN_FUNC_REALSERVER_ARECEIVE_HANDLE_EVENT, //! down_thread_realserver_async_read_some_handler function
- DOWN_FUNC_REALSERVER_HANDLE_ARECEIVE, //! down_thread_realserver_handle_async_read_some function
+ DOWN_FUNC_REALSERVER_HANDLE_ASYNC_RECEIVE, //! down_thread_realserver_handle_async_read_some function
DOWN_FUNC_REALSERVER_DISCONNECT, //! down_thread_realserver_disconnect function
DOWN_FUNC_REALSERVER_DISCONNECT_EVENT, //! down_thread_realserver_disconnect_event function
DOWN_FUNC_REALSERVER_ALL_DISCONNECT, //! down_thread_all_realserver_disconnect function
DOWN_FUNC_SORRYSERVER_RECEIVE, //! down_thread_sorryserver_receive function
- DOWN_FUNC_SORRYSERVER_ARECEIVE_HANDLE_EVENT, //! down_thread_sorryserver_async_read_some_handler function
- DOWN_FUNC_SORRYSERVER_HANDLE_ARECEIVE, //! down_thread_sorryserver_handle_async_read_some function
+ DOWN_FUNC_SORRYSERVER_HANDLE_ASYNC_RECEIVE, //! down_thread_sorryserver_handle_async_read_some function
DOWN_FUNC_SORRYSERVER_DISCONNECT, //! down_thread_sorryserver_disconnect function
DOWN_FUNC_SORRYSERVER_MOD_DISCONNECT, //! down_thread_sorryserver_mod_disconnect function
DOWN_FUNC_SORRYSERVER_DISCONNECT_EVENT, //! down_thread_sorryserver_disconnect_event function
: in == UP_FUNC_CLIENT_DISCONNECT ? "UP_FUNC_CLIENT_DISCONNECT"
: in == UP_FUNC_CLIENT_DISCONNECT_EVENT ? "UP_FUNC_CLIENT_DISCONNECT_EVENT"
: in == UP_FUNC_CLIENT_RECEIVE ? "UP_FUNC_CLIENT_RECEIVE"
- : in == UP_FUNC_CLIENT_ARECEIVE_HANDLE_EVENT ? "UP_FUNC_CLIENT_ARECIEVE_HANDLE_EVENT"
: in == UP_FUNC_CLIENT_HANDLE_ARECIEVE ? "UP_FUNC_CLIENT_HANDLE_ARECIEVE"
: in == UP_FUNC_CLIENT_RESPOND_SEND ? "UP_FUNC_CLIENT_RESPOND_SEND"
: in == UP_FUNC_CLIENT_RESPOND_SEND_EVENT ? "UP_FUNC_CLIENT_RESPOND_SEND_EVENT"
: in == UP_FUNC_REALSERVER_CONNECT_EVENT ? "UP_FUNC_REALSERVER_CONNECT_EVENT"
: in == UP_FUNC_REALSERVER_CONNECT_FAIL_EVENT ? "UP_FUNC_REALSERVER_CONNECT_FAIL_EVENT"
: in == UP_FUNC_REALSERVER_SEND ? "UP_FUNC_REALSERVER_SEND"
- : in == UP_FUNC_REALSERVER_ASEND_HANDLE_EVENT ? "UP_FUNC_REALSERVER_ASEND_HANDLE_EVENT"
- : in == UP_FUNC_REALSERVER_HANDLE_ASEND ? "UP_FUNC_REALSERVER_HANDLE_ASEND"
+ : in == UP_FUNC_REALSERVER_HANDLE_ASYNC_SEND ? "UP_FUNC_REALSERVER_HANDLE_ASYNC_SEND"
: in == UP_FUNC_REALSERVER_DISCONNECT ? "UP_FUNC_REALSERVER_DISCONNECT"
: in == UP_FUNC_REALSERVER_DISCONNECT_EVENT ? "UP_FUNC_REALSERVER_DISCONNECT_EVENT"
: in == UP_FUNC_REALSERVER_ALL_DISCONNECT ? "UP_FUNC_REALSERVER_ALL_DISCONNECT"
: in == UP_FUNC_SORRYSERVER_CONNECT_EVENT ? "UP_FUNC_SORRYSERVER_CONNECT_EVENT"
: in == UP_FUNC_SORRYSERVER_CONNECT_FAIL_EVENT ? "UP_FUNC_SORRYSERVER_CONNECT_FAIL_EVENT"
: in == UP_FUNC_SORRYSERVER_SEND ? "UP_FUNC_SORRYSERVER_SEND"
- : in == UP_FUNC_SORRYSERVER_ASEND_HANDLE_EVENT ? "UP_FUNC_SORRYSERVER_ASEND_HANDLE_EVENT"
- : in == UP_FUNC_SORRYSERVER_HANDLE_ASEND ? "UP_FUNC_SORRYSERVER_HANDLE_ASEND"
+ : in == UP_FUNC_SORRYSERVER_HANDLE_ASYNC_SEND ? "UP_FUNC_SORRYSERVER_HANDLE_ASYNC_SEND"
: in == UP_FUNC_SORRYSERVER_DISCONNECT ? "UP_FUNC_SORRYSERVER_DISCONNECT"
: in == UP_FUNC_SORRYSERVER_MOD_DISCONNECT ? "UP_FUNC_SORRYSERVER_MOD_DISCONNECT"
: in == UP_FUNC_SORRYSERVER_DISCONNECT_EVENT ? "UP_FUNC_SORRYSERVER_DISCONNECT_EVENT"
: in == DOWN_FUNC_CLIENT_DISCONNECT_EVENT ? "DOWN_FUNC_CLIENT_DISCONNECT_EVENT"
: in == DOWN_FUNC_CLIENT_CONNECTION_CHK ? "DOWN_FUNC_CLIENT_CONNECTION_CHK"
: in == DOWN_FUNC_CLIENT_SEND ? "DOWN_FUNC_CLIENT_SEND"
- : in == DOWN_FUNC_CLIENT_ASEND_HANDLE_EVENT ? "DOWN_FUNC_CLIENT_ASEND_HANDLE_EVENT"
- : in == DOWN_FUNC_CLIENT_HANDLE_ASEND ? "DOWN_FUNC_CLIENT_HANDLE_ASEND"
+ : in == DOWN_FUNC_CLIENT_HANDLE_ASYNC_SEND ? "DOWN_FUNC_CLIENT_HANDLE_ASYNC_SEND"
: in == DOWN_FUNC_CLIENT_RESPOND_SEND_EVENT ? "DOWN_FUNC_CLIENT_RESPOND_SEND_EVENT"
: in == DOWN_FUNC_REALSERVER_RECEIVE ? "DOWN_FUNC_REALSERVER_RECEIVE"
- : in == DOWN_FUNC_REALSERVER_ARECEIVE_HANDLE_EVENT ? "DOWN_FUNC_REALSERVER_ARECEIVE_HANDLE_EVENT"
- : in == DOWN_FUNC_REALSERVER_HANDLE_ARECEIVE ? "DOWN_FUNC_REALSERVER_HANDLE_ARECEIVE"
+ : in == DOWN_FUNC_REALSERVER_HANDLE_ASYNC_RECEIVE ? "DOWN_FUNC_REALSERVER_HANDLE_ASYNC_RECEIVE"
: in == DOWN_FUNC_REALSERVER_DISCONNECT ? "DOWN_FUNC_REALSERVER_DISCONNECT"
: in == DOWN_FUNC_REALSERVER_DISCONNECT_EVENT ? "DOWN_FUNC_REALSERVER_DISCONNECT_EVENT"
: in == DOWN_FUNC_SORRYSERVER_RECEIVE ? "DOWN_FUNC_SORRYSERVER_RECEIVE"
- : in == DOWN_FUNC_SORRYSERVER_ARECEIVE_HANDLE_EVENT ? "DOWN_FUNC_SORRYSERVER_ARECEIVE_HANDLE_EVENT"
- : in == DOWN_FUNC_SORRYSERVER_HANDLE_ARECEIVE ? "DOWN_FUNC_SORRYSERVER_HANDLE_ARECEIVE"
+ : in == DOWN_FUNC_SORRYSERVER_HANDLE_ASYNC_RECEIVE ? "DOWN_FUNC_SORRYSERVER_HANDLE_ASYNC_RECEIVE"
: in == DOWN_FUNC_SORRYSERVER_DISCONNECT ? "DOWN_FUNC_SORRYSERVER_DISCONNECT"
: in == DOWN_FUNC_SORRYSERVER_MOD_DISCONNECT ? "DOWN_FUNC_SORRYSERVER_MOD_DISCONNECT"
: in == DOWN_FUNC_SORRYSERVER_DISCONNECT_EVENT ? "DOWN_FUNC_SORRYSERVER_DISCONNECT_EVENT"
std::make_pair(
UP_FUNC_REALSERVER_SEND,
boost::bind(&tcp_session::up_thread_realserver_send, this, _1));
- up_thread_function_array[UP_FUNC_REALSERVER_HANDLE_ASEND] =
+ up_thread_function_array[UP_FUNC_REALSERVER_HANDLE_ASYNC_SEND] =
std::make_pair(
- UP_FUNC_REALSERVER_HANDLE_ASEND,
+ UP_FUNC_REALSERVER_HANDLE_ASYNC_SEND,
boost::bind(&tcp_session::up_thread_realserver_handle_async_write_some, this, _1));
up_thread_function_array[UP_FUNC_REALSERVER_DISCONNECT] =
std::make_pair(
std::make_pair(
UP_FUNC_SORRYSERVER_SEND,
boost::bind(&tcp_session::up_thread_sorryserver_send, this, _1));
- up_thread_function_array[UP_FUNC_SORRYSERVER_HANDLE_ASEND] =
+ up_thread_function_array[UP_FUNC_SORRYSERVER_HANDLE_ASYNC_SEND] =
std::make_pair(
- UP_FUNC_SORRYSERVER_HANDLE_ASEND,
+ UP_FUNC_SORRYSERVER_HANDLE_ASYNC_SEND,
boost::bind(&tcp_session::up_thread_sorryserver_handle_async_write_some, this, _1));
up_thread_function_array[UP_FUNC_SORRYSERVER_DISCONNECT] =
std::make_pair(
std::make_pair(
DOWN_FUNC_CLIENT_SEND,
boost::bind(&tcp_session::down_thread_client_send, this, _1));
- down_thread_function_array[DOWN_FUNC_CLIENT_HANDLE_ASEND] =
+ down_thread_function_array[DOWN_FUNC_CLIENT_HANDLE_ASYNC_SEND] =
std::make_pair(
- DOWN_FUNC_CLIENT_HANDLE_ASEND,
+ DOWN_FUNC_CLIENT_HANDLE_ASYNC_SEND,
boost::bind(&tcp_session::down_thread_client_handle_async_write_some, this, _1));
down_thread_function_array[DOWN_FUNC_REALSERVER_RECEIVE] =
std::make_pair(
DOWN_FUNC_REALSERVER_RECEIVE,
boost::bind(&tcp_session::down_thread_realserver_receive, this, _1));
- down_thread_function_array[DOWN_FUNC_REALSERVER_HANDLE_ARECEIVE] =
+ down_thread_function_array[DOWN_FUNC_REALSERVER_HANDLE_ASYNC_RECEIVE] =
std::make_pair(
- DOWN_FUNC_REALSERVER_HANDLE_ARECEIVE,
+ DOWN_FUNC_REALSERVER_HANDLE_ASYNC_RECEIVE,
boost::bind(&tcp_session::down_thread_realserver_handle_async_read_some, this, _1));
down_thread_function_array[DOWN_FUNC_REALSERVER_DISCONNECT] =
std::make_pair(
std::make_pair(
DOWN_FUNC_SORRYSERVER_RECEIVE,
boost::bind(&tcp_session::down_thread_sorryserver_receive, this, _1));
- down_thread_function_array[DOWN_FUNC_SORRYSERVER_HANDLE_ARECEIVE] =
+ down_thread_function_array[DOWN_FUNC_SORRYSERVER_HANDLE_ASYNC_RECEIVE] =
std::make_pair(
- DOWN_FUNC_SORRYSERVER_HANDLE_ARECEIVE,
+ DOWN_FUNC_SORRYSERVER_HANDLE_ASYNC_RECEIVE,
boost::bind(&tcp_session::down_thread_sorryserver_handle_async_read_some, this, _1));
down_thread_function_array[DOWN_FUNC_SORRYSERVER_DISCONNECT] =
std::make_pair(
} else {
if (error_code == boost::asio::error::try_again) {
upthread_status = UPTHREAD_LOCK;
- func_tag = UP_FUNC_REALSERVER_HANDLE_ASEND;
+ func_tag = UP_FUNC_REALSERVER_HANDLE_ASYNC_SEND;
basic_tcp_socket<boost::asio::ip::tcp>::async_rw_handler_t handler =
boost::bind(&tcp_session::up_thread_realserver_async_write_some_handler,
this,
} else {
if (ec == boost::asio::error::try_again) {
upthread_status = UPTHREAD_LOCK;
- func_tag = UP_FUNC_SORRYSERVER_HANDLE_ASEND;
+ func_tag = UP_FUNC_SORRYSERVER_HANDLE_ASYNC_SEND;
basic_tcp_socket<boost::asio::ip::tcp>::async_rw_handler_t handler =
boost::bind(&tcp_session::up_thread_sorryserver_async_write_some_handler,
this,
} else {
if (error_code == boost::asio::error::try_again) {
downthread_status = DOWNTHREAD_LOCK;
- func_tag = DOWN_FUNC_REALSERVER_HANDLE_ARECEIVE;
+ func_tag = DOWN_FUNC_REALSERVER_HANDLE_ASYNC_RECEIVE;
basic_tcp_socket<boost::asio::ip::tcp>::async_rw_handler_t handler =
boost::bind(&tcp_session::down_thread_realserver_async_read_some_handler,
this,
if (error_code == boost::asio::error::try_again) {
downthread_status = DOWNTHREAD_LOCK;
- func_tag = DOWN_FUNC_CLIENT_HANDLE_ASEND;
+ func_tag = DOWN_FUNC_CLIENT_HANDLE_ASYNC_SEND;
basic_tcp_socket<boost::asio::ip::tcp>::async_rw_handler_t handler =
boost::bind(&tcp_session::down_thread_client_async_write_some_handler,
this,
} else {
if (error_code == boost::asio::error::try_again) {
downthread_status = DOWNTHREAD_LOCK;
- func_tag = DOWN_FUNC_SORRYSERVER_HANDLE_ARECEIVE;
+ func_tag = DOWN_FUNC_SORRYSERVER_HANDLE_ASYNC_RECEIVE;
basic_tcp_socket<boost::asio::ip::tcp>::async_rw_handler_t handler =
boost::bind(&tcp_session::down_thread_sorryserver_async_read_some_handler,
this,
func_tag = up_thread_module_event_map[protocol_module->handle_realserver_send(up_thread_id)];
} else { // error
if (up_thread_data_dest_side.get_error_code() == boost::asio::error::try_again) {
- func_tag = UP_FUNC_REALSERVER_HANDLE_ASEND;
+ func_tag = UP_FUNC_REALSERVER_HANDLE_ASYNC_SEND;
upthread_status = UPTHREAD_LOCK;
boost::array<char, MAX_BUFFER_SIZE>& send_buff = up_thread_data_dest_side.get_data();
tcp_socket::async_rw_handler_t handler = boost::bind(&tcp_session::up_thread_realserver_async_write_some_handler,
func_tag = up_thread_module_event_map[protocol_module->handle_realserver_send(up_thread_id)];
} else {
if (up_thread_data_dest_side.get_error_code() == boost::asio::error::try_again) {
- func_tag = UP_FUNC_SORRYSERVER_HANDLE_ASEND;
+ func_tag = UP_FUNC_SORRYSERVER_HANDLE_ASYNC_SEND;
upthread_status = UPTHREAD_LOCK;
boost::array<char, MAX_BUFFER_SIZE>& send_buff = up_thread_data_dest_side.get_data();
func_tag = down_thread_module_event_map[module_event];
} else { // zero byte recv = try again.
downthread_status = DOWNTHREAD_LOCK;
- func_tag = DOWN_FUNC_REALSERVER_HANDLE_ARECEIVE;
+ func_tag = DOWN_FUNC_REALSERVER_HANDLE_ASYNC_RECEIVE;
tcp_socket::async_rw_handler_t handler = boost::bind(&tcp_session::down_thread_realserver_async_read_some_handler,
this,
boost::asio::placeholders::error,
} else { // error
if (error_code == boost::asio::error::try_again) {
downthread_status = DOWNTHREAD_LOCK;
- func_tag = DOWN_FUNC_REALSERVER_HANDLE_ARECEIVE;
+ func_tag = DOWN_FUNC_REALSERVER_HANDLE_ASYNC_RECEIVE;
tcp_socket::async_rw_handler_t handler = boost::bind(&tcp_session::down_thread_realserver_async_read_some_handler,
this,
boost::asio::placeholders::error,
}
} else { //error
if (error_code == boost::asio::error::try_again) {
- func_tag = DOWN_FUNC_CLIENT_HANDLE_ASEND;
+ func_tag = DOWN_FUNC_CLIENT_HANDLE_ASYNC_SEND;
downthread_status = DOWNTHREAD_LOCK;
tcp_socket::async_rw_handler_t handler = boost::bind(
&tcp_session::down_thread_client_async_write_some_handler,
func_tag = down_thread_module_event_map[module_event];
} else { // zero byte recv try_again
downthread_status = DOWNTHREAD_LOCK;
- func_tag = DOWN_FUNC_SORRYSERVER_HANDLE_ARECEIVE;
+ func_tag = DOWN_FUNC_SORRYSERVER_HANDLE_ASYNC_RECEIVE;
tcp_socket::async_rw_handler_t handler =
boost::bind(&tcp_session::down_thread_sorryserver_async_read_some_handler,
this,
} else {
if (error_code == boost::asio::error::try_again) {
downthread_status = DOWNTHREAD_LOCK;
- func_tag = DOWN_FUNC_SORRYSERVER_HANDLE_ARECEIVE;
+ func_tag = DOWN_FUNC_SORRYSERVER_HANDLE_ASYNC_RECEIVE;
tcp_socket::async_rw_handler_t handler =
boost::bind(&tcp_session::down_thread_sorryserver_async_read_some_handler,
this,