Method loop

net/TcpConnection.cpp:236–274

}

void TcpConnection::loop() {
  auto status = [&] {
    td::ChainBufferReader *input_ptr;
    if (socket_pipe_) {
      TRY_STATUS(socket_pipe_.flush_read());
      input_ptr = &socket_pipe_.input_buffer();
    } else {
      TRY_STATUS(simple_pipe_.flush_read());
      input_ptr = &simple_pipe_.input_buffer();
    }
    auto &input = *input_ptr;
    bool exit_loop = false;
    if (!received_attestation_) {
      TRY_RESULT(attested_peer_info, cocoon::framed_tl_read<RATLSAttestedPeerInfo>(input));
      if (!attested_peer_info) {
        exit_loop = true;
      } else {
        process_attestation((*attested_peer_info).report());
      }
    }
    while (!exit_loop) {
      TRY_STATUS(receive(input, exit_loop));
    }
    if (socket_pipe_) {
      TRY_STATUS(socket_pipe_.flush_write());
    } else {
      TRY_STATUS(simple_pipe_.flush_write());
    }

    /*if (td::can_close(buffered_fd_)) {
      LOG(INFO) << "tcp: stopping (can close)";
      stop();
    }*/
    return td::Status::OK();
  }();
  if (status.is_error()) {
    fail(status.move_as_error_prefix("tcp: client got error: "));
  }
}

td::Status TcpConnection::receive_packet(td::BufferSlice data) {
  LOG(DEBUG) << "tcp: received packet of size " << data.size();