Minor fixes.
GitOrigin-RevId: fb737b1ddcb72ce4c6393d9e282336184285dafd
This commit is contained in:
parent
251553b2e9
commit
744df9f511
@ -319,7 +319,7 @@ Result<Transport::ReadResult> Transport::read(MutableSlice message, const AuthKe
|
||||
TRY_STATUS(read_crypto(message, auth_key, info, &data));
|
||||
}
|
||||
return ReadResult::make_packet(data);
|
||||
} // namespace mtproto
|
||||
}
|
||||
|
||||
size_t Transport::write(const Storer &storer, const AuthKey &auth_key, PacketInfo *info, MutableSlice dest) {
|
||||
if (info->type == PacketInfo::EndToEnd) {
|
||||
|
@ -80,7 +80,7 @@ struct BinlogEvent {
|
||||
Status init(BufferSlice &&raw_event, bool check_crc = true) TD_WARN_UNUSED_RESULT;
|
||||
|
||||
static BufferSlice create_raw(uint64 id, int32 type, int32 flags, const Storer &storer);
|
||||
std::string public_to_string() {
|
||||
std::string public_to_string() const {
|
||||
return PSTRING() << "LogEvent[" << tag("id", format::as_hex(id_)) << tag("type", type_) << tag("flags", flags_)
|
||||
<< tag("data", data_.size()) << "]";
|
||||
}
|
||||
|
@ -12,6 +12,7 @@
|
||||
|
||||
namespace td {
|
||||
namespace detail {
|
||||
|
||||
void BinlogEventsProcessor::do_event(BinlogEvent &&event) {
|
||||
offset_ = event.offset_;
|
||||
auto fixed_id = event.id_ * 2;
|
||||
@ -66,5 +67,6 @@ void BinlogEventsProcessor::compactify() {
|
||||
empty_events_ = 0;
|
||||
CHECK(ids_.size() == events_.size());
|
||||
}
|
||||
|
||||
} // namespace detail
|
||||
} // namespace td
|
||||
|
Loading…
Reference in New Issue
Block a user