| 575 | } |
| 576 | |
| 577 | Status ExecEnv::StartStatestoreSubscriberService() { |
| 578 | LOG(INFO) << "Starting statestore subscriber service"; |
| 579 | |
| 580 | // Must happen after all topic registrations / callbacks are done |
| 581 | if (statestore_subscriber_.get() != nullptr) { |
| 582 | Status status = statestore_subscriber_->Start(); |
| 583 | if (!status.ok()) { |
| 584 | status.AddDetail("Statestore subscriber did not start up."); |
| 585 | return status; |
| 586 | } |
| 587 | if (statestore_subscriber_->IsRegistered()) SetStatestoreRegistrationCompleted(); |
| 588 | } |
| 589 | |
| 590 | return Status::OK(); |
| 591 | } |
| 592 | |
| 593 | Status ExecEnv::StartKrpcService() { |
| 594 | LOG(INFO) << "Starting KRPC service"; |