strepsirrhini/libreoffice-online
3
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

wsd: load torture test

Browse source 
Load multiple views on multiple documents
concurrently and verify that the number
of views for each case is consistent and
as expected.

Change-Id: Ie550dd42880da7bdd0aef6d642e9b000be5c3f84
Reviewed-on: https://gerrit.libreoffice.org/32556
Reviewed-by: Ashod Nakashian <ashnakash@gmail.com>
Tested-by: Ashod Nakashian <ashnakash@gmail.com>
This commit is contained in:
Ashod Nakashian 2016-12-21 21:22:03 -05:00 committed by Ashod Nakashian
parent 94ed8393c5
commit 2f81b37c07
1 changed files with 88 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

88
test/httpwstest.cpp
View file

@ -64,6 +64,7 @@ class HTTPWSTest : public CPPUNIT_NS::TestFixture
CPPUNIT_TEST(testCloseAfterClose);
CPPUNIT_TEST(testConnectNoLoad); // This fails most of the times but occasionally succeeds
CPPUNIT_TEST(testLoad);
CPPUNIT_TEST(testLoadTorture);
CPPUNIT_TEST(testBadLoad);
CPPUNIT_TEST(testReload);
CPPUNIT_TEST(testGetTextSelection);
@ -107,6 +108,7 @@ class HTTPWSTest : public CPPUNIT_NS::TestFixture
void testCloseAfterClose();
void testConnectNoLoad();
void testLoad();
void testLoadTorture();
void testBadLoad();
void testReload();
void testGetTextSelection();
@ -145,6 +147,11 @@ class HTTPWSTest : public CPPUNIT_NS::TestFixture
void loadDoc(const std::string& documentURL, const std::string& testname);
void loadTorture(const std::string& docName,
const size_t thread_count,
const size_t loads_per_thread,
const size_t max_jitter_ms);
void getPartHashCodes(const std::string response,
std::vector<std::string>& parts);
@ -378,6 +385,87 @@ void HTTPWSTest::testLoad()
loadDoc(documentURL, "load ");
}
void HTTPWSTest::loadTorture(const std::string& docName,
const size_t thread_count,
const size_t loads_per_thread,
const size_t max_jitter_ms)
{
const auto testname = "loadTorture ";
// Load same document from many threads together.
std::string documentPath, documentURL;
getDocumentPathAndURL(docName, documentPath, documentURL);
const auto number_of_loads = thread_count * loads_per_thread;
const int exp_sum_view_ids = number_of_loads * (number_of_loads - 1) / 2; // 0-based view-ids.
std::atomic<int> sum_view_ids;
sum_view_ids = 0;
std::vector<std::thread> threads;
for (size_t i = 0; i < thread_count; ++i)
{
threads.emplace_back([&]
{
try
{
for (size_t j = 0; j < loads_per_thread; ++j)
{
// Load a document and wait for the status.
Poco::Net::HTTPRequest request(Poco::Net::HTTPRequest::HTTP_GET, documentURL);
auto socket = connectLOKit(_uri, request, _response, testname);
sendTextFrame(socket, "load url=" + documentURL, testname);
const auto status = assertResponseString(socket, "status:", testname);
int viewid = -1;
LOOLProtocol::getTokenIntegerFromMessage(status, "viewid", viewid);
sum_view_ids += viewid;
if (max_jitter_ms > 0)
{
const auto ms = std::chrono::milliseconds(Util::rng::getNext() % max_jitter_ms);
std::this_thread::sleep_for(ms);
}
}
}
catch (const Poco::Exception& exc)
{
CPPUNIT_FAIL(exc.displayText());
}
});
}
for (auto& thread : threads)
{
thread.join();
}
CPPUNIT_ASSERT_EQUAL(exp_sum_view_ids, sum_view_ids.load());
}
void HTTPWSTest::testLoadTorture()
{
const auto thread_count = 3;
const auto loads_per_thread = 3;
const auto max_jitter_ms = 75;
std::vector<std::string> docNames = { "setclientpart.ods", "hello.odt", "empty.ods" };
std::vector<std::thread> threads;
for (const auto& docName : docNames)
{
threads.emplace_back([&]
{
loadTorture(docName, thread_count, loads_per_thread, max_jitter_ms);
});
}
for (auto& thread : threads)
{
thread.join();
}
}
void HTTPWSTest::testBadLoad()
{
try