blob: 8b114e73d6cb7068d1cef99374c73b44104df83a (
plain)
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
|
// $Id$
#if !defined (_CLIENT_ACCEPTOR_H)
#define _CLIENT_ACCEPTOR_H
#include "ace/SOCK_Acceptor.h"
#include "ace/Event_Handler.h"
#include "logger.h"
class Logging_Acceptor : public ACE_Event_Handler
{
friend class Logging_Handler;
public:
Logging_Acceptor ( const ACE_INET_Addr &addr) : peer_acceptor_(addr)
{
}
~Logging_Acceptor (void)
{
this->handle_close (ACE_INVALID_HANDLE, ACE_Event_Handler::READ_MASK);
}
virtual int open (const ACE_INET_Addr &addr)
{
if (this->peer_acceptor_.open (addr, 1) == -1)
return -1;
else
return 0;
}
private:
virtual ACE_HANDLE get_handle (void) const
{
return this->peer_acceptor_.get_handle ();
}
virtual int handle_input (ACE_HANDLE)
{
Logging_Handler *svc_handler = new Logging_Handler;
if (this->peer_acceptor_.accept (*svc_handler) == -1)
ACE_ERROR_RETURN ((LM_ERROR, "%p", "accept failed"), -1);
else if (svc_handler->open () == -1)
svc_handler->close ();
return 0;
}
virtual int handle_close (ACE_HANDLE, ACE_Reactor_Mask)
{
return this->peer_acceptor_.close ();
}
ACE_SOCK_Acceptor peer_acceptor_;
};
#endif /* _CLIENT_ACCEPTOR_H */
|
