"src/models/jiuge_awq/jiuge_awq.hpp" did not exist on "5540d53a04e77eee51e868dbe3cf9637cbfd9f04"
gtest-internal-inl.h 44.6 KB
Newer Older
shiqian's avatar
shiqian committed
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
// Copyright 2005, Google Inc.
// All rights reserved.
//
// Redistribution and use in source and binary forms, with or without
// modification, are permitted provided that the following conditions are
// met:
//
//     * Redistributions of source code must retain the above copyright
// notice, this list of conditions and the following disclaimer.
//     * Redistributions in binary form must reproduce the above
// copyright notice, this list of conditions and the following disclaimer
// in the documentation and/or other materials provided with the
// distribution.
//     * Neither the name of Google Inc. nor the names of its
// contributors may be used to endorse or promote products derived from
// this software without specific prior written permission.
//
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

Gennadiy Civil's avatar
 
Gennadiy Civil committed
30
// Utility functions and classes used by the Google C++ testing framework.//
shiqian's avatar
shiqian committed
31
32
33
34
35
36
// This file contains purely Google Test's internal implementation.  Please
// DO NOT #INCLUDE IT IN A USER PROGRAM.

#ifndef GTEST_SRC_GTEST_INTERNAL_INL_H_
#define GTEST_SRC_GTEST_INTERNAL_INL_H_

37
#ifndef _WIN32_WCE
38
# include <errno.h>
39
#endif  // !_WIN32_WCE
shiqian's avatar
shiqian committed
40
#include <stddef.h>
41
42
#include <stdlib.h>  // For strtoll/_strtoul64/malloc/free.
#include <string.h>  // For memmove.
shiqian's avatar
shiqian committed
43

44
#include <algorithm>
45
#include <string>
46
#include <vector>
47

48
#include "gtest/internal/gtest-port.h"
49

kosak's avatar
kosak committed
50
51
52
53
54
#if GTEST_CAN_STREAM_RESULTS_
# include <arpa/inet.h>  // NOLINT
# include <netdb.h>  // NOLINT
#endif

zhanyong.wan's avatar
zhanyong.wan committed
55
#if GTEST_OS_WINDOWS
56
# include <windows.h>  // NOLINT
shiqian's avatar
shiqian committed
57
58
#endif  // GTEST_OS_WINDOWS

Gennadiy Civil's avatar
Gennadiy Civil committed
59
#include "gtest/gtest.h"
60
#include "gtest/gtest-spi.h"
shiqian's avatar
shiqian committed
61

misterg's avatar
misterg committed
62
63
64
GTEST_DISABLE_MSC_WARNINGS_PUSH_(4251 \
/* class A needs to have dll-interface to be used by clients of class B */)

shiqian's avatar
shiqian committed
65
66
67
68
namespace testing {

// Declares the flags.
//
69
70
71
// We don't want the users to modify this flag in the code, but want
// Google Test's own unit tests to be able to access it. Therefore we
// declare it here as opposed to in gtest.h.
72
GTEST_DECLARE_bool_(death_test_use_fork);
shiqian's avatar
shiqian committed
73
74
75

namespace internal {

76
77
// The value of GetTestTypeId() as seen from within the Google Test
// library.  This is solely for testing GetTestTypeId().
zhanyong.wan's avatar
zhanyong.wan committed
78
GTEST_API_ extern const TypeId kTestTypeIdInGoogleTest;
79

shiqian's avatar
shiqian committed
80
// Names of the flags (needed for parsing Google Test flags).
81
const char kAlsoRunDisabledTestsFlag[] = "also_run_disabled_tests";
shiqian's avatar
shiqian committed
82
83
const char kBreakOnFailureFlag[] = "break_on_failure";
const char kCatchExceptionsFlag[] = "catch_exceptions";
84
const char kColorFlag[] = "color";
shiqian's avatar
shiqian committed
85
86
87
const char kFilterFlag[] = "filter";
const char kListTestsFlag[] = "list_tests";
const char kOutputFlag[] = "output";
88
const char kPrintTimeFlag[] = "print_time";
Gennadiy Civil's avatar
Gennadiy Civil committed
89
const char kPrintUTF8Flag[] = "print_utf8";
90
const char kRandomSeedFlag[] = "random_seed";
shiqian's avatar
shiqian committed
91
const char kRepeatFlag[] = "repeat";
92
const char kShuffleFlag[] = "shuffle";
93
const char kStackTraceDepthFlag[] = "stack_trace_depth";
94
const char kStreamResultToFlag[] = "stream_result_to";
95
const char kThrowOnFailureFlag[] = "throw_on_failure";
kosak's avatar
kosak committed
96
const char kFlagfileFlag[] = "flagfile";
shiqian's avatar
shiqian committed
97

98
// A valid random seed must be in [1, kMaxRandomSeed].
99
const int kMaxRandomSeed = 99999;
100

zhanyong.wan's avatar
zhanyong.wan committed
101
102
103
104
// g_help_flag is true iff the --help flag or an equivalent form is
// specified on the command line.
GTEST_API_ extern bool g_help_flag;

105
// Returns the current time in milliseconds.
zhanyong.wan's avatar
zhanyong.wan committed
106
107
108
109
110
111
112
113
GTEST_API_ TimeInMillis GetTimeInMillis();

// Returns true iff Google Test should use colors in the output.
GTEST_API_ bool ShouldUseColor(bool stdout_is_tty);

// Formats the given time in milliseconds as seconds.
GTEST_API_ std::string FormatTimeInMillisAsSeconds(TimeInMillis ms);

114
115
116
117
118
119
// Converts the given time in milliseconds to a date string in the ISO 8601
// format, without the timezone information.  N.B.: due to the use the
// non-reentrant localtime() function, this function is not thread safe.  Do
// not use it in any code that can be called from multiple threads.
GTEST_API_ std::string FormatEpochTimeInMillisAsIso8601(TimeInMillis ms);

zhanyong.wan's avatar
zhanyong.wan committed
120
121
122
123
124
125
// Parses a string for an Int32 flag, in the form of "--flag=value".
//
// On success, stores the value of the flag in *value, and returns
// true.  On failure, returns false without changing *value.
GTEST_API_ bool ParseInt32Flag(
    const char* str, const char* flag, Int32* value);
126
127
128
129
130
131
132
133
134
135
136

// Returns a random seed in range [1, kMaxRandomSeed] based on the
// given --gtest_random_seed flag value.
inline int GetRandomSeedFromFlag(Int32 random_seed_flag) {
  const unsigned int raw_seed = (random_seed_flag == 0) ?
      static_cast<unsigned int>(GetTimeInMillis()) :
      static_cast<unsigned int>(random_seed_flag);

  // Normalizes the actual seed to range [1, kMaxRandomSeed] such that
  // it's easy to type.
  const int normalized_seed =
137
138
      static_cast<int>((raw_seed - 1U) %
                       static_cast<unsigned int>(kMaxRandomSeed)) + 1;
139
140
141
142
143
144
145
146
147
148
149
150
151
152
  return normalized_seed;
}

// Returns the first valid random seed after 'seed'.  The behavior is
// undefined if 'seed' is invalid.  The seed after kMaxRandomSeed is
// considered to be 1.
inline int GetNextRandomSeed(int seed) {
  GTEST_CHECK_(1 <= seed && seed <= kMaxRandomSeed)
      << "Invalid random seed " << seed << " - must be in [1, "
      << kMaxRandomSeed << "].";
  const int next_seed = seed + 1;
  return (next_seed > kMaxRandomSeed) ? 1 : next_seed;
}

shiqian's avatar
shiqian committed
153
154
155
156
157
158
// This class saves the values of all Google Test flags in its c'tor, and
// restores them in its d'tor.
class GTestFlagSaver {
 public:
  // The c'tor.
  GTestFlagSaver() {
159
    also_run_disabled_tests_ = GTEST_FLAG(also_run_disabled_tests);
shiqian's avatar
shiqian committed
160
161
162
163
    break_on_failure_ = GTEST_FLAG(break_on_failure);
    catch_exceptions_ = GTEST_FLAG(catch_exceptions);
    color_ = GTEST_FLAG(color);
    death_test_style_ = GTEST_FLAG(death_test_style);
164
    death_test_use_fork_ = GTEST_FLAG(death_test_use_fork);
shiqian's avatar
shiqian committed
165
166
167
168
    filter_ = GTEST_FLAG(filter);
    internal_run_death_test_ = GTEST_FLAG(internal_run_death_test);
    list_tests_ = GTEST_FLAG(list_tests);
    output_ = GTEST_FLAG(output);
169
    print_time_ = GTEST_FLAG(print_time);
Gennadiy Civil's avatar
Gennadiy Civil committed
170
    print_utf8_ = GTEST_FLAG(print_utf8);
171
    random_seed_ = GTEST_FLAG(random_seed);
shiqian's avatar
shiqian committed
172
    repeat_ = GTEST_FLAG(repeat);
173
    shuffle_ = GTEST_FLAG(shuffle);
174
    stack_trace_depth_ = GTEST_FLAG(stack_trace_depth);
175
    stream_result_to_ = GTEST_FLAG(stream_result_to);
176
    throw_on_failure_ = GTEST_FLAG(throw_on_failure);
shiqian's avatar
shiqian committed
177
178
179
180
  }

