51a52
> struct comm_base;
70a72,73
> /** number of messages in the queue */
> int msgcount;
75a79,80
> /** the wakeup timer for dtio, on worker event base */
> struct comm_timer* wakeup_timer;
168a174,177
> /** lock on wakeup_timer_enabled */
> lock_basic_type wakeup_timer_lock;
> /** if wakeup timer is enabled in some thread */
> int wakeup_timer_enabled;
235a245
> * @param base: event base for wakeup timer.
238c248
< struct dt_msg_queue* dt_msg_queue_create(void);
---
> struct dt_msg_queue* dt_msg_queue_create(struct comm_base* base);
260a271,273
> /** timer callback to wakeup dtio thread to process messages */
> void mq_wakeup_cb(void* arg);
>