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/finish_trajectory_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/proto/map_builder_service.pb.h"
00023 #include "google/protobuf/empty.pb.h"
00024
00025 namespace cartographer {
00026 namespace cloud {
00027 namespace handlers {
00028
00029 void FinishTrajectoryHandler::OnRequest(
00030 const proto::FinishTrajectoryRequest& request) {
00031 if (!GetContext<MapBuilderContextInterface>()->CheckClientIdForTrajectory(
00032 request.client_id(), request.trajectory_id())) {
00033 LOG(ERROR) << "Unknown trajectory with ID " << request.trajectory_id()
00034 << " and client_id " << request.client_id();
00035 Finish(::grpc::Status(::grpc::NOT_FOUND, "Unknown trajectory"));
00036 return;
00037 }
00038 GetContext<MapBuilderContextInterface>()->map_builder().FinishTrajectory(
00039 request.trajectory_id());
00040 GetUnsynchronizedContext<MapBuilderContextInterface>()
00041 ->NotifyFinishTrajectory(request.trajectory_id());
00042 if (GetUnsynchronizedContext<MapBuilderContextInterface>()
00043 ->local_trajectory_uploader()) {
00044 auto status =
00045 GetContext<MapBuilderContextInterface>()
00046 ->local_trajectory_uploader()
00047 ->FinishTrajectory(request.client_id(), request.trajectory_id());
00048 if (!status.ok()) {
00049 LOG(ERROR) << "Failed to finish trajectory in uplink: "
00050 << status.error_message();
00051 }
00052 }
00053 Send(absl::make_unique<google::protobuf::Empty>());
00054 }
00055
00056 }
00057 }
00058 }