  // The d'tor is not virtual.  DO NOT INHERIT FROM THIS CLASS.
  ~GTestFlagSaver() {
181
    GTEST_FLAG(also_run_disabled_tests) = also_run_disabled_tests_;
shiqian's avatar
shiqian committed
182
183
184
185
    GTEST_FLAG(break_on_failure) = break_on_failure_;
    GTEST_FLAG(catch_exceptions) = catch_exceptions_;
    GTEST_FLAG(color) = color_;
    GTEST_FLAG(death_test_style) = death_test_style_;
186
    GTEST_FLAG(death_test_use_fork) = death_test_use_fork_;
shiqian's avatar
shiqian committed
187
188
189
190
    GTEST_FLAG(filter) = filter_;
    GTEST_FLAG(internal_run_death_test) = internal_run_death_test_;
    GTEST_FLAG(list_tests) = list_tests_;
    GTEST_FLAG(output) = output_;
191
    GTEST_FLAG(print_time) = print_time_;
Gennadiy Civil's avatar
Gennadiy Civil committed
192
    GTEST_FLAG(print_utf8) = print_utf8_;
193
    GTEST_FLAG(random_seed) = random_seed_;
shiqian's avatar
shiqian committed
194
    GTEST_FLAG(repeat) = repeat_;
195
    GTEST_FLAG(shuffle) = shuffle_;
196
    GTEST_FLAG(stack_trace_depth) = stack_trace_depth_;
197
    GTEST_FLAG(stream_result_to) = stream_result_to_;
198
    GTEST_FLAG(throw_on_failure) = throw_on_failure_;
shiqian's avatar
shiqian committed
199
  }
200

shiqian's avatar
shiqian committed
201
202
 private:
  // Fields for saving the original values of flags.
203
  bool also_run_disabled_tests_;
shiqian's avatar
shiqian committed
204
205
  bool break_on_failure_;
  bool catch_exceptions_;
206
207
  std::string color_;
  std::string death_test_style_;
208
  bool death_test_use_fork_;
209
210
  std::string filter_;
  std::string internal_run_death_test_;
shiqian's avatar
shiqian committed
211
  bool list_tests_;
212
  std::string output_;
213
  bool print_time_;
Gennadiy Civil's avatar
Gennadiy Civil committed
214
  bool print_utf8_;
215
  internal::Int32 random_seed_;
shiqian's avatar
shiqian committed
216
  internal::Int32 repeat_;
217
  bool shuffle_;
218
  internal::Int32 stack_trace_depth_;
219
  std::string stream_result_to_;
220
  bool throw_on_failure_;
shiqian's avatar
shiqian committed
221
} GTEST_ATTRIBUTE_UNUSED_;
shiqian's avatar
shiqian committed
222

223
224
225
226
// Converts a Unicode code point to a narrow string in UTF-8 encoding.
// code_point parameter is of type UInt32 because wchar_t may not be
// wide enough to contain a code point.
// If the code_point is not a valid Unicode code point
227
228
229
// (i.e. outside of Unicode range U+0 to U+10FFFF) it will be converted
// to "(Invalid Unicode 0xXXXXXXXX)".
GTEST_API_ std::string CodePointToUtf8(UInt32 code_point);
230
231
232
233
234
235
236
237
238
239
240
241
242
243

// Converts a wide string to a narrow string in UTF-8 encoding.
// The wide string is assumed to have the following encoding:
//   UTF-16 if sizeof(wchar_t) == 2 (on Windows, Cygwin, Symbian OS)
//   UTF-32 if sizeof(wchar_t) == 4 (on Linux)
// Parameter str points to a null-terminated wide string.
// Parameter num_chars may additionally limit the number
// of wchar_t characters processed. -1 is used when the entire string
// should be processed.
// If the string contains code points that are not valid Unicode code points
// (i.e. outside of Unicode range U+0 to U+10FFFF) they will be output
// as '(Invalid Unicode 0xXXXXXXXX)'. If the string is in UTF16 encoding
// and contains invalid UTF-16 surrogate pairs, values in those pairs
// will be encoded as individual Unicode characters from Basic Normal Plane.
244
GTEST_API_ std::string WideStringToUtf8(const wchar_t* str, int num_chars);
shiqian's avatar
shiqian committed
245

246
247
248
249
250
251
252
253
254
255
256
257
// Reads the GTEST_SHARD_STATUS_FILE environment variable, and creates the file
// if the variable is present. If a file already exists at this location, this
// function will write over it. If the variable is present, but the file cannot
// be created, prints an error and exits.
void WriteToShardStatusFileIfNeeded();

// Checks whether sharding is enabled by examining the relevant
// environment variable values. If the variables are present,
// but inconsistent (e.g., shard_index >= total_shards), prints
// an error and exits. If in_subprocess_for_death_test, sharding is
// disabled because it must only be applied to the original test
// process. Otherwise, we could filter out death tests we intended to execute.
zhanyong.wan's avatar
zhanyong.wan committed
258
259
260
GTEST_API_ bool ShouldShard(const char* total_shards_str,
                            const char* shard_index_str,
                            bool in_subprocess_for_death_test);
261
262
263
264

// Parses the environment variable var as an Int32. If it is unset,
// returns default_val. If it is not an Int32, prints an error and
// and aborts.
zhanyong.wan's avatar
zhanyong.wan committed
265
GTEST_API_ Int32 Int32FromEnvOrDie(const char* env_var, Int32 default_val);
266
267
268
269
270

// Given the total number of shards, the shard index, and the test id,
// returns true iff the test should be run on this shard. The test id is
// some arbitrary but unique non-negative integer assigned to each test
// method. Assumes that 0 <= shard_index < total_shards.
zhanyong.wan's avatar
zhanyong.wan committed
271
272
GTEST_API_ bool ShouldRunTestOnShard(
    int total_shards, int shard_index, int test_id);
273

274
// STL container utilities.
shiqian's avatar
shiqian committed
275

276
277
278
279
// Returns the number of elements in the given container that satisfy
// the given predicate.
template <class Container, typename Predicate>
inline int CountIf(const Container& c, Predicate predicate) {
280
281
282
283
284
285
286
287
  // Implemented as an explicit loop since std::count_if() in libCstd on
  // Solaris has a non-standard signature.
  int count = 0;
  for (typename Container::const_iterator it = c.begin(); it != c.end(); ++it) {
    if (predicate(*it))
      ++count;
  }
  return count;
288
}
289

290
291
292
293
294
// Applies a function/functor to each element in the container.
template <class Container, typename Functor>
void ForEach(const Container& c, Functor functor) {
  std::for_each(c.begin(), c.end(), functor);
}
295

296
297
298
299
300
301
// Returns the i-th element of the vector, or default_value if i is not
// in range [0, v.size()).
template <typename E>
inline E GetElementOr(const std::vector<E>& v, int i, E default_value) {
  return (i < 0 || i >= static_cast<int>(v.size())) ? default_value : v[i];
}
302

303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
// Performs an in-place shuffle of a range of the vector's elements.
// 'begin' and 'end' are element indices as an STL-style range;
// i.e. [begin, end) are shuffled, where 'end' == size() means to
// shuffle to the end of the vector.
template <typename E>
void ShuffleRange(internal::Random* random, int begin, int end,
                  std::vector<E>* v) {
  const int size = static_cast<int>(v->size());
  GTEST_CHECK_(0 <= begin && begin <= size)
      << "Invalid shuffle range start " << begin << ": must be in range [0, "
      << size << "].";
  GTEST_CHECK_(begin <= end && end <= size)
      << "Invalid shuffle range finish " << end << ": must be in range ["
      << begin << ", " << size << "].";

  // Fisher-Yates shuffle, from
  // http://en.wikipedia.org/wiki/Fisher-Yates_shuffle
  for (int range_width = end - begin; range_width >= 2; range_width--) {
    const int last_in_range = begin + range_width - 1;
    const int selected = begin + random->Generate(range_width);
    std::swap((*v)[selected], (*v)[last_in_range]);
324
  }
325
}
326

327
328
329
// Performs an in-place shuffle of the vector's elements.
template <typename E>
inline void Shuffle(internal::Random* random, std::vector<E>* v) {
330
  ShuffleRange(random, 0, static_cast<int>(v->size()), v);
331
}
shiqian's avatar
shiqian committed
332
333
334
335

// A function for deleting an object.  Handy for being used as a
// functor.
template <typename T>
336
static void Delete(T* x) {
shiqian's avatar
shiqian committed
337
338
339
340
341
342
343
344
345
346
347
  delete x;
}

// A predicate that checks the key of a TestProperty against a known key.
//
// TestPropertyKeyIs is copyable.
class TestPropertyKeyIs {
 public:
  // Constructor.
  //
  // TestPropertyKeyIs has NO default constructor.
348
  explicit TestPropertyKeyIs(const std::string& key) : key_(key) {}
shiqian's avatar
shiqian committed
349
350
351

