EXPECT_FALSE(ec1);
EXPECT_FALSE(ec2);
- EXPECT_EQ(1, counters(client_id::admin)->get(queue_counters::l_qlen));
- EXPECT_EQ(1, counters(client_id::auth)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::admin)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::auth)->get(queue_counters::l_qlen));
context.poll();
EXPECT_TRUE(context.stopped());
ASSERT_TRUE(p2);
EXPECT_EQ(PhaseType::priority, *p2);
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_qlen));
- EXPECT_EQ(1, counters(client_id::admin)->get(queue_counters::l_res));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_prio));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_limit));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_cancel));
-
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_qlen));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_res));
- EXPECT_EQ(1, counters(client_id::auth)->get(queue_counters::l_prio));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_limit));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_cancel));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::admin)->get(queue_counters::l_res));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_prio));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_limit));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_cancel));
+
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_qlen));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_res));
+ EXPECT_EQ(1u, counters(client_id::auth)->get(queue_counters::l_prio));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_limit));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_cancel));
}
TEST(Queue, SyncRequest)
// We can't see the queue at length 1 as the queue len is decremented as the
//request is processed
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_qlen));
- EXPECT_EQ(1, counters(client_id::admin)->get(queue_counters::l_res));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_prio));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_limit));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_cancel));
-
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_qlen));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_res));
- EXPECT_EQ(1, counters(client_id::auth)->get(queue_counters::l_prio));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_limit));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_cancel));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::admin)->get(queue_counters::l_res));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_prio));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_limit));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_cancel));
+
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_qlen));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_res));
+ EXPECT_EQ(1u, counters(client_id::auth)->get(queue_counters::l_prio));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_limit));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_cancel));
}
TEST(Queue, RateLimit)
EXPECT_FALSE(ec3);
EXPECT_FALSE(ec4);
- EXPECT_EQ(1, counters(client_id::admin)->get(queue_counters::l_qlen));
- EXPECT_EQ(1, counters(client_id::auth)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::admin)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::auth)->get(queue_counters::l_qlen));
context.poll();
EXPECT_TRUE(context.stopped());
ASSERT_TRUE(ec4);
EXPECT_EQ(boost::system::errc::resource_unavailable_try_again, *ec4);
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_qlen));
- EXPECT_EQ(1, counters(client_id::admin)->get(queue_counters::l_res));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_prio));
- EXPECT_EQ(1, counters(client_id::admin)->get(queue_counters::l_limit));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_cancel));
-
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_qlen));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_res));
- EXPECT_EQ(1, counters(client_id::auth)->get(queue_counters::l_prio));
- EXPECT_EQ(1, counters(client_id::auth)->get(queue_counters::l_limit));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_cancel));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::admin)->get(queue_counters::l_res));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_prio));
+ EXPECT_EQ(1u, counters(client_id::admin)->get(queue_counters::l_limit));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_cancel));
+
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_qlen));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_res));
+ EXPECT_EQ(1u, counters(client_id::auth)->get(queue_counters::l_prio));
+ EXPECT_EQ(1u, counters(client_id::auth)->get(queue_counters::l_limit));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_cancel));
}
TEST(Queue, Cancel)
EXPECT_FALSE(ec1);
EXPECT_FALSE(ec2);
- EXPECT_EQ(1, counters(client_id::admin)->get(queue_counters::l_qlen));
- EXPECT_EQ(1, counters(client_id::auth)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::admin)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::auth)->get(queue_counters::l_qlen));
queue.cancel();
ASSERT_TRUE(ec2);
EXPECT_EQ(boost::asio::error::operation_aborted, *ec2);
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_qlen));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_res));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_prio));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_limit));
- EXPECT_EQ(1, counters(client_id::admin)->get(queue_counters::l_cancel));
-
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_qlen));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_res));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_prio));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_limit));
- EXPECT_EQ(1, counters(client_id::auth)->get(queue_counters::l_cancel));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_qlen));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_res));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_prio));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_limit));
+ EXPECT_EQ(1u, counters(client_id::admin)->get(queue_counters::l_cancel));
+
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_qlen));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_res));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_prio));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_limit));
+ EXPECT_EQ(1u, counters(client_id::auth)->get(queue_counters::l_cancel));
}
TEST(Queue, CancelClient)
EXPECT_FALSE(ec1);
EXPECT_FALSE(ec2);
- EXPECT_EQ(1, counters(client_id::admin)->get(queue_counters::l_qlen));
- EXPECT_EQ(1, counters(client_id::auth)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::admin)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::auth)->get(queue_counters::l_qlen));
queue.cancel(client_id::admin);
ASSERT_TRUE(p2);
EXPECT_EQ(PhaseType::priority, *p2);
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_qlen));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_res));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_prio));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_limit));
- EXPECT_EQ(1, counters(client_id::admin)->get(queue_counters::l_cancel));
-
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_qlen));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_res));
- EXPECT_EQ(1, counters(client_id::auth)->get(queue_counters::l_prio));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_limit));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_cancel));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_qlen));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_res));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_prio));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_limit));
+ EXPECT_EQ(1u, counters(client_id::admin)->get(queue_counters::l_cancel));
+
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_qlen));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_res));
+ EXPECT_EQ(1u, counters(client_id::auth)->get(queue_counters::l_prio));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_limit));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_cancel));
}
TEST(Queue, CancelOnDestructor)
queue.async_request(client_id::admin, {}, now, 1, capture(ec1, p1));
queue.async_request(client_id::auth, {}, now, 1, capture(ec2, p2));
- EXPECT_EQ(1, counters(client_id::admin)->get(queue_counters::l_qlen));
- EXPECT_EQ(1, counters(client_id::auth)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::admin)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::auth)->get(queue_counters::l_qlen));
}
EXPECT_FALSE(ec1);
ASSERT_TRUE(ec2);
EXPECT_EQ(boost::asio::error::operation_aborted, *ec2);
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_qlen));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_res));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_prio));
- EXPECT_EQ(0, counters(client_id::admin)->get(queue_counters::l_limit));
- EXPECT_EQ(1, counters(client_id::admin)->get(queue_counters::l_cancel));
-
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_qlen));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_res));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_prio));
- EXPECT_EQ(0, counters(client_id::auth)->get(queue_counters::l_limit));
- EXPECT_EQ(1, counters(client_id::auth)->get(queue_counters::l_cancel));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_qlen));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_res));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_prio));
+ EXPECT_EQ(0u, counters(client_id::admin)->get(queue_counters::l_limit));
+ EXPECT_EQ(1u, counters(client_id::admin)->get(queue_counters::l_cancel));
+
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_qlen));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_res));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_prio));
+ EXPECT_EQ(0u, counters(client_id::auth)->get(queue_counters::l_limit));
+ EXPECT_EQ(1u, counters(client_id::auth)->get(queue_counters::l_cancel));
}
// return a lambda from capture() that's bound to run on the given executor
queue.async_request(client_id::admin, {}, now, 1, capture(ex2, ec1, p1));
queue.async_request(client_id::auth, {}, now, 1, capture(ex2, ec2, p2));
- EXPECT_EQ(1, counters(client_id::admin)->get(queue_counters::l_qlen));
- EXPECT_EQ(1, counters(client_id::auth)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::admin)->get(queue_counters::l_qlen));
+ EXPECT_EQ(1u, counters(client_id::auth)->get(queue_counters::l_qlen));
callback_context.poll();
// maintains work on callback executor while in queue