Commit: 1a0320df21c18f7fe764c9e2c0e59f4810e26073 - ultramonkey-l7-v3 (git)

UltraMonkey-L7 V3(multi-thread implementation)

Commit MetaInfo

• Revisão: 1a0320df21c18f7fe764c9e2c0e59f4810e26073 (tree)
• Hora: 2011-12-27 14:14:51
• Autor: Michiro HIBARI <hibari@user...>
• Commiter: Michiro HIBARI

Mensagem de Log

Rename

ASEND=>ASYNC_SEND
ARECEIVE=>ASYNC_RECEIVE

Delete

UP_FUNC_CLIENT_ARECEIVE_HANDLE_EVENT
UP_FUNC_REALSERVER_ASEND_HANDLE_EVENT
UP_FUNC_SORRYSERVER_ASEND_HANDLE_EVENT
DOWN_FUNC_CLIENT_ASEND_HANDLE_EVENT
DOWN_FUNC_REALSERVER_ARECEIVE_HANDLE_EVENT
DOWN_FUNC_SORRYSERVER_ARECEIVE_HANDLE_EVENT

Mudança Sumário

• modified: l7vsd/include/tcp_session.h
• modified: l7vsd/src/tcp_session.cpp

Diff

--- a/l7vsd/include/tcp_session.h
+++ b/l7vsd/include/tcp_session.h
@@ -144,7 +144,6 @@ protected:
                 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
@@ -153,8 +152,7 @@ protected:
                 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
@@ -164,8 +162,7 @@ protected:
                 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
@@ -184,18 +181,15 @@ protected:
                 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
@@ -633,7 +627,6 @@ protected:
                         : 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"
@@ -642,8 +635,7 @@ protected:
                         : 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"
@@ -653,8 +645,7 @@ protected:
                         : 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"
@@ -672,17 +663,14 @@ protected:
                         : 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"

--- a/l7vsd/src/tcp_session.cpp
+++ b/l7vsd/src/tcp_session.cpp
@@ -161,9 +161,9 @@ tcp_session::tcp_session(
                 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(
@@ -197,9 +197,9 @@ tcp_session::tcp_session(
                 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(
@@ -262,17 +262,17 @@ tcp_session::tcp_session(
                 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(
@@ -286,9 +286,9 @@ tcp_session::tcp_session(
                 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(
@@ -1543,7 +1543,7 @@ void tcp_session::up_thread_realserver_send(const TCP_PROCESS_TYPE_TAG process_t
         } 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,
@@ -2128,7 +2128,7 @@ void tcp_session::up_thread_sorryserver_send(const TCP_PROCESS_TYPE_TAG process_
         } 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,
@@ -2788,7 +2788,7 @@ void tcp_session::down_thread_realserver_receive(const TCP_PROCESS_TYPE_TAG proc
         } 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,
@@ -3025,7 +3025,7 @@ void tcp_session::down_thread_client_send(const TCP_PROCESS_TYPE_TAG process_typ
                 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,
@@ -3200,7 +3200,7 @@ void tcp_session::down_thread_sorryserver_receive(const TCP_PROCESS_TYPE_TAG pro
         } 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,
@@ -3670,7 +3670,7 @@ void tcp_session::up_thread_realserver_handle_async_write_some(const tcp_session
                         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,
@@ -3757,7 +3757,7 @@ void tcp_session::up_thread_sorryserver_handle_async_write_some(const TCP_PROCES
                         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();
@@ -3841,7 +3841,7 @@ void tcp_session::down_thread_realserver_handle_async_read_some(const tcp_sessio
                         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,
@@ -3856,7 +3856,7 @@ void tcp_session::down_thread_realserver_handle_async_read_some(const tcp_sessio
         } 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,
@@ -3952,7 +3952,7 @@ void tcp_session::down_thread_client_handle_async_write_some(tcp_session::TCP_PR
                 }
         } 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,
@@ -4033,7 +4033,7 @@ void tcp_session::down_thread_sorryserver_handle_async_read_some(tcp_session::TC
                         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,
@@ -4044,7 +4044,7 @@ void tcp_session::down_thread_sorryserver_handle_async_read_some(tcp_session::TC
         } 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,