Lines Matching refs:msg
130 struct msg_msg *msg; /* ptr of loaded message */ member
193 static int msg_insert(struct msg_msg *msg, struct mqueue_inode_info *info) in msg_insert() argument
204 if (likely(leaf->priority == msg->m_type)) in msg_insert()
206 else if (msg->m_type < leaf->priority) { in msg_insert()
221 leaf->priority = msg->m_type; in msg_insert()
230 info->qsize += msg->m_ts; in msg_insert()
231 list_add_tail(&msg->m_list, &leaf->msg_list); in msg_insert()
254 struct msg_msg *msg; in msg_get() local
280 msg = list_first_entry(&leaf->msg_list, in msg_get()
282 list_del(&msg->m_list); in msg_get()
288 info->qsize -= msg->m_ts; in msg_get()
289 return msg; in msg_get()
516 struct msg_msg *msg, *nmsg; in mqueue_evict_inode() local
527 while ((msg = msg_get(info)) != NULL) in mqueue_evict_inode()
528 list_add_tail(&msg->m_list, &tmp_msg); in mqueue_evict_inode()
532 list_for_each_entry_safe(msg, nmsg, &tmp_msg, m_list) { in mqueue_evict_inode()
533 list_del(&msg->m_list); in mqueue_evict_inode()
534 free_msg(msg); in mqueue_evict_inode()
1038 receiver->msg = message; in pipelined_send()
1054 if (msg_insert(sender->msg, info)) in pipelined_receive()
1143 wait.msg = (void *) msg_ptr; in do_mq_timedsend()
1253 msg_ptr = wait.msg; in do_mq_timedreceive()