Lines Matching refs:msr
272 struct msg_receiver* msr; in expunge_all() local
274 msr = list_entry(tmp,struct msg_receiver,r_list); in expunge_all()
276 msr->r_msg = ERR_PTR(res); in expunge_all()
277 wake_up_process(msr->r_tsk); in expunge_all()
606 struct msg_receiver* msr; in pipelined_send() local
607 msr = list_entry(tmp,struct msg_receiver,r_list); in pipelined_send()
609 if(testmsg(msg,msr->r_msgtype,msr->r_mode)) { in pipelined_send()
610 list_del(&msr->r_list); in pipelined_send()
611 if(msr->r_maxsize < msg->m_ts) { in pipelined_send()
612 msr->r_msg = ERR_PTR(-E2BIG); in pipelined_send()
613 wake_up_process(msr->r_tsk); in pipelined_send()
615 msr->r_msg = msg; in pipelined_send()
616 msq->q_lrpid = msr->r_tsk->pid; in pipelined_send()
618 wake_up_process(msr->r_tsk); in pipelined_send()