Lines Matching refs:p_msg_q
166 msg_q* p_msg_q = (msg_q*)*msg_q_data; in msg_q_destroy() local
168 linked_list_destroy(&p_msg_q->msg_list); in msg_q_destroy()
169 pthread_mutex_destroy(&p_msg_q->list_mutex); in msg_q_destroy()
170 pthread_cond_destroy(&p_msg_q->list_cond); in msg_q_destroy()
172 p_msg_q->unblocked = 0; in msg_q_destroy()
199 msg_q* p_msg_q = (msg_q*)msg_q_data; in msg_q_snd() local
201 pthread_mutex_lock(&p_msg_q->list_mutex); in msg_q_snd()
204 if( p_msg_q->unblocked ) in msg_q_snd()
207 pthread_mutex_unlock(&p_msg_q->list_mutex); in msg_q_snd()
211 rv = convert_linked_list_err_type(linked_list_add(p_msg_q->msg_list, msg_obj, dealloc)); in msg_q_snd()
214 pthread_cond_signal(&p_msg_q->list_cond); in msg_q_snd()
216 pthread_mutex_unlock(&p_msg_q->list_mutex); in msg_q_snd()
243 msg_q* p_msg_q = (msg_q*)msg_q_data; in msg_q_rcv() local
247 pthread_mutex_lock(&p_msg_q->list_mutex); in msg_q_rcv()
249 if( p_msg_q->unblocked ) in msg_q_rcv()
252 pthread_mutex_unlock(&p_msg_q->list_mutex); in msg_q_rcv()
257 while( linked_list_empty(p_msg_q->msg_list) && !p_msg_q->unblocked ) in msg_q_rcv()
259 pthread_cond_wait(&p_msg_q->list_cond, &p_msg_q->list_mutex); in msg_q_rcv()
262 rv = convert_linked_list_err_type(linked_list_remove(p_msg_q->msg_list, msg_obj)); in msg_q_rcv()
264 pthread_mutex_unlock(&p_msg_q->list_mutex); in msg_q_rcv()
285 msg_q* p_msg_q = (msg_q*)msg_q_data; in msg_q_flush() local
289 pthread_mutex_lock(&p_msg_q->list_mutex); in msg_q_flush()
292 rv = convert_linked_list_err_type(linked_list_flush(p_msg_q->msg_list)); in msg_q_flush()
294 pthread_mutex_unlock(&p_msg_q->list_mutex); in msg_q_flush()
314 msg_q* p_msg_q = (msg_q*)msg_q_data; in msg_q_unblock() local
315 pthread_mutex_lock(&p_msg_q->list_mutex); in msg_q_unblock()
317 if( p_msg_q->unblocked ) in msg_q_unblock()
320 pthread_mutex_unlock(&p_msg_q->list_mutex); in msg_q_unblock()
326 p_msg_q->unblocked = 1; in msg_q_unblock()
329 pthread_cond_broadcast(&p_msg_q->list_cond); in msg_q_unblock()
331 pthread_mutex_unlock(&p_msg_q->list_mutex); in msg_q_unblock()