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
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file test_config.h
*
* $Id: test_config.h 93651 2011-03-28 08:49:11Z johnnyw $
*
* @author Prashant Jain <pjain@cs.wustl.edu>
* @author Tim Harrison <harrison@cs.wustl.edu>
* @author and David Levine <levine@cs.wustl.edu>
*/
//=============================================================================
#ifndef ACE_TEST_CONFIG_H
#define ACE_TEST_CONFIG_H
#include "ace/ACE.h"
#include "ace/Log_Msg.h"
#include "ace/OS_main.h"
#include "ace/OS_NS_stdio.h"
#include "ace/OS_NS_time.h"
#include "ace/OS_NS_sys_stat.h"
#include "ace/OS_NS_stdlib.h"
// FUZZ: disable check_for_streams_include
#include "ace/streams.h"
#if defined (ACE_WIN32)
#define ACE_DEFAULT_TEST_FILE ACE_TEXT ("C:\\temp\\ace_test_file")
#define ACE_TEMP_FILE_NAME ACE_TEXT ("C:\\temp\\ace_temp_file")
#define ACE_LOG_DIRECTORY ACE_TEXT ("C:\\temp\\log\\")
#define MAKE_PIPE_NAME(X) ACE_TEXT ("\\\\.\\pipe\\"#X)
#else
#define ACE_DEFAULT_TEST_FILE ACE_TEXT ("/tmp/ace_test_file")
#define ACE_TEMP_FILE_NAME ACE_TEXT ("/tmp/ace_temp_file")
#define ACE_LOG_DIRECTORY ACE_TEXT ("log/")
#define MAKE_PIPE_NAME(X) ACE_TEXT (X)
#endif /* ACE_WIN32 */
#ifndef ACE_START_TEST
#define ACE_START_TEST(NAME) \
const ACE_TCHAR *program = NAME; \
ACE_LOG_MSG->open (program, ACE_Log_Msg::OSTREAM); \
if (ace_file_stream.set_output (program) != 0) \
ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("set_output failed")), -1); \
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) starting %s test at %D\n"), program));
#endif /* ACE_START_TEST */
#ifndef ACE_END_TEST
#define ACE_END_TEST \
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Ending %s test at %D\n"), program)); \
ace_file_stream.close ();
#endif /* ACE_END_TEST */
#define ACE_NEW_THREAD \
do {\
ACE_LOG_MSG->msg_ostream (ace_file_stream.output_file ()); \
ACE_LOG_MSG->clr_flags (ACE_Log_Msg::STDERR | ACE_Log_Msg::LOGGER ); \
ACE_LOG_MSG->set_flags (ACE_Log_Msg::OSTREAM); \
} while (0)
#define ACE_APPEND_LOG(NAME) \
const ACE_TCHAR *program = NAME; \
ACE_LOG_MSG->open (program, ACE_Log_Msg::OSTREAM); \
if (ace_file_stream.set_output (program, 1) != 0) \
ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("set_output failed")), -1); \
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Starting %s test at %D\n"), program));
#define ACE_END_LOG \
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Ending %s test at %D\n\n"), program)); \
ace_file_stream.close ();
#define ACE_INIT_LOG(NAME) \
char temp[BUFSIZ]; \
ACE_OS::sprintf (temp, "%s%s%s", \
ACE_TEXT_ALWAYS_CHAR (ACE_LOG_DIRECTORY), \
ACE_TEXT_ALWAYS_CHAR (ACE::basename (NAME, ACE_DIRECTORY_SEPARATOR_CHAR)), \
".log"); \
ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Deleting old log file %C (if any)\n\n"), temp)); \
ACE_OS::unlink (temp);
const int ACE_NS_MAX_ENTRIES = 1000;
const int ACE_MAX_TIMERS = 4;
const int ACE_MAX_THREADS = 4;
const int ACE_MAX_DELAY = 10;
const int ACE_MAX_INTERVAL = 0;
const int ACE_MAX_ITERATIONS = 10;
const int ACE_MAX_PROCESSES = 10;
char ACE_ALPHABET[] = "abcdefghijklmnopqrstuvwxyz";
class ACE_Test_Output
{
public:
ACE_Test_Output (void);
~ACE_Test_Output (void);
int set_output (const ACE_TCHAR *filename, int append = 0);
ofstream *output_file (void);
void close (void);
private:
ofstream output_file_;
};
static ACE_Test_Output ace_file_stream;
ACE_Test_Output::ACE_Test_Output (void)
{
}
ACE_Test_Output::~ACE_Test_Output (void)
{
}
int
ACE_Test_Output::set_output (const ACE_TCHAR *filename, int append)
{
char temp[BUFSIZ];
// Ignore the error value since the directory may already exist.
ACE_OS::mkdir (ACE_LOG_DIRECTORY);
ACE_OS::sprintf (temp, "%s%s%s",
ACE_TEXT_ALWAYS_CHAR (ACE_LOG_DIRECTORY),
ACE_TEXT_ALWAYS_CHAR (ACE::basename (filename, ACE_DIRECTORY_SEPARATOR_CHAR)),
".log");
this->output_file_.open (temp, ios::out | (append ? ios::app : ios::trunc));
if (this->output_file_.bad ())
return -1;
ACE_LOG_MSG->msg_ostream (ace_file_stream.output_file ());
ACE_LOG_MSG->clr_flags (ACE_Log_Msg::STDERR | ACE_Log_Msg::LOGGER );
ACE_LOG_MSG->set_flags (ACE_Log_Msg::OSTREAM);
return 0;
}
ofstream *
ACE_Test_Output::output_file (void)
{
return &this->output_file_;
}
void
ACE_Test_Output::close (void)
{
this->output_file_.flush ();
this->output_file_.close ();
}
void
randomize (int array[], size_t size)
{
size_t i;
for (i = 0; i < size; i++)
array [i] = static_cast<int> (i);
ACE_OS::srand ((u_int) ACE_OS::time (0L));
// Generate an array of random numbers from 0 .. size - 1.
for (i = 0; i < size; i++)
{
int index = ACE_OS::rand() % static_cast<int> (size);
--size;
int temp = array [index];
array [index] = array [size];
array [size] = temp;
}
}
#endif /* ACE_TEST_CONFIG_H */
|
