X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=clients%2Fms_thread.c;h=92d68871fd70c7d327957946023dd902ad39bffd;hb=0b0a30bb53359a9aff8afff1a45209c4be7b8881;hp=af856366c345ddea87ddbc9f2fd0a7693155d92c;hpb=ad624f93ee91351c4f3839ca0dc1a9981644d391;p=awesomized%2Flibmemcached diff --git a/clients/ms_thread.c b/clients/ms_thread.c index af856366..92d68871 100644 --- a/clients/ms_thread.c +++ b/clients/ms_thread.c @@ -61,7 +61,7 @@ static void ms_check_sock_timeout(void) 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) @@ -69,10 +69,10 @@ static void ms_check_sock_timeout(void) /* 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); } } @@ -169,7 +169,7 @@ static int ms_set_thread_cpu_affinity(int cpu) */ 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);