  // Returns true iff the test name of test property matches on key_.
  bool operator()(const TestProperty& test_property) const {
352
    return test_property.key() == key_;
shiqian's avatar
shiqian committed
353
354
355
  }

 private:
356
  std::string key_;
shiqian's avatar
shiqian committed
357
358
359
360
361
362
363
364
365
366
367
368
};

// Class UnitTestOptions.
//
// This class contains functions for processing options the user
// specifies when running the tests.  It has only static members.
//
// In most cases, the user can specify an option using either an
// environment variable or a command line flag.  E.g. you can set the
// test filter using either GTEST_FILTER or --gtest_filter.  If both
// the variable and the flag are present, the latter overrides the
// former.
zhanyong.wan's avatar
zhanyong.wan committed
369
class GTEST_API_ UnitTestOptions {
shiqian's avatar
shiqian committed
370
371
372
373
 public:
  // Functions for processing the gtest_output flag.

  // Returns the output format, or "" for normal printed output.
374
  static std::string GetOutputFormat();
shiqian's avatar
shiqian committed
375

376
377
378
  // Returns the absolute path of the requested output file, or the
  // default (test_detail.xml in the original working directory) if
  // none was explicitly specified.
379
  static std::string GetAbsolutePathToOutputFile();
shiqian's avatar
shiqian committed
380
381
382
383
384
385
386
387
388
389
390
391

  // Functions for processing the gtest_filter flag.

  // Returns true iff the wildcard pattern matches the string.  The
  // first ':' or '\0' character in pattern marks the end of it.
  //
  // This recursive algorithm isn't very efficient, but is clear and
  // works well enough for matching test names, which are short.
  static bool PatternMatchesString(const char *pattern, const char *str);

  // Returns true iff the user-specified filter matches the test case
  // name and the test name.
392
393
  static bool FilterMatchesTest(const std::string &test_case_name,
                                const std::string &test_name);
shiqian's avatar
shiqian committed
394

zhanyong.wan's avatar
zhanyong.wan committed
395
#if GTEST_OS_WINDOWS
shiqian's avatar
shiqian committed
396
397
398
399
400
401
402
  // Function for supporting the gtest_catch_exception flag.

  // Returns EXCEPTION_EXECUTE_HANDLER if Google Test should handle the
  // given SEH exception, or EXCEPTION_CONTINUE_SEARCH otherwise.
  // This function is useful as an __except condition.
  static int GTestShouldProcessSEH(DWORD exception_code);
#endif  // GTEST_OS_WINDOWS
403

shiqian's avatar
shiqian committed
404
405
  // Returns true if "name" matches the ':' separated list of glob-style
  // filters in "filter".
406
  static bool MatchesFilter(const std::string& name, const char* filter);
shiqian's avatar
shiqian committed
407
408
409
410
};

// Returns the current application's name, removing directory path if that
// is present.  Used by UnitTestOptions::GetOutputFile.
zhanyong.wan's avatar
zhanyong.wan committed
411
GTEST_API_ FilePath GetCurrentExecutableName();
shiqian's avatar
shiqian committed
412
413
414
415
416
417
418

// The role interface for getting the OS stack trace as a string.
class OsStackTraceGetterInterface {
 public:
  OsStackTraceGetterInterface() {}
  virtual ~OsStackTraceGetterInterface() {}

419
  // Returns the current OS stack trace as an std::string.  Parameters:
shiqian's avatar
shiqian committed
420
421
422
423
424
  //
  //   max_depth  - the maximum number of stack frames to be included
  //                in the trace.
  //   skip_count - the number of top frames to be skipped; doesn't count
  //                against max_depth.
425
  virtual std::string CurrentStackTrace(int max_depth, int skip_count) = 0;
shiqian's avatar
shiqian committed
426
427
428
429
430
431

