comm_timer_create
xfr->task_transfer->timer = comm_timer_create(env->worker_base,
xfr->task_probe->timer = comm_timer_create(env->worker_base,
xfr->task_nextprobe->timer = comm_timer_create(
mstate->s.serve_expired_data->timer = comm_timer_create(
pend->timer = comm_timer_create(sq->outnet->base, pending_udp_timer_cb,
if(!(w->timer = comm_timer_create(sq->outnet->base, outnet_tcptimer, w))) {
sq->timer = comm_timer_create(outnet->base, serviced_timer_cb, sq);
doq_socket->timer = comm_timer_create(base, doq_timer_cb, doq_socket);
struct comm_timer* comm_timer_create(struct comm_base* base,
vq->suspend_timer = comm_timer_create(
worker->stat_timer = comm_timer_create(worker->base,
worker->env.probe_timer = comm_timer_create(worker->base,
mq->wakeup_timer = comm_timer_create(base, mq_wakeup_cb, mq);
xfr->task_transfer->timer = comm_timer_create(env->worker_base,
xfr->task_probe->timer = comm_timer_create(env->worker_base,
xfr->task_nextprobe->timer = comm_timer_create(
mstate->s.serve_expired_data->timer = comm_timer_create(
pend->timer = comm_timer_create(sq->outnet->base, pending_udp_timer_cb,
if(!(w->timer = comm_timer_create(sq->outnet->base, outnet_tcptimer, w))) {
sq->timer = comm_timer_create(outnet->base, serviced_timer_cb, sq);
doq_socket->timer = comm_timer_create(base, doq_timer_cb, doq_socket);
struct comm_timer* comm_timer_create(struct comm_base* base,
vq->suspend_timer = comm_timer_create(