From mboxrd@z Thu Jan 1 00:00:00 1970 Received: from eggs.gnu.org ([2001:4830:134:3::10]:52253) by lists.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1XbUnP-0004Ce-Lp for qemu-devel@nongnu.org; Tue, 07 Oct 2014 09:27:24 -0400 Received: from Debian-exim by eggs.gnu.org with spam-scanned (Exim 4.71) (envelope-from ) id 1XbUnG-0007iQ-4x for qemu-devel@nongnu.org; Tue, 07 Oct 2014 09:27:19 -0400 Received: from lputeaux-656-01-25-125.w80-12.abo.wanadoo.fr ([80.12.84.125]:60874 helo=paradis.irqsave.net) by eggs.gnu.org with esmtp (Exim 4.71) (envelope-from ) id 1XbUnF-0007hh-Vg for qemu-devel@nongnu.org; Tue, 07 Oct 2014 09:27:10 -0400 From: =?UTF-8?q?Beno=C3=AEt=20Canet?= Date: Tue, 7 Oct 2014 15:24:34 +0200 Message-Id: <1412688279-8312-4-git-send-email-benoit.canet@nodalink.com> In-Reply-To: <1412688279-8312-1-git-send-email-benoit.canet@nodalink.com> References: <1412688279-8312-1-git-send-email-benoit.canet@nodalink.com> Subject: [Qemu-devel] [PATCH v1 3/8] throttle: Add throttle group infrastructure tests List-Id: List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , To: qemu-devel@nongnu.org Cc: kwolf@redhat.com, famz@redhat.com, =?UTF-8?q?Beno=C3=AEt=20Canet?= , stefanha@redhat.com Signed-off-by: Benoit Canet --- tests/test-throttle.c | 51 +++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 51 insertions(+) diff --git a/tests/test-throttle.c b/tests/test-throttle.c index 3e52df3..ecb5504 100644 --- a/tests/test-throttle.c +++ b/tests/test-throttle.c @@ -15,6 +15,7 @@ #include "block/aio.h" #include "qemu/throttle.h" #include "qemu/error-report.h" +#include "block/throttle-groups.h" static AioContext *ctx; static LeakyBucket bkt; @@ -500,6 +501,55 @@ static void test_accounting(void) (64.0 / 13))); } +static void test_groups(void) +{ + bool removed; + + ThrottleState *ts_foo, *ts_bar, *tmp; + + ts_bar = throttle_group_incref("bar"); + throttle_group_set_token(ts_bar, (BlockDriverState *) 0x5, false); + ts_foo = throttle_group_incref("foo"); + + tmp = throttle_group_incref("foo"); + throttle_group_set_token(tmp, (BlockDriverState *) 0x7, true); + g_assert(tmp == ts_foo); + + tmp = throttle_group_incref("bar"); + g_assert(tmp == ts_bar); + + tmp = throttle_group_incref("bar"); + g_assert(tmp == ts_bar); + + g_assert((int64_t) throttle_group_token(ts_bar, false) == 0x5); + g_assert((int64_t) throttle_group_token(ts_foo, true) == 0x7); + + removed = throttle_group_unref(ts_foo); + g_assert(removed); + removed = throttle_group_unref(ts_bar); + g_assert(removed); + + g_assert((int64_t) throttle_group_token(ts_foo, true) == 0x7); + + removed = throttle_group_unref(ts_foo); + g_assert(removed); + removed = throttle_group_unref(ts_bar); + g_assert(removed); + + /* "foo" group should be destroyed when reaching this */ + removed = throttle_group_unref(ts_foo); + g_assert(!removed); + + g_assert((int64_t) throttle_group_token(ts_bar, false) == 0x5); + + removed = throttle_group_unref(ts_bar); + g_assert(removed); + + /* "bar" group should be destroyed when reaching this */ + removed = throttle_group_unref(ts_bar); + g_assert(!removed); +} + int main(int argc, char **argv) { GSource *src; @@ -533,6 +583,7 @@ int main(int argc, char **argv) g_test_add_func("/throttle/config/is_valid", test_is_valid); g_test_add_func("/throttle/config_functions", test_config_functions); g_test_add_func("/throttle/accounting", test_accounting); + g_test_add_func("/throttle/groups", test_groups); return g_test_run(); } -- 2.1.1