123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200 |
- #include "test.h"
- #ifdef __GNUC__
- #include <stdlib.h>
- #endif
- #include "benchtest.h"
- #define PTW32_MUTEX_TYPES
- #define ITERATIONS 10000L
- static pthread_mutex_t gate1, gate2;
- static pthread_mutexattr_t ma;
- static long durationMilliSecs;
- static long overHeadMilliSecs = 0;
- static struct _timeb currSysTimeStart;
- static struct _timeb currSysTimeStop;
- static pthread_t worker;
- static int running = 0;
- #define GetDurationMilliSecs(_TStart, _TStop) ((_TStop.time*1000+_TStop.millitm) \
- - (_TStart.time*1000+_TStart.millitm))
- #define TESTSTART \
- { int i, j = 0, k = 0; _ftime(&currSysTimeStart); for (i = 0; i < ITERATIONS; i++) { j++;
- #define TESTSTOP \
- }; _ftime(&currSysTimeStop); if (j + k == i) j++; }
- static void *
- overheadThread(void * arg)
- {
- do
- {
- sched_yield();
- }
- while (running);
- return NULL;
- }
- static void *
- workerThread(void * arg)
- {
- do
- {
- (void) pthread_mutex_lock(&gate1);
- (void) pthread_mutex_lock(&gate2);
- (void) pthread_mutex_unlock(&gate1);
- sched_yield();
- (void) pthread_mutex_unlock(&gate2);
- }
- while (running);
- return NULL;
- }
- static void
- runTest (char * testNameString, int mType)
- {
- #ifdef PTW32_MUTEX_TYPES
- assert(pthread_mutexattr_settype(&ma, mType) == 0);
- #endif
- assert(pthread_mutex_init(&gate1, &ma) == 0);
- assert(pthread_mutex_init(&gate2, &ma) == 0);
- assert(pthread_mutex_lock(&gate1) == 0);
- assert(pthread_mutex_lock(&gate2) == 0);
- running = 1;
- assert(pthread_create(&worker, NULL, workerThread, NULL) == 0);
- TESTSTART
- (void) pthread_mutex_unlock(&gate1);
- sched_yield();
- (void) pthread_mutex_unlock(&gate2);
- (void) pthread_mutex_lock(&gate1);
- (void) pthread_mutex_lock(&gate2);
- TESTSTOP
- running = 0;
- assert(pthread_mutex_unlock(&gate2) == 0);
- assert(pthread_mutex_unlock(&gate1) == 0);
- assert(pthread_join(worker, NULL) == 0);
- assert(pthread_mutex_destroy(&gate2) == 0);
- assert(pthread_mutex_destroy(&gate1) == 0);
- durationMilliSecs = GetDurationMilliSecs(currSysTimeStart, currSysTimeStop) - overHeadMilliSecs;
- printf( "%-45s %15ld %15.3f\n",
- testNameString,
- durationMilliSecs,
- (float) durationMilliSecs * 1E3 / ITERATIONS / 4 );
- }
- int pthread_test_bench2()
- {
- assert(pthread_mutexattr_init(&ma) == 0);
- printf( "=============================================================================\n");
- printf( "\nLock plus unlock on a locked mutex.\n");
- printf("%ld iterations, four locks/unlocks per iteration.\n\n", ITERATIONS);
- printf( "%-45s %15s %15s\n",
- "Test",
- "Total(msec)",
- "average(usec)");
-
- running = 1;
- assert(pthread_create(&worker, NULL, overheadThread, NULL) == 0);
- TESTSTART
- sched_yield();
- sched_yield();
- TESTSTOP
- running = 0;
- assert(pthread_join(worker, NULL) == 0);
- durationMilliSecs = GetDurationMilliSecs(currSysTimeStart, currSysTimeStop) - overHeadMilliSecs;
- overHeadMilliSecs = durationMilliSecs;
-
- #ifdef PTW32_MUTEX_TYPES
- runTest("PTHREAD_MUTEX_DEFAULT", PTHREAD_MUTEX_DEFAULT);
- runTest("PTHREAD_MUTEX_NORMAL", PTHREAD_MUTEX_NORMAL);
- runTest("PTHREAD_MUTEX_ERRORCHECK", PTHREAD_MUTEX_ERRORCHECK);
- runTest("PTHREAD_MUTEX_RECURSIVE", PTHREAD_MUTEX_RECURSIVE);
- #else
- runTest("Blocking locks", 0);
- #endif
- printf( "=============================================================================\n");
-
- pthread_mutexattr_destroy(&ma);
- return 0;
- }
|