75 {
76 std::string val;
77
78 COMMAND com = ParseOption(argc, argv, &val);
79
80 switch (com) {
81 case TOO_MANY_PARAMETER:
82 std::cout << "Too many paramtes\n";
83 case HELP:
84 printHelp(argv[0]);
85 return 0;
86 default: {}
87 }
88
90 FLAGS_minloglevel = 3;
91 FLAGS_alsologtostderr = 0;
92 FLAGS_colorlogtostderr = 0;
93
95
96 auto topology_callback =
98 apollo::cyber::Async([&topology_msg, change_msg] {
99 topology_msg.TopologyChanged(change_msg);
100 });
101 };
102
103 auto channel_manager =
104 apollo::cyber::service_discovery::TopologyManager::Instance()
105 ->channel_manager();
106 if (channel_manager == nullptr) {
107 AERROR <<
"Cyber Service Discovery is not ready.";
108 return -1;
109 }
110 channel_manager->AddChangeListener(topology_callback);
111
112 std::vector<apollo::cyber::proto::RoleAttributes> role_vec;
113 channel_manager->GetWriters(&role_vec);
114 for (auto &role : role_vec) {
115 topology_msg.AddReaderWriter(role, true);
116 }
117
118 role_vec.clear();
119 channel_manager->GetReaders(&role_vec);
120 for (auto &role : role_vec) {
121 topology_msg.AddReaderWriter(role, false);
122 }
123
125
126 signal(SIGWINCH, SigResizeHandle);
127 signal(SIGINT, SigCtrlCHandle);
128
130
133
134 return 0;
135}
void SetCurrentRenderMessage(RenderableMessage *const render_obj)
static Screen * Instance(void)
bool Init(const char *binary_name, const std::string &dag_info)