loolwsd/test/TileCacheTests.cpp | 51 ---------------------------------------- 1 file changed, 1 insertion(+), 50 deletions(-)
New commits: commit cfe414cc8aa9ca1319aba7d8110bd981cb7c0c08 Author: Ashod Nakashian <ashod.nakash...@collabora.co.uk> Date: Sun May 15 17:42:24 2016 -0400 loolwsd: simplified duplicate code with utility Change-Id: I2b9d88a78e73065d65b1722d363e8492f80438c9 Reviewed-on: https://gerrit.libreoffice.org/25017 Reviewed-by: Ashod Nakashian <ashnak...@gmail.com> Tested-by: Ashod Nakashian <ashnak...@gmail.com> diff --git a/loolwsd/test/TileCacheTests.cpp b/loolwsd/test/TileCacheTests.cpp index 65eb729..abd8865 100644 --- a/loolwsd/test/TileCacheTests.cpp +++ b/loolwsd/test/TileCacheTests.cpp @@ -56,9 +56,6 @@ class TileCacheTests : public CPPUNIT_NS::TestFixture const int docWidth, const int docHeight); - void getTileMessage(Poco::Net::WebSocket& ws, - std::string& tile); - static std::vector<char> genRandomData(const size_t size) { @@ -418,7 +415,7 @@ void TileCacheTests::requestTiles(Poco::Net::WebSocket& socket, const int part, part, pixTileSize, pixTileSize, tileX, tileY, tileWidth, tileHeight); sendTextFrame(socket, text); - getTileMessage(socket, tile); + tile = assertResponseLine(socket, "tile:", "requestTiles "); // expected tile: part= width= height= tileposx= tileposy= tilewidth= tileheight= Poco::StringTokenizer tokens(tile, " ", Poco::StringTokenizer::TOK_IGNORE_EMPTY | Poco::StringTokenizer::TOK_TRIM); CPPUNIT_ASSERT_EQUAL(std::string("tile:"), tokens[0]); @@ -433,52 +430,6 @@ void TileCacheTests::requestTiles(Poco::Net::WebSocket& socket, const int part, } } -void TileCacheTests::getTileMessage(Poco::Net::WebSocket& ws, std::string& tile) -{ - int flags; - int bytes; - int size = 0; - int retries = 10; - const Poco::Timespan waitTime(1000000); - - ws.setReceiveTimeout(0); - std::cout << "==> getTileMessage\n"; - tile.clear(); - do - { - std::vector<char> payload(READ_BUFFER_SIZE * 100); - if (retries > 0 && ws.poll(waitTime, Poco::Net::Socket::SELECT_READ)) - { - bytes = ws.receiveFrame(payload.data(), payload.capacity(), flags); - payload.resize(bytes > 0 ? bytes : 0); - std::cout << "Got " << bytes << " bytes, flags: " << std::bitset<8>(flags) << '\n'; - if (bytes > 0 && (flags & Poco::Net::WebSocket::FRAME_OP_BITMASK) != Poco::Net::WebSocket::FRAME_OP_CLOSE) - { - tile = LOOLProtocol::getFirstLine(payload.data(), bytes); - std::cout << "message: " << tile << '\n'; - Poco::StringTokenizer tokens(tile, " ", Poco::StringTokenizer::TOK_IGNORE_EMPTY | Poco::StringTokenizer::TOK_TRIM); - if (tokens.count() == 2 && - tokens[0] == "nextmessage:" && - LOOLProtocol::getTokenInteger(tokens[1], "size", size) && - size > 0) - { - payload.resize(size); - bytes = ws.receiveFrame(payload.data(), size, flags); - tile = LOOLProtocol::getFirstLine(payload.data(), bytes); - break; - } - } - retries = 10; - } - else - { - std::cout << "Timeout\n"; - --retries; - } - } - while (retries > 0 && (flags & Poco::Net::WebSocket::FRAME_OP_BITMASK) != Poco::Net::WebSocket::FRAME_OP_CLOSE); -} - CPPUNIT_TEST_SUITE_REGISTRATION(TileCacheTests); /* vim:set shiftwidth=4 softtabstop=4 expandtab: */ _______________________________________________ Libreoffice-commits mailing list libreoffice-comm...@lists.freedesktop.org https://lists.freedesktop.org/mailman/listinfo/libreoffice-commits