Commit f21300b0 authored by Adam Wujek's avatar Adam Wujek 💬

userspace/tools: retry oconnecting to RTUd mini-rpc server

Retry connecting to the RTUd mini-rpc server.
Signed-off-by: Adam Wujek's avatarAdam Wujek <adam.wujek@cern.ch>
parent 5e7dd3e4
...@@ -150,13 +150,20 @@ int main(int argc, char *argv[]) ...@@ -150,13 +150,20 @@ int main(int argc, char *argv[])
print_help(prgname); print_help(prgname);
exit(0); exit(0);
} }
rtud_ch = minipc_client_create("rtud", 0);
if(!rtud_ch) { n_wait = 0;
fprintf(stderr, "%s: Can't connect to RTUd mini-rpc server\n", /* connect to the RTUd mini-rpc */
prgname); while((rtud_ch = minipc_client_create("rtud", 0)) == 0) {
exit(1); n_wait++;
if (n_wait > 10) {
fprintf(stderr, "%s: Can't connect to RTUd mini-rpc "
"server\n", prgname);
exit(1);
}
sleep(1);
} }
n_wait = 0;
/* open rtu shm */ /* open rtu shm */
while ((ret = wrs_shm_get_and_check(wrs_shm_rtu, &rtu_port_shmem)) != 0) { while ((ret = wrs_shm_get_and_check(wrs_shm_rtu, &rtu_port_shmem)) != 0) {
n_wait++; n_wait++;
...@@ -181,6 +188,8 @@ int main(int argc, char *argv[]) ...@@ -181,6 +188,8 @@ int main(int argc, char *argv[])
exit(1); exit(1);
} }
/* get vlans array */ /* get vlans array */
rtu_hdr = (void *)rtu_port_shmem + rtu_port_shmem->data_off; rtu_hdr = (void *)rtu_port_shmem + rtu_port_shmem->data_off;
vlan_tab_shm = wrs_shm_follow(rtu_port_shmem, rtu_hdr->vlans); vlan_tab_shm = wrs_shm_follow(rtu_port_shmem, rtu_hdr->vlans);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment