@@ -23,7 +23,7 @@ using cdw::multibody::Visualizer;
2323 constexpr std::string_view CMD_##name = #name
2424
2525CANDLEWICK_RUNTIME_DEFINE_COMMAND (send_models);
26- CANDLEWICK_RUNTIME_DEFINE_COMMAND (send_state );
26+ CANDLEWICK_RUNTIME_DEFINE_COMMAND (state_update );
2727CANDLEWICK_RUNTIME_DEFINE_COMMAND (send_cam_pose);
2828CANDLEWICK_RUNTIME_DEFINE_COMMAND (clean);
2929
@@ -74,13 +74,15 @@ void run_main_loop(Visualizer &viz, ApplicationContext &app_ctx) {
7474
7575 while (!viz.shouldExit ()) {
7676 std::array<zmq::message_t , 2 > msgs;
77+
78+ // route subscriber socket
7779 auto rec = zmq::recv_multipart_n (app_ctx.state_sock , msgs.begin (), 2 ,
7880 zmq::recv_flags::dontwait);
7981
8082 if (rec) {
8183 // route through message headers
8284 auto header = msgs[0 ].to_string_view ();
83- if (header == CMD_send_state ) {
85+ if (header == CMD_state_update ) {
8486 auto oh = get_handle_from_zmq_msg (std::move (msgs[1 ]));
8587 msgpack::object obj = oh.get ();
8688 std::tuple<ArrayMessage, std::optional<ArrayMessage>> arrays;
@@ -96,6 +98,7 @@ void run_main_loop(Visualizer &viz, ApplicationContext &app_ctx) {
9698 }
9799 }
98100
101+ // route synchronous socket
99102 rec = zmq::recv_multipart_n (app_ctx.sync_sock , msgs.begin (), 2 ,
100103 zmq::recv_flags::dontwait);
101104 if (rec) {
@@ -138,7 +141,7 @@ int main(int argc, char **argv) {
138141 zmq::socket_t &state_sock = app_ctx.state_sock ;
139142 sync_sock.bind (std::format (" tcp://{:s}:{:d}" , hostname, port));
140143 state_sock.bind (std::format (" tcp://{:s}:{:d}" , hostname, port + 2 ));
141- state_sock.set (zmq::sockopt::subscribe, CMD_send_state );
144+ state_sock.set (zmq::sockopt::subscribe, CMD_state_update );
142145
143146 std::string endpoint;
144147 endpoint = sync_sock.get (zmq::sockopt::last_endpoint);
0 commit comments