Home
last modified time | relevance | path

Searched refs:msg (Results 1 – 25 of 1184) sorted by relevance

12345678910>>...48

/dflybsd-src/sbin/nvmectl/
H A Dsubs.c53 const char *msg = NULL; in status_to_str() local
59 msg = "SUCCESS"; in status_to_str()
62 msg = "Bad Op"; in status_to_str()
65 msg = "Bad Field"; in status_to_str()
68 msg = "ID Conflict"; in status_to_str()
71 msg = "Bad XFer"; in status_to_str()
74 msg = "Abort on Power Loss"; in status_to_str()
77 msg = "Internal Error"; in status_to_str()
80 msg = "Abort on Request"; in status_to_str()
83 msg = "Abort on SubQ Deletion"; in status_to_str()
[all …]
/dflybsd-src/sys/kern/
H A Dlwkt_msgport.c78 lwkt_beginmsg(lwkt_port_t port, lwkt_msg_t msg) in lwkt_beginmsg() argument
80 return port->mp_putport(port, msg); in lwkt_beginmsg()
84 lwkt_beginmsg_oncpu(lwkt_port_t port, lwkt_msg_t msg) in lwkt_beginmsg_oncpu() argument
86 return port->mp_putport_oncpu(port, msg); in lwkt_beginmsg_oncpu()
90 _lwkt_sendmsg_prepare(lwkt_port_t port, lwkt_msg_t msg) in _lwkt_sendmsg_prepare() argument
92 KKASSERT(msg->ms_reply_port != NULL && in _lwkt_sendmsg_prepare()
93 (msg->ms_flags & (MSGF_DONE|MSGF_QUEUED)) == MSGF_DONE); in _lwkt_sendmsg_prepare()
94 msg->ms_flags &= ~(MSGF_REPLY | MSGF_SYNC | MSGF_DONE); in _lwkt_sendmsg_prepare()
98 _lwkt_sendmsg_start(lwkt_port_t port, lwkt_msg_t msg) in _lwkt_sendmsg_start() argument
102 if ((error = lwkt_beginmsg(port, msg)) != EASYNC) { in _lwkt_sendmsg_start()
[all …]
H A Duipc_msg.c69 struct netmsg_pru_abort *msg; in so_pru_abort_async() local
71 msg = kmalloc(sizeof(*msg), M_LWKTMSG, M_WAITOK | M_ZERO); in so_pru_abort_async()
72 netmsg_init(&msg->base, so, &netisr_afree_free_so_rport, in so_pru_abort_async()
74 lwkt_sendmsg(so->so_port, &msg->base.lmsg); in so_pru_abort_async()
85 struct netmsg_pru_abort msg; in so_pru_abort_direct() local
88 netmsg_init(&msg.base, so, &netisr_adone_rport, 0, func); in so_pru_abort_direct()
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()
91 func((netmsg_t)&msg); in so_pru_abort_direct()
92 KKASSERT(msg.base.lmsg.ms_flags & MSGF_DONE); in so_pru_abort_direct()
[all …]
H A Dkern_dmsg.c72 static int kdmsg_msg_receive_handling(kdmsg_msg_t *msg);
73 static int kdmsg_state_msgrx(kdmsg_msg_t *msg);
74 static int kdmsg_state_msgtx(kdmsg_msg_t *msg);
75 static void kdmsg_msg_write_locked(kdmsg_iocom_t *iocom, kdmsg_msg_t *msg);
76 static void kdmsg_state_cleanuprx(kdmsg_msg_t *msg);
77 static void kdmsg_state_cleanuptx(kdmsg_msg_t *msg);
83 static void kdmsg_drain_msg(kdmsg_msg_t *msg);
100 static int kdmsg_autorxmsg(kdmsg_msg_t *msg);
111 int (*rcvmsg)(kdmsg_msg_t *msg)) in kdmsg_iocom_init() argument
173 static int kdmsg_lnk_conn_reply(kdmsg_state_t *state, kdmsg_msg_t *msg);
[all …]
H A Dsubr_diskiocom.c78 static int disk_rcvdmsg(kdmsg_msg_t *msg);
80 static void disk_blk_open(struct disk *dp, kdmsg_msg_t *msg);
81 static void disk_blk_read(struct disk *dp, kdmsg_msg_t *msg);
82 static void disk_blk_write(struct disk *dp, kdmsg_msg_t *msg);
83 static void disk_blk_flush(struct disk *dp, kdmsg_msg_t *msg);
84 static void disk_blk_freeblks(struct disk *dp, kdmsg_msg_t *msg);
192 disk_rcvdmsg(kdmsg_msg_t *msg) in disk_rcvdmsg() argument
194 struct disk *dp = msg->state->iocom->handle; in disk_rcvdmsg()
199 switch(msg->any.head.cmd & DMSGF_CMDSWMASK) { in disk_rcvdmsg()
204 kdmsg_msg_reply(msg, DMSG_ERR_NOSUPP); in disk_rcvdmsg()
[all …]
/dflybsd-src/contrib/wpa_supplicant/src/p2p/
H A Dp2p_parse.c37 struct p2p_message *msg) in p2p_parse_attribute() argument
50 msg->capability = data; in p2p_parse_attribute()
61 msg->device_id = data; in p2p_parse_attribute()
63 MAC2STR(msg->device_id)); in p2p_parse_attribute()
71 msg->go_intent = data; in p2p_parse_attribute()
81 msg->status = data; in p2p_parse_attribute()
95 msg->listen_channel = data; in p2p_parse_attribute()
112 msg->operating_channel = data; in p2p_parse_attribute()
124 msg->channel_list = data; in p2p_parse_attribute()
125 msg->channel_list_len = len; in p2p_parse_attribute()
[all …]
H A Dp2p_pd.c444 static int p2ps_validate_pd_req(struct p2p_data *p2p, struct p2p_message *msg, in p2ps_validate_pd_req() argument
456 if ((_val) && !msg->_attr) { \ in p2ps_validate_pd_req()
475 if (msg->status && *msg->status != P2P_SC_SUCCESS_DEFERRED) in p2ps_validate_pd_req()
490 if (msg->feature_cap_len < sizeof(struct p2ps_feature_capab)) { in p2ps_validate_pd_req()
495 switch (*msg->conn_cap) { in p2ps_validate_pd_req()
532 if (msg->persistent_dev) { in p2ps_validate_pd_req()
535 if (os_memcmp(msg->persistent_dev, addr, ETH_ALEN) == 0) { in p2ps_validate_pd_req()
557 struct p2p_message msg; in p2p_process_prov_disc_req() local
578 if (p2p_parse(data, len, &msg)) in p2p_process_prov_disc_req()
583 MAC2STR(sa), msg.wps_config_methods, rx_freq); in p2p_process_prov_disc_req()
[all …]
/dflybsd-src/contrib/wpa_supplicant/src/wps/
H A Dwps_attr_build.c21 int wps_build_public_key(struct wps_data *wps, struct wpabuf *msg) in wps_build_public_key() argument
81 wpabuf_put_be16(msg, ATTR_PUBLIC_KEY); in wps_build_public_key()
82 wpabuf_put_be16(msg, wpabuf_len(pubkey)); in wps_build_public_key()
83 wpabuf_put_buf(msg, pubkey); in wps_build_public_key()
97 int wps_build_req_type(struct wpabuf *msg, enum wps_request_type type) in wps_build_req_type() argument
100 wpabuf_put_be16(msg, ATTR_REQUEST_TYPE); in wps_build_req_type()
101 wpabuf_put_be16(msg, 1); in wps_build_req_type()
102 wpabuf_put_u8(msg, type); in wps_build_req_type()
107 int wps_build_resp_type(struct wpabuf *msg, enum wps_response_type type) in wps_build_resp_type() argument
110 wpabuf_put_be16(msg, ATTR_RESPONSE_TYPE); in wps_build_resp_type()
[all …]
H A Dwps_dev_attr.c16 int wps_build_manufacturer(struct wps_device_data *dev, struct wpabuf *msg) in wps_build_manufacturer() argument
20 wpabuf_put_be16(msg, ATTR_MANUFACTURER); in wps_build_manufacturer()
29 wpabuf_put_be16(msg, 1); in wps_build_manufacturer()
30 wpabuf_put_u8(msg, ' '); in wps_build_manufacturer()
34 wpabuf_put_be16(msg, len); in wps_build_manufacturer()
35 wpabuf_put_data(msg, dev->manufacturer, len); in wps_build_manufacturer()
40 int wps_build_model_name(struct wps_device_data *dev, struct wpabuf *msg) in wps_build_model_name() argument
44 wpabuf_put_be16(msg, ATTR_MODEL_NAME); in wps_build_model_name()
53 wpabuf_put_be16(msg, 1); in wps_build_model_name()
54 wpabuf_put_u8(msg, ' '); in wps_build_model_name()
[all …]
H A Dwps_enrollee.c19 static int wps_build_wps_state(struct wps_data *wps, struct wpabuf *msg) in wps_build_wps_state() argument
28 wpabuf_put_be16(msg, ATTR_WPS_STATE); in wps_build_wps_state()
29 wpabuf_put_be16(msg, 1); in wps_build_wps_state()
30 wpabuf_put_u8(msg, state); in wps_build_wps_state()
35 static int wps_build_e_hash(struct wps_data *wps, struct wpabuf *msg) in wps_build_e_hash() argument
54 wpabuf_put_be16(msg, ATTR_E_HASH1); in wps_build_e_hash()
55 wpabuf_put_be16(msg, SHA256_MAC_LEN); in wps_build_e_hash()
56 hash = wpabuf_put(msg, SHA256_MAC_LEN); in wps_build_e_hash()
70 wpabuf_put_be16(msg, ATTR_E_HASH2); in wps_build_e_hash()
71 wpabuf_put_be16(msg, SHA256_MAC_LEN); in wps_build_e_hash()
[all …]
H A Dwps_common.c272 void wps_fail_event(struct wps_context *wps, enum wps_msg_type msg, in wps_fail_event() argument
281 data.fail.msg = msg; in wps_fail_event()
437 struct wpabuf msg; in wps_oob_use_cred() local
445 wpabuf_set(&msg, attr->cred[i], attr->cred_len[i]); in wps_oob_use_cred()
446 if (wps_parse_msg(&msg, &cattr) < 0 || in wps_oob_use_cred()
577 struct wpabuf *msg; in wps_build_wsc_ack() local
581 msg = wpabuf_alloc(1000); in wps_build_wsc_ack()
582 if (msg == NULL) in wps_build_wsc_ack()
585 if (wps_build_version(msg) || in wps_build_wsc_ack()
586 wps_build_msg_type(msg, WPS_WSC_ACK) || in wps_build_wsc_ack()
[all …]
/dflybsd-src/sys/bus/u4b/net/
H A Dif_urndis.c504 const struct urndis_init_comp *msg; in urndis_ctrl_handle_init() local
506 msg = (const struct urndis_init_comp *)hdr; in urndis_ctrl_handle_init()
511 le32toh(msg->rm_len), in urndis_ctrl_handle_init()
512 le32toh(msg->rm_rid), in urndis_ctrl_handle_init()
513 le32toh(msg->rm_status), in urndis_ctrl_handle_init()
514 le32toh(msg->rm_ver_major), in urndis_ctrl_handle_init()
515 le32toh(msg->rm_ver_minor), in urndis_ctrl_handle_init()
516 le32toh(msg->rm_devflags), in urndis_ctrl_handle_init()
517 le32toh(msg->rm_medium), in urndis_ctrl_handle_init()
518 le32toh(msg->rm_pktmaxcnt), in urndis_ctrl_handle_init()
[all …]
/dflybsd-src/crypto/libressl/ssl/
H A Dtls13_handshake_msg.c39 struct tls13_handshake_msg *msg = NULL; in tls13_handshake_msg_new() local
41 if ((msg = calloc(1, sizeof(struct tls13_handshake_msg))) == NULL) in tls13_handshake_msg_new()
43 if ((msg->buf = tls_buffer_new(0)) == NULL) in tls13_handshake_msg_new()
46 return msg; in tls13_handshake_msg_new()
49 tls13_handshake_msg_free(msg); in tls13_handshake_msg_new()
55 tls13_handshake_msg_free(struct tls13_handshake_msg *msg) in tls13_handshake_msg_free() argument
57 if (msg == NULL) in tls13_handshake_msg_free()
60 tls_buffer_free(msg->buf); in tls13_handshake_msg_free()
62 CBB_cleanup(&msg->cbb); in tls13_handshake_msg_free()
64 freezero(msg->data, msg->data_len); in tls13_handshake_msg_free()
[all …]
/dflybsd-src/sys/dev/disk/mpt/
H A Dmpt_debug.c360 mpt_print_reply_hdr(MSG_DEFAULT_REPLY *msg) in mpt_print_reply_hdr() argument
363 kprintf("%s Reply @ %p\n", mpt_ioc_function(msg->Function), msg); in mpt_print_reply_hdr()
364 kprintf("\tIOC Status %s\n", mpt_ioc_status(msg->IOCStatus)); in mpt_print_reply_hdr()
365 kprintf("\tIOCLogInfo 0x%08x\n", msg->IOCLogInfo); in mpt_print_reply_hdr()
366 kprintf("\tMsgLength 0x%02x\n", msg->MsgLength); in mpt_print_reply_hdr()
367 kprintf("\tMsgFlags 0x%02x\n", msg->MsgFlags); in mpt_print_reply_hdr()
368 kprintf("\tMsgContext 0x%08x\n", msg->MsgContext); in mpt_print_reply_hdr()
372 mpt_print_init_reply(MSG_IOC_INIT_REPLY *msg) in mpt_print_init_reply() argument
375 mpt_print_reply_hdr((MSG_DEFAULT_REPLY *)msg); in mpt_print_init_reply()
376 kprintf("\tWhoInit %s\n", mpt_who(msg->WhoInit)); in mpt_print_init_reply()
[all …]
/dflybsd-src/contrib/wpa_supplicant/src/radius/
H A Dradius.c52 struct radius_hdr * radius_msg_get_hdr(struct radius_msg *msg) in radius_msg_get_hdr() argument
54 return msg->hdr; in radius_msg_get_hdr()
58 struct wpabuf * radius_msg_get_buf(struct radius_msg *msg) in radius_msg_get_buf() argument
60 return msg->buf; in radius_msg_get_buf()
65 radius_get_attr_hdr(struct radius_msg *msg, int idx) in radius_get_attr_hdr() argument
68 (wpabuf_mhead_u8(msg->buf) + msg->attr_pos[idx]); in radius_get_attr_hdr()
72 static void radius_msg_set_hdr(struct radius_msg *msg, u8 code, u8 identifier) in radius_msg_set_hdr() argument
74 msg->hdr->code = code; in radius_msg_set_hdr()
75 msg->hdr->identifier = identifier; in radius_msg_set_hdr()
79 static int radius_msg_initialize(struct radius_msg *msg) in radius_msg_initialize() argument
[all …]
/dflybsd-src/lib/libdmsg/
H A Dmsg.c46 static int dmsg_state_msgrx(dmsg_msg_t *msg, int mstate);
47 static void dmsg_state_cleanuptx(dmsg_iocom_t *iocom, dmsg_msg_t *msg);
48 static void dmsg_msg_free_locked(dmsg_msg_t *msg);
90 dmsg_msg_t *msg; in dmsg_ioq_done() local
92 while ((msg = TAILQ_FIRST(&ioq->msgq)) != NULL) { in dmsg_ioq_done()
94 TAILQ_REMOVE(&ioq->msgq, msg, qentry); in dmsg_ioq_done()
95 dmsg_msg_free(msg); in dmsg_ioq_done()
97 if ((msg = ioq->msg) != NULL) { in dmsg_ioq_done()
98 ioq->msg = NULL; in dmsg_ioq_done()
99 dmsg_msg_free(msg); in dmsg_ioq_done()
[all …]
H A Dservice.c39 static void master_auth_rxmsg(dmsg_msg_t *msg);
41 static void master_link_rxmsg(dmsg_msg_t *msg);
96 static void master_auth_conn_rx(dmsg_msg_t *msg);
102 dmsg_msg_t *msg; in master_auth_signal() local
110 msg = dmsg_msg_alloc(&iocom->state0, 0, in master_auth_signal()
113 msg->any.lnk_conn.peer_mask = (uint64_t)-1; in master_auth_signal()
114 msg->any.lnk_conn.peer_type = DMSG_PEER_ROUTER; in master_auth_signal()
115 msg->any.lnk_conn.peer_mask = (uint64_t)-1; in master_auth_signal()
117 dmsg_msg_write(msg); in master_auth_signal()
124 master_auth_conn_rx(dmsg_msg_t *msg) in master_auth_conn_rx() argument
[all …]
/dflybsd-src/sys/net/ipfw3/
H A Dip_fw3_set.c87 struct netmsg_sets *msg = (struct netmsg_sets *)smsg; in move_set_dispatch() local
91 if (rule->set == msg->set_from) in move_set_dispatch()
92 rule->set = msg->set_to; in move_set_dispatch()
101 struct netmsg_sets msg; in ip_fw3_ctl_set_move_set() local
108 bzero(&msg, sizeof(msg)); in ip_fw3_ctl_set_move_set()
109 netmsg_init(&msg.base, NULL, &curthread->td_msgport, in ip_fw3_ctl_set_move_set()
111 msg.set_from = *set1; in ip_fw3_ctl_set_move_set()
112 msg.set_to = *set2; in ip_fw3_ctl_set_move_set()
114 netisr_domsg(&msg.base, 0); in ip_fw3_ctl_set_move_set()
122 struct netmsg_sets *msg = (struct netmsg_sets *)smsg; in move_rule_dispatch() local
[all …]
/dflybsd-src/crypto/openssh/
H A Dsftp-client.c236 struct sshbuf *msg; in send_string_request() local
239 if ((msg = sshbuf_new()) == NULL) in send_string_request()
241 if ((r = sshbuf_put_u8(msg, code)) != 0 || in send_string_request()
242 (r = sshbuf_put_u32(msg, id)) != 0 || in send_string_request()
243 (r = sshbuf_put_string(msg, s, len)) != 0) in send_string_request()
245 send_msg(conn, msg); in send_string_request()
247 sshbuf_free(msg); in send_string_request()
254 struct sshbuf *msg; in send_string_attrs_request() local
257 if ((msg = sshbuf_new()) == NULL) in send_string_attrs_request()
259 if ((r = sshbuf_put_u8(msg, code)) != 0 || in send_string_attrs_request()
[all …]
/dflybsd-src/contrib/wpa_supplicant/src/drivers/
H A Ddriver_nl80211.c235 static int nl80211_put_mesh_config(struct nl_msg *msg,
315 static int ack_handler(struct nl_msg *msg, void *arg) in ack_handler() argument
322 static int finish_handler(struct nl_msg *msg, void *arg) in finish_handler() argument
345 ack_len += err->msg.nlmsg_len - sizeof(*nlh); in error_handler()
365 static int no_seq_check(struct nl_msg *msg, void *arg) in no_seq_check() argument
371 static void nl80211_nlmsg_clear(struct nl_msg *msg) in nl80211_nlmsg_clear() argument
377 if (msg) { in nl80211_nlmsg_clear()
378 struct nlmsghdr *hdr = nlmsg_hdr(msg); in nl80211_nlmsg_clear()
394 struct nl_handle *nl_handle, struct nl_msg *msg, in send_and_recv() argument
401 if (!msg) in send_and_recv()
[all …]
H A Ddriver_nl80211_scan.c32 static int get_noise_for_scan_results(struct nl_msg *msg, void *arg) in get_noise_for_scan_results() argument
35 struct genlmsghdr *gnlh = nlmsg_data(nlmsg_hdr(msg)); in get_noise_for_scan_results()
81 struct nl_msg *msg; in nl80211_get_noise_for_scan_results() local
84 msg = nl80211_drv_msg(drv, NLM_F_DUMP, NL80211_CMD_GET_SURVEY); in nl80211_get_noise_for_scan_results()
85 return send_and_recv_msgs(drv, msg, get_noise_for_scan_results, info); in nl80211_get_noise_for_scan_results()
92 struct nl_msg *msg; in nl80211_abort_scan() local
96 msg = nl80211_cmd_msg(bss, 0, NL80211_CMD_ABORT_SCAN); in nl80211_abort_scan()
97 ret = send_and_recv_msgs(drv, msg, NULL, NULL); in nl80211_abort_scan()
110 struct nl_msg *msg; in nl80211_abort_vendor_scan() local
117 msg = nl80211_drv_msg(drv, 0, NL80211_CMD_VENDOR); in nl80211_abort_vendor_scan()
[all …]
/dflybsd-src/sys/net/
H A Draw_usrreq.c146 raw_ctlinput(netmsg_t msg) in raw_ctlinput() argument
152 if (msg->ctlinput.nm_cmd < 0 || msg->ctlinput.nm_cmd > PRC_NCMDS) { in raw_ctlinput()
155 lwkt_replymsg(&msg->lmsg, error); in raw_ctlinput()
163 raw_uabort(netmsg_t msg) in raw_uabort() argument
165 struct rawcb *rp = sotorawcb(msg->base.nm_so); in raw_uabort()
172 soisdisconnected(msg->base.nm_so); in raw_uabort()
177 lwkt_replymsg(&msg->lmsg, error); in raw_uabort()
183 raw_uattach(netmsg_t msg) in raw_uattach() argument
185 struct socket *so = msg->base.nm_so; in raw_uattach()
186 int proto = msg->attach.nm_proto; in raw_uattach()
[all …]
/dflybsd-src/sys/vfs/hammer2/
H A Dhammer2_iocom.c46 static int hammer2_rcvdmsg(kdmsg_msg_t *msg);
47 static void hammer2_autodmsg(kdmsg_msg_t *msg);
48 static int hammer2_lnk_span_reply(kdmsg_state_t *state, kdmsg_msg_t *msg);
133 hammer2_rcvdmsg(kdmsg_msg_t *msg) in hammer2_rcvdmsg() argument
135 kprintf("RCVMSG %08x\n", msg->tcmd); in hammer2_rcvdmsg()
137 switch(msg->tcmd) { in hammer2_rcvdmsg()
143 kdmsg_msg_result(msg, DMSG_ERR_NOSUPP); in hammer2_rcvdmsg()
149 if (msg->aux_data) { in hammer2_rcvdmsg()
150 msg->aux_data[msg->aux_size - 1] = 0; in hammer2_rcvdmsg()
151 kprintf("HAMMER2 DBG: %s\n", msg->aux_data); in hammer2_rcvdmsg()
[all …]
/dflybsd-src/lib/libc/sysvipc/
H A Dsockets.c133 struct msghdr msg; in send_fd() local
145 memset(&msg, 0, sizeof(msg)); in send_fd()
151 msg.msg_accrights = (caddr_t)&fd; in send_fd()
152 msg.msg_accrightslen = sizeof(fd); in send_fd()
154 msg.msg_control = (caddr_t)cmsgbuf.buf; in send_fd()
155 msg.msg_controllen = sizeof(cmsgbuf.buf); in send_fd()
156 cmsg = CMSG_FIRSTHDR(&msg); in send_fd()
166 msg.msg_iov = &vec; in send_fd()
167 msg.msg_iovlen = 1; in send_fd()
169 if ((n = sendmsg(sock, &msg, 0)) == -1) { in send_fd()
[all …]
/dflybsd-src/sys/netinet/
H A Dtcp_usrreq.c138 static void tcp_connect (netmsg_t msg);
140 static void tcp6_connect (netmsg_t msg);
200 tcp_usr_attach(netmsg_t msg) in tcp_usr_attach() argument
202 struct socket *so = msg->base.nm_so; in tcp_usr_attach()
203 struct pru_attach_info *ai = msg->attach.nm_ai; in tcp_usr_attach()
222 lwkt_replymsg(&msg->lmsg, error); in tcp_usr_attach()
233 tcp_usr_detach(netmsg_t msg) in tcp_usr_detach() argument
235 struct socket *so = msg->base.nm_so; in tcp_usr_detach()
255 lwkt_replymsg(&msg->lmsg, error); in tcp_usr_detach()
283 lwkt_replymsg(&msg->lmsg, error); \
[all …]

12345678910>>...48