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
|
// $Id$
#include "ace/WFMO_Reactor.h"
#include "Logging_Acceptor.h"
#include "Logging_Handler.h"
#include "Reactor_Singleton.h"
ACE_RCSID(simple_server, Logging_Acceptor, "$Id$")
// Initialize peer_acceptor object.
int
Logging_Acceptor::open (const ACE_INET_Addr &addr)
{
// Reuse addr if already in use.
if (this->peer_acceptor_.open (addr, 1) == -1)
return -1;
else
return 0;
}
// Default constructor.
Logging_Acceptor::Logging_Acceptor (void)
{
}
// Performs termination activities.
int
Logging_Acceptor::handle_close (ACE_HANDLE, ACE_Reactor_Mask)
{
return this->peer_acceptor_.close ();
}
Logging_Acceptor::~Logging_Acceptor (void)
{
this->handle_close (ACE_INVALID_HANDLE,
ACE_Event_Handler::ACCEPT_MASK);
}
// Returns underlying device descriptor.
ACE_HANDLE
Logging_Acceptor::get_handle (void) const
{
return this->peer_acceptor_.get_handle ();
}
// Accepts connections from client and registers new object with the
// ACE_Reactor.
int
Logging_Acceptor::handle_input (ACE_HANDLE)
{
Logging_Handler *svc_handler;
ACE_NEW_RETURN (svc_handler, Logging_Handler, -1);
// Accept the connection from a client client daemon.
// Try to find out if the implementation of the reactor that we are
// using requires us to reset the event association for the newly
// created handle. This is because the newly created handle will
// inherit the properties of the listen handle, including its event
// associations.
int reset_new_handle = this->reactor ()->uses_event_associations ();
if (this->peer_acceptor_.accept (svc_handler->peer (), // stream
0, // remote address
0, // timeout
1, // restart
reset_new_handle // reset new handler
) == -1
|| svc_handler->open () == -1)
{
svc_handler->close ();
ACE_ERROR_RETURN ((LM_ERROR, "%p", "accept/open failed"), -1);
}
return 0;
}
|
