Go to the documentation of this file.00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017 #include "cartographer/cloud/internal/handlers/load_state_handler.h"
00018
00019 #include "absl/memory/memory.h"
00020 #include "async_grpc/rpc_handler.h"
00021 #include "cartographer/cloud/internal/map_builder_context_interface.h"
00022 #include "cartographer/cloud/internal/mapping/serialization.h"
00023 #include "cartographer/cloud/proto/map_builder_service.pb.h"
00024
00025 namespace cartographer {
00026 namespace cloud {
00027 namespace handlers {
00028
00029 void LoadStateHandler::OnRequest(const proto::LoadStateRequest& request) {
00030 switch (request.state_chunk_case()) {
00031 case proto::LoadStateRequest::kSerializedData:
00032 reader_.AddProto(request.serialized_data());
00033 break;
00034 case proto::LoadStateRequest::kSerializationHeader:
00035 reader_.AddProto(request.serialization_header());
00036 break;
00037 case proto::LoadStateRequest::kClientId:
00038 client_id_ = request.client_id();
00039 break;
00040 default:
00041 LOG(FATAL) << "Unhandled proto::LoadStateRequest case.";
00042 }
00043 load_frozen_state_ = request.load_frozen_state();
00044 }
00045
00046 void LoadStateHandler::OnReadsDone() {
00047 auto trajectory_remapping =
00048 GetContext<MapBuilderContextInterface>()->map_builder().LoadState(
00049 &reader_, load_frozen_state_);
00050 for (const auto& entry : trajectory_remapping) {
00051 GetContext<MapBuilderContextInterface>()->RegisterClientIdForTrajectory(
00052 client_id_, entry.second);
00053 }
00054 auto response = absl::make_unique<proto::LoadStateResponse>();
00055 *response->mutable_trajectory_remapping() = ToProto(trajectory_remapping);
00056 Send(std::move(response));
00057 }
00058
00059 }
00060 }
00061 }