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
|
/**
* $Id$
*
* A simple client program using ACE_Svc_Handler and ACE_Connector.
*/
#include "ace/OS_NS_stdio.h"
#include "ace/OS_NS_errno.h"
#include "ace/OS_NS_string.h"
#include "ace/OS_NS_sys_time.h"
#include "Client.h"
// Listing 2 code/ch07
int Client::open (void *p)
{
ACE_Time_Value iter_delay (2); // Two seconds
if (super::open (p) == -1)
return -1;
this->notifier_.reactor (this->reactor ());
this->msg_queue ()->notification_strategy (&this->notifier_);
this->iterations_ = 0;
return this->reactor ()->schedule_timer
(this, 0, ACE_Time_Value::zero, iter_delay);
}
// Listing 2
// Listing 3 code/ch07
int Client::handle_input (ACE_HANDLE)
{
char buf[64];
ssize_t recv_cnt = this->peer ().recv (buf, sizeof (buf) - 1);
if (recv_cnt > 0)
{
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("%.*C"),
static_cast<int> (recv_cnt),
buf));
return 0;
}
if (recv_cnt == 0 || ACE_OS::last_error () != EWOULDBLOCK)
{
this->reactor ()->end_reactor_event_loop ();
return -1;
}
return 0;
}
// Listing 3
// Listing 4 code/ch07
int Client::handle_timeout(const ACE_Time_Value &, const void *)
{
if (++this->iterations_ >= ITERATIONS)
{
this->peer ().close_writer ();
return 0;
}
ACE_Message_Block *mb;
ACE_NEW_RETURN (mb, ACE_Message_Block (128), -1);
int nbytes = ACE_OS::sprintf
(mb->wr_ptr (), "Iteration %d\n", this->iterations_);
ACE_ASSERT (nbytes > 0);
mb->wr_ptr (static_cast<size_t> (nbytes));
this->putq (mb);
return 0;
}
// Listing 4
// Listing 5 code/ch07
int Client::handle_output (ACE_HANDLE)
{
ACE_Message_Block *mb;
ACE_Time_Value nowait (ACE_OS::gettimeofday ());
while (-1 != this->getq (mb, &nowait))
{
ssize_t send_cnt =
this->peer ().send (mb->rd_ptr (), mb->length ());
if (send_cnt == -1)
ACE_ERROR ((LM_ERROR,
ACE_TEXT ("(%P|%t) %p\n"),
ACE_TEXT ("send")));
else
mb->rd_ptr (static_cast<size_t> (send_cnt));
if (mb->length () > 0)
{
this->ungetq (mb);
break;
}
mb->release ();
}
if (this->msg_queue ()->is_empty ())
this->reactor ()->cancel_wakeup
(this, ACE_Event_Handler::WRITE_MASK);
else
this->reactor ()->schedule_wakeup
(this, ACE_Event_Handler::WRITE_MASK);
return 0;
}
// Listing 5
// Listing 6 code/ch07
int ACE_TMAIN (int, ACE_TCHAR *[])
{
ACE_INET_Addr port_to_connect (ACE_TEXT ("HAStatus"), ACE_LOCALHOST);
ACE_Connector<Client, ACE_SOCK_CONNECTOR> connector;
Client client;
Client *pc = &client;
if (connector.connect (pc, port_to_connect) == -1)
ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"),
ACE_TEXT ("connect")), 1);
ACE_Reactor::instance ()->run_reactor_event_loop ();
return (0);
}
// Listing 6
// Listing 7 code/ch07
#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
template class ACE_Connector<Client, ACE_SOCK_CONNECTOR>;
template class ACE_Connector_Base<Client>;
template class ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH>;
template class ACE_NonBlocking_Connect_Handler<Client>;
#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
# pragma instantiate ACE_Connector<Client, ACE_SOCK_CONNECTOR>
# pragma instantiate ACE_Connector_Base<Client>
# pragma instantiate ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH>
# pragma instantiate ACE_NonBlocking_Connect_Handler<Client>
#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
// Listing 7
|
