mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-05-12 19:02:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

idl: add start_frame() overload for seastar::simple_output_stream

Browse Source 
(cherry picked from commit 018d16d315)

(part of #2468)
This commit is contained in:
Paweł Dziepak
2017-02-27 16:59:27 +00:00
committed by Avi Kivity
parent a85b70d846
commit cd14b83192
1 changed files with 38 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
serialization_visitors.hh
View File

@@ -115,4 +115,42 @@ inline frame<seastar::measuring_output_stream> start_frame(seastar::measuring_ou
return { };
}
template<>
class place_holder<seastar::simple_output_stream> {
seastar::simple_output_stream _substream;
public:
place_holder(seastar::simple_output_stream substream)
: _substream(substream) { }
void set(seastar::simple_output_stream& out, size_type v) {
serialize(_substream, v);
}
};
template<>
class frame<seastar::simple_output_stream> : public place_holder<seastar::simple_output_stream> {
char* _start;
public:
frame(seastar::simple_output_stream ph, char* start)
: place_holder(ph), _start(start) { }
void end(seastar::simple_output_stream& out) {
set(out, out.begin() - _start);
}
};
inline place_holder<seastar::simple_output_stream> start_place_holder(seastar::simple_output_stream& out) {
return { out.write_substream(sizeof(size_type)) };
}
inline frame<seastar::simple_output_stream> start_frame(seastar::simple_output_stream& out) {
auto start = out.begin();
auto substream = out.write_substream(sizeof(size_type));
{
auto sstr = substream;
serialize(sstr, size_type(0));
}
return frame<seastar::simple_output_stream>(substream, start);
}
}