diff options
Diffstat (limited to 'TAO/tests/Cubit/TAO/MT_Cubit/client.cpp')
| -rw-r--r-- | TAO/tests/Cubit/TAO/MT_Cubit/client.cpp | 814 |
1 files changed, 0 insertions, 814 deletions
diff --git a/TAO/tests/Cubit/TAO/MT_Cubit/client.cpp b/TAO/tests/Cubit/TAO/MT_Cubit/client.cpp deleted file mode 100644 index fa42dfbe3f4..00000000000 --- a/TAO/tests/Cubit/TAO/MT_Cubit/client.cpp +++ /dev/null @@ -1,814 +0,0 @@ -// $Id$ - -// ============================================================================ -// -// = LIBRARY -// TAO/tests -// -// = FILENAME -// client.cpp -// -// = AUTHOR -// Andy Gokhale, Brian Mendel, Sumedh Mungee, and Sergio Flores-Gaitan -// -// ============================================================================ - -#include "client.h" -#include "ace/Sched_Params.h" - -#if defined (NO_ACE_QUANTIFY) -#include "quantify.h" -#endif /* NO_ACE_QUANTIFY */ - -ACE_RCSID(MT_Cubit, client, "$Id$") - -#if defined (VXWORKS) -u_int ctx = 0; -u_int ct = 0; - -typedef struct { - char name[15]; - WIND_TCB *tcb; - INSTR * pc; -} task_info; - -#define SWITCHES 25000 -task_info tInfo[SWITCHES]; - -extern "C" -int -switchHook ( WIND_TCB *pOldTcb, /* pointer to old task's WIND_TCB */ - WIND_TCB *pNewTcb ) /* pointer to new task's WIND_TCB */ -{ - // We create the client threads with names starting with "@". - if ( pNewTcb->name[0] == '@') - ctx++; - - if (ct < SWITCHES) - { - strncpy (tInfo[ct].name, pNewTcb->name, 14); - tInfo[ct].tcb = pNewTcb; - tInfo[ct].pc = pNewTcb->regs.pc; - ct++; - } - - return 0; -} -#endif /* VXWORKS */ - -int -initialize (void) -{ -#if defined (VXWORKS) && defined (VME_DRIVER) - STATUS status = vmeDrv (); - if (status != OK) - printf ("ERROR on call to vmeDrv()\n"); - status = vmeDevCreate ("/vme"); - if (status != OK) - printf ("ERROR on call to vmeDevCreate()\n"); -#endif /* VXWORKS && VME_DRIVER */ - - // Make sure we've got plenty of socket handles. This call will - // use the default maximum. - ACE::set_handle_limit (); - - return 0; -} - -#if defined (VXWORKS) -void -output_taskinfo (void) -{ - FILE *file_handle = 0; - - if ((file_handle = ACE_OS::fopen ("taskinfo.txt", "w")) == 0) - perror ("open"); - - ACE_OS::fprintf(stderr, - "--->Output file for taskinfo data is \"taskinfo.txt\"\n"); - - // This loop visits each client. thread_count_ is the number of clients. - for (u_int j = 0; j < SWITCHES; j ++) - { - ACE_OS::fprintf(file_handle, - "\tname= %s\ttcb= %p\tpc= %p\n", - tInfo[j].name, - tInfo[j].tcb, - tInfo[j].pc); - } - - ACE_OS::fclose (file_handle); -} -#endif /* VXWORKS */ - -void -output_latency (Task_State *ts) -{ - FILE *latency_file_handle = 0; - char latency_file[BUFSIZ]; - char buffer[BUFSIZ]; - - ACE_OS::sprintf (latency_file, - "cb__%d.txt", - ts->thread_count_); - - ACE_OS::fprintf(stderr, - "--->Output file for latency data is \"%s\"\n", - latency_file); - - latency_file_handle = ACE_OS::fopen (latency_file, "w"); - - // This loop visits each client. thread_count_ is the number of clients. - for (u_int j = 0; j < ts->thread_count_; j ++) - { - ACE_OS::sprintf(buffer, - "%s #%d", - j==0? "High Priority": "Low Priority", - j); - // this loop visits each request latency from a client - for (u_int i = 0; i < (j==0? ts->high_priority_loop_count_:ts->loop_count_)/ts->granularity_; i ++) - { - ACE_OS::sprintf(buffer+strlen(buffer), -#if defined (CHORUS) - "\t%u\n", -#else - "\t%f\n", -#endif /* !CHORUS */ - ts->global_jitter_array_[j][i]); - fputs (buffer, latency_file_handle); - buffer[0]=0; - } - } - - ACE_OS::fclose (latency_file_handle); -} - -int -do_priority_inversion_test (ACE_Thread_Manager *thread_manager, - Task_State *ts) -{ - int i; - u_int j; - - char * task_id = 0; - - ACE_High_Res_Timer timer_; - ACE_Time_Value delta_t; - - timer_.start (); - -#if defined (VXWORKS) - ctx = 0; - ACE_NEW_RETURN (task_id, - char [32], - -1); -#endif /* VXWORKS */ - - ACE_DEBUG ((LM_DEBUG, "(%P|%t) <<<<<<< starting test on %D\n")); - - // stores the total number of context switches incurred by the - // program while making CORBA requests -#if defined (ACE_HAS_PRUSAGE_T) || defined (ACE_HAS_GETRUSAGE) - u_int context_switch = 0; -#endif /* ACE_HAS_PRUSAGE_T || ACE_HAS_GETRUSAGE */ - - double util_task_duration = 0.0; - double total_latency = 0.0; - double total_latency_high = 0.0; - double total_util_task_duration = 0.0; - - // Create the clients. - Client high_priority_client (thread_manager, ts, 0); - - // Create an array to hold pointers to the low priority tasks. - Client **low_priority_client; - - ACE_NEW_RETURN (low_priority_client, - Client *[ts->thread_count_], - -1); - - // hack to make sure we have something in this pointer, when - // thread_count == 1 - low_priority_client[0] = &high_priority_client; - - // Create the daemon thread in its own <ACE_Thread_Manager>. - ACE_Thread_Manager util_thr_mgr; - - Util_Thread util_thread (ts, &util_thr_mgr); - - // - // Time the utilization thread' "computation" to get %IdleCPU at the end of the test. - // -#if defined (CHORUS) - int pstartTime = 0; - int pstopTime = 0; - // Elapsed time will be in microseconds. - pstartTime = pccTime1Get(); - // execute one computation. - util_thread.computation (); - pstopTime = pccTime1Get(); - // Store the time in micro-seconds. - util_task_duration = pstopTime - pstartTime; -#else /* CHORUS */ - // Elapsed time will be in microseconds. - timer_.start (); - // execute computations. - for (i = 0; i < 10000; i++) - util_thread.computation (); - timer_.stop (); - timer_.elapsed_time (delta_t); - // Store the time in milli-seconds. - util_task_duration = (delta_t.sec () * - ACE_ONE_SECOND_IN_MSECS + - (double)delta_t.usec () / ACE_ONE_SECOND_IN_MSECS) / 10000; -#endif /* !CHORUS */ - - // The thread priority - ACE_Sched_Priority priority; - -#if defined (VXWORKS) - // set a task_id string starting with "@", so we are able to - // accurately count the number of context switches. - strcpy (task_id, "@High"); -#endif /* VXWORKS */ - - // Now activate the high priority client. -#if defined (VXWORKS) - priority = ACE_THR_PRI_FIFO_DEF; -#elif defined (ACE_WIN32) - priority = ACE_Sched_Params::priority_max (ACE_SCHED_FIFO, - ACE_SCOPE_THREAD); -#else /* ! VXWORKS */ - priority = ACE_THR_PRI_FIFO_DEF + 25; -#endif /* ! ACE_WIN32 */ - - ACE_DEBUG ((LM_DEBUG, - "Creating 1 client with high priority of %d\n", - priority)); - - if (high_priority_client.activate (THR_BOUND | ACE_SCHED_FIFO, - 1, - 0, - priority, - -1, - 0, - 0, - 0, - 0, - (ACE_thread_t*)task_id) == -1) - ACE_ERROR ((LM_ERROR, - "%p; priority is %d\n", - "activate failed", - priority)); - - ACE_DEBUG ((LM_DEBUG,"(%t) Waiting for argument parsing\n")); - ACE_MT (ACE_GUARD_RETURN (ACE_Thread_Mutex, ready_mon, ts->ready_mtx_,-1)); - while (!ts->ready_) - ts->ready_cnd_.wait (); - ACE_DEBUG ((LM_DEBUG,"(%t) Argument parsing waiting done\n")); - - u_int number_of_low_priority_client = 0; - u_int number_of_priorities = 0; - u_int grain = 0; - u_int counter = 0; - - number_of_low_priority_client = ts->thread_count_ - 1; - - // mechanism to distribute the available priorities among the - // threads when there are not enough different priorities for all - // threads. - if (ts->use_multiple_priority_ == 1) - { - ACE_Sched_Priority_Iterator priority_iterator (ACE_SCHED_FIFO, - ACE_SCOPE_THREAD); - - number_of_priorities = 0; - while (priority_iterator.more ()) - { - number_of_priorities ++; - priority_iterator.next (); - } - - // 1 priority is exclusive for the high priority client. - number_of_priorities --; - - // if utilization thread is present, reduce in 1 the available - // priorities. - if (ts->use_utilization_test_ == 1) - { - number_of_priorities --; - } - - // Drop the priority, so that the priority of clients will - // increase with increasing client number. - for (j = 0; j < number_of_low_priority_client; j++) - priority = ACE_Sched_Params::previous_priority (ACE_SCHED_FIFO, - priority, - ACE_SCOPE_THREAD); - - // if the lowest priority of the "low priority clients" is the - // minimum, and we are running the utilization thread, increment - // the priority, since we don't want the utlization thread and a - // "low priority thread" to have the same priority. - if ( priority == ACE_Sched_Params::priority_min (ACE_SCHED_FIFO, - ACE_SCOPE_THREAD) && - ts->use_utilization_test_ == 1) - priority = ACE_Sched_Params::next_priority (ACE_SCHED_FIFO, - priority, - ACE_SCOPE_THREAD); - - // granularity of the assignment of the priorities. Some OSs - // have fewer levels of priorities than we have threads in our - // test, so with this mechanism we assign priorities to groups - // of threads when there are more threads than priorities. - grain = number_of_low_priority_client / number_of_priorities; - counter = 0; - - if (grain <= 0) - grain = 1; - } - else - { - // Drop the priority one level - priority = ACE_Sched_Params::previous_priority (ACE_SCHED_FIFO, - priority, - ACE_SCOPE_THREAD); - } - - ACE_DEBUG ((LM_DEBUG, - "Creating %d clients at priority %d\n", - ts->thread_count_ - 1, - priority)); - - for (i = number_of_low_priority_client; i > 0; i--) - { - ACE_NEW_RETURN (low_priority_client [i - 1], - Client (thread_manager, ts, i), - -1); - -#if defined (VXWORKS) - // Pace the connection establishment on VxWorks. - const ACE_Time_Value delay (0L, 500000L); - ACE_OS::sleep (delay); - - // set a task_id string startiing with "@", so we are able to - // accurately count the number of context switches on VXWORKS - sprintf (task_id, "@Low%u", i); -#endif /* VXWORKS */ - - ACE_DEBUG ((LM_DEBUG, - "Creating client with thread ID %d and priority %d\n", - i, - priority)); - - // The first thread starts at the lowest priority of all the low - // priority clients. - if (low_priority_client[i - 1]->activate (THR_BOUND | ACE_SCHED_FIFO, - 1, - 0, - priority, // These are constructor defaults. - -1, // int grp_id = -1, - 0, // ACE_Task_Base *task = 0, - 0, // ACE_hthread_t thread_handles[] = 0, - 0, // void *stack[] = 0, - 0, // size_t stack_size[] = 0, - (ACE_thread_t*)task_id) == -1) - ACE_ERROR ((LM_ERROR, - "%p; priority is %d\n", - "activate failed", - priority)); - - if (ts->use_multiple_priority_ == 1) - { - counter = (counter + 1) % grain; - if ( (counter == 0) && - //Just so when we distribute the priorities among the - //threads, we make sure we don't go overboard. - ((number_of_priorities * grain) > (number_of_low_priority_client - (i - 1))) ) - { - // Get the next higher priority. - priority = ACE_Sched_Params::next_priority (ACE_SCHED_FIFO, - priority, - ACE_SCOPE_THREAD); - } - - } - } /* end of for () */ - - if (ts->use_utilization_test_ == 1) - // activate the utilization thread only if specified. See - // description of this variable in header file. - { - priority = - ACE_Sched_Params::priority_min (ACE_SCHED_FIFO, - ACE_SCOPE_THREAD); - ACE_DEBUG ((LM_DEBUG, - "Creating utilization thread with priority of %d\n", - priority)); - - // activate the Utilization thread. It will wait until - // all threads have finished binding. - util_thread.activate (THR_BOUND | ACE_SCHED_FIFO, - 1, - 0, - priority); - } - else - { - util_thread.close (); - } - // Wait for all the client threads to be initialized before going - // any further. - ts->barrier_->wait (); - -#if defined (NO_ACE_QUANTIFY) - quantify_stop_recording_data(); - quantify_clear_data (); -#endif /* NO_ACE_QUANTIFY */ - -#if (defined (ACE_HAS_PRUSAGE_T) || defined (ACE_HAS_GETRUSAGE)) && !defined (ACE_WIN32) - ACE_Profile_Timer timer_for_context_switch; - ACE_Profile_Timer::Rusage usage; - - if (ts->context_switch_test_ == 1) - { - timer_for_context_switch.start (); - timer_for_context_switch.get_rusage (usage); -# if defined (ACE_HAS_PRUSAGE_T) - context_switch = usage.pr_vctx + usage.pr_ictx; -# else /* ACE_HAS_PRUSAGE_T */ - context_switch = usage.ru_nvcsw + usage.ru_nivcsw; -# endif /* ACE_HAS_GETRUSAGE */ - } -#endif /* ACE_HAS_PRUSAGE_T || ACE_HAS_GETRUSAGE */ - -#if defined (VXWORKS) - if (ts->context_switch_test_ == 1) - { - fprintf(stderr, "Adding the context switch hook!\n"); - taskSwitchHookAdd ((FUNCPTR)&switchHook); - } -#endif - - // Wait for all the client threads to exit (except the utilization - // thread). - thread_manager->wait (); - -#if defined (NO_ACE_QUANTIFY) - quantify_stop_recording_data(); -#endif /* NO_ACE_QUANTIFY */ - - ACE_DEBUG ((LM_DEBUG, "(%P|%t) >>>>>>> ending test on %D\n")); - - timer_.stop (); - timer_.elapsed_time (delta_t); - - if (ts->use_utilization_test_ == 1) - // signal the utilization thread to finish with its work.. only - // if utilization test was specified. See description of this - // variable in header file. - { - util_thread.done_ = 1; - - // This will wait for the utilization thread to finish. - util_thr_mgr.wait (); - } - - ACE_DEBUG ((LM_DEBUG, - "-------------------------- Stats -------------------------------\n")); - - if (ts->context_switch_test_ == 1) - { -#if defined (ACE_HAS_PRUSAGE_T) - timer_for_context_switch.stop (); - timer_for_context_switch.get_rusage (usage); - // Add up the voluntary context switches & involuntary context - // switches - context_switch = usage.pr_vctx + usage.pr_ictx - context_switch; - ACE_DEBUG ((LM_DEBUG, - "Voluntary context switches=%d, Involuntary context switches=%d\n", - usage.pr_vctx, - usage.pr_ictx)); -#elif defined (ACE_HAS_GETRUSAGE) && !defined (ACE_WIN32) - timer_for_context_switch.stop (); - timer_for_context_switch.get_rusage (usage); - // Add up the voluntary context switches & involuntary context - // switches - context_switch = usage.ru_nvcsw + usage.ru_nivcsw - context_switch; - ACE_DEBUG ((LM_DEBUG, - "Voluntary context switches=%d, Involuntary context switches=%d\n", - usage.ru_nvcsw, - usage.ru_nivcsw)); -#elif defined (VXWORKS) /* ACE_HAS_GETRUSAGE */ - taskSwitchHookDelete ((FUNCPTR)&switchHook); - ACE_DEBUG ((LM_DEBUG, - "Context switches=%d\n", - ctx)); -#endif - } - - // if running the utilization test, don't report latency nor jitter. - if (ts->use_utilization_test_ == 0 && - ts->run_server_utilization_test_ == 0) - { -#if defined (VXWORKS) - ACE_DEBUG ((LM_DEBUG, "Test done.\n" - "High priority client latency : %f msec, jitter: %f msec\n" - "Low priority client latency : %f msec, jitter: %f msec\n", - high_priority_client.get_high_priority_latency (), - high_priority_client.get_high_priority_jitter (), - low_priority_client[0]->get_low_priority_latency (), - low_priority_client[0]->get_low_priority_jitter ())); - // output the latency values to a file, tab separated, to import - // it to Excel to calculate jitter, in the mean time we come up - // with the sqrt() function. - output_latency (ts); -#elif defined (CHORUS) - ACE_DEBUG ((LM_DEBUG, - "Test done.\n" - "High priority client latency : %u usec\n" - "Low priority client latency : %u usec\n", - high_priority_client.get_high_priority_latency (), - low_priority_client[0]->get_low_priority_latency () )); - - // output the latency values to a file, tab separated, to import - // it to Excel to calculate jitter, in the mean time we come up - // with the sqrt() function. - output_latency (ts); -#else /* !CHORUS */ - ACE_DEBUG ((LM_DEBUG, "Test done.\n" - "High priority client latency : %f msec, jitter: %f msec\n" - "Low priority client latency : %f msec, jitter: %f msec\n", - high_priority_client.get_high_priority_latency (), - high_priority_client.get_high_priority_jitter (), - low_priority_client[0]->get_low_priority_latency (), - low_priority_client[0]->get_low_priority_jitter ())); - // output_latency (ts); -#endif /* !VXWORKS && !CHORUS */ - } - - if (ts->use_utilization_test_ == 1) - { - total_util_task_duration = util_task_duration * util_thread.get_number_of_computations (); - - total_latency = (delta_t.sec () * - ACE_ONE_SECOND_IN_MSECS + - (double)delta_t.usec () / ACE_ONE_SECOND_IN_MSECS); - - total_latency_high = total_latency - total_util_task_duration; - - // Calc and print the CPU percentage. I add 0.5 to round to the - // nearest integer before casting it to int. - ACE_DEBUG ((LM_DEBUG, - "\t%% ORB Client CPU utilization: %u %%\n" - "\t%% Idle time: %u %%\n\n", - (u_int) (total_latency_high * 100 / total_latency + 0.5), - (u_int) (total_util_task_duration * 100 / total_latency + 0.5) )); - - ACE_DEBUG ((LM_DEBUG, - "(%t) UTILIZATION task performed \t%u computations\n" - "(%t) CLIENT task performed \t\t%u CORBA calls\n" - "\t Ratio of computations to CORBA calls is %u.%u:1\n\n", - util_thread.get_number_of_computations (), - ts->loop_count_, - util_thread.get_number_of_computations () / ts->loop_count_, - (util_thread.get_number_of_computations () % ts->loop_count_) * 100 / ts->loop_count_ - )); - -#if defined (ACE_LACKS_FLOATING_POINT) - ACE_DEBUG ((LM_DEBUG, - "(%t) utilization computation time is %u usecs\n", - util_task_duration)); -#else - ACE_DEBUG ((LM_DEBUG, - "(%t) utilization computation time is %f msecs\n", - util_task_duration)); -#endif /* ! ACE_LACKS_FLOATING_POINT */ - } - -#if defined (VXWORKS) - delete task_id; -#endif /* VXWORKS */ - return 0; -} - -int -do_thread_per_rate_test (ACE_Thread_Manager *thread_manager, - Task_State *ts) -{ - Client CB_20Hz_client (thread_manager, ts, CB_20HZ_CONSUMER); - Client CB_10Hz_client (thread_manager, ts, CB_10HZ_CONSUMER); - Client CB_5Hz_client (thread_manager, ts, CB_5HZ_CONSUMER); - Client CB_1Hz_client (thread_manager, ts, CB_1HZ_CONSUMER); - - ACE_Sched_Priority priority; - -#if defined (VXWORKS) - priority = ACE_THR_PRI_FIFO_DEF; -#elif defined (ACE_WIN32) - priority = ACE_Sched_Params::priority_max (ACE_SCHED_FIFO, - ACE_SCOPE_THREAD); -#else /* ! VXWORKS */ - priority = ACE_THR_PRI_FIFO_DEF + 25; -#endif /* ! ACE_WIN32 */ - - ACE_DEBUG ((LM_DEBUG, - "Creating 20 Hz client with priority %d\n", - priority)); - - if (CB_20Hz_client.activate (THR_BOUND | ACE_SCHED_FIFO, 1, 1, priority) == -1) - ACE_ERROR ((LM_ERROR, "(%P|%t) errno = %p: activate failed\n")); - - // The high priority thread is parsing the arguments, so wait on the - // condition variable until it wakes us up. - - ACE_DEBUG ((LM_DEBUG,"(%t) Waiting for argument parsing\n")); - ACE_MT (ACE_GUARD_RETURN (ACE_Thread_Mutex, ready_mon, ts->ready_mtx_,-1)); - while (!ts->ready_) - ts->ready_cnd_.wait (); - ACE_DEBUG ((LM_DEBUG,"(%t) Argument parsing waiting done\n")); - - priority = ACE_Sched_Params::previous_priority (ACE_SCHED_FIFO, - priority, - ACE_SCOPE_THREAD); - - ACE_DEBUG ((LM_DEBUG, - "Creating 10 Hz client with priority %d\n", - priority)); - - if (CB_10Hz_client.activate (THR_BOUND | ACE_SCHED_FIFO, 1, 1, priority) == -1) - ACE_ERROR ((LM_ERROR, "(%P|%t) errno = %p: activate failed\n")); - - priority = ACE_Sched_Params::previous_priority (ACE_SCHED_FIFO, - priority, - ACE_SCOPE_THREAD); - ACE_DEBUG ((LM_DEBUG, - "Creating 5 Hz client with priority %d\n", - priority)); - - if (CB_5Hz_client.activate (THR_BOUND | ACE_SCHED_FIFO, 1, 1, priority) == -1) - ACE_ERROR ((LM_ERROR, "(%P|%t) errno = %p: activate failed\n")); - - priority = ACE_Sched_Params::previous_priority (ACE_SCHED_FIFO, - priority, - ACE_SCOPE_THREAD); - ACE_DEBUG ((LM_DEBUG, - "Creating 1 Hz client with priority %d\n", - priority)); - - if (CB_1Hz_client.activate (THR_BOUND | ACE_SCHED_FIFO, 1, 1, priority) == -1) - ACE_ERROR ((LM_ERROR, "(%P|%t) errno = %p: activate failed\n")); - - // Wait for all the threads to exit. - thread_manager->wait (); - -#if defined (ACE_LACKS_FLOATING_POINT) - ACE_DEBUG ((LM_DEBUG, - "Test done.\n" - "20Hz client latency : %u usec, jitter: %u usec\n" - "10Hz client latency : %u usec, jitter: %u usec\n" - "5Hz client latency : %u usec, jitter: %u usec\n" - "1Hz client latency : %u usec, jitter: %u usec\n", - CB_20Hz_client.get_latency (0), CB_20Hz_client.get_jitter (0), - CB_10Hz_client.get_latency (1), CB_10Hz_client.get_jitter (1), - CB_5Hz_client.get_latency (2), CB_5Hz_client.get_jitter (2), - CB_1Hz_client.get_latency (3), CB_1Hz_client.get_jitter (3) )); -#else - ACE_DEBUG ((LM_DEBUG, - "Test done.\n" - "20Hz client latency : %f msec, jitter: %f msec\n" - "10Hz client latency : %f msec, jitter: %f msec\n" - "5Hz client latency : %f msec, jitter: %f msec\n" - "1Hz client latency : %f msec, jitter: %f msec\n", - CB_20Hz_client.get_latency (0), CB_20Hz_client.get_jitter (0), - CB_10Hz_client.get_latency (1), CB_10Hz_client.get_jitter (1), - CB_5Hz_client.get_latency (2), CB_5Hz_client.get_jitter (2), - CB_1Hz_client.get_latency (3), CB_1Hz_client.get_jitter (3) )); -#endif /* ! ACE_LACKS_FLOATING_POINT */ - return 0; -} - -// This is the main routine of the client, where we create a high -// priority and a low priority client. we then activate the clients -// with the appropriate priority threads, and wait for them to -// finish. After they aer done, we compute the latency and jitter -// metrics and print them. - -#if defined (VXWORKS) -extern "C" -int -client (int argc, char *argv[]) -{ - ACE_Object_Manager ace_object_manager; -#else -int -main (int argc, char *argv[]) -{ -#endif - -#if defined (ACE_HAS_THREADS) -#if defined (FORCE_ARGS) - int argc = 4; - char *argv[] = {"client", - "-s", - "-f", - "ior.txt"}; -#endif /* defined (FORCE_ARGS) */ - - // Enable FIFO scheduling, e.g., RT scheduling class on Solaris. - if (ACE_OS::sched_params ( - ACE_Sched_Params ( - ACE_SCHED_FIFO, -#if defined (__Lynx__) - 30, -#elif defined (VXWORKS) /* ! __Lynx__ */ - 6, -#elif defined (ACE_WIN32) - ACE_Sched_Params::priority_max (ACE_SCHED_FIFO, - ACE_SCOPE_THREAD), -#else - ACE_THR_PRI_FIFO_DEF + 25, -#endif /* ! __Lynx__ */ - ACE_SCOPE_PROCESS)) != 0) - { - if (ACE_OS::last_error () == EPERM) - ACE_DEBUG ((LM_MAX, "preempt: user is not superuser, " - "so remain in time-sharing class\n")); - else - ACE_ERROR_RETURN ((LM_ERROR, "%n: ACE_OS::sched_params failed\n%a"), - -1); - } - - ACE_High_Res_Timer timer_; - ACE_Time_Value delta_t; - -#if 0 // this is a debug section that will be removed soon. 1/6/98 - ACE_DEBUG ((LM_MAX, "<<<<<Delay of 5 seconds>>>>>\n")); - - timer_.start (); - - const ACE_Time_Value delay (5L, 0L); - ACE_OS::sleep (delay); - - timer_.stop (); - timer_.elapsed_time (delta_t); - - ACE_DEBUG ((LM_DEBUG, "5secs= %u secs, %u usecs\n", delta_t.sec (), delta_t.usec ())); -#endif - - initialize (); - - Task_State ts (argc, argv); - - // preliminary argument processing - for (int i=0 ; i< argc; i++) - { - if ((ACE_OS::strcmp (argv[i],"-r") == 0)) - ts.thread_per_rate_ = 1; - else if ((ACE_OS::strcmp (argv[i],"-t") == 0) && (i-1 < argc)) - ts.thread_count_ = ACE_OS::atoi (argv[i+1]); - } - -#if defined (CHORUS) - // start the pccTimer for chorus classix - int pTime; - - // Initialize the PCC timer Chip - pccTimerInit(); - - if(pccTimer(PCC2_TIMER1_START,&pTime) != K_OK) - { - printf("pccTimer has a pending benchmark\n"); - } -#endif /* CHORUS */ - - // Create a separate manager for the client. This allows the use - // of its wait () method on VxWorks, without interfering with the - // server's (global) thread manager. - ACE_Thread_Manager client_thread_manager; - - if (ts.thread_per_rate_ == 0) - do_priority_inversion_test (&client_thread_manager, &ts); - else - do_thread_per_rate_test (&client_thread_manager, &ts); - -#if defined (CHORUS) - if(pccTimer(PCC2_TIMER1_STOP,&pTime) !=K_OK) - { - printf("pccTimer has a pending bench mark\n"); - } -#elif defined (VXWORKS) - // Shoot myself. Otherwise, there's a General Protection Fault. This - // will leak memory, but that's preferable. It looks like the problem - // might be due to static objects in libTAO or liborbsvcs? - int status; - ACE_OS::thr_exit (&status); -#endif /* CHORUS */ - -#else /* !ACE_HAS_THREADS */ - ACE_DEBUG ((LM_DEBUG, - "Test not run. This platform doesn't seem to have threads.\n")); -#endif /* ACE_HAS_THREADS */ - - return 0; -} |