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
|
/*
** $Id: Logging_Server.cpp 80826 2008-03-04 14:51:23Z wotte $
**
** Copyright 2001 Addison Wesley. All Rights Reserved.
*/
#include "ace/FILE_Addr.h"
#include "ace/FILE_Connector.h"
#include "ace/FILE_IO.h"
#include "ace/INET_Addr.h"
#include "ace/SOCK_Stream.h"
#include "Logging_Server.h"
#include "ace/OS_NS_string.h"
#include "ace/OS_NS_stdlib.h"
#include "ace/os_include/os_netdb.h"
int Logging_Server::run (int argc, char *argv[])
{
if (this->open (argc > 1 ? ACE_OS::atoi (argv[1]) : 0) == -1)
return -1;
for (;;) {
if (wait_for_multiple_events () == -1)
return -1;
if (handle_connections () == -1)
return -1;
if (handle_data () == -1)
return -1;
}
ACE_NOTREACHED (return 0;)
}
int Logging_Server::open (u_short logger_port)
{
ACE_INET_Addr server_addr;
int result;
if (logger_port != 0)
result = server_addr.set (logger_port,
(ACE_UINT32) INADDR_ANY);
else
result = server_addr.set ("ace_logger",
(ACE_UINT32) INADDR_ANY);
if (result == -1) return -1;
// Start listening, enable reuse of listen address for quick restarts.
return acceptor_.open (server_addr, 1);
}
int Logging_Server::make_log_file (ACE_FILE_IO &logging_file,
ACE_SOCK_Stream *logging_peer)
{
char filename[MAXHOSTNAMELEN + sizeof (".log")];
if (logging_peer != 0) { // Use client's hostname as log file name.
ACE_INET_Addr logging_peer_addr;
logging_peer->get_remote_addr (logging_peer_addr);
logging_peer_addr.get_host_name (filename, MAXHOSTNAMELEN);
ACE_OS::strcat (filename, ".log");
}
else
ACE_OS::strcpy (filename, "logging_server.log");
ACE_FILE_Connector connector;
return connector.connect (logging_file,
ACE_FILE_Addr (filename),
0, // No timeout.
ACE_Addr::sap_any, // Ignored.
0, // Don't try to reuse the addr.
O_RDWR|O_CREAT|O_APPEND,
ACE_DEFAULT_FILE_PERMS);
}
|