  // UponLeavingGTest() should be called immediately before Google Test calls
  // user code. It saves some information about the current stack that
  // CurrentStackTrace() will use to find and hide Google Test stack frames.
  virtual void UponLeavingGTest() = 0;

432
433
434
435
  // This string is inserted in place of stack frames that are part of
  // Google Test's implementation.
  static const char* const kElidedFramesMarker;

shiqian's avatar
shiqian committed
436
 private:
shiqian's avatar
shiqian committed
437
  GTEST_DISALLOW_COPY_AND_ASSIGN_(OsStackTraceGetterInterface);
shiqian's avatar
shiqian committed
438
439
};

440
// A working implementation of the OsStackTraceGetterInterface interface.
shiqian's avatar
shiqian committed
441
442
class OsStackTraceGetter : public OsStackTraceGetterInterface {
 public:
443
  OsStackTraceGetter() {}
444

445
  virtual std::string CurrentStackTrace(int max_depth, int skip_count);
446
  virtual void UponLeavingGTest();
shiqian's avatar
shiqian committed
447
448

 private:
449
450
451
452
453
454
455
456
457
458
#if GTEST_HAS_ABSL
  Mutex mutex_;  // Protects all internal state.

  // We save the stack frame below the frame that calls user code.
  // We do this because the address of the frame immediately below
  // the user code changes between the call to UponLeavingGTest()
  // and any calls to the stack trace code from within the user code.
  void* caller_frame_ = nullptr;
#endif  // GTEST_HAS_ABSL

shiqian's avatar
shiqian committed
459
  GTEST_DISALLOW_COPY_AND_ASSIGN_(OsStackTraceGetter);
shiqian's avatar
shiqian committed
460
461
462
463
464
465
};

// Information about a Google Test trace point.
struct TraceInfo {
  const char* file;
  int line;
466
  std::string message;
shiqian's avatar
shiqian committed
467
468
};

shiqian's avatar
shiqian committed
469
470
471
472
473
474
475
476
477
478
479
480
// This is the default global test part result reporter used in UnitTestImpl.
// This class should only be used by UnitTestImpl.
class DefaultGlobalTestPartResultReporter
  : public TestPartResultReporterInterface {
 public:
  explicit DefaultGlobalTestPartResultReporter(UnitTestImpl* unit_test);
  // Implements the TestPartResultReporterInterface. Reports the test part
  // result in the current test.
  virtual void ReportTestPartResult(const TestPartResult& result);

 private:
  UnitTestImpl* const unit_test_;
481
482

  GTEST_DISALLOW_COPY_AND_ASSIGN_(DefaultGlobalTestPartResultReporter);
shiqian's avatar
shiqian committed
483
484
485
486
487
488
489
490
491
492
493
494
495
496
};

// This is the default per thread test part result reporter used in
// UnitTestImpl. This class should only be used by UnitTestImpl.
class DefaultPerThreadTestPartResultReporter
    : public TestPartResultReporterInterface {
 public:
  explicit DefaultPerThreadTestPartResultReporter(UnitTestImpl* unit_test);
  // Implements the TestPartResultReporterInterface. The implementation just
  // delegates to the current global test part result reporter of *unit_test_.
  virtual void ReportTestPartResult(const TestPartResult& result);

 private:
  UnitTestImpl* const unit_test_;
497
498

  GTEST_DISALLOW_COPY_AND_ASSIGN_(DefaultPerThreadTestPartResultReporter);
shiqian's avatar
shiqian committed
499
500
};

shiqian's avatar
shiqian committed
501
502
503
504
// The private implementation of the UnitTest class.  We don't protect
// the methods under a mutex, as this class is not accessible by a
// user and the UnitTest class that delegates work to this class does
// proper locking.
zhanyong.wan's avatar
zhanyong.wan committed
505
class GTEST_API_ UnitTestImpl {
shiqian's avatar
shiqian committed
506
507
508
509
 public:
  explicit UnitTestImpl(UnitTest* parent);
  virtual ~UnitTestImpl();

shiqian's avatar
shiqian committed
510
511
512
513
514
515
516
517
518
  // There are two different ways to register your own TestPartResultReporter.
  // You can register your own repoter to listen either only for test results
  // from the current thread or for results from all threads.
  // By default, each per-thread test result repoter just passes a new
  // TestPartResult to the global test result reporter, which registers the
  // test part result for the currently running test.

  // Returns the global test part result reporter.
  TestPartResultReporterInterface* GetGlobalTestPartResultReporter();
shiqian's avatar
shiqian committed
519

shiqian's avatar
shiqian committed
520
521
522
  // Sets the global test part result reporter.
  void SetGlobalTestPartResultReporter(
      TestPartResultReporterInterface* reporter);
shiqian's avatar
shiqian committed
523

shiqian's avatar
shiqian committed
524
525
526
527
528
529
  // Returns the test part result reporter for the current thread.
  TestPartResultReporterInterface* GetTestPartResultReporterForCurrentThread();

  // Sets the test part result reporter for the current thread.
  void SetTestPartResultReporterForCurrentThread(
      TestPartResultReporterInterface* reporter);
shiqian's avatar
shiqian committed
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549

  // Gets the number of successful test cases.
  int successful_test_case_count() const;

  // Gets the number of failed test cases.
  int failed_test_case_count() const;

  // Gets the number of all test cases.
  int total_test_case_count() const;

  // Gets the number of all test cases that contain at least one test
  // that should run.
  int test_case_to_run_count() const;

  // Gets the number of successful tests.
  int successful_test_count() const;

  // Gets the number of failed tests.
  int failed_test_count() const;

550
551
552
  // Gets the number of disabled tests that will be reported in the XML report.
  int reportable_disabled_test_count() const;

shiqian's avatar
shiqian committed
553
554
555
  // Gets the number of disabled tests.
  int disabled_test_count() const;

556
557
558
  // Gets the number of tests to be printed in the XML report.
  int reportable_test_count() const;

shiqian's avatar
shiqian committed
559
560
561
562
563
564
  // Gets the number of all tests.
  int total_test_count() const;

  // Gets the number of tests that should run.
  int test_to_run_count() const;

565
566
567
568
  // Gets the time of the test program start, in ms from the start of the
  // UNIX epoch.
  TimeInMillis start_timestamp() const { return start_timestamp_; }

shiqian's avatar
shiqian committed
569
570
571
572
573
574
575
576
577
578
579
580
  // Gets the elapsed time, in milliseconds.
  TimeInMillis elapsed_time() const { return elapsed_time_; }

  // Returns true iff the unit test passed (i.e. all test cases passed).
  bool Passed() const { return !Failed(); }

