ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-20 11:05:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Improve websocket send performance (RIPD-1158)

Browse Source
This commit is contained in:
Miguel Portilla
2016-05-18 12:28:02 -04:00
committed by Nik Bougalis
parent 154e90b1ca
commit b14555c742
1 changed files with 5 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/ripple/server/impl/ServerHandlerImp.cpp
View File

@@ -288,15 +288,11 @@ ServerHandlerImp::onWSMessage(
{ {
auto const jr = auto const jr =
this->processSession(session, jc, jv); this->processSession(session, jc, jv);
beast::streambuf sb; auto const s = to_string(jr);
Json::stream(jr, auto const n = s.length();
[&sb](auto const p, auto const n) beast::streambuf sb(n);
{ sb.commit(boost::asio::buffer_copy(
sb.commit(boost::asio::buffer_copy( sb.prepare(n), boost::asio::buffer(s.c_str(), n)));
sb.prepare(n), boost::asio::buffer(p, n)));
});
JLOG(m_journal.trace())
<< "Websocket sending '" << jr << "'";
session->send(std::make_shared< session->send(std::make_shared<
StreambufWSMsg<decltype(sb)>>(std::move(sb))); StreambufWSMsg<decltype(sb)>>(std::move(sb)));
session->complete(); session->complete();