local_trajectory_uploader.cc File Reference

#include "cartographer/cloud/internal/local_trajectory_uploader.h"
#include <map>
#include <thread>
#include "async_grpc/client.h"
#include "cartographer/cloud/internal/handlers/add_sensor_data_batch_handler.h"
#include "cartographer/cloud/internal/handlers/add_trajectory_handler.h"
#include "cartographer/cloud/internal/handlers/finish_trajectory_handler.h"
#include "cartographer/cloud/internal/sensor/serialization.h"
#include "cartographer/common/blocking_queue.h"
#include "cartographer/common/make_unique.h"
#include "glog/logging.h"
#include "grpc++/grpc++.h"

Include dependency graph for local_trajectory_uploader.cc:

Go to the source code of this file.

Namespaces
	cartographer
	cartographer::cloud

Functions
std::unique_ptr< LocalTrajectoryUploaderInterface >	cartographer::cloud::CreateLocalTrajectoryUploader (const std::string &uplink_server_address, int batch_size, bool enable_ssl_encryption)

Variable Documentation

batch_size_

int batch_size_

private

Definition at line 70 of file local_trajectory_uploader.cc.

client_channel_

std::shared_ptr<::grpc::Channel> client_channel_

private

Definition at line 69 of file local_trajectory_uploader.cc.

local_to_cloud_trajectory_id_map_

std::map<int, int> local_to_cloud_trajectory_id_map_

private

Definition at line 71 of file local_trajectory_uploader.cc.

send_queue_

common::BlockingQueue<std::unique_ptr<proto::SensorData> > send_queue_

private

Definition at line 72 of file local_trajectory_uploader.cc.

shutting_down_

bool shutting_down_ = false

private

Definition at line 73 of file local_trajectory_uploader.cc.

upload_thread_

std::unique_ptr<std::thread> upload_thread_

private

Definition at line 74 of file local_trajectory_uploader.cc.