if (c->udp)
{
- time_diff= (int)(ms_thread->curr_time - c->start_time.tv_sec);
+ time_diff= (int)(ms_thread->curr_time - (rel_time_t)c->start_time.tv_sec);
/* wait time out */
if (time_diff > SOCK_WAIT_TIMEOUT)
/* calculate dropped packets count */
if (c->recvpkt > 0)
{
- atomic_add_64(&ms_stats.pkt_drop, c->packets - c->recvpkt);
+ atomic_add_size(&ms_stats.pkt_drop, c->packets - c->recvpkt);
}
- atomic_add_64(&ms_stats.udp_timeout, 1);
+ atomic_add_size(&ms_stats.udp_timeout, 1);
ms_reset_conn(c, true);
}
}
*/
static int ms_setup_thread(ms_thread_ctx_t *thread_ctx)
{
-
+
ms_thread_t *ms_thread= (ms_thread_t *)calloc(sizeof(*ms_thread), 1);
pthread_setspecific(ms_thread_key, (void *)ms_thread);