Home
last modified time | relevance | path

Searched refs:lmsg (Results 1 – 25 of 81) sorted by relevance

1234

/dflybsd-src/sys/kern/
H A Duipc_msg.c74 lwkt_sendmsg(so->so_port, &msg->base.lmsg); in so_pru_abort_async()
89 msg.base.lmsg.ms_flags &= ~(MSGF_REPLY | MSGF_DONE); in so_pru_abort_direct()
90 msg.base.lmsg.ms_flags |= MSGF_SYNC; in so_pru_abort_direct()
92 KKASSERT(msg.base.lmsg.ms_flags & MSGF_DONE); in so_pru_abort_direct()
105 return lwkt_domsg(so->so_port, &msg.base.lmsg, 0); in so_pru_accept()
118 error = lwkt_domsg(so->so_port, &msg.base.lmsg, 0); in so_pru_attach()
129 msg.base.lmsg.ms_flags &= ~(MSGF_REPLY | MSGF_DONE); in so_pru_attach_direct()
130 msg.base.lmsg.ms_flags |= MSGF_SYNC; in so_pru_attach_direct()
134 KKASSERT(msg.base.lmsg.ms_flags & MSGF_DONE); in so_pru_attach_direct()
135 return(msg.base.lmsg.ms_error); in so_pru_attach_direct()
[all …]
H A Dsubr_cpuhelper.c58 cpuhelper_putport(lwkt_port_t port, lwkt_msg_t lmsg) in cpuhelper_putport() argument
60 struct cpuhelper_msg *msg = (struct cpuhelper_msg *)lmsg; in cpuhelper_putport()
63 if ((lmsg->ms_flags & MSGF_SYNC) && port == &curthread->td_msgport) { in cpuhelper_putport()
67 return (cpuhelper_saved_putport(port, lmsg)); in cpuhelper_putport()
/dflybsd-src/sys/net/
H A Dnetisr.c166 netmsg_put_port(lwkt_port_t port, lwkt_msg_t lmsg) in netmsg_put_port() argument
168 netmsg_base_t nmsg = (void *)lmsg; in netmsg_put_port()
170 if ((lmsg->ms_flags & MSGF_SYNC) && port == &curthread->td_msgport) { in netmsg_put_port()
174 return(netmsg_fwd_port_fn(port, lmsg)); in netmsg_put_port()
189 netmsg_sync_putport(lwkt_port_t port, lwkt_msg_t lmsg) in netmsg_sync_putport() argument
191 netmsg_base_t nmsg = (void *)lmsg; in netmsg_sync_putport()
193 KKASSERT((lmsg->ms_flags & MSGF_DONE) == 0); in netmsg_sync_putport()
195 lmsg->ms_target_port = port; /* required for abort */ in netmsg_sync_putport()
300 lwkt_domsg(reg->npr_port, &smsg.lmsg, 0); in netmsg_service_sync()
311 lwkt_replymsg(&msg->lmsg, 0); in netmsg_sync_handler()
[all …]
H A Dnetisr2.h154 return (lwkt_domsg(port, &nm->lmsg, 0)); in netisr_domsg_port()
176 lwkt_sendmsg(netisr_cpuport(cpu), &nm->lmsg); in netisr_sendmsg()
183 lwkt_sendmsg_oncpu(netisr_cpuport(mycpuid), &nm->lmsg); in netisr_sendmsg_oncpu()
190 lwkt_replymsg(&nm->lmsg, error); in netisr_replymsg()
197 lwkt_dropmsg(&nm->lmsg); in netisr_dropmsg()
209 lwkt_forwardmsg(netisr_cpuport(next_cpu), &nm->lmsg); in netisr_forwardmsg_all()
224 lwkt_forwardmsg(netisr_cpuport(next_cpu), &nm->lmsg); in netisr_forwardmsg_error()
H A Draw_usrreq.c155 lwkt_replymsg(&msg->lmsg, error); in raw_ctlinput()
177 lwkt_replymsg(&msg->lmsg, error); in raw_uabort()
202 lwkt_replymsg(&msg->lmsg, error); in raw_uattach()
209 lwkt_replymsg(&msg->lmsg, EINVAL); in raw_ubind()
216 lwkt_replymsg(&msg->lmsg, EINVAL); in raw_uconnect()
236 lwkt_replymsg(&msg->lmsg, error); in raw_udetach()
260 lwkt_replymsg(&msg->lmsg, error); in raw_udisconnect()
281 lwkt_replymsg(&msg->lmsg, error); in raw_upeeraddr()
332 lwkt_replymsg(&msg->lmsg, error); in raw_usend()
351 lwkt_replymsg(&msg->lmsg, error); in raw_ushutdown()
[all …]
H A Dif_poll.c310 if (msg->lmsg.ms_flags & MSGF_DONE) in ifpoll_sendmsg_oncpu()
335 nmsg->lmsg.ms_flags &= ~(MSGF_REPLY | MSGF_DONE); in sched_iopollmore()
336 nmsg->lmsg.ms_flags |= MSGF_SYNC; in sched_iopollmore()
338 KKASSERT(nmsg->lmsg.ms_flags & MSGF_DONE); in sched_iopollmore()
413 nmsg.lmsg.u.ms_resultp = info; in ifpoll_register()
448 nmsg.lmsg.u.ms_resultp = ifp; in ifpoll_deregister()
462 const struct ifpoll_info *info = nmsg->lmsg.u.ms_resultp; in ifpoll_register_handler()
497 struct ifnet *ifp = nmsg->lmsg.u.ms_resultp; in ifpoll_deregister_handler()
729 io_ctx->poll_netmsg.lmsg.u.ms_resultp = io_ctx; in iopoll_ctx_create()
733 io_ctx->poll_more_netmsg.lmsg.u.ms_resultp = io_ctx; in iopoll_ctx_create()
[all …]
/dflybsd-src/sys/netinet/
H A Dudp_usrreq.c261 lwkt_replymsg(&msg->lmsg, EINVAL); in udp_ctloutput()
715 lwkt_forwardmsg(netisr_cpuport(nextcpu), &nm->base.lmsg); in udp_notifyall_oncpu()
717 lwkt_replymsg(&nm->base.lmsg, 0); in udp_notifyall_oncpu()
803 lwkt_sendmsg(netisr_cpuport(0), &nm->base.lmsg); in udp_ctlinput()
806 lwkt_replymsg(&msg->lmsg, 0); in udp_ctlinput()
874 lwkt_replymsg(&msg->send.base.lmsg, error); in udp_send_redispatch()
928 msg->send.base.lmsg.ms_flags |= MSGF_UDP_SEND; in udp_send()
1183 smsg->base.lmsg.ms_flags |= MSGF_IGNSOPORT; in udp_send()
1185 lwkt_forwardmsg(port, &smsg->base.lmsg); in udp_send()
1202 lwkt_sendmsg(port, &smsg->base.lmsg); in udp_send()
[all …]
H A Dip_divert.c262 port = msg->lmsg.u.ms_result32 & 0xffff; in div_packet_handler()
263 if (msg->lmsg.u.ms_result32 & DIV_INPUT) in div_packet_handler()
298 nmp->base.lmsg.u.ms_result32 = port; /* port is 16bits */ in divert_packet()
300 nmp->base.lmsg.u.ms_result32 |= DIV_INPUT; in divert_packet()
302 nmp->base.lmsg.u.ms_result32 |= DIV_OUTPUT; in divert_packet()
304 lwkt_sendmsg(netisr_cpuport(0), &nmp->base.lmsg); in divert_packet()
410 lwkt_replymsg(&msg->attach.base.lmsg, error); in div_attach()
425 lwkt_replymsg(&msg->detach.base.lmsg, 0); in div_detach()
452 lwkt_replymsg(&msg->disconnect.base.lmsg, error); in div_disconnect()
478 lwkt_replymsg(&msg->bind.base.lmsg, error); in div_bind()
[all …]
H A Dtcp_usrreq.c222 lwkt_replymsg(&msg->lmsg, error); in tcp_usr_attach()
255 lwkt_replymsg(&msg->lmsg, error); in tcp_usr_detach()
283 lwkt_replymsg(&msg->lmsg, error); \
355 lwkt_msg_t lmsg = &msg->bind.base.lmsg; in tcp_usr_bind() local
366 lwkt_setmsg_receipt(lmsg, tcp_sosetport); in tcp_usr_bind()
367 lwkt_forwardmsg(port0, lmsg); in tcp_usr_bind()
434 lwkt_forwardmsg(netisr_cpuport(nextcpu), &nm->base.lmsg); in in_pcbinswildcardhash_handler()
436 lwkt_replymsg(&nm->base.lmsg, 0); in in_pcbinswildcardhash_handler()
456 lwkt_msg_t lmsg = &msg->listen.base.lmsg; in tcp_usr_listen() local
467 lwkt_setmsg_receipt(lmsg, tcp_sosetport); in tcp_usr_listen()
[all …]
H A Din.c198 lwkt_replymsg(&msg->lmsg, error); in in_control_dispatch()
210 lwkt_replymsg(&msg->lmsg, error); in in_control_internal_dispatch()
244 lwkt_domsg(netisr_cpuport(0), &msg.base.lmsg, 0); in in_control()
245 return msg.base.lmsg.ms_error; in in_control()
255 struct in_ifaddr *ia = msg->lmsg.u.ms_resultp; in in_ialink_dispatch()
279 struct in_ifaddr *ia = msg->lmsg.u.ms_resultp; in in_iaunlink_dispatch()
303 struct in_ifaddr *ia = msg->lmsg.u.ms_resultp; in in_iahashins_dispatch()
328 struct in_ifaddr *ia = msg->lmsg.u.ms_resultp; in in_iahashrem_dispatch()
356 msg.lmsg.u.ms_resultp = ia; in in_ialink()
368 msg.lmsg.u.ms_resultp = ia; in in_iaunlink()
[all …]
H A Draw_ip.c448 lwkt_replymsg(&msg->lmsg, error); in rip_ctloutput()
489 lwkt_replymsg(&msg->lmsg, error); in rip_attach()
510 lwkt_replymsg(&msg->lmsg, 0); in rip_detach()
537 lwkt_replymsg(&msg->lmsg, error); in rip_disconnect()
565 lwkt_replymsg(&msg->lmsg, error); in rip_bind()
593 lwkt_replymsg(&msg->lmsg, error); in rip_connect()
602 lwkt_replymsg(&msg->lmsg, 0); in rip_shutdown()
636 lwkt_replymsg(&msg->lmsg, error); in rip_send()
H A Din_rmx.c339 lwkt_replymsg(&nmsg->lmsg, 0); in in_rtqtimo_dispatch()
391 struct lwkt_msg *lmsg = &in_rtq_pcpu[cpuid].timo_nmsg.lmsg; in in_rtqtimo() local
394 if (lmsg->ms_flags & MSGF_DONE) in in_rtqtimo()
395 lwkt_sendmsg_oncpu(netisr_cpuport(cpuid), lmsg); in in_rtqtimo()
424 lwkt_replymsg(&nmsg->lmsg, 0); in in_rtqdrain_dispatch()
435 struct lwkt_msg *msg = &in_rtq_pcpu[cpu].drain_nmsg.lmsg; in in_rtqdrain_ipi()
/dflybsd-src/sys/netbt/
H A Drfcomm_socket.c139 lwkt_replymsg(&msg->ctloutput.base.lmsg, error); in rfcomm_ctloutput()
264 lwkt_replymsg(&msg->detach.base.lmsg, error); in rfcomm_sdetach()
292 lwkt_replymsg(&msg->disconnect.base.lmsg, error); in rfcomm_sdisconnect()
298 lwkt_replymsg(&msg->control.base.lmsg, EPASSTHROUGH); in rfcomm_scontrol()
330 lwkt_replymsg(&msg->attach.base.lmsg, error); in rfcomm_sattach()
352 lwkt_replymsg(&msg->bind.base.lmsg, error); in rfcomm_sbind()
375 lwkt_replymsg(&msg->connect.base.lmsg, error); in rfcomm_sconnect()
394 lwkt_replymsg(&msg->peeraddr.base.lmsg, error); in rfcomm_speeraddr()
413 lwkt_replymsg(&msg->sockaddr.base.lmsg, error); in rfcomm_ssockaddr()
422 lwkt_replymsg(&msg->shutdown.base.lmsg, 0); in rfcomm_sshutdown()
[all …]
H A Dl2cap_socket.c143 lwkt_replymsg(&msg->ctloutput.base.lmsg, error); in l2cap_ctloutput()
255 lwkt_replymsg(&msg->detach.base.lmsg, error); in l2cap_sdetach()
285 lwkt_replymsg(&msg->disconnect.base.lmsg, error); in l2cap_sdisconnect()
291 lwkt_replymsg(&msg->control.base.lmsg, EPASSTHROUGH); in l2cap_scontrol()
316 lwkt_replymsg(&msg->attach.base.lmsg, error); in l2cap_sattach()
338 lwkt_replymsg(&msg->bind.base.lmsg, error); in l2cap_sbind()
361 lwkt_replymsg(&msg->connect.base.lmsg, error); in l2cap_sconnect()
380 lwkt_replymsg(&msg->peeraddr.base.lmsg, error); in l2cap_speeraddr()
399 lwkt_replymsg(&msg->sockaddr.base.lmsg, error); in l2cap_ssockaddr()
409 lwkt_replymsg(&msg->shutdown.base.lmsg, 0); in l2cap_sshutdown()
[all …]
H A Dsco_socket.c142 lwkt_replymsg(&msg->ctloutput.base.lmsg, err); in sco_ctloutput()
240 lwkt_replymsg(&msg->detach.base.lmsg, error); in sco_sdetach()
269 lwkt_replymsg(&msg->disconnect.base.lmsg, error); in sco_sdisconnect()
288 lwkt_replymsg(&msg->attach.base.lmsg, error); in sco_sattach()
310 lwkt_replymsg(&msg->bind.base.lmsg, error); in sco_sbind()
333 lwkt_replymsg(&msg->connect.base.lmsg, error); in sco_sconnect()
351 lwkt_replymsg(&msg->peeraddr.base.lmsg, error); in sco_speeraddr()
370 lwkt_replymsg(&msg->sockaddr.base.lmsg, error); in sco_ssockaddr()
377 lwkt_replymsg(&msg->shutdown.base.lmsg, 0); in sco_sshutdown()
419 lwkt_replymsg(&msg->send.base.lmsg, error); in sco_ssend()
[all …]
H A Dhci_socket.c580 lwkt_replymsg(&msg->detach.base.lmsg, error); in hci_sdetach()
604 lwkt_replymsg(&msg->disconnect.base.lmsg, error); in hci_sdisconnect()
615 lwkt_replymsg(&msg->control.base.lmsg, error); in hci_scontrol()
660 lwkt_replymsg(&msg->attach.base.lmsg, error); in hci_sattach()
693 lwkt_replymsg(&msg->bind.base.lmsg, error); in hci_sbind()
726 lwkt_replymsg(&msg->connect.base.lmsg, error); in hci_sconnect()
745 lwkt_replymsg(&msg->connect.base.lmsg, 0); in hci_speeraddr()
764 lwkt_replymsg(&msg->connect.base.lmsg, 0); in hci_ssockaddr()
773 lwkt_replymsg(&msg->connect.base.lmsg, 0); in hci_sshutdown()
815 lwkt_replymsg(&msg->send.base.lmsg, error); in hci_ssend()
[all …]
/dflybsd-src/usr.bin/talk/
H A Dctl_transact.c46 ctl_transact(struct in_addr target, CTL_MSG lmsg, int type, CTL_RESPONSE *rp) in ctl_transact() argument
52 lmsg.type = type; in ctl_transact()
67 cc = sendto(ctl_sockt, (char *)&lmsg, sizeof (lmsg), 0, in ctl_transact()
70 if (cc != sizeof (lmsg)) { in ctl_transact()
/dflybsd-src/sys/net/dummynet3/
H A Dip_dummynet3_glue.c98 lwkt_sendmsg(port, &nmp->base.lmsg); in ip_dn_queue()
116 lwkt_sendmsg(pkt->msgport, &nmp->base.lmsg); in ip_dn_packet_free()
151 lwkt_sendmsg(pkt->msgport, &nmp->base.lmsg); in ip_dn_packet_redispatch()
449 lwkt_msg *msg = &nmsg->lmsg; in ip_dn_sockopt_dispatch()
476 smsg.lmsg.u.ms_resultp = &dn_sopt; in ip_dn_sockopt_flush()
477 lwkt_domsg(netisr_cpuport(ip_dn_cpu), &smsg.lmsg, 0); in ip_dn_sockopt_flush()
479 return smsg.lmsg.ms_error; in ip_dn_sockopt_flush()
494 smsg.lmsg.u.ms_resultp = &dn_sopt; in ip_dn_sockopt_get()
495 lwkt_domsg(netisr_cpuport(ip_dn_cpu), &smsg.lmsg, 0); in ip_dn_sockopt_get()
497 error = smsg.lmsg.ms_error; in ip_dn_sockopt_get()
[all …]
/dflybsd-src/sys/net/dummynet/
H A Dip_dummynet_glue.c98 lwkt_sendmsg(port, &nmp->base.lmsg); in ip_dn_queue()
116 lwkt_sendmsg(pkt->msgport, &nmp->base.lmsg); in ip_dn_packet_free()
151 lwkt_sendmsg(pkt->msgport, &nmp->base.lmsg); in ip_dn_packet_redispatch()
449 lwkt_msg *msg = &nmsg->lmsg; in ip_dn_sockopt_dispatch()
476 smsg.lmsg.u.ms_resultp = &dn_sopt; in ip_dn_sockopt_flush()
477 lwkt_domsg(netisr_cpuport(ip_dn_cpu), &smsg.lmsg, 0); in ip_dn_sockopt_flush()
479 return smsg.lmsg.ms_error; in ip_dn_sockopt_flush()
494 smsg.lmsg.u.ms_resultp = &dn_sopt; in ip_dn_sockopt_get()
495 lwkt_domsg(netisr_cpuport(ip_dn_cpu), &smsg.lmsg, 0); in ip_dn_sockopt_get()
497 error = smsg.lmsg.ms_error; in ip_dn_sockopt_get()
[all …]
/dflybsd-src/sys/netinet6/
H A Din6_ifattach.c668 lwkt_replymsg(&nmsg->nmsg.lmsg, 0); in in6_nigroup_attach_dispatch()
680 lwkt_domsg(netisr_cpuport(0), &nmsg.nmsg.lmsg, 0); in in6_nigroup_attach()
709 lwkt_replymsg(&nmsg->nmsg.lmsg, 0); in in6_nigroup_detach_dispatch()
721 lwkt_domsg(netisr_cpuport(0), &nmsg.nmsg.lmsg, 0); in in6_nigroup_detach()
785 struct lwkt_msg *lmsg = &nmsg->lmsg; in in6_ifdetach_dispatch() local
786 struct ifnet *ifp = lmsg->u.ms_resultp; in in6_ifdetach_dispatch()
851 lwkt_replymsg(lmsg, 0); in in6_ifdetach_dispatch()
858 struct lwkt_msg *lmsg = &nmsg.lmsg; in in6_ifdetach() local
862 lmsg->u.ms_resultp = ifp; in in6_ifdetach()
863 lwkt_domsg(netisr_cpuport(0), lmsg, 0); in in6_ifdetach()
[all …]
H A Din6_rmx.c351 struct lwkt_msg *lmsg = &in6_rtqtimo_ctx[cpuid].timo_nmsg.lmsg; in in6_rtqtimo() local
354 if (lmsg->ms_flags & MSGF_DONE) in in6_rtqtimo()
355 lwkt_sendmsg_oncpu(netisr_cpuport(cpuid), lmsg); in in6_rtqtimo()
372 lwkt_replymsg(&nmsg->lmsg, 0); in in6_rtqtimo_dispatch()
456 struct lwkt_msg *lmsg = &in6_mtutimo_ctx[cpuid].timo_nmsg.lmsg; in in6_mtutimo() local
459 if (lmsg->ms_flags & MSGF_DONE) in in6_mtutimo()
460 lwkt_sendmsg_oncpu(netisr_cpuport(cpuid), lmsg); in in6_mtutimo()
476 lwkt_replymsg(&nmsg->lmsg, 0); in in6_mtutimo_dispatch()
H A Dudp6_usrreq.c449 lwkt_replymsg(&msg->ctlinput.base.lmsg, 0); in udp6_ctlinput()
511 lwkt_replymsg(&msg->abort.base.lmsg, error); in udp6_abort()
551 lwkt_replymsg(&msg->attach.base.lmsg, error); in udp6_attach()
577 lwkt_replymsg(&msg->bind.base.lmsg, error); in udp6_bind()
622 lwkt_replymsg(&msg->connect.base.lmsg, error); in udp6_connect()
639 lwkt_replymsg(&msg->detach.base.lmsg, error); in udp6_detach()
663 lwkt_replymsg(&msg->disconnect.base.lmsg, error); in udp6_disconnect()
703 lwkt_replymsg(&msg->send.base.lmsg, error); in udp6_send()
707 lwkt_replymsg(&msg->send.base.lmsg, error); in udp6_send()
H A Draw_ip6.c262 lwkt_replymsg(&msg->ctlinput.base.lmsg, 0); in rip6_ctlinput()
515 lwkt_replymsg(&msg->ctloutput.base.lmsg, error); in rip6_ctloutput()
553 lwkt_replymsg(&msg->attach.base.lmsg, error); in rip6_attach()
573 lwkt_replymsg(&msg->detach.base.lmsg, 0); in rip6_detach()
602 lwkt_replymsg(&msg->disconnect.base.lmsg, ENOTCONN); in rip6_disconnect()
647 lwkt_replymsg(&msg->bind.base.lmsg, error); in rip6_bind()
701 lwkt_replymsg(&msg->connect.base.lmsg, error); in rip6_connect()
708 lwkt_replymsg(&msg->shutdown.base.lmsg, 0); in rip6_shutdown()
753 lwkt_replymsg(&msg->send.base.lmsg, error); in rip6_send()
/dflybsd-src/sys/net/vlan/
H A Dif_vlan.c428 lwkt_replymsg(&vmsg->base.lmsg, 0); in vlan_ifdetach_dispatch()
444 lwkt_domsg(netisr_cpuport(0), &vmsg.base.lmsg, 0); in vlan_ifdetach()
572 nmp->base.lmsg.u.ms_resultp = ifp_p; in vlan_start()
574 lwkt_sendmsg(p_port, &nmp->base.lmsg); in vlan_start()
779 lwkt_replymsg(&vmsg->base.lmsg, error); in vlan_config_dispatch()
797 return lwkt_domsg(netisr_cpuport(0), &vmsg.base.lmsg, 0); in vlan_config()
919 lwkt_replymsg(&vmsg->base.lmsg, error); in vlan_unconfig_dispatch()
935 return lwkt_domsg(netisr_cpuport(0), &vmsg.base.lmsg, 0); in vlan_unconfig()
1061 lwkt_replymsg(&vmsg->base.lmsg, error); in vlan_multi_dispatch()
1077 return lwkt_domsg(netisr_cpuport(0), &vmsg.base.lmsg, 0); in vlan_config_multi()
[all …]
/dflybsd-src/lib/libdmsg/
H A Dmsg.c2485 dmsg_state_relay(dmsg_msg_t *lmsg) argument
2494 switch (lmsg->tcmd) {
2508 biocount, lmsg->any.head.msgid,
2509 lmsg->any.blk_read.bytes,
2510 lmsg->any.blk_read.offset);
2516 biocount, lmsg->any.head.msgid,
2517 lmsg->any.blk_read.bytes,
2518 lmsg->any.blk_read.offset);
2526 if ((lmsg->any.head.cmd & (DMSGF_CREATE | DMSGF_REPLY)) ==
2531 lstate = lmsg->state;
[all …]

1234