global_data.h

/******************************************************************************
 * Copyright 2018 The Apollo Authors. All Rights Reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *****************************************************************************/

#ifndef CYBERTRON_COMMON_GLOBAL_DATA_H_
#define CYBERTRON_COMMON_GLOBAL_DATA_H_

#include <string>
#include <unordered_map>

#include "cybertron/base/atomic_hash_map.h"
#include "cybertron/base/atomic_rw_lock.h"
#include "cybertron/common/log.h"
#include "cybertron/common/macros.h"
#include "cybertron/proto/cyber_config.pb.h"

namespace apollo {
namespace cybertron {
namespace common {

using ::apollo::cybertron::base::AtomicHashMap;
using ::apollo::cybertron::proto::CyberConfig;

class GlobalData {
 public:
  ~GlobalData();

  int ProcessId() const;

  void SetProcessName(const std::string& process_name);
  const std::string& ProcessName() const;

  const std::string& HostIp() const;

  const std::string& HostName() const;

  const CyberConfig& Config() const;

  void EnableSimulationMode();
  void DisableSimulationMode();

  bool IsRealityMode() const;

  static uint64_t RegisterNode(const std::string& node_name);
  static const std::string& GetNodeById(uint64_t id);

  static uint64_t RegisterChannel(const std::string& channel);
  static const std::string& GetChannelById(uint64_t id);

  static uint64_t RegisterService(const std::string& service);
  static const std::string& GetServiceById(uint64_t id);

  static uint64_t RegisterTaskName(const std::string& task_name);
  static const std::string& GetTaskNameById(uint64_t id);

 private:
  void InitHostInfo();
  void InitConfig();

  // global config
  CyberConfig config_;

  // host info
  std::string host_ip_;
  std::string host_name_;

  // process info
  int process_id_;
  std::string process_name_;

  // run mode
  bool is_reality_mode_;

  static AtomicHashMap<uint64_t, std::string, 512> node_id_map_;
  static AtomicHashMap<uint64_t, std::string, 256> channel_id_map_;
  static AtomicHashMap<uint64_t, std::string, 256> service_id_map_;
  static AtomicHashMap<uint64_t, std::string, 256> task_id_map_;

  static const std::string dummy_str_;

  DECLARE_SINGLETON(GlobalData)
};

}  // namespace common
}  // namespace cybertron
}  // namespace apollo

#endif  // CYBERTRON_COMMON_GLOBAL_DATA_H_