  // Returns true iff the unit test failed (i.e. some test case failed
  // or something outside of all tests failed).
  bool Failed() const {
    return failed_test_case_count() > 0 || ad_hoc_test_result()->Failed();
  }

581
582
583
  // Gets the i-th test case among all the test cases. i can range from 0 to
  // total_test_case_count() - 1. If i is not in that range, returns NULL.
  const TestCase* GetTestCase(int i) const {
584
585
    const int index = GetElementOr(test_case_indices_, i, -1);
    return index < 0 ? NULL : test_cases_[i];
586
587
588
589
590
  }

  // Gets the i-th test case among all the test cases. i can range from 0 to
  // total_test_case_count() - 1. If i is not in that range, returns NULL.
  TestCase* GetMutableTestCase(int i) {
591
592
    const int index = GetElementOr(test_case_indices_, i, -1);
    return index < 0 ? NULL : test_cases_[index];
593
594
  }

595
  // Provides access to the event listener list.
596
  TestEventListeners* listeners() { return &listeners_; }
597

shiqian's avatar
shiqian committed
598
599
  // Returns the TestResult for the test that's currently running, or
  // the TestResult for the ad hoc test if no test is running.
600
  TestResult* current_test_result();
shiqian's avatar
shiqian committed
601
602

  // Returns the TestResult for the ad hoc test.
603
  const TestResult* ad_hoc_test_result() const { return &ad_hoc_test_result_; }
shiqian's avatar
shiqian committed
604
605
606
607
608
609
610
611
612
613
614
615
616

  // Sets the OS stack trace getter.
  //
  // Does nothing if the input and the current OS stack trace getter
  // are the same; otherwise, deletes the old getter and makes the
  // input the current getter.
  void set_os_stack_trace_getter(OsStackTraceGetterInterface* getter);

  // Returns the current OS stack trace getter if it is not NULL;
  // otherwise, creates an OsStackTraceGetter, makes it the current
  // getter, and returns it.
  OsStackTraceGetterInterface* os_stack_trace_getter();

617
  // Returns the current OS stack trace as an std::string.
shiqian's avatar
shiqian committed
618
619
620
621
622
623
624
625
626
  //
  // The maximum number of stack frames to be included is specified by
  // the gtest_stack_trace_depth flag.  The skip_count parameter
  // specifies the number of top frames to be skipped, which doesn't
  // count against the number of frames to be included.
  //
  // For example, if Foo() calls Bar(), which in turn calls
  // CurrentOsStackTraceExceptTop(1), Foo() will be included in the
  // trace but Bar() and CurrentOsStackTraceExceptTop() won't.
627
  std::string CurrentOsStackTraceExceptTop(int skip_count) GTEST_NO_INLINE_;
shiqian's avatar
shiqian committed
628
629
630
631
632
633
634

  // Finds and returns a TestCase with the given name.  If one doesn't
  // exist, creates one and returns it.
  //
  // Arguments:
  //
  //   test_case_name: name of the test case
635
636
  //   type_param:     the name of the test's type parameter, or NULL if
  //                   this is not a typed or a type-parameterized test.
shiqian's avatar
shiqian committed
637
638
639
  //   set_up_tc:      pointer to the function that sets up the test case
  //   tear_down_tc:   pointer to the function that tears down the test case
  TestCase* GetTestCase(const char* test_case_name,
640
                        const char* type_param,
shiqian's avatar
shiqian committed
641
642
643
644
645
646
647
648
649
650
651
652
                        Test::SetUpTestCaseFunc set_up_tc,
                        Test::TearDownTestCaseFunc tear_down_tc);

  // Adds a TestInfo to the unit test.
  //
  // Arguments:
  //
  //   set_up_tc:    pointer to the function that sets up the test case
  //   tear_down_tc: pointer to the function that tears down the test case
  //   test_info:    the TestInfo object
  void AddTestInfo(Test::SetUpTestCaseFunc set_up_tc,
                   Test::TearDownTestCaseFunc tear_down_tc,
653
                   TestInfo* test_info) {
654
655
656
657
658
659
660
661
662
    // In order to support thread-safe death tests, we need to
    // remember the original working directory when the test program
    // was first invoked.  We cannot do this in RUN_ALL_TESTS(), as
    // the user may have changed the current directory before calling
    // RUN_ALL_TESTS().  Therefore we capture the current directory in
    // AddTestInfo(), which is called to register a TEST or TEST_F
    // before main() is reached.
    if (original_working_dir_.IsEmpty()) {
      original_working_dir_.Set(FilePath::GetCurrentDir());
663
664
      GTEST_CHECK_(!original_working_dir_.IsEmpty())
          << "Failed to get the current working directory.";
665
666
    }

shiqian's avatar
shiqian committed
667
    GetTestCase(test_info->test_case_name(),
668
                test_info->type_param(),
shiqian's avatar
shiqian committed
669
670
671
672
                set_up_tc,
                tear_down_tc)->AddTestInfo(test_info);
  }

673
674
675
676
677
678
  // Returns ParameterizedTestCaseRegistry object used to keep track of
  // value-parameterized tests and instantiate and register them.
  internal::ParameterizedTestCaseRegistry& parameterized_test_registry() {
    return parameterized_test_registry_;
  }

shiqian's avatar
shiqian committed
679
  // Sets the TestCase object for the test that's currently running.
680
681
  void set_current_test_case(TestCase* a_current_test_case) {
    current_test_case_ = a_current_test_case;
shiqian's avatar
shiqian committed
682
683
684
685
686
  }

  // Sets the TestInfo object for the test that's currently running.  If
  // current_test_info is NULL, the assertion results will be stored in
  // ad_hoc_test_result_.
687
688
  void set_current_test_info(TestInfo* a_current_test_info) {
    current_test_info_ = a_current_test_info;
shiqian's avatar
shiqian committed
689
690
  }

691
  // Registers all parameterized tests defined using TEST_P and
vladlosev's avatar
vladlosev committed
692
693
694
695
696
  // INSTANTIATE_TEST_CASE_P, creating regular tests for each test/parameter
  // combination. This method can be called more then once; it has guards
  // protecting from registering the tests more then once.  If
  // value-parameterized tests are disabled, RegisterParameterizedTests is
  // present but does nothing.
697
698
  void RegisterParameterizedTests();

shiqian's avatar
shiqian committed
699
  // Runs all tests in this UnitTest object, prints the result, and
700
701
702
703
  // returns true if all tests are successful.  If any exception is
  // thrown during a test, this test is considered to be failed, but
  // the rest of the tests will still be run.
  bool RunAllTests();
shiqian's avatar
shiqian committed
704

705
706
  // Clears the results of all tests, except the ad hoc tests.
  void ClearNonAdHocTestResult() {
707
    ForEach(test_cases_, TestCase::ClearTestCaseResult);
708
709
710
711
  }

