1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
|
<HTML>
<HEAD>
<META HTTP-EQUIV="Content-Type" CONTENT="text/html; charset=iso-8859-1">
<META NAME="Author" CONTENT="Ambreen Ilyas">
<META NAME="GENERATOR" CONTENT="Mozilla/4.05 [en] (X11; I; SunOS 5.5.1 sun4u) [Netscape]">
<TITLE>Example 3</TITLE>
</HEAD>
<BODY>
<FONT COLOR="#CC0000">/////////////////////////////////////////////////////////////////////////////////////////////////////////////////</FONT>
<BR><FONT COLOR="#CC0000">//// This example is from the ACE Programmers
Guide.</FONT>
<BR><FONT COLOR="#CC0000">//// Chapter: "The Message Queue"</FONT>
<BR><FONT COLOR="#CC0000">//// For details please see the guide at</FONT>
<BR><FONT COLOR="#CC0000">//// http://www.cs.wustl.edu/~schmidt/ACE.html</FONT>
<BR><FONT COLOR="#CC0000">//// AUTHOR: Umar Syyid (usyyid@hns.com)</FONT>
<BR><FONT COLOR="#CC0000">//// and Ambreen Ilyas (ambreen@bitsmart.com)</FONT>
<BR><FONT COLOR="#CC0000">/////////////////////////////////////////////////////////////////////////////////////////////////////////////</FONT>
<P><FONT COLOR="#CC0000">//Example 3</FONT>
<BR><FONT COLOR="#000099">#include</FONT> "<FONT COLOR="#006600">ace/Message_Queue.h"</FONT>
<BR><FONT COLOR="#000099">#include</FONT> "<FONT COLOR="#006600">ace/Get_Opt.h"</FONT>
<BR><FONT COLOR="#000099">#include</FONT> "<FONT COLOR="#006600">ace/OS.h"</FONT>
<P>class Args{
<BR>public:
<BR>Args(int argc, char*argv[],int& no_msgs, int& time,ACE_Message_Queue<ACE_NULL_SYNCH>*
&mq){
<BR> ACE_Get_Opt get_opts(argc,argv,"h:l:t:n:xsd");
<BR> while((opt=get_opts())!=-1)
<BR> switch(opt){
<BR> case 't':
<BR> time=ACE_OS::atoi(get_opts.optarg);
<BR> ACE_DEBUG((LM_INFO,"Time: %d \n",time));
<BR> break;
<BR> case 'n':
<BR> no_msgs=ACE_OS::atoi(get_opts.optarg);
<BR> ACE_DEBUG((LM_INFO,"Number of Messages %d \n",no_msgs));
<BR> break;
<BR> case 'x':
<BR> mq=ACE_Message_Queue_Factory<ACE_NULL_SYNCH>:: create_laxity_message_queue();
<BR> ACE_DEBUG((LM_DEBUG,"Creating laxity q\n"));
<BR> break;
<BR> case 'd':
<BR> mq=ACE_Message_Queue_Factory<ACE_NULL_SYNCH>:: create_deadline_message_queue();
<BR> ACE_DEBUG((LM_DEBUG,"Creating deadline q\n"));
<BR> break;
<BR> case 's':
<BR> mq=ACE_Message_Queue_Factory<ACE_NULL_SYNCH>:: create_static_message_queue();
<BR> ACE_DEBUG((LM_DEBUG,"Creating static q\n"));
<BR> break;
<BR> case 'h':
<BR> hwm=ACE_OS::atoi(get_opts.optarg);
<BR> mq->high_water_mark(hwm);
<BR> ACE_DEBUG((LM_INFO,"High Water Mark %d msgs \n",hwm));
<BR> break;
<BR> case 'l':
<BR> lwm=ACE_OS::atoi(get_opts.optarg);
<BR> mq->low_water_mark(lwm);
<BR> ACE_DEBUG((LM_INFO,"Low Water Mark %d msgs \n",lwm));
<BR> break;
<BR> default:
<BR> ACE_DEBUG((LM_ERROR,"Usage specify queue type\n"));
<BR> break;
<BR> }
<BR> }
<P>private:
<BR> int opt;
<BR> int hwm;
<BR> int lwm;
<BR>};
<BR>
<BR>
<P>class QTest{
<BR>public:
<BR>QTest(int argc, char*argv[]){
<BR> args_ = new Args(argc,argv,no_msgs_,time_,mq_);
<BR> array_ =new ACE_Message_Block*[no_msgs_];
<BR> }
<P>int start_test(){
<BR> for(int i=0; i<no_msgs_;i++){
<BR> ACE_NEW_RETURN (array_[i], ACE_Message_Block (1), -1);
<BR> set_deadline(i);
<BR> set_execution_time(i);
<BR> enqueue(i);
<BR> }
<P> this->dequeue_all();
<BR> return 0;
<BR> }
<P><FONT COLOR="#FF0000">//Call the underlying ACE_Message_Block method
msg_deadline_time() to set the deadline of the message.</FONT>
<BR>void set_deadline(int msg_no){
<BR> float temp=(float) time_/(msg_no+1);
<BR> ACE_Time_Value tv;
<BR> tv.set(temp);
<BR> ACE_Time_Value deadline(ACE_OS::gettimeofday()+tv);
<BR> array_[msg_no]->msg_deadline_time(deadline);
<BR> ACE_DEBUG((LM_INFO,"EQd with DLine %d:%d\n", deadline.sec(),deadline.usec()));
<BR> }
<P><FONT COLOR="#FF0000">//Call the underlying ACE_Message_Block method
to set the execution time</FONT>
<BR>void set_execution_time(int msg_no){
<BR> float temp=(float) time_/10*msg_no;
<BR> ACE_Time_Value tv;
<BR> tv.set(temp);
<BR> ACE_Time_Value xtime(ACE_OS::gettimeofday()+tv);
<BR> array_[msg_no]->msg_execution_time (xtime);
<BR> ACE_DEBUG((LM_INFO,"Xtime %d:%d\n",xtime.sec(),xtime.usec()));
<BR> }
<P>void enqueue(int msg_no){
<BR><FONT COLOR="#FF0000"> //Set the value of data at the read position</FONT>
<BR> *array_[msg_no]->rd_ptr()=msg_no;
<BR><FONT COLOR="#FF0000"> //Advance write pointer</FONT>
<BR> array_[msg_no]->wr_ptr(1);
<BR><FONT COLOR="#FF0000"> //Enqueue on the message queue</FONT>
<BR> if(mq_->enqueue_prio(array_[msg_no])==-1){
<BR> ACE_DEBUG((LM_ERROR,"\nCould not enqueue on to mq!!\n"));
<BR> return;
<BR> }
<BR> ACE_DEBUG((LM_INFO,"Data %d\n",*array_[msg_no]->rd_ptr()));
<BR> }
<P>void dequeue_all(){
<BR> ACE_DEBUG((LM_INFO,"Beginning DQ \n"));
<BR> ACE_DEBUG((LM_INFO,"No. of Messages on Q:%d Bytes on Q:%d \n",
mq_->message_count(),mq_->message_bytes()));
<BR> for(int i=0;i<no_msgs_ ;i++){
<BR> ACE_Message_Block *mb;
<BR> if(mq_->dequeue_head(mb)==-1){
<BR> ACE_DEBUG((LM_ERROR,'\nCould not dequeue from mq!!\n"));
<BR> return;
<BR> }
<BR> ACE_DEBUG((LM_INFO,"DQd data %d\n",*mb->rd_ptr()));
<BR> }
<BR> }
<BR>private:
<BR> Args *args_;
<BR> ACE_Message_Block **array_;
<BR> ACE_Message_Queue<ACE_NULL_SYNCH> *mq_;
<BR> int no_msgs_;
<BR> int time_;
<BR>};
<P>int main(int argc, char* argv[]){
<BR> QTest test(argc,argv);
<BR> if(test.start_test()<0)
<BR> ACE_DEBUG((LM_ERROR,"Program failure \n"));
<BR>
<BR>}
<BR>
</BODY>
</HTML>
|
