void FakeAcsAgentServerReactor::OnReadDone()

in cpp/fake_acs_agent_server_reactor.cc [45:62]

• 18 lines of code
• 5 McCabe index (conditional complexity)

void FakeAcsAgentServerReactor::OnReadDone(bool ok) {
  if (!ok) {
    Finish(grpc::Status(grpc::StatusCode::UNKNOWN, "Unexpected read failure"));
    return;
  }
  read_callback_(request_);
  if (request_.has_message_body() || request_.has_register_connection()) {
    std::unique_ptr<
        google::cloud::agentcommunication::v1::StreamAgentMessagesResponse>
        ack = MakeAckResponse(request_.message_id());
    absl::MutexLock lock(&response_mtx_);
    responses_.push(std::move(ack));
    if (!writing_) {
      NextWrite();
    }
  }
  StartRead(&request_);
}