  // Clears the results of ad-hoc test assertions.
  void ClearAdHocTestResult() {
shiqian's avatar
shiqian committed
712
713
714
    ad_hoc_test_result_.Clear();
  }

715
716
717
718
719
720
  // Adds a TestProperty to the current TestResult object when invoked in a
  // context of a test or a test case, or to the global property set. If the
  // result already contains a property with the same key, the value will be
  // updated.
  void RecordProperty(const TestProperty& test_property);

721
722
723
724
725
  enum ReactionToSharding {
    HONOR_SHARDING_PROTOCOL,
    IGNORE_SHARDING_PROTOCOL
  };

shiqian's avatar
shiqian committed
726
727
728
  // Matches the full name of each test against the user-specified
  // filter to decide whether the test should run, then records the
  // result in each TestCase and TestInfo object.
729
730
  // If shard_tests == HONOR_SHARDING_PROTOCOL, further filters tests
  // based on sharding variables in the environment.
shiqian's avatar
shiqian committed
731
  // Returns the number of tests that should run.
732
  int FilterTests(ReactionToSharding shard_tests);
shiqian's avatar
shiqian committed
733

734
735
  // Prints the names of the tests matching the user-specified filter flag.
  void ListTestsMatchingFilter();
shiqian's avatar
shiqian committed
736
737
738
739
740

  const TestCase* current_test_case() const { return current_test_case_; }
  TestInfo* current_test_info() { return current_test_info_; }
  const TestInfo* current_test_info() const { return current_test_info_; }

741
  // Returns the vector of environments that need to be set-up/torn-down
shiqian's avatar
shiqian committed
742
  // before/after the tests are run.
743
  std::vector<Environment*>& environments() { return environments_; }
shiqian's avatar
shiqian committed
744
745

  // Getters for the per-thread Google Test trace stack.
746
747
  std::vector<TraceInfo>& gtest_trace_stack() {
    return *(gtest_trace_stack_.pointer());
shiqian's avatar
shiqian committed
748
  }
749
750
  const std::vector<TraceInfo>& gtest_trace_stack() const {
    return gtest_trace_stack_.get();
shiqian's avatar
shiqian committed
751
752
  }

zhanyong.wan's avatar
zhanyong.wan committed
753
#if GTEST_HAS_DEATH_TEST
754
755
756
  void InitDeathTestSubprocessControlInfo() {
    internal_run_death_test_flag_.reset(ParseInternalRunDeathTestFlag());
  }
shiqian's avatar
shiqian committed
757
758
759
  // Returns a pointer to the parsed --gtest_internal_run_death_test
  // flag, or NULL if that flag was not specified.
  // This information is useful only in a death test child process.
760
  // Must not be called before a call to InitGoogleTest.
shiqian's avatar
shiqian committed
761
762
763
764
765
766
767
768
769
  const InternalRunDeathTestFlag* internal_run_death_test_flag() const {
    return internal_run_death_test_flag_.get();
  }

  // Returns a pointer to the current death test factory.
  internal::DeathTestFactory* death_test_factory() {
    return death_test_factory_.get();
  }

770
771
  void SuppressTestEventsIfInSubprocess();

shiqian's avatar
shiqian committed
772
773
774
  friend class ReplaceDeathTestFactory;
#endif  // GTEST_HAS_DEATH_TEST

775
776
777
778
  // Initializes the event listener performing XML output as specified by
  // UnitTestOptions. Must not be called before InitGoogleTest.
  void ConfigureXmlOutput();

779
780
781
782
783
784
#if GTEST_CAN_STREAM_RESULTS_
  // Initializes the event listener for streaming test results to a socket.
  // Must not be called before InitGoogleTest.
  void ConfigureStreamingOutput();
#endif

785
786
787
788
789
  // Performs initialization dependent upon flag values obtained in
  // ParseGoogleTestFlagsOnly.  Is called from InitGoogleTest after the call to
  // ParseGoogleTestFlagsOnly.  In case a user neglects to call InitGoogleTest
  // this function is also called from RunAllTests.  Since this function can be
  // called more than once, it has to be idempotent.
790
791
  void PostFlagParsingInit();

792
  // Gets the random seed used at the start of the current test iteration.
793
794
  int random_seed() const { return random_seed_; }

795
796
797
798
799
800
801
802
803
804
  // Gets the random number generator.
  internal::Random* random() { return &random_; }

  // Shuffles all test cases, and the tests within each test case,
  // making sure that death tests are still run first.
  void ShuffleTests();

  // Restores the test cases and tests to their order before the first shuffle.
  void UnshuffleTests();

805
806
807
808
  // Returns the value of GTEST_FLAG(catch_exceptions) at the moment
  // UnitTest::Run() starts.
  bool catch_exceptions() const { return catch_exceptions_; }

shiqian's avatar
shiqian committed
809
 private:
810
811
  friend class ::testing::UnitTest;

812
813
814
815
  // Used by UnitTest::Run() to capture the state of
  // GTEST_FLAG(catch_exceptions) at the moment it starts.
  void set_catch_exceptions(bool value) { catch_exceptions_ = value; }

shiqian's avatar
shiqian committed
816
817
818
  // The UnitTest object that owns this implementation object.
  UnitTest* const parent_;

819
820
821
822
  // The working directory when the first TEST() or TEST_F() was
  // executed.
  internal::FilePath original_working_dir_;

shiqian's avatar
shiqian committed
823
824
825
826
827
828
829
830
831
832
833
834
835
836
  // The default test part result reporters.
  DefaultGlobalTestPartResultReporter default_global_test_part_result_reporter_;
  DefaultPerThreadTestPartResultReporter
      default_per_thread_test_part_result_reporter_;

  // Points to (but doesn't own) the global test part result reporter.
  TestPartResultReporterInterface* global_test_part_result_repoter_;

  // Protects read and write access to global_test_part_result_reporter_.
  internal::Mutex global_test_part_result_reporter_mutex_;

  // Points to (but doesn't own) the per-thread test part result reporter.
  internal::ThreadLocal<TestPartResultReporterInterface*>
      per_thread_test_part_result_reporter_;
shiqian's avatar
shiqian committed
837

838
  // The vector of environments that need to be set-up/torn-down
839
840
  // before/after the tests are run.
  std::vector<Environment*> environments_;
shiqian's avatar
shiqian committed
841

842
843
  // The vector of TestCases in their original order.  It owns the
  // elements in the vector.
844
  std::vector<TestCase*> test_cases_;
845
846
847
848
849

  // Provides a level of indirection for the test case list to allow
  // easy shuffling and restoring the test case order.  The i-th
  // element of this vector is the index of the i-th test case in the
  // shuffled order.
850
  std::vector<int> test_case_indices_;
shiqian's avatar
shiqian committed
851

852
853
854
855
856
857
858
  // ParameterizedTestRegistry object used to register value-parameterized
  // tests.
  internal::ParameterizedTestCaseRegistry parameterized_test_registry_;

  // Indicates whether RegisterParameterizedTests() has been called already.
  bool parameterized_tests_registered_;

859
860
  // Index of the last death test case registered.  Initially -1.
  int last_death_test_case_;
shiqian's avatar
shiqian committed
861
862
863
864

  // This points to the TestCase for the currently running test.  It
  // changes as Google Test goes through one test case after another.
  // When no test is running, this is set to NULL and Google Test
865
  // stores assertion results in ad_hoc_test_result_.  Initially NULL.
shiqian's avatar
shiqian committed
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
  TestCase* current_test_case_;

  // This points to the TestInfo for the currently running test.  It
  // changes as Google Test goes through one test after another.  When
  // no test is running, this is set to NULL and Google Test stores
  // assertion results in ad_hoc_test_result_.  Initially NULL.
  TestInfo* current_test_info_;

  // Normally, a user only writes assertions inside a TEST or TEST_F,
  // or inside a function called by a TEST or TEST_F.  Since Google
  // Test keeps track of which test is current running, it can
  // associate such an assertion with the test it belongs to.
  //
  // If an assertion is encountered when no TEST or TEST_F is running,
  // Google Test attributes the assertion result to an imaginary "ad hoc"
  // test, and records the result in ad_hoc_test_result_.
882
  TestResult ad_hoc_test_result_;
shiqian's avatar
shiqian committed
883

884
885
  // The list of event listeners that can be used to track events inside
  // Google Test.
886
  TestEventListeners listeners_;
shiqian's avatar
shiqian committed
887
888
889
890
891
892
893

  // The OS stack trace getter.  Will be deleted when the UnitTest
  // object is destructed.  By default, an OsStackTraceGetter is used,
  // but the user can set this field to use a custom getter if that is
  // desired.
  OsStackTraceGetterInterface* os_stack_trace_getter_;

894
895
896
  // True iff PostFlagParsingInit() has been called.
  bool post_flag_parse_init_performed_;

897
898
899
  // The random number seed used at the beginning of the test run.
  int random_seed_;

900
901
902
  // Our random number generator.
  internal::Random random_;

903
904
905
906
  // The time of the test program start, in ms from the start of the
  // UNIX epoch.
  TimeInMillis start_timestamp_;

shiqian's avatar
shiqian committed
907
908
909
  // How long the test took to run, in milliseconds.
  TimeInMillis elapsed_time_;

zhanyong.wan's avatar
zhanyong.wan committed
910
#if GTEST_HAS_DEATH_TEST
shiqian's avatar
shiqian committed
911
912
913
914
915
916
917
  // The decomposed components of the gtest_internal_run_death_test flag,
  // parsed when RUN_ALL_TESTS is called.
  internal::scoped_ptr<InternalRunDeathTestFlag> internal_run_death_test_flag_;
  internal::scoped_ptr<internal::DeathTestFactory> death_test_factory_;
#endif  // GTEST_HAS_DEATH_TEST

  // A per-thread stack of traces created by the SCOPED_TRACE() macro.
918
  internal::ThreadLocal<std::vector<TraceInfo> > gtest_trace_stack_;
shiqian's avatar
shiqian committed
919

920
921
922
923
  // The value of GTEST_FLAG(catch_exceptions) at the moment RunAllTests()
  // starts.
  bool catch_exceptions_;

shiqian's avatar
shiqian committed
924
  GTEST_DISALLOW_COPY_AND_ASSIGN_(UnitTestImpl);
shiqian's avatar
shiqian committed
925
926
927
928
929
930
931
932
};  // class UnitTestImpl

// Convenience function for accessing the global UnitTest
// implementation object.
inline UnitTestImpl* GetUnitTestImpl() {
  return UnitTest::GetInstance()->impl();
}

933
934
#if GTEST_USES_SIMPLE_RE

935
936
// Internal helper functions for implementing the simple regular
// expression matcher.
zhanyong.wan's avatar
zhanyong.wan committed
937
GTEST_API_ bool IsInSet(char ch, const char* str);
938
939
GTEST_API_ bool IsAsciiDigit(char ch);
GTEST_API_ bool IsAsciiPunct(char ch);
zhanyong.wan's avatar
zhanyong.wan committed
940
GTEST_API_ bool IsRepeat(char ch);
941
942
GTEST_API_ bool IsAsciiWhiteSpace(char ch);
GTEST_API_ bool IsAsciiWordChar(char ch);
zhanyong.wan's avatar
zhanyong.wan committed
943
944
945
946
947
GTEST_API_ bool IsValidEscape(char ch);
GTEST_API_ bool AtomMatchesChar(bool escaped, char pattern, char ch);
GTEST_API_ bool ValidateRegex(const char* regex);
GTEST_API_ bool MatchRegexAtHead(const char* regex, const char* str);
GTEST_API_ bool MatchRepetitionAndRegexAtHead(
948
    bool escaped, char ch, char repeat, const char* regex, const char* str);
zhanyong.wan's avatar
zhanyong.wan committed
949
GTEST_API_ bool MatchRegexAnywhere(const char* regex, const char* str);
950

951
952
#endif  // GTEST_USES_SIMPLE_RE

953
954
// Parses the command line for Google Test flags, without initializing
// other parts of Google Test.
zhanyong.wan's avatar
zhanyong.wan committed
955
956
GTEST_API_ void ParseGoogleTestFlagsOnly(int* argc, char** argv);
GTEST_API_ void ParseGoogleTestFlagsOnly(int* argc, wchar_t** argv);
957

958
959
960
961
#if GTEST_HAS_DEATH_TEST

// Returns the message describing the last system error, regardless of the
// platform.
962
GTEST_API_ std::string GetLastErrnoDescription();
963
964
965
966
967
968
969
970
971
972

// Attempts to parse a string into a positive integer pointed to by the
// number parameter.  Returns true if that is possible.
// GTEST_HAS_DEATH_TEST implies that we have ::std::string, so we can use
// it here.
template <typename Integer>
bool ParseNaturalNumber(const ::std::string& str, Integer* number) {
  // Fail fast if the given string does not begin with a digit;
  // this bypasses strtoXXX's "optional leading whitespace and plus
  // or minus sign" semantics, which are undesirable here.
973
  if (str.empty() || !IsDigit(str[0])) {
974
975
976
977
978
979
980
    return false;
  }
  errno = 0;

  char* end;
  // BiggestConvertible is the largest integer type that system-provided
  // string-to-number conversion routines can return.
981
982
983

# if GTEST_OS_WINDOWS && !defined(__GNUC__)

984
  // MSVC and C++ Builder define __int64 instead of the standard long long.
985
986
  typedef unsigned __int64 BiggestConvertible;
  const BiggestConvertible parsed = _strtoui64(str.c_str(), &end, 10);
987
988
989

# else

990
991
  typedef unsigned long long BiggestConvertible;  // NOLINT
  const BiggestConvertible parsed = strtoull(str.c_str(), &end, 10);
992
993
994

# endif  // GTEST_OS_WINDOWS && !defined(__GNUC__)

995
996
  const bool parse_success = *end == '\0' && errno == 0;

Gennadiy Civil's avatar
 
Gennadiy Civil committed
997
  // FIXME: Convert this to compile time assertion when it is
998
999
1000
1001
1002
1003
1004
1005
1006
1007
1008
1009
  // available.
  GTEST_CHECK_(sizeof(Integer) <= sizeof(parsed));

  const Integer result = static_cast<Integer>(parsed);
  if (parse_success && static_cast<BiggestConvertible>(result) == parsed) {
    *number = result;
    return true;
  }
  return false;
}
#endif  // GTEST_HAS_DEATH_TEST

1010
1011
1012
// TestResult contains some private methods that should be hidden from
// Google Test user but are required for testing. This class allow our tests
// to access them.
1013
1014
1015
//
// This class is supplied only for the purpose of testing Google Test's own
// constructs. Do not use it in user tests, either directly or indirectly.
1016
1017
1018
class TestResultAccessor {
 public:
  static void RecordProperty(TestResult* test_result,
1019
                             const std::string& xml_element,
1020
                             const TestProperty& property) {
1021
    test_result->RecordProperty(xml_element, property);
1022
1023
1024
1025
1026
1027
  }

  static void ClearTestPartResults(TestResult* test_result) {
    test_result->ClearTestPartResults();
  }

1028
  static const std::vector<testing::TestPartResult>& test_part_results(
1029
1030
1031
1032
1033
      const TestResult& test_result) {
    return test_result.test_part_results();
  }
};

kosak's avatar
kosak committed
1034
1035
1036
#if GTEST_CAN_STREAM_RESULTS_

// Streams test results to the given port on the given host machine.
Gennadiy Civil's avatar
Gennadiy Civil committed
1037
class StreamingListener : public EmptyTestEventListener {
kosak's avatar
kosak committed
1038
1039
1040
1041
1042
1043
1044
 public:
  // Abstract base class for writing strings to a socket.
  class AbstractSocketWriter {
   public:
    virtual ~AbstractSocketWriter() {}

    // Sends a string to the socket.
1045
    virtual void Send(const std::string& message) = 0;
kosak's avatar
kosak committed
1046
1047
1048
1049
1050

    // Closes the socket.
    virtual void CloseConnection() {}

    // Sends a string and a newline to the socket.
1051
    void SendLn(const std::string& message) { Send(message + "\n"); }
kosak's avatar
kosak committed
1052
1053
1054
1055
1056
  };

  // Concrete class for actually writing strings to a socket.
  class SocketWriter : public AbstractSocketWriter {
   public:
1057
    SocketWriter(const std::string& host, const std::string& port)
kosak's avatar
kosak committed
1058
1059
1060
1061
1062
1063
1064
1065
1066
1067
        : sockfd_(-1), host_name_(host), port_num_(port) {
      MakeConnection();
    }

    virtual ~SocketWriter() {
      if (sockfd_ != -1)
        CloseConnection();
    }

    // Sends a string to the socket.
1068
    virtual void Send(const std::string& message) {
kosak's avatar
kosak committed
1069
1070
1071
1072
1073
1074
1075
1076
1077
1078
1079
1080
1081
1082
1083
1084
1085
1086
1087
1088
1089
1090
1091
1092
1093
      GTEST_CHECK_(sockfd_ != -1)
          << "Send() can be called only when there is a connection.";

      const int len = static_cast<int>(message.length());
      if (write(sockfd_, message.c_str(), len) != len) {
        GTEST_LOG_(WARNING)
            << "stream_result_to: failed to stream to "
            << host_name_ << ":" << port_num_;
      }
    }

   private:
    // Creates a client socket and connects to the server.
    void MakeConnection();

    // Closes the socket.
    void CloseConnection() {
      GTEST_CHECK_(sockfd_ != -1)
          << "CloseConnection() can be called only when there is a connection.";

      close(sockfd_);
      sockfd_ = -1;
    }

    int sockfd_;  // socket file descriptor
1094
1095
    const std::string host_name_;
    const std::string port_num_;
kosak's avatar
kosak committed
1096
1097
1098
1099
1100

    GTEST_DISALLOW_COPY_AND_ASSIGN_(SocketWriter);
  };  // class SocketWriter

  // Escapes '=', '&', '%', and '\n' characters in str as "%xx".
1101
  static std::string UrlEncode(const char* str);
kosak's avatar
kosak committed
1102

1103
1104
1105
1106
  StreamingListener(const std::string& host, const std::string& port)
      : socket_writer_(new SocketWriter(host, port)) {
    Start();
  }
kosak's avatar
kosak committed
1107
1108
1109
1110
1111
1112
1113
1114
1115
1116
1117
1118
1119
1120
1121
1122
1123
1124
1125
1126
1127
1128
1129
1130
1131
1132
1133
1134
1135
1136
1137
1138
1139
1140
1141
1142
1143
1144
1145
1146
1147
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
1161
1162
1163
1164
1165
1166

  explicit StreamingListener(AbstractSocketWriter* socket_writer)
      : socket_writer_(socket_writer) { Start(); }

  void OnTestProgramStart(const UnitTest& /* unit_test */) {
    SendLn("event=TestProgramStart");
  }

  void OnTestProgramEnd(const UnitTest& unit_test) {
    // Note that Google Test current only report elapsed time for each
    // test iteration, not for the entire test program.
    SendLn("event=TestProgramEnd&passed=" + FormatBool(unit_test.Passed()));

    // Notify the streaming server to stop.
    socket_writer_->CloseConnection();
  }

  void OnTestIterationStart(const UnitTest& /* unit_test */, int iteration) {
    SendLn("event=TestIterationStart&iteration=" +
           StreamableToString(iteration));
  }

  void OnTestIterationEnd(const UnitTest& unit_test, int /* iteration */) {
    SendLn("event=TestIterationEnd&passed=" +
           FormatBool(unit_test.Passed()) + "&elapsed_time=" +
           StreamableToString(unit_test.elapsed_time()) + "ms");
  }

  void OnTestCaseStart(const TestCase& test_case) {
    SendLn(std::string("event=TestCaseStart&name=") + test_case.name());
  }

  void OnTestCaseEnd(const TestCase& test_case) {
    SendLn("event=TestCaseEnd&passed=" + FormatBool(test_case.Passed())
           + "&elapsed_time=" + StreamableToString(test_case.elapsed_time())
           + "ms");
  }

  void OnTestStart(const TestInfo& test_info) {
    SendLn(std::string("event=TestStart&name=") + test_info.name());
  }

  void OnTestEnd(const TestInfo& test_info) {
    SendLn("event=TestEnd&passed=" +
           FormatBool((test_info.result())->Passed()) +
           "&elapsed_time=" +
           StreamableToString((test_info.result())->elapsed_time()) + "ms");
  }

  void OnTestPartResult(const TestPartResult& test_part_result) {
    const char* file_name = test_part_result.file_name();
    if (file_name == NULL)
      file_name = "";
    SendLn("event=TestPartResult&file=" + UrlEncode(file_name) +
           "&line=" + StreamableToString(test_part_result.line_number()) +
           "&message=" + UrlEncode(test_part_result.message()));
  }

 private:
  // Sends the given message and a newline to the socket.
1167
  void SendLn(const std::string& message) { socket_writer_->SendLn(message); }
kosak's avatar
kosak committed
1168
1169
1170
1171
1172

  // Called at the start of streaming to notify the receiver what
  // protocol we are using.
  void Start() { SendLn("gtest_streaming_protocol_version=1.0"); }

1173
  std::string FormatBool(bool value) { return value ? "1" : "0"; }
kosak's avatar
kosak committed
1174
1175
1176
1177
1178
1179
1180
1181

  const scoped_ptr<AbstractSocketWriter> socket_writer_;

  GTEST_DISALLOW_COPY_AND_ASSIGN_(StreamingListener);
};  // class StreamingListener

#endif  // GTEST_CAN_STREAM_RESULTS_

shiqian's avatar
shiqian committed
1182
1183
1184
}  // namespace internal
}  // namespace testing

misterg's avatar
misterg committed
1185
1186
GTEST_DISABLE_MSC_WARNINGS_POP_()  //  4251

shiqian's avatar
shiqian committed
1187
#endif  // GTEST_SRC_GTEST_INTERNAL_INL_H_