summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorhh1 <hh1@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2004-12-06 18:05:34 +0000
committerhh1 <hh1@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2004-12-06 18:05:34 +0000
commit831578c0a84f6e560c221ec4a077ae9edba06788 (patch)
treef56f3d0e40a0f0fc3b2aeae22b733f7f8f8f0f17
parent125eacc96c35b8447a03237fd7f817705eceb276 (diff)
downloadATCD-group_sched.tar.gz
*** empty log message ***group_sched
-rw-r--r--examples/Group_Schedule/simple/scenarioa.cpp88
1 files changed, 44 insertions, 44 deletions
diff --git a/examples/Group_Schedule/simple/scenarioa.cpp b/examples/Group_Schedule/simple/scenarioa.cpp
index ad24a307fad..b93f634fd9a 100644
--- a/examples/Group_Schedule/simple/scenarioa.cpp
+++ b/examples/Group_Schedule/simple/scenarioa.cpp
@@ -45,70 +45,70 @@ void my_sleep(int secs){
void child_process(SchedGroup& grp, const char* process_name)
{
- DSTRM_EVENT(SCENARIOA_FAM, JOINING_GROUP, getpid(), 0, NULL);
- Seq_QoS qos;
- SchedThread thr_member(&grp, qos, process_name);
+ DSTRM_EVENT(SCENARIOA_FAM, JOINING_GROUP, getpid(), 0, NULL);
+ Seq_QoS qos;
+ SchedThread thr_member(&grp, qos, process_name);
- if(!thr_member.is_valid()){
+ if(!thr_member.is_valid()){
printf("Error! in join_grp\n");
return;
- }
-
+ }
+
- for (int k = 0; k < 3; ++k) {
- DSTRM_EVENT(SCENARIOA_FAM,IN_WHILE_LOOP, getpid(), 0, NULL);
+ for (int k = 0; k < 3; ++k) {
+ DSTRM_EVENT(SCENARIOA_FAM,IN_WHILE_LOOP, getpid(), 0, NULL);
int j;
- for(int i=0; i<100000; i++)
- j++;
-
+ for(int i=0; i<100000; i++)
+ j++;
+
DSTRM_EVENT(SCENARIOA_FAM, CALLING_SLEEP, getpid(), 0, NULL);
- my_sleep(2);
- DSTRM_EVENT(SCENARIOA_FAM, AFTER_SLEEP, getpid(), 0, NULL);
- }
-
+ my_sleep(2);
+ DSTRM_EVENT(SCENARIOA_FAM, AFTER_SLEEP, getpid(), 0, NULL);
+ }
+
DSTRM_EVENT(SCENARIOA_FAM, EXITING, getpid(), 0, NULL);
- return;
+ return;
}
int main(int argc, char **argv){
- int pid=0, num_processes=0;
+ int pid=0, num_processes=0;
- if(argc!=3){
- printf("usage\n");
- printf("scenarioa <name of process> <number of processes>\n");
- exit(0);
- }
+ if(argc!=3){
+ printf("usage\n");
+ printf("scenarioa <name of process> <number of processes>\n");
+ exit(0);
+ }
- num_processes=atoi(argv[2]);
-
- Seq_QoS qos;
-
- SchedGroup top_group("SS", qos);
-
- if (top_group.set_as_top() == -1) {
- fprintf (stderr, "Error in setting top group\n");
- exit(1);
- }
+ num_processes=atoi(argv[2]);
+
+ Seq_QoS qos;
+
+ SchedGroup top_group("SS", qos);
+
+ if (top_group.set_as_top() == -1) {
+ fprintf (stderr, "Error in setting top group\n");
+ exit(1);
+ }
- DSUI_INIT("scenarioa", "scenarioa_enable.dsui");
+ DSUI_INIT("scenarioa", "scenarioa_enable.dsui");
- for(int i=0;i<num_processes;i++) {
- char process_name[100];
+ for(int i=0;i<num_processes;i++) {
+ char process_name[100];
- DSTRM_EVENT(SCENARIOA_FAM, CREATING_THREAD, getpid(), 0, NULL);
- pid=fork();
- sprintf(process_name,"%s%d", "THREAD",i);
+ DSTRM_EVENT(SCENARIOA_FAM, CREATING_THREAD, getpid(), 0, NULL);
+ pid=fork();
+ sprintf(process_name,"%s%d", "THREAD",i);
- if(pid==0){
- child_process(top_group, process_name);
+ if(pid==0){
+ child_process(top_group, process_name);
exit(0);
}
- }
+ }
- /* Make the main thread sleep for 10 secs */
- sleep(10);
+ /* Make the main thread sleep for 10 secs */
+ sleep(10);
DSTRM_EVENT(SCENARIOA_FAM, EXITING, getpid(), 0, NULL);
- return 0;
+ return 0;
}