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