Lines Matching refs:msg_queue
48 struct msg_queue {
101 static inline struct msg_queue *msq_obtain_object(struct ipc_namespace *ns, int id)
109 return container_of(ipcp, struct msg_queue, q_perm);
112 static inline struct msg_queue *msq_obtain_object_check(struct ipc_namespace *ns, int id)
120 return container_of(ipcp, struct msg_queue, q_perm);
123 static inline void msg_rmid(struct ipc_namespace *ns, struct msg_queue *s)
131 struct msg_queue *msq = container_of(p, struct msg_queue, q_perm);
146 struct msg_queue *msq;
188 static inline bool msg_fits_inqueue(struct msg_queue *msq, size_t msgsz)
193 static inline void ss_add(struct msg_queue *msq, struct msg_sender *mss, size_t msgsz)
212 static void ss_wakeup(struct msg_queue *msq, struct wake_q_head *wake_q, bool kill)
237 static void expunge_all(struct msg_queue *msq, int res, struct wake_q_head *wake_q)
264 struct msg_queue *msq = container_of(ipcp, struct msg_queue, q_perm);
393 struct msg_queue *msq;
405 msq = container_of(ipcp, struct msg_queue, q_perm);
502 struct msg_queue *msq;
815 static inline int pipelined_send(struct msg_queue *msq, struct msg_msg *msg, struct wake_q_head *wake_q)
847 struct msg_queue *msq;
1082 static struct msg_msg *find_msg(struct msg_queue *msq, long *msgtyp, int mode)
1111 struct msg_queue *msq;
1344 struct msg_queue *msq = container_of(ipcp, struct msg_queue, q_perm);