|
181 | 181 | -- local routine prototypes
|
182 | 182 | --
|
183 | 183 | --------------------------------------------------------------------------------
|
184 |
| -ROUTINE hndl_client_(fd : FILE; cfg : cfg_t) : INTEGER FROM ros_traj |
| 184 | +ROUTINE hndl_client_(fd : FILE; cfg : cfg_t; grp_nfo : grp_info_t) : INTEGER FROM ros_traj |
185 | 185 | ROUTINE has_msgs_(len : INTEGER; fd : FILE) : INTEGER FROM ros_traj
|
186 | 186 | ROUTINE read_sm000B_(fd : FILE; msg : sm000B_t) : INTEGER FROM ros_traj
|
187 | 187 | ROUTINE ack_svcreq_(seq : INTEGER; fd : FILE) : INTEGER FROM ros_traj
|
@@ -284,7 +284,7 @@ BEGIN
|
284 | 284 | log_info(LOG_PFIX + 'connected')
|
285 | 285 |
|
286 | 286 | -- client connected, 'spin-off' connection handler
|
287 |
| - stat_ = hndl_client_(sock_fd_, cfg_) |
| 287 | + stat_ = hndl_client_(sock_fd_, cfg_, grp_nfo_) |
288 | 288 |
|
289 | 289 | -- if there was no error and we were also not requested to shutdown,
|
290 | 290 | -- continue listening for clients
|
@@ -454,7 +454,7 @@ BEGIN
|
454 | 454 |
|
455 | 455 | -- .. and try pushing the oldest traj pt to the TP side, but do so
|
456 | 456 | -- without blocking (we'll try again next iter)
|
457 |
| - stat__ = push_pt_(sm000B_lst_[HEAD_OF_LIST], NO_BLOCK, cfg, grp_nfo_) |
| 457 | + stat__ = push_pt_(sm000B_lst_[HEAD_OF_LIST], NO_BLOCK, cfg, grp_nfo) |
458 | 458 |
|
459 | 459 | -- if TP side was busy, try again later
|
460 | 460 | -- TODO: add 'nodelay' lbl to skip DELAY
|
|
0 commit comments