ticket #387

git-svn-id: http://10.144.169.20/repos/um/branches/l7vsd-3.x-ramiel@9430 1ed66053-1c2d-0410-8867-f7571e6e31d3

diff --git a/l7vsd/src/session_thread_control.cpp b/l7vsd/src/session_thread_control.cpp
index dc281da..4e50896 100644 (file)
--- a/l7vsd/src/session_thread_control.cpp
+++ b/l7vsd/src/session_thread_control.cpp
@@ -46,6 +46,14 @@ void    session_thread_control::upstream_run(){
             CPU_SET( i, &mask );
         }
         sched_setaffinity( 0, sizeof( cpu_set_t ), &mask );
+        
+        if( unlikely( LOG_LV_DEBUG == Logger::getLogLevel( LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
+            boost::format formatter("void virtualservice_tcp::upstream_run() "
+                                    "sched_setaffinity after num_of_core_uses = %d");
+            formatter % num_of_core_uses;
+            Logger::putLogDebug( LOG_CAT_L7VSD_VIRTUALSERVICE, 2, formatter.str(), __FILE__, __LINE__ );
+        }
+
     }
 #ifdef    SCHED_SETAFFINITY
     sched_setaffinity( 0, sizeof( cpu_set_t ), &vsnic_cpumask );
@@ -83,7 +91,7 @@ void    session_thread_control::upstream_run(){
     upthread_joining_condition.notify_all();
     if( unlikely( LOG_LV_DEBUG == l7vs::Logger::getLogLevel( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
         boost::format fmt("out_function : void session_thread_control::upstream_run()");
-        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 2, fmt.str(), __FILE__, __LINE__ );
+        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 3, fmt.str(), __FILE__, __LINE__ );
     }
 }
 //
@@ -92,7 +100,7 @@ void    session_thread_control::upstream_run(){
 void    session_thread_control::downstream_run(){
     if( unlikely( LOG_LV_DEBUG == Logger::getLogLevel( LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
         boost::format fmt("in_function : void session_thread_control::downstream_run()");
-        Logger::putLogDebug( LOG_CAT_L7VSD_VIRTUALSERVICE, 3, fmt.str(), __FILE__, __LINE__ );
+        Logger::putLogDebug( LOG_CAT_L7VSD_VIRTUALSERVICE, 4, fmt.str(), __FILE__, __LINE__ );
     }
     cpu_set_t       mask;
     //numが1以上なら、その数だけCPU_SETする
@@ -139,7 +147,7 @@ void    session_thread_control::downstream_run(){
     downthread_joining_condition.notify_all();
     if( unlikely( LOG_LV_DEBUG == l7vs::Logger::getLogLevel( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
         boost::format fmt("out_function : void session_thread_control::downstream_run()");
-        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 4, fmt.str(), __FILE__, __LINE__ );
+        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 5, fmt.str(), __FILE__, __LINE__ );
     }
 }
 //
@@ -148,7 +156,7 @@ void    session_thread_control::downstream_run(){
 void    session_thread_control::startupstream(){
     if( unlikely( LOG_LV_DEBUG == l7vs::Logger::getLogLevel( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
         boost::format fmt("in_function : void session_thread_control::startupstream()");
-        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 5, fmt.str(), __FILE__, __LINE__ );
+        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 6, fmt.str(), __FILE__, __LINE__ );
     }
     rw_scoped_lock    upstate_lock( upthread_state_mutex );
     if( upthread_state != EXIT ) upthread_state = RUNNING;        // upthread state update.[RUNNING] -> alive mode
@@ -156,7 +164,7 @@ void    session_thread_control::startupstream(){
     if( unlikely( LOG_LV_DEBUG == l7vs::Logger::getLogLevel( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
         boost::format fmt("out_function : void session_thread_control::startupstream() :status = %d");
          fmt % upthread_state;
-        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 6, fmt.str(), __FILE__, __LINE__ );
+        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 7, fmt.str(), __FILE__, __LINE__ );
     }
 }
 //
@@ -165,14 +173,14 @@ void    session_thread_control::startupstream(){
 void    session_thread_control::stopupstream(){
     if( unlikely( LOG_LV_DEBUG == l7vs::Logger::getLogLevel( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
         boost::format fmt("in_function : void session_thread_control::stopupstream()");
-        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 7, fmt.str(), __FILE__, __LINE__ );
+        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 8, fmt.str(), __FILE__, __LINE__ );
     }
     rw_scoped_lock    upstate_lock( upthread_state_mutex );
     if( upthread_state != EXIT ) upthread_state = WAIT;                // upthread state is update [WAIT] -> pooling mode
     if( unlikely( LOG_LV_DEBUG == l7vs::Logger::getLogLevel( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
         boost::format fmt("out_function : void session_thread_control::stopupstream() : status = %d");
          fmt % upthread_state;
-        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 8, fmt.str(), __FILE__, __LINE__ );
+        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 9, fmt.str(), __FILE__, __LINE__ );
     }
 }
 //
@@ -181,7 +189,7 @@ void    session_thread_control::stopupstream(){
 void    session_thread_control::startdownstream(){
     if( unlikely( LOG_LV_DEBUG == l7vs::Logger::getLogLevel( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
         boost::format fmt("in_function : void session_thread_control::startdownstream()");
-        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 9, fmt.str(), __FILE__, __LINE__ );
+        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 10, fmt.str(), __FILE__, __LINE__ );
     }
     rw_scoped_lock    downstate_lock( downthread_state_mutex );
     if( downthread_state != EXIT ) downthread_state = RUNNING;        // downstream state is update [RUNNING] -> alive mode
@@ -189,7 +197,7 @@ void    session_thread_control::startdownstream(){
     if( unlikely( LOG_LV_DEBUG == l7vs::Logger::getLogLevel( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
         boost::format fmt("out_function : void session_thread_control::startdownstream() : status = %d");
         fmt % downthread_state;
-        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 10, fmt.str(), __FILE__, __LINE__ );
+        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 11, fmt.str(), __FILE__, __LINE__ );
     }
 }
 //
@@ -198,14 +206,14 @@ void    session_thread_control::startdownstream(){
 void    session_thread_control::stopdownstream(){
     if( unlikely( LOG_LV_DEBUG == l7vs::Logger::getLogLevel( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
         boost::format fmt("in_function : void session_thread_control::stopdownstream()");
-        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 11, fmt.str(), __FILE__, __LINE__ );
+        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 12, fmt.str(), __FILE__, __LINE__ );
     }
     rw_scoped_lock    downstate_lock( downthread_state_mutex );
     if( downthread_state != EXIT ) downthread_state = WAIT;            // downstream state is update [WAIT] -> pooling mode
     if( unlikely( LOG_LV_DEBUG == l7vs::Logger::getLogLevel( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
         boost::format fmt("out_function : void session_thread_control::stopdownstream() : status = %d");
         fmt % downthread_state;
-        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 12, fmt.str(), __FILE__, __LINE__ );
+        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 13, fmt.str(), __FILE__, __LINE__ );
     }
 }
 //
@@ -214,7 +222,7 @@ void    session_thread_control::stopdownstream(){
 void    session_thread_control::join(){
     if( unlikely( LOG_LV_DEBUG == l7vs::Logger::getLogLevel( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
         boost::format fmt("in_function : void session_thread_control::join() :");
-        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 13, fmt.str(), __FILE__, __LINE__ );
+        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 14, fmt.str(), __FILE__, __LINE__ );
     }
 
     boost::mutex::scoped_lock    up_lk( upthread_joining_mutex );
@@ -244,7 +252,7 @@ void    session_thread_control::join(){
     if( unlikely( LOG_LV_DEBUG == l7vs::Logger::getLogLevel( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE ) ) ){
         boost::format fmt("out_function : void session_thread_control::stopdownstream() : up_status = %d / down_status = %d");
         fmt % upthread_state % downthread_state;
-        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 14, fmt.str(), __FILE__, __LINE__ );
+        l7vs::Logger::putLogDebug( l7vs::LOG_CAT_L7VSD_VIRTUALSERVICE, 15, fmt.str(), __FILE__, __LINE__ );
     }
 }
 //