diff options
author | yamuna <yamuna@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-01-17 21:09:36 +0000 |
---|---|---|
committer | yamuna <yamuna@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-01-17 21:09:36 +0000 |
commit | 75a342198e9d81a31980e21d79c295fe06901359 (patch) | |
tree | ebaa1f9d06f610b2f4a61c57e41f90175cd6da0b /TAO/examples/RTCORBA/Activity/Periodic_Task.cpp | |
parent | 44093e523e234227f5d39d58a9e9ee1b40352ec0 (diff) | |
download | ATCD-RTCORBA_Diffserv.tar.gz |
*** empty log message ***RTCORBA_Diffserv
Diffstat (limited to 'TAO/examples/RTCORBA/Activity/Periodic_Task.cpp')
-rw-r--r-- | TAO/examples/RTCORBA/Activity/Periodic_Task.cpp | 33 |
1 files changed, 26 insertions, 7 deletions
diff --git a/TAO/examples/RTCORBA/Activity/Periodic_Task.cpp b/TAO/examples/RTCORBA/Activity/Periodic_Task.cpp index 03a87bb3a6c..079a101c280 100644 --- a/TAO/examples/RTCORBA/Activity/Periodic_Task.cpp +++ b/TAO/examples/RTCORBA/Activity/Periodic_Task.cpp @@ -51,6 +51,14 @@ Periodic_Task::init_task (ACE_Arg_Shifter& arg_shifter) { exec_time_ = ACE_OS::atoi (current_arg); arg_shifter.consume_arg (); + + if (exec_time_ != 0) + { + ACE_NEW_RETURN (task_stats_, Task_Stats (5000), -1); + + if (task_stats_->init () == -1) + return -1; + } } else if ((current_arg = arg_shifter.get_the_parameter ("-Phase"))) { @@ -61,20 +69,31 @@ Periodic_Task::init_task (ACE_Arg_Shifter& arg_shifter) { iter_ = ACE_OS::atoi (current_arg); arg_shifter.consume_arg (); - - // create the stat object. - ACE_NEW_RETURN (task_stats_, Task_Stats (iter_), -1); - - if (task_stats_->init () == -1) - return -1; + + if (iter_ != 0) + { + // create the stat object. + ACE_NEW_RETURN (task_stats_, Task_Stats (iter_), -1); + + if (task_stats_->init () == -1) + return -1; + } } else if ((current_arg = arg_shifter.get_the_parameter ("-Load"))) { load_ = ACE_OS::atoi (current_arg); arg_shifter.consume_arg (); + } + else if ((current_arg = arg_shifter.get_the_parameter ("-Diffserv"))) + { + enable_network_priority_ = ACE_OS::atoi (current_arg); + arg_shifter.consume_arg (); + ACE_DEBUG ((LM_DEBUG, + "Enable Network Priority %d\n", + enable_network_priority_)); return 0; - } + } else { ACE_DEBUG ((LM_DEBUG, "parse Task unknown option %s\n", |