tests BUGFIX RPC poll fix
@@ -66,9 +66,7 @@ server_thread(void *arg)
nc_assert(ret & NC_PSPOLL_RPC);
ret = nc_ps_poll(ps, NC_PS_POLL_TIMEOUT, NULL);
nc_assert(ret & NC_PSPOLL_RPC);
- ret = nc_ps_poll(ps, NC_PS_POLL_TIMEOUT, NULL);
- nc_assert(ret & NC_PSPOLL_RPC);
- nc_ps_clear(ps, 0, NULL);
+ nc_ps_clear(ps, 1, NULL);
#endif
msgtype = nc_accept(NC_ACCEPT_TIMEOUT, ctx, &session);
@@ -79,9 +77,7 @@ server_thread(void *arg)
nc_assert(ret & NC_PSPOLL_RPC);
ret = nc_ps_poll(ps, NC_PS_POLL_TIMEOUT, NULL);
nc_assert(ret & NC_PSPOLL_RPC);
- ret = nc_ps_poll(ps, NC_PS_POLL_TIMEOUT, NULL);
- nc_assert(ret & NC_PSPOLL_RPC);
- nc_ps_clear(ps, 0, NULL);
+ nc_ps_clear(ps, 1, NULL);
nc_ps_free(ps);
