Method receive

net/TcpConnection.cpp:185–234

}

td::Status TcpConnection::receive(td::ChainBufferReader &input, bool &exit_loop) {
  if (stop_read_) {
    exit_loop = true;
    return td::Status::OK();
  }
  if (input.size() > 0) {
    received_bytes_ = 1;
  }
  if (!read_len_) {
    if (input.size() < 4) {
      exit_loop = true;
      return td::Status::OK();
    }

    td::MutableSlice s{reinterpret_cast<td::uint8 *>(&len_), 4};
    input.advance(4, s);

    LOG(DEBUG) << "tcp: len=" << len_;
    if (len_ > (1 << 24) || len_ < 4) {
      return td::Status::Error(ton::ErrorCode::protoviolation, PSTRING() << "Too big packet " << len_);
    }
    read_len_ = true;
  }
  if (input.size() < len_ + 4) {
    exit_loop = true;
    return td::Status::OK();
  }

  td::int32 in_seqno;
  td::MutableSlice s{reinterpret_cast<td::uint8 *>(&in_seqno), 4};
  input.advance(4, s);

  if (in_seqno != in_seqno_) {
    return td::Status::Error(ton::ErrorCode::protoviolation,
                             PSTRING() << "bad seqno: expected " << in_seqno_ << " got " << in_seqno);
  }

  auto data = input.cut_head(len_).move_as_buffer_slice();
  update_timer();

  exit_loop = false;
  read_len_ = false;
  in_seqno_++;
  len_ = 0;
  if (inited_) {
    return receive_packet(std::move(data));
  } else {
    return process_init_packet(std::move(data));
  }
}

void TcpConnection::loop() {
  auto status = [&] {