X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftest%2Frbd_mirror%2Ftest_mock_ImageSyncThrottler.cc;fp=src%2Fceph%2Fsrc%2Ftest%2Frbd_mirror%2Ftest_mock_ImageSyncThrottler.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=24815aeb799aa2bf41d818a708b2e78dd3f7a137;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

diff --git a/src/ceph/src/test/rbd_mirror/test_mock_ImageSyncThrottler.cc b/src/ceph/src/test/rbd_mirror/test_mock_ImageSyncThrottler.cc
deleted file mode 100644
index 24815ae..0000000
--- a/src/ceph/src/test/rbd_mirror/test_mock_ImageSyncThrottler.cc
+++ /dev/null
@@ -1,182 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-/*
- * Ceph - scalable distributed file system
- *
- * Copyright (C) 2016 SUSE LINUX GmbH
- *
- * This is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software
- * Foundation.  See file COPYING.
- *
- */
-
-#include "test/rbd_mirror/test_mock_fixture.h"
-#include "test/librbd/mock/MockImageCtx.h"
-
-namespace librbd {
-
-namespace {
-
-struct MockTestImageCtx : public librbd::MockImageCtx {
-  MockTestImageCtx(librbd::ImageCtx &image_ctx)
-    : librbd::MockImageCtx(image_ctx) {
-  }
-};
-
-} // anonymous namespace
-
-} // namespace librbd
-
-// template definitions
-#include "tools/rbd_mirror/ImageSyncThrottler.cc"
-
-namespace rbd {
-namespace mirror {
-
-class TestMockImageSyncThrottler : public TestMockFixture {
-public:
-  typedef ImageSyncThrottler<librbd::MockTestImageCtx> MockImageSyncThrottler;
-
-};
-
-TEST_F(TestMockImageSyncThrottler, Single_Sync) {
-  MockImageSyncThrottler throttler;
-  C_SaferCond on_start;
-  throttler.start_op("id", &on_start);
-  ASSERT_EQ(0, on_start.wait());
-  throttler.finish_op("id");
-}
-
-TEST_F(TestMockImageSyncThrottler, Multiple_Syncs) {
-  MockImageSyncThrottler throttler;
-  throttler.set_max_concurrent_syncs(2);
-
-  C_SaferCond on_start1;
-  throttler.start_op("id1", &on_start1);
-  C_SaferCond on_start2;
-  throttler.start_op("id2", &on_start2);
-  C_SaferCond on_start3;
-  throttler.start_op("id3", &on_start3);
-  C_SaferCond on_start4;
-  throttler.start_op("id4", &on_start4);
-
-  ASSERT_EQ(0, on_start2.wait());
-  throttler.finish_op("id2");
-  ASSERT_EQ(0, on_start3.wait());
-  throttler.finish_op("id3");
-  ASSERT_EQ(0, on_start1.wait());
-  throttler.finish_op("id1");
-  ASSERT_EQ(0, on_start4.wait());
-  throttler.finish_op("id4");
-}
-
-TEST_F(TestMockImageSyncThrottler, Cancel_Running_Sync) {
-  MockImageSyncThrottler throttler;
-  C_SaferCond on_start;
-  throttler.start_op("id", &on_start);
-  ASSERT_EQ(0, on_start.wait());
-  ASSERT_FALSE(throttler.cancel_op("id"));
-  throttler.finish_op("id");
-}
-
-TEST_F(TestMockImageSyncThrottler, Cancel_Waiting_Sync) {
-  MockImageSyncThrottler throttler;
-  throttler.set_max_concurrent_syncs(1);
-
-  C_SaferCond on_start1;
-  throttler.start_op("id1", &on_start1);
-  C_SaferCond on_start2;
-  throttler.start_op("id2", &on_start2);
-
-  ASSERT_EQ(0, on_start1.wait());
-  ASSERT_TRUE(throttler.cancel_op("id2"));
-  ASSERT_EQ(-ECANCELED, on_start2.wait());
-  throttler.finish_op("id1");
-}
-
-
-TEST_F(TestMockImageSyncThrottler, Cancel_Running_Sync_Start_Waiting) {
-  MockImageSyncThrottler throttler;
-  throttler.set_max_concurrent_syncs(1);
-
-  C_SaferCond on_start1;
-  throttler.start_op("id1", &on_start1);
-  C_SaferCond on_start2;
-  throttler.start_op("id2", &on_start2);
-
-  ASSERT_EQ(0, on_start1.wait());
-  ASSERT_FALSE(throttler.cancel_op("id1"));
-  throttler.finish_op("id1");
-  ASSERT_EQ(0, on_start2.wait());
-  throttler.finish_op("id2");
-}
-
-TEST_F(TestMockImageSyncThrottler, Increase_Max_Concurrent_Syncs) {
-  MockImageSyncThrottler throttler;
-  throttler.set_max_concurrent_syncs(2);
-
-  C_SaferCond on_start1;
-  throttler.start_op("id1", &on_start1);
-  C_SaferCond on_start2;
-  throttler.start_op("id2", &on_start2);
-  C_SaferCond on_start3;
-  throttler.start_op("id3", &on_start3);
-  C_SaferCond on_start4;
-  throttler.start_op("id4", &on_start4);
-  C_SaferCond on_start5;
-  throttler.start_op("id5", &on_start5);
-
-  ASSERT_EQ(0, on_start1.wait());
-  ASSERT_EQ(0, on_start2.wait());
-
-  throttler.set_max_concurrent_syncs(4);
-
-  ASSERT_EQ(0, on_start3.wait());
-  ASSERT_EQ(0, on_start4.wait());
-
-  throttler.finish_op("id4");
-  ASSERT_EQ(0, on_start5.wait());
-
-  throttler.finish_op("id1");
-  throttler.finish_op("id2");
-  throttler.finish_op("id3");
-  throttler.finish_op("id5");
-}
-
-TEST_F(TestMockImageSyncThrottler, Decrease_Max_Concurrent_Syncs) {
-  MockImageSyncThrottler throttler;
-  throttler.set_max_concurrent_syncs(4);
-
-  C_SaferCond on_start1;
-  throttler.start_op("id1", &on_start1);
-  C_SaferCond on_start2;
-  throttler.start_op("id2", &on_start2);
-  C_SaferCond on_start3;
-  throttler.start_op("id3", &on_start3);
-  C_SaferCond on_start4;
-  throttler.start_op("id4", &on_start4);
-  C_SaferCond on_start5;
-  throttler.start_op("id5", &on_start5);
-
-  ASSERT_EQ(0, on_start1.wait());
-  ASSERT_EQ(0, on_start2.wait());
-  ASSERT_EQ(0, on_start3.wait());
-  ASSERT_EQ(0, on_start4.wait());
-
-  throttler.set_max_concurrent_syncs(2);
-
-  throttler.finish_op("id1");
-  throttler.finish_op("id2");
-  throttler.finish_op("id3");
-
-  ASSERT_EQ(0, on_start5.wait());
-
-  throttler.finish_op("id4");
-  throttler.finish_op("id5");
-}
-
-} // namespace mirror
-} // namespace rbd
-