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
|
<HTML>
<!-- $Id$ -->
<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 2</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 Reactor" (Event
Management)</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 2</FONT>
<BR><FONT COLOR="#000099">#include</FONT><FONT COLOR="#006600"> "ace/Reactor.h"</FONT>
<BR><FONT COLOR="#000099">#include</FONT> <FONT COLOR="#006600">"ace/SOCK_Acceptor.h"</FONT>
<BR><FONT COLOR="#000099">#define</FONT> <FONT COLOR="#663366">PORT_NO
19998</FONT>
<BR>typedef ACE_SOCK_Acceptor Acceptor;
<BR><FONT COLOR="#FF0000">//forward declaration</FONT>
<BR>class My_Accept_Handler;
<P>class
<BR>My_Input_Handler: public ACE_Event_Handler{
<BR>public:
<BR><FONT COLOR="#FF0000"> //Constructor</FONT>
<BR> My_Input_Handler(){
<BR> ACE_DEBUG((LM_DEBUG,?Constructor\n?);
<BR> }
<BR>
<BR><FONT COLOR="#FF0000"> //Called back to handle any input receieved</FONT>
<BR> int
<BR> handle_input(ACE_HANDLE){
<BR><FONT COLOR="#FF0000"> //receive the data</FONT>
<BR> peer_i().recv_n(data,12);
<BR> ACE_DEBUG((LM_DEBUG,?%s\n?,data));
<BR>
<BR> <FONT COLOR="#FF0000"> // do something with the input received.</FONT>
<BR><FONT COLOR="#FF0000"> // ...</FONT>
<P><FONT COLOR="#FF0000"> //keep yourself registered with the reactor</FONT>
<BR> return 0;
<BR> }
<BR>
<BR><FONT COLOR="#FF0000"> //Used by the reactor to determine the
underlying handle</FONT>
<BR> ACE_HANDLE
<BR> get_handle()const {
<BR> return this->peer_i().get_handle();
<BR> }
<BR>
<BR><FONT COLOR="#FF0000"> //Returns a reference to the underlying
stream.</FONT>
<BR> ACE_SOCK_Stream &
<BR> peer_i(){
<BR> return this->peer_;
<BR> }
<P>private:
<BR> ACE_SOCK_Stream peer_;
<BR> char data [12];
<BR>};
<BR>
<P>class
<BR>My_Accept_Handler: public ACE_Event_Handler{
<BR>public:
<BR><FONT COLOR="#FF0000">//Constructor</FONT>
<BR> My_Accept_Handler(ACE_Addr &addr){
<BR> this->open(addr);
<BR> }
<P><FONT COLOR="#FF0000">//Open the peer_acceptor so it starts to ?listen?</FONT>
<BR><FONT COLOR="#FF0000">//for incoming clients.</FONT>
<BR> int
<BR> open(ACE_Addr &addr){
<BR> peer_acceptor.open(addr);
<BR> return 0;
<BR> }
<P><FONT COLOR="#FF0000">//Overload the handle input method</FONT>
<BR> int
<BR> handle_input(ACE_HANDLE handle){
<BR> <FONT COLOR="#FF0000"> //Client has requested connection to server.</FONT>
<BR><FONT COLOR="#FF0000"> //Create a handler to handle the connection</FONT>
<BR> My_Input_Handler *eh= new My_Input_Handler();
<P> <FONT COLOR="#FF0000">//Accept the connection ?into? the Event
Handler</FONT>
<BR> if (this->peer_acceptor.accept (eh->peer (), <FONT COLOR="#FF0000">//
stream</FONT>
<BR> 0, <FONT COLOR="#FF0000">// remote address</FONT>
<BR> 0, <FONT COLOR="#FF0000">// timeout</FONT>
<BR> 1) ==-1) <FONT COLOR="#FF0000">//restart
if interrupted</FONT>
<BR> ACE_DEBUG((LM_ERROR,"Error in connection\n"));
<P> ACE_DEBUG((LM_DEBUG,"Connection established\n"));
<P><FONT COLOR="#FF0000"> //Register the input event handler for
reading</FONT>
<BR> ACE_Reactor::instance()->
<BR> register_handler(eh,ACE_Event_Handler::READ_MASK);
<P><FONT COLOR="#FF0000"> //Unregister as the acceptor is not expecting
new clients</FONT>
<BR> return -1;
<BR> }
<P><FONT COLOR="#FF6666"> //Used by the reactor to determine the underlying
handle</FONT>
<BR> ACE_HANDLE
<BR> get_handle(void) const{
<BR> return this->peer_acceptor.get_handle();
<BR> }
<BR>private:
<BR> Acceptor peer_acceptor;
<BR>};
<P>int main(int argc, char * argv[]){
<BR><FONT COLOR="#FF0000"> //Create an address on which to receive
connections</FONT>
<BR> ACE_INET_Addr addr(PORT_NO);
<P><FONT COLOR="#FF0000">//Create the Accept Handler which automatically
begins to "listen"</FONT>
<BR><FONT COLOR="#FF0000">//for client requests for connections</FONT>
<BR> My_Accept_Handler *eh=new My_Accept_Handler(addr);
<P><FONT COLOR="#FF0000">//Register the reactor to call back when incoming
client connects</FONT>
<BR>ACE_Reactor::instance()->register_handler(eh,
<BR> ACE_Event_Handler::ACCEPT_MASK);
<P><FONT COLOR="#FF0000">//Start the event loop</FONT>
<BR>while(1)
<BR> ACE_Reactor::instance()->handle_events();
<BR>}
<P> <A HREF="ex03.html">Next Example</A>
</BODY>
</HTML>
|
