Lines Matching refs:tmsg
218 struct netmsg_tcp_timer *tmsg = tp->tt_msg; in tcp_send_timermsg() local
220 KKASSERT(tmsg != NULL && tmsg->tt_cpuid == mycpuid && in tcp_send_timermsg()
221 tmsg->tt_tcb != NULL); in tcp_send_timermsg()
223 tmsg->tt_tasks |= task; in tcp_send_timermsg()
224 if (tmsg->tt_msg.lmsg.ms_flags & MSGF_DONE) in tcp_send_timermsg()
225 lwkt_sendmsg_oncpu(tmsg->tt_msgport, &tmsg->tt_msg.lmsg); in tcp_send_timermsg()
689 struct netmsg_tcp_timer *tmsg = (struct netmsg_tcp_timer *)msg; in tcp_timer_handler() local
695 KKASSERT(tmsg->tt_cpuid == mycpuid && tmsg->tt_tcb != NULL); in tcp_timer_handler()
696 tp = tmsg->tt_tcb; in tcp_timer_handler()
699 tmsg->tt_running_tasks = tmsg->tt_tasks; in tcp_timer_handler()
700 tmsg->tt_prev_tasks = tmsg->tt_tasks; in tcp_timer_handler()
701 tmsg->tt_tasks = 0; in tcp_timer_handler()
704 lwkt_replymsg(&tmsg->tt_msg.lmsg, 0); in tcp_timer_handler()
706 if (tmsg->tt_running_tasks == 0) { in tcp_timer_handler()
716 if ((tmsg->tt_running_tasks & tt->tt_task) == 0) in tcp_timer_handler()
719 tmsg->tt_running_tasks &= ~tt->tt_task; in tcp_timer_handler()
724 if (tmsg->tt_running_tasks == 0) /* nothing left to do */ in tcp_timer_handler()
734 struct netmsg_tcp_timer *tmsg = tp->tt_msg; in tcp_create_timermsg() local
736 netmsg_init(&tmsg->tt_msg, NULL, &netisr_adone_rport, in tcp_create_timermsg()
738 tmsg->tt_cpuid = mycpuid; in tcp_create_timermsg()
739 tmsg->tt_msgport = msgport; in tcp_create_timermsg()
740 tmsg->tt_tcb = tp; in tcp_create_timermsg()
741 tmsg->tt_tasks = 0; in tcp_create_timermsg()
747 struct netmsg_tcp_timer *tmsg = tp->tt_msg; in tcp_destroy_timermsg() local
749 if (tmsg == NULL || /* listen socket */ in tcp_destroy_timermsg()
750 tmsg->tt_tcb == NULL) /* only tcp_attach() is called */ in tcp_destroy_timermsg()
753 KKASSERT(tmsg->tt_cpuid == mycpuid); in tcp_destroy_timermsg()
760 if ((tmsg->tt_msg.lmsg.ms_flags & MSGF_DONE) == 0) { in tcp_destroy_timermsg()
761 lwkt_dropmsg(&tmsg->tt_msg.lmsg); in tcp_destroy_timermsg()