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
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
|
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 3.2//EN">
<HTML>
<HEAD>
<TITLE>ACE Tutorial 004</TITLE>
<META NAME="GENERATOR" CONTENT="Mozilla/3.01Gold (Win95; I) [Netscape]">
<META NAME="Author" CONTENT="James CE Johnson">
<META NAME="Description" CONTENT="A first step towards using ACE productively">
</HEAD>
<BODY text = "#000000" link="#000fff" vlink="#ff0f0f" bgcolor="#ffffff">
<CENTER><P><B><FONT SIZE=+2>ACE Tutorial 004<BR>
A much more clever Client</FONT></B></P></CENTER>
<P>
<HR WIDTH="100%"></P>
<P>
<HR WIDTH="100%"></P>
<P>The code:</P>
<UL>
<PRE>
1. #include "ace/SOCK_Connector.h"
2. #include "ace/SString.h"
3. class Client : public ACE_SOCK_Stream
{
public:
4. Client(void);
5. Client( const char * server, u_short port );
6. int open( const char * server, u_short port );
7. inline int initialized(void) { return mInitialized; }
8. inline int error(void) { return mError; }
9. Client operator<<( ACE_SString & str );
10. Client operator<<( char * str );
11. Client operator<<( int n );
protected:
private:
12. unsigned char mInitialized;
13. unsigned char mError;
};
14. Client::Client(void)
{
15. mInitialized = 0;
16. mError = 0;
}
17. Client::Client( const char * server, u_short port )
{
18. mInitialized = 0;
19. mError = 0;
20. (void)open(server,port);
}
21. int Client::open( const char * server, u_short port )
{
22. ACE_SOCK_Connector connector;
23. ACE_INET_Addr addr (port, server);
24. if (connector.connect (*this, addr) == -1)
{
25. ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1);
}
26. mInitialized = 1;
27. return(0);
}
28. Client Client::operator<<( ACE_SString & str )
{
29. if( initialized() && ! error() )
{
30. char * cp = str.rep();
31. mError = 0;
32. if( this->send_n(cp,strlen(cp)) == -1 )
{
33. mError = 1;
}
}
34. else
{
35. mError = 1;
}
36. return *this ;
}
37. Client Client::operator<< ( char * str )
{
38. ACE_SString newStr(str);
39. *this << newStr;
40. return *this ;
}
41. Client Client::operator<< ( int n )
{
// ACE_SString newStr;
// newStr = n;
42. char buf[1024];
43. sprintf(buf,"(%d)\n",n);
44. ACE_SString newStr(buf);
45. *this << newStr;
46. return *this;
}
47. int main (int argc, char *argv[])
{
48. const char *server_host = argc > 1 ? argv[1] : ACE_DEFAULT_SERVER_HOST;
49. u_short server_port = argc > 2 ? ACE_OS::atoi (argv[2]) : ACE_DEFAULT_SERVER_PORT;
50. int max_iterations = argc > 3 ? ACE_OS::atoi (argv[3]) : 4;
51. Client server(server_host,server_port);
52. if( ! server.initialized() )
{
53. ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "intialization"), -1);
}
54. for (int i = 0; i < max_iterations; i++)
{
55. server << "message = " << i+1;
56. if ( server.error() )
{
57. ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "send"), -1);
}
58. else
{
59. ACE_OS::sleep (1);
}
}
60. if (server.close () == -1)
{
61. ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "close"), -1);
}
62. return 0;
}
</PRE>
</UL>
<P>
<HR WIDTH="100%"></P>
<P>Now, the code description:</P>
<OL></OL>
<P>
<HR WIDTH="100%"></P>
<P>If you want to compile it yourself, here's the <A HREF="client.cpp">source</A>,
the <A HREF="Makefile">Makefile</A>,
and <A HREF="00SetEnv">Environment
settings</A>. </P>
<P>
<HR WIDTH="100%"></P>
<CENTER><P>[<A HREF="..">Tutorial
Index</A>]</P></CENTER>
</BODY>
</HTML>
|
