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
|
// $Id: client.cpp 91671 2010-09-08 18:39:23Z johnnyw $
// This program reads in messages from stdin and sends them to a
// Log_Wrapper.
#include "ace/OS_main.h"
#include "ace/OS_NS_stdlib.h"
#include "ace/OS_NS_string.h"
#include "ace/OS_NS_unistd.h"
#include "ace/OS_Memory.h"
#include "ace/Get_Opt.h"
#include "ace/Log_Msg.h"
#include "Log_Wrapper.h"
// Multi-cast address.
static const char *MCAST_ADDR = ACE_DEFAULT_MULTICAST_ADDR;
// UDP port.
static const int UDP_PORT = ACE_DEFAULT_MULTICAST_PORT;
// Maximum message size.
static int max_message_size = BUFSIZ;
// Number of times to send message of max_message_size.
static int iterations = 0;
static void
parse_args (int argc, ACE_TCHAR *argv[])
{
ACE_LOG_MSG->open (argv[0]);
//FUZZ: disable check_for_lack_ACE_OS
// Start at argv[1]
ACE_Get_Opt getopt (argc, argv, ACE_TEXT("m:ui:"), 1);
for (int c; (c = getopt ()) != -1; )
//FUZZ: enable check_for_lack_ACE_OS
switch (c)
{
case 'm':
max_message_size = ACE_OS::atoi (getopt.opt_arg ()) * BUFSIZ;
break;
case 'i':
iterations = ACE_OS::atoi (getopt.opt_arg ());
break;
case 'u':
// usage fallthrough
default:
ACE_ERROR ((LM_ERROR,
"%n: -m max_message_size (in k) -i iterations\n%a",
1));
/* NOTREACHED */
}
}
int
ACE_TMAIN (int argc, ACE_TCHAR *argv[])
{
int user_prompt;
parse_args (argc,argv);
ACE_DEBUG ((LM_DEBUG, "max buffer size = %d\n", max_message_size));
// Instantiate a log wrapper for logging
Log_Wrapper log;
// Make a connection to a logger.
if (log.open (UDP_PORT, MCAST_ADDR) == -1)
ACE_ERROR_RETURN ((LM_ERROR, "%p\n" "open"), -1);
char *buf;
ACE_NEW_RETURN (buf, char[max_message_size], -1);
// If -i has been specified, send max_message_size messages
// iterations number of times.
if (iterations)
{
ACE_OS::memset (buf, 1, max_message_size);
while (iterations--)
if (log.log_message (Log_Wrapper::LM_DEBUG, buf) == -1)
ACE_ERROR_RETURN ((LM_ERROR, "%p\n" "log"), -1);
}
// otherwise, a file has been redirected, or give prompts
else
{
// If a file has been redirected, don't activate user prompts.
if (ACE_OS::isatty (0))
user_prompt = 1;
else
user_prompt = 0;
// Continually read messages from stdin and log them.
for (int count = 1;;)
{
if (user_prompt)
ACE_DEBUG ((LM_DEBUG, "\nEnter message ('Q':quit):\n"));
ssize_t nbytes = ACE_OS::read (ACE_STDIN, buf, max_message_size);
if (nbytes <= 0)
break; // End of file or error.
buf[nbytes - 1] = '\0';
// Quitting?
if (user_prompt)
{
if (buf[0] == 'Q' || buf[0] == 'q')
break;
}
else // Keep from overrunning the receiver.
ACE_OS::sleep (1);
// Send the message to the logger.
if (log.log_message (Log_Wrapper::LM_DEBUG, buf) == -1)
ACE_ERROR_RETURN ((LM_ERROR, "%p\n" "log_message"), -1);
ACE_DEBUG ((LM_DEBUG, "finished sending message %d\n", count++));
}
}
ACE_DEBUG ((LM_DEBUG, "Client done.\n"));
return 0;
}
|
