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

loolwsd: split tilecombined in the TileQueue

Browse source 
Delaying the splitting maximizes the chances
that we will deduplicate and combine them
in the queue optimally.

Change-Id: Ib721fe7596de7ad5d34159949fe75f16e861eb24
Reviewed-on: https://gerrit.libreoffice.org/29287
Reviewed-by: Ashod Nakashian <ashnakash@gmail.com>
Tested-by: Ashod Nakashian <ashnakash@gmail.com>
This commit is contained in:
Ashod Nakashian 2016-09-25 16:04:27 -04:00 committed by Ashod Nakashian
parent d9c90e30fd
commit e9a7f8c6c6
3 changed files with 25 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
loolwsd/DocumentBroker.cpp
View file

@ -526,6 +526,7 @@ void DocumentBroker::handleTileCombinedRequest(TileCombined& tileCombined,
Log::trace() << "TileCombined request for " << tileCombined.serialize() << Log::end;
// Satisfy as many tiles from the cache.
std::vector<TileDesc> tiles;
for (auto& tile : tileCombined.getTiles())
{
std::unique_ptr<std::fstream> cachedTile = _tileCache->lookupTile(tile);
@ -559,14 +560,20 @@ void DocumentBroker::handleTileCombinedRequest(TileCombined& tileCombined,
// Not cached, needs rendering.
tile.setVersion(++_tileVersion);
tileCache().subscribeToTileRendering(tile, session);
// Forward to child to render.
Log::debug() << "Sending render request for tile (" << tile.getPart() << ',' << tile.getTilePosX() << ',' << tile.getTilePosY() << ")." << Log::end;
const auto req = tile.serialize("tile");
Log::debug() << "Tile request: " << req << Log::end;
_childProcess->getWebSocket()->sendFrame(req.data(), req.size());
tiles.push_back(tile);
}
}
if (!tiles.empty())
{
auto newTileCombined = TileCombined::create(tiles);
newTileCombined.setVersion(++_tileVersion);
// Forward to child to render.
const auto req = newTileCombined.serialize("tilecombine");
Log::debug() << "Sending residual tilecombine: " << req << Log::end;
_childProcess->getWebSocket()->sendFrame(req.data(), req.size());
}
}
void DocumentBroker::cancelTileRequests(const std::shared_ptr<ClientSession>& session)

17
loolwsd/MessageQueue.cpp
View file

@ -106,17 +106,22 @@ void TileQueue::put_impl(const Payload& value)
Log::trace() << "After canceltiles have " << _queue.size() << " in queue." << Log::end;
return;
}
// TODO because we are doing tile combining ourselves in the get_impl(),
// we could split the "tilecombine" messages into separate tiles here;
// could lead to some improvements in case we are getting subsequent
// tilecombines with overlapping, but not completely same areas.
else if (msg.compare(0, 10, "tilecombine") == 0)
{
// Breakup tilecombine and deduplicate.
const auto tileCombined = TileCombined::parse(msg);
for (auto& tile : tileCombined.getTiles())
{
const auto newMsg = tile.serialize("tile");
_queue.push_back(Payload(newMsg.data(), newMsg.data() + newMsg.size()));
}
}
if (!_queue.empty())
{
// TODO probably we could do the same with the invalidation callbacks
// (later one wins).
if (msg.compare(0, 4, "tile") == 0 || msg.compare(0, 10, "tilecombine") == 0)
if (msg.compare(0, 4, "tile") == 0)
{
const auto newMsg = msg.substr(0, msg.find(" ver"));

1
loolwsd/TileCache.cpp
View file

@ -433,6 +433,7 @@ void TileCache::subscribeToTileRendering(const TileDesc& tile, const std::shared
{
Log::debug("Redundant request to subscribe on tile " + name);
tileBeingRendered->setVersion(tile.getVersion());
return;
}
}