Moves channel-dependent audio input processing to separate encoder task queue

webrtc/base/swap_queue_unittest.cc

Index: webrtc/base/swap_queue_unittest.cc
diff --git a/webrtc/base/swap_queue_unittest.cc b/webrtc/base/swap_queue_unittest.cc
index ff00626cbc09e81a190e293082456df053c2781d..aef5a44a8b163652701efc56eedcdd329e026989 100644
--- a/webrtc/base/swap_queue_unittest.cc
+++ b/webrtc/base/swap_queue_unittest.cc
@@ -42,17 +42,24 @@ class LengthVerifierFunctor {
 }  // anonymous namespace
 
 TEST(SwapQueueTest, BasicOperation) {
+  const size_t kCapacity = 2;
   std::vector<int> i(kChunkSize, 0);
-  SwapQueue<std::vector<int>> queue(2, i);
+  SwapQueue<std::vector<int>> queue(kCapacity, i);
 
+  EXPECT_EQ(queue.Capacity(), kCapacity);
+  EXPECT_EQ(queue.Size(), 0u);
   EXPECT_TRUE(queue.Insert(&i));
   EXPECT_EQ(i.size(), kChunkSize);
+  EXPECT_EQ(queue.Size(), 1u);
   EXPECT_TRUE(queue.Insert(&i));
   EXPECT_EQ(i.size(), kChunkSize);
+  EXPECT_EQ(queue.Size(), 2u);

[the sun, 2017/03/23 12:45:55]

nit: check capacity again here (guard against regressions, document behavior)

[henrika_webrtc, 2017/03/23 14:02:17]

These changes are now removed.

   EXPECT_TRUE(queue.Remove(&i));
   EXPECT_EQ(i.size(), kChunkSize);
+  EXPECT_EQ(queue.Size(), 1u);
   EXPECT_TRUE(queue.Remove(&i));
   EXPECT_EQ(i.size(), kChunkSize);
+  EXPECT_EQ(queue.Size(), 0u);
 }
 
 TEST(SwapQueueTest, FullQueue) {