Same problem for me... Solved with patch of Ingo Molnar from: http://kerneltrap.org/Linux/Finding_Bugs_With_CFS
--- compat/Thread.c | 3 --- src/Reporter.c | 13 +++++++++---- src/main.cpp | 2 ++ 3 files changed, 11 insertions(+), 7 deletions(-)
Index: iperf-2.0.2/compat/Thread.c =================================================================== --- iperf-2.0.2.orig/compat/Thread.c +++ iperf-2.0.2/compat/Thread.c @@ -405,9 +405,6 @@ int thread_numuserthreads( void ) { void thread_rest ( void ) { #if defined( HAVE_THREAD ) #if defined( HAVE_POSIX_THREAD ) - // TODO add checks for sched_yield or pthread_yield and call that - // if available - usleep( 0 ); #else // Win32 SwitchToThread( ); #endif Index: iperf-2.0.2/src/Reporter.c =================================================================== --- iperf-2.0.2.orig/src/Reporter.c +++ iperf-2.0.2/src/Reporter.c @@ -111,6 +111,7 @@ report_statistics multiple_reports[kRepo char buffer[64]; // Buffer for printing ReportHeader *ReportRoot = NULL; extern Condition ReportCond; +extern Condition ReportDoneCond; int reporter_process_report ( ReportHeader *report ); void process_report ( ReportHeader *report ); int reporter_handle_packet( ReportHeader *report ); @@ -338,7 +339,7 @@ void ReportPacket( ReportHeader* agent, // item while ( index == 0 ) { Condition_Signal( &ReportCond ); - thread_rest(); + Condition_Wait( &ReportDoneCond ); index = agent->reporterindex; } agent->agentindex = 0; @@ -346,7 +347,7 @@ void ReportPacket( ReportHeader* agent, // Need to make sure that reporter is not about to be "lapped" while ( index - 1 == agent->agentindex ) { Condition_Signal( &ReportCond ); - thread_rest(); + Condition_Wait( &ReportDoneCond ); index = agent->reporterindex; }
@@ -553,6 +554,7 @@ void reporter_spawn( thread_Settings *th } Condition_Unlock ( ReportCond );
+again: if ( ReportRoot != NULL ) { ReportHeader *temp = ReportRoot; //Condition_Unlock ( ReportCond ); @@ -575,9 +577,12 @@ void reporter_spawn( thread_Settings *th // finished with report so free it free( temp ); Condition_Unlock ( ReportCond ); + Condition_Signal( &ReportDoneCond ); + if (ReportRoot) + goto again; } - // yield control of CPU is another thread is waiting - thread_rest(); + Condition_Signal( &ReportDoneCond ); + usleep(10000); } else { //Condition_Unlock ( ReportCond ); } Index: iperf-2.0.2/src/main.cpp =================================================================== --- iperf-2.0.2.orig/src/main.cpp +++ iperf-2.0.2/src/main.cpp @@ -96,6 +96,7 @@ extern "C" { // records being accessed in a report and also to // serialize modification of the report list Condition ReportCond; + Condition ReportDoneCond; }
// global variables only accessed within this file @@ -141,6 +142,7 @@ int main( int argc, char **argv ) {
// Initialize global mutexes and conditions Condition_Initialize ( &ReportCond ); + Condition_Initialize ( &ReportDoneCond ); Mutex_Initialize( &groupCond ); Mutex_Initialize( &clients_mutex );
-
Same problem for me... kerneltrap. org/Linux/ Finding_ Bugs_With_ CFS
Solved with patch of Ingo Molnar from:
http://
---
compat/Thread.c | 3 ---
src/Reporter.c | 13 +++++++++----
src/main.cpp | 2 ++
3 files changed, 11 insertions(+), 7 deletions(-)
Index: iperf-2. 0.2/compat/ Thread. c ======= ======= ======= ======= ======= ======= ======= ======= ==== 0.2.orig/ compat/ Thread. c 0.2/compat/ Thread. c numuserthreads( void ) { read( ); 0.2/src/ Reporter. c ======= ======= ======= ======= ======= ======= ======= ======= ==== 0.2.orig/ src/Reporter. c 0.2/src/ Reporter. c reports[ kRepo process_ report ( ReportHeader *report ); handle_ packet( ReportHeader *report );
Condition_ Signal( &ReportCond );
index = agent-> reporterindex;
agent- >agentindex = 0;
Condition _Signal( &ReportCond ); reporterindex;
=======
--- iperf-2.
+++ iperf-2.
@@ -405,9 +405,6 @@ int thread_
void thread_rest ( void ) {
#if defined( HAVE_THREAD )
#if defined( HAVE_POSIX_THREAD )
- // TODO add checks for sched_yield or pthread_yield and call that
- // if available
- usleep( 0 );
#else // Win32
SwitchToTh
#endif
Index: iperf-2.
=======
--- iperf-2.
+++ iperf-2.
@@ -111,6 +111,7 @@ report_statistics multiple_
char buffer[64]; // Buffer for printing
ReportHeader *ReportRoot = NULL;
extern Condition ReportCond;
+extern Condition ReportDoneCond;
int reporter_
void process_report ( ReportHeader *report );
int reporter_
@@ -338,7 +339,7 @@ void ReportPacket( ReportHeader* agent,
// item
while ( index == 0 ) {
- thread_rest();
+ Condition_Wait( &ReportDoneCond );
}
@@ -346,7 +347,7 @@ void ReportPacket( ReportHeader* agent,
// Need to make sure that reporter is not about to be "lapped"
while ( index - 1 == agent->agentindex ) {
- thread_rest();
+ Condition_Wait( &ReportDoneCond );
index = agent->
}
@@ -553,6 +554,7 @@ void reporter_spawn( thread_Settings *th
Condition_ Unlock ( ReportCond );
}
+again:
ReportHea der *temp = ReportRoot;
/ /Condition_ Unlock ( ReportCond );
free( temp );
Condition_ Unlock ( ReportCond );
/ /Condition_ Unlock ( ReportCond ); 0.2/src/ main.cpp ======= ======= ======= ======= ======= ======= ======= ======= ==== 0.2.orig/ src/main. cpp 0.2/src/ main.cpp
if ( ReportRoot != NULL ) {
@@ -575,9 +577,12 @@ void reporter_spawn( thread_Settings *th
// finished with report so free it
+ Condition_Signal( &ReportDoneCond );
+ if (ReportRoot)
+ goto again;
}
- // yield control of CPU is another thread is waiting
- thread_rest();
+ Condition_Signal( &ReportDoneCond );
+ usleep(10000);
} else {
}
Index: iperf-2.
=======
--- iperf-2.
+++ iperf-2.
@@ -96,6 +96,7 @@ extern "C" {
// records being accessed in a report and also to
// serialize modification of the report list
Condition ReportCond;
+ Condition ReportDoneCond;
}
// global variables only accessed within this file
@@ -141,6 +142,7 @@ int main( int argc, char **argv ) {
// Initialize global mutexes and conditions Initialize ( &ReportCond ); Initialize ( &ReportDoneCond ); Initialize( &groupCond ); Initialize( &clients_mutex );
Condition_
+ Condition_
Mutex_
Mutex_
-