void AcsAgentClientReactor::OnReadDone()

in cpp/acs_agent_client_reactor.cc [140:159]

• 20 lines of code
• 4 McCabe index (conditional complexity)

void AcsAgentClientReactor::OnReadDone(bool ok) {
  if (!ok) {
    ABSL_VLOG(1) << "OnReadDone not ok";
    {
      absl::MutexLock lock(&status_mtx_);
      if (rpc_cancelled_by_client_) {
        read_callback_(Response(), RpcStatus::kRpcClosedByClient);
        return;
      }
    }
    read_callback_(Response(), RpcStatus::kRpcClosedByServer);
    return;
  }
  if (response_.has_message_body()) {
    ABSL_VLOG(1) << "Client Ack on message with id: " << response_.message_id();
    Ack(response_.message_id());
  }
  read_callback_(std::move(response_), RpcStatus::kRpcOk);
  StartRead(&response_);
}