1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/media/mtransport/test/rlogringbuffer_unittest.cpp Wed Dec 31 06:09:35 2014 +0100
1.3 @@ -0,0 +1,269 @@
1.4 +/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
1.5 +/* vim: set ts=2 et sw=2 tw=80: */
1.6 +/* This Source Code Form is subject to the terms of the Mozilla Public
1.7 + * License, v. 2.0. If a copy of the MPL was not distributed with this file,
1.8 + * You can obtain one at http://mozilla.org/MPL/2.0/. */
1.9 +
1.10 +/* Original author: bcampen@mozilla.com */
1.11 +
1.12 +#include "rlogringbuffer.h"
1.13 +
1.14 +extern "C" {
1.15 +#include "registry.h"
1.16 +#include "r_log.h"
1.17 +}
1.18 +
1.19 +#define GTEST_HAS_RTTI 0
1.20 +#include "gtest/gtest.h"
1.21 +#include "gtest_utils.h"
1.22 +
1.23 +#include <deque>
1.24 +#include <string>
1.25 +#include <vector>
1.26 +
1.27 +using mozilla::RLogRingBuffer;
1.28 +
1.29 +int NR_LOG_TEST = 0;
1.30 +
1.31 +class RLogRingBufferTest : public ::testing::Test {
1.32 + public:
1.33 + RLogRingBufferTest() {
1.34 + Init();
1.35 + }
1.36 +
1.37 + ~RLogRingBufferTest() {
1.38 + Free();
1.39 + }
1.40 +
1.41 + void Init() {
1.42 + RLogRingBuffer::CreateInstance();
1.43 + }
1.44 +
1.45 + void Free() {
1.46 + RLogRingBuffer::DestroyInstance();
1.47 + }
1.48 +
1.49 + void ReInit() {
1.50 + Free();
1.51 + Init();
1.52 + }
1.53 +};
1.54 +
1.55 +TEST_F(RLogRingBufferTest, TestGetFree) {
1.56 + RLogRingBuffer* instance = RLogRingBuffer::GetInstance();
1.57 + ASSERT_NE(nullptr, instance);
1.58 +}
1.59 +
1.60 +TEST_F(RLogRingBufferTest, TestFilterEmpty) {
1.61 + std::deque<std::string> logs;
1.62 + RLogRingBuffer::GetInstance()->GetAny(0, &logs);
1.63 + ASSERT_EQ(0U, logs.size());
1.64 +}
1.65 +
1.66 +TEST_F(RLogRingBufferTest, TestBasicFilter) {
1.67 + r_log(NR_LOG_TEST, LOG_INFO, "Test");
1.68 + std::deque<std::string> logs;
1.69 + RLogRingBuffer::GetInstance()->Filter("Test", 0, &logs);
1.70 + ASSERT_EQ(1U, logs.size());
1.71 +}
1.72 +
1.73 +TEST_F(RLogRingBufferTest, TestBasicFilterContent) {
1.74 + r_log(NR_LOG_TEST, LOG_INFO, "Test");
1.75 + std::deque<std::string> logs;
1.76 + RLogRingBuffer::GetInstance()->Filter("Test", 0, &logs);
1.77 + ASSERT_EQ("Test", logs.back());
1.78 +}
1.79 +
1.80 +TEST_F(RLogRingBufferTest, TestFilterAnyFrontMatch) {
1.81 + r_log(NR_LOG_TEST, LOG_INFO, "Test");
1.82 + std::vector<std::string> substrings;
1.83 + substrings.push_back("foo");
1.84 + substrings.push_back("Test");
1.85 + std::deque<std::string> logs;
1.86 + RLogRingBuffer::GetInstance()->FilterAny(substrings, 0, &logs);
1.87 + ASSERT_EQ("Test", logs.back());
1.88 +}
1.89 +
1.90 +TEST_F(RLogRingBufferTest, TestFilterAnyBackMatch) {
1.91 + r_log(NR_LOG_TEST, LOG_INFO, "Test");
1.92 + std::vector<std::string> substrings;
1.93 + substrings.push_back("Test");
1.94 + substrings.push_back("foo");
1.95 + std::deque<std::string> logs;
1.96 + RLogRingBuffer::GetInstance()->FilterAny(substrings, 0, &logs);
1.97 + ASSERT_EQ("Test", logs.back());
1.98 +}
1.99 +
1.100 +TEST_F(RLogRingBufferTest, TestFilterAnyBothMatch) {
1.101 + r_log(NR_LOG_TEST, LOG_INFO, "Test");
1.102 + std::vector<std::string> substrings;
1.103 + substrings.push_back("Tes");
1.104 + substrings.push_back("est");
1.105 + std::deque<std::string> logs;
1.106 + RLogRingBuffer::GetInstance()->FilterAny(substrings, 0, &logs);
1.107 + ASSERT_EQ("Test", logs.back());
1.108 +}
1.109 +
1.110 +TEST_F(RLogRingBufferTest, TestFilterAnyNeitherMatch) {
1.111 + r_log(NR_LOG_TEST, LOG_INFO, "Test");
1.112 + std::vector<std::string> substrings;
1.113 + substrings.push_back("tes");
1.114 + substrings.push_back("esT");
1.115 + std::deque<std::string> logs;
1.116 + RLogRingBuffer::GetInstance()->FilterAny(substrings, 0, &logs);
1.117 + ASSERT_EQ(0U, logs.size());
1.118 +}
1.119 +
1.120 +TEST_F(RLogRingBufferTest, TestAllMatch) {
1.121 + r_log(NR_LOG_TEST, LOG_INFO, "Test1");
1.122 + r_log(NR_LOG_TEST, LOG_INFO, "Test2");
1.123 + std::deque<std::string> logs;
1.124 + RLogRingBuffer::GetInstance()->GetAny(0, &logs);
1.125 + ASSERT_EQ(2U, logs.size());
1.126 +}
1.127 +
1.128 +TEST_F(RLogRingBufferTest, TestOrder) {
1.129 + r_log(NR_LOG_TEST, LOG_INFO, "Test1");
1.130 + r_log(NR_LOG_TEST, LOG_INFO, "Test2");
1.131 + std::deque<std::string> logs;
1.132 + RLogRingBuffer::GetInstance()->GetAny(0, &logs);
1.133 + ASSERT_EQ("Test2", logs.back());
1.134 + ASSERT_EQ("Test1", logs.front());
1.135 +}
1.136 +
1.137 +TEST_F(RLogRingBufferTest, TestNoMatch) {
1.138 + r_log(NR_LOG_TEST, LOG_INFO, "Test1");
1.139 + r_log(NR_LOG_TEST, LOG_INFO, "Test2");
1.140 + std::deque<std::string> logs;
1.141 + RLogRingBuffer::GetInstance()->Filter("foo", 0, &logs);
1.142 + ASSERT_EQ(0U, logs.size());
1.143 +}
1.144 +
1.145 +TEST_F(RLogRingBufferTest, TestSubstringFilter) {
1.146 + r_log(NR_LOG_TEST, LOG_INFO, "Test1");
1.147 + r_log(NR_LOG_TEST, LOG_INFO, "Test2");
1.148 + std::deque<std::string> logs;
1.149 + RLogRingBuffer::GetInstance()->Filter("t1", 0, &logs);
1.150 + ASSERT_EQ(1U, logs.size());
1.151 + ASSERT_EQ("Test1", logs.back());
1.152 +}
1.153 +
1.154 +TEST_F(RLogRingBufferTest, TestFilterLimit) {
1.155 + r_log(NR_LOG_TEST, LOG_INFO, "Test1");
1.156 + r_log(NR_LOG_TEST, LOG_INFO, "Test2");
1.157 + r_log(NR_LOG_TEST, LOG_INFO, "Test3");
1.158 + r_log(NR_LOG_TEST, LOG_INFO, "Test4");
1.159 + r_log(NR_LOG_TEST, LOG_INFO, "Test5");
1.160 + r_log(NR_LOG_TEST, LOG_INFO, "Test6");
1.161 + std::deque<std::string> logs;
1.162 + RLogRingBuffer::GetInstance()->Filter("Test", 2, &logs);
1.163 + ASSERT_EQ(2U, logs.size());
1.164 + ASSERT_EQ("Test6", logs.back());
1.165 + ASSERT_EQ("Test5", logs.front());
1.166 +}
1.167 +
1.168 +TEST_F(RLogRingBufferTest, TestFilterAnyLimit) {
1.169 + r_log(NR_LOG_TEST, LOG_INFO, "TestOne");
1.170 + r_log(NR_LOG_TEST, LOG_INFO, "TestTwo");
1.171 + r_log(NR_LOG_TEST, LOG_INFO, "TestThree");
1.172 + r_log(NR_LOG_TEST, LOG_INFO, "TestFour");
1.173 + r_log(NR_LOG_TEST, LOG_INFO, "TestFive");
1.174 + r_log(NR_LOG_TEST, LOG_INFO, "TestSix");
1.175 + std::vector<std::string> substrings;
1.176 + // Matches Two, Three, Four, and Six
1.177 + substrings.push_back("tT");
1.178 + substrings.push_back("o");
1.179 + substrings.push_back("r");
1.180 + substrings.push_back("S");
1.181 + std::deque<std::string> logs;
1.182 + RLogRingBuffer::GetInstance()->FilterAny(substrings, 2, &logs);
1.183 + ASSERT_EQ(2U, logs.size());
1.184 + ASSERT_EQ("TestSix", logs.back());
1.185 + ASSERT_EQ("TestFour", logs.front());
1.186 +}
1.187 +
1.188 +TEST_F(RLogRingBufferTest, TestLimit) {
1.189 + RLogRingBuffer::GetInstance()->SetLogLimit(3);
1.190 + r_log(NR_LOG_TEST, LOG_INFO, "Test1");
1.191 + r_log(NR_LOG_TEST, LOG_INFO, "Test2");
1.192 + r_log(NR_LOG_TEST, LOG_INFO, "Test3");
1.193 + r_log(NR_LOG_TEST, LOG_INFO, "Test4");
1.194 + r_log(NR_LOG_TEST, LOG_INFO, "Test5");
1.195 + r_log(NR_LOG_TEST, LOG_INFO, "Test6");
1.196 + std::deque<std::string> logs;
1.197 + RLogRingBuffer::GetInstance()->GetAny(0, &logs);
1.198 + ASSERT_EQ(3U, logs.size());
1.199 + ASSERT_EQ("Test6", logs.back());
1.200 + ASSERT_EQ("Test4", logs.front());
1.201 +}
1.202 +
1.203 +TEST_F(RLogRingBufferTest, TestLimitBulkDiscard) {
1.204 + r_log(NR_LOG_TEST, LOG_INFO, "Test1");
1.205 + r_log(NR_LOG_TEST, LOG_INFO, "Test2");
1.206 + r_log(NR_LOG_TEST, LOG_INFO, "Test3");
1.207 + r_log(NR_LOG_TEST, LOG_INFO, "Test4");
1.208 + r_log(NR_LOG_TEST, LOG_INFO, "Test5");
1.209 + r_log(NR_LOG_TEST, LOG_INFO, "Test6");
1.210 + RLogRingBuffer::GetInstance()->SetLogLimit(3);
1.211 + std::deque<std::string> logs;
1.212 + RLogRingBuffer::GetInstance()->GetAny(0, &logs);
1.213 + ASSERT_EQ(3U, logs.size());
1.214 + ASSERT_EQ("Test6", logs.back());
1.215 + ASSERT_EQ("Test4", logs.front());
1.216 +}
1.217 +
1.218 +TEST_F(RLogRingBufferTest, TestIncreaseLimit) {
1.219 + RLogRingBuffer::GetInstance()->SetLogLimit(3);
1.220 + r_log(NR_LOG_TEST, LOG_INFO, "Test1");
1.221 + r_log(NR_LOG_TEST, LOG_INFO, "Test2");
1.222 + r_log(NR_LOG_TEST, LOG_INFO, "Test3");
1.223 + r_log(NR_LOG_TEST, LOG_INFO, "Test4");
1.224 + r_log(NR_LOG_TEST, LOG_INFO, "Test5");
1.225 + r_log(NR_LOG_TEST, LOG_INFO, "Test6");
1.226 + RLogRingBuffer::GetInstance()->SetLogLimit(300);
1.227 + std::deque<std::string> logs;
1.228 + RLogRingBuffer::GetInstance()->GetAny(0, &logs);
1.229 + ASSERT_EQ(3U, logs.size());
1.230 + ASSERT_EQ("Test6", logs.back());
1.231 + ASSERT_EQ("Test4", logs.front());
1.232 +}
1.233 +
1.234 +TEST_F(RLogRingBufferTest, TestClear) {
1.235 + r_log(NR_LOG_TEST, LOG_INFO, "Test1");
1.236 + r_log(NR_LOG_TEST, LOG_INFO, "Test2");
1.237 + r_log(NR_LOG_TEST, LOG_INFO, "Test3");
1.238 + r_log(NR_LOG_TEST, LOG_INFO, "Test4");
1.239 + r_log(NR_LOG_TEST, LOG_INFO, "Test5");
1.240 + r_log(NR_LOG_TEST, LOG_INFO, "Test6");
1.241 + RLogRingBuffer::GetInstance()->SetLogLimit(0);
1.242 + RLogRingBuffer::GetInstance()->SetLogLimit(4096);
1.243 + std::deque<std::string> logs;
1.244 + RLogRingBuffer::GetInstance()->GetAny(0, &logs);
1.245 + ASSERT_EQ(0U, logs.size());
1.246 +}
1.247 +
1.248 +TEST_F(RLogRingBufferTest, TestReInit) {
1.249 + r_log(NR_LOG_TEST, LOG_INFO, "Test1");
1.250 + r_log(NR_LOG_TEST, LOG_INFO, "Test2");
1.251 + r_log(NR_LOG_TEST, LOG_INFO, "Test3");
1.252 + r_log(NR_LOG_TEST, LOG_INFO, "Test4");
1.253 + r_log(NR_LOG_TEST, LOG_INFO, "Test5");
1.254 + r_log(NR_LOG_TEST, LOG_INFO, "Test6");
1.255 + ReInit();
1.256 + std::deque<std::string> logs;
1.257 + RLogRingBuffer::GetInstance()->GetAny(0, &logs);
1.258 + ASSERT_EQ(0U, logs.size());
1.259 +}
1.260 +
1.261 +int main(int argc, char** argv) {
1.262 + NR_reg_init(NR_REG_MODE_LOCAL);
1.263 + r_log_init();
1.264 + /* Would be nice to be able to register/unregister in the fixture */
1.265 + const char* facility = "rlogringbuffer_test";
1.266 + r_log_register(const_cast<char*>(facility), &NR_LOG_TEST);
1.267 + ::testing::InitGoogleTest(&argc, argv);
1.268 +
1.269 + int rv = RUN_ALL_TESTS();
1.270 + return rv;
1.271 +}
1.272 +
