UltraMonkey-L7 V3(multi-thread implementation)
修訂 | 35e0656a76d470b452762e961553d770fe8887c9 (tree) |
---|---|
時間 | 2012-07-30 17:22:10 |
作者 | Hiroaki Nakano <nakano.hiroaki@nttc...> |
Commiter | Hiroaki Nakano |
ticket 29147 mutex.unlockコーディングエラーfix
down_thread_realserver_handle_async_read_some関数内で、
パケット受信エラー時にrealserver_socket_mutexをロックする処理を
行っているが、これは2重ロックとなってしまっている。
ここは本来、realserver_socket_mutexのロックを解除するべき処理を行う。
* @@ -3724,8 +3724,8 @@ void tcp_session::up_thread_realserver_h で、
空白が挿入。
→これは、元ファイルにtabインデントが残っていたため。空白で置き換える。
Signed-off-by: Hiroaki Nakano <nakano.hiroaki@nttcom.co.jp>
@@ -3716,8 +3716,8 @@ void tcp_session::up_thread_realserver_handle_async_write_some(const tcp_session | ||
3716 | 3716 | data_size - send_data_size |
3717 | 3717 | ), |
3718 | 3718 | handler); |
3719 | - else | |
3720 | - func_tag = UP_FUNC_REALSERVER_DISCONNECT; | |
3719 | + else | |
3720 | + func_tag = UP_FUNC_REALSERVER_DISCONNECT; | |
3721 | 3721 | } else { |
3722 | 3722 | func_tag = UP_FUNC_REALSERVER_DISCONNECT; |
3723 | 3723 | boost::format fmt("Thread ID[%d] realserver send error: %s"); |
@@ -3898,7 +3898,7 @@ void tcp_session::down_thread_realserver_handle_async_read_some(const tcp_sessio | ||
3898 | 3898 | realserver_socket->async_read_some(boost::asio::buffer(down_thread_data_dest_side.get_data()), handler); |
3899 | 3899 | else |
3900 | 3900 | func_tag = DOWN_FUNC_REALSERVER_DISCONNECT; |
3901 | - realserver_socket_mutex.lock(); | |
3901 | + realserver_socket_mutex.unlock(); | |
3902 | 3902 | } else { //recv error |
3903 | 3903 | func_tag = DOWN_FUNC_REALSERVER_DISCONNECT; |
3904 | 3904 | boost::format fmt("Thread ID[%d] down_thread_realserver_handle_async_read_some recv error:%s"); |