michael@0: /* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
michael@0: /* vim: set ts=2 et sw=2 tw=80: */
michael@0: /* This Source Code Form is subject to the terms of the Mozilla Public
michael@0:  * License, v. 2.0. If a copy of the MPL was not distributed with this file,
michael@0:  * You can obtain one at http://mozilla.org/MPL/2.0/. */
michael@0: 
michael@0: /* Original author: bcampen@mozilla.com */
michael@0: 
michael@0: #include "simpletokenbucket.h"
michael@0: 
michael@0: #define GTEST_HAS_RTTI 0
michael@0: #include "gtest/gtest.h"
michael@0: #include "gtest_utils.h"
michael@0: 
michael@0: using mozilla::SimpleTokenBucket;
michael@0: 
michael@0: class TestSimpleTokenBucket : public SimpleTokenBucket {
michael@0:   public:
michael@0:     TestSimpleTokenBucket(size_t bucketSize, size_t tokensPerSecond) :
michael@0:       SimpleTokenBucket(bucketSize, tokensPerSecond) {
michael@0:     }
michael@0: 
michael@0:     void fastForward(int32_t timeMilliSeconds) {
michael@0:       if (timeMilliSeconds >= 0) {
michael@0:         last_time_tokens_added_ -= PR_MillisecondsToInterval(timeMilliSeconds);
michael@0:       } else {
michael@0:         last_time_tokens_added_ += PR_MillisecondsToInterval(-timeMilliSeconds);
michael@0:       }
michael@0:     }
michael@0: };
michael@0: 
michael@0: TEST(SimpleTokenBucketTest, TestConstruct) {
michael@0:   TestSimpleTokenBucket b(10, 1);
michael@0: }
michael@0: 
michael@0: TEST(SimpleTokenBucketTest, TestGet) {
michael@0:   TestSimpleTokenBucket b(10, 1);
michael@0:   ASSERT_EQ(5U, b.getTokens(5));
michael@0: }
michael@0: 
michael@0: TEST(SimpleTokenBucketTest, TestGetAll) {
michael@0:   TestSimpleTokenBucket b(10, 1);
michael@0:   ASSERT_EQ(10U, b.getTokens(10));
michael@0: }
michael@0: 
michael@0: TEST(SimpleTokenBucketTest, TestGetInsufficient) {
michael@0:   TestSimpleTokenBucket b(10, 1);
michael@0:   ASSERT_EQ(5U, b.getTokens(5));
michael@0:   ASSERT_EQ(5U, b.getTokens(6));
michael@0: }
michael@0: 
michael@0: TEST(SimpleTokenBucketTest, TestGetBucketCount) {
michael@0:   TestSimpleTokenBucket b(10, 1);
michael@0:   ASSERT_EQ(10U, b.getTokens(UINT32_MAX));
michael@0:   ASSERT_EQ(5U, b.getTokens(5));
michael@0:   ASSERT_EQ(5U, b.getTokens(UINT32_MAX));
michael@0: }
michael@0: 
michael@0: TEST(SimpleTokenBucketTest, TestTokenRefill) {
michael@0:   TestSimpleTokenBucket b(10, 1);
michael@0:   ASSERT_EQ(5U, b.getTokens(5));
michael@0:   b.fastForward(1000);
michael@0:   ASSERT_EQ(6U, b.getTokens(6));
michael@0: }
michael@0: 
michael@0: TEST(SimpleTokenBucketTest, TestNoTimeWasted) {
michael@0:   // Makes sure that when the time elapsed is insufficient to add any
michael@0:   // tokens to the bucket, the internal timestamp that is used in this
michael@0:   // calculation is not updated (ie; two subsequent 0.5 second elapsed times
michael@0:   // counts as a full second)
michael@0:   TestSimpleTokenBucket b(10, 1);
michael@0:   ASSERT_EQ(5U, b.getTokens(5));
michael@0:   b.fastForward(500);
michael@0:   ASSERT_EQ(5U, b.getTokens(6));
michael@0:   b.fastForward(500);
michael@0:   ASSERT_EQ(6U, b.getTokens(6));
michael@0: }
michael@0: 
michael@0: TEST(SimpleTokenBucketTest, TestNegativeTime) {
michael@0:   TestSimpleTokenBucket b(10, 1);
michael@0:   b.fastForward(-1000);
michael@0:   // Make sure we don't end up with an invalid number of tokens, but otherwise
michael@0:   // permit anything.
michael@0:   ASSERT_GT(11U, b.getTokens(100));
michael@0: }
michael@0: 
michael@0: TEST(SimpleTokenBucketTest, TestEmptyBucket) {
michael@0:   TestSimpleTokenBucket b(10, 1);
michael@0:   ASSERT_EQ(10U, b.getTokens(10));
michael@0:   ASSERT_EQ(0U, b.getTokens(10));
michael@0: }
michael@0: 
michael@0: TEST(SimpleTokenBucketTest, TestEmptyThenFillBucket) {
michael@0:   TestSimpleTokenBucket b(10, 1);
michael@0:   ASSERT_EQ(10U, b.getTokens(10));
michael@0:   ASSERT_EQ(0U, b.getTokens(1));
michael@0:   b.fastForward(50000);
michael@0:   ASSERT_EQ(10U, b.getTokens(10));
michael@0: }
michael@0: 
michael@0: TEST(SimpleTokenBucketTest, TestNoOverflow) {
michael@0:   TestSimpleTokenBucket b(10, 1);
michael@0:   ASSERT_EQ(10U, b.getTokens(10));
michael@0:   ASSERT_EQ(0U, b.getTokens(1));
michael@0:   b.fastForward(50000);
michael@0:   ASSERT_EQ(10U, b.getTokens(11));
michael@0: }
michael@0: 
michael@0: int main(int argc, char** argv) {
michael@0:   ::testing::InitGoogleTest(&argc, argv);
michael@0: 
michael@0:   int rv = RUN_ALL_TESTS();
michael@0:   return rv;
michael@0: }
michael@0: