diff --git a/td/mtproto/Transport.cpp b/td/mtproto/Transport.cpp index c68cb899..cafaa08e 100644 --- a/td/mtproto/Transport.cpp +++ b/td/mtproto/Transport.cpp @@ -319,7 +319,7 @@ Result 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) { diff --git a/tddb/td/db/binlog/BinlogEvent.h b/tddb/td/db/binlog/BinlogEvent.h index 5a8bff44..334f7cdc 100644 --- a/tddb/td/db/binlog/BinlogEvent.h +++ b/tddb/td/db/binlog/BinlogEvent.h @@ -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()) << "]"; } diff --git a/tddb/td/db/binlog/detail/BinlogEventsProcessor.cpp b/tddb/td/db/binlog/detail/BinlogEventsProcessor.cpp index 1eb23fe2..ad2820de 100644 --- a/tddb/td/db/binlog/detail/BinlogEventsProcessor.cpp +++ b/tddb/td/db/binlog/detail/BinlogEventsProcessor.cpp @@ -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