You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by bm...@apache.org on 2019/12/04 17:15:21 UTC
[mesos] 03/04: Updated StreamingHttpConnection to allow writing
serialized records.
This is an automated email from the ASF dual-hosted git repository.
bmahler pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/mesos.git
commit a15e5a3b5f5620b933ab709839a5ac5714e5c56c
Author: Benjamin Mahler <bm...@apache.org>
AuthorDate: Mon Nov 25 17:43:18 2019 -0500
Updated StreamingHttpConnection to allow writing serialized records.
In order to more efficiently write the initial payload of the
master's operator API event stream, we will need to directly
serialize from the in-memory master state. To enable this, this
patch updates the streaming http connection to allow writing an
already serialized record.
Review: https://reviews.apache.org/r/71826
---
src/common/http.hpp | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/src/common/http.hpp b/src/common/http.hpp
index 534fc26..47a4d6a 100644
--- a/src/common/http.hpp
+++ b/src/common/http.hpp
@@ -168,6 +168,12 @@ struct StreamingHttpConnection
return writer.write(::recordio::encode(record));
}
+ // Like the above send, but for already serialized data.
+ bool send(const std::string& event)
+ {
+ return writer.write(::recordio::encode(event));
+ }
+
bool close()
{
return writer.close();