Home
last modified time | relevance | path

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

12345

/net/tipc/
Dmsg.c46 void tipc_msg_dbg(struct print_buf *buf, struct tipc_msg *msg, const char *str) in tipc_msg_dbg() argument
48 u32 usr = msg_user(msg); in tipc_msg_dbg()
54 tipc_printf(buf, "MSGS(%u):", msg_msgcnt(msg)); in tipc_msg_dbg()
61 switch (msg_type(msg)) { in tipc_msg_dbg()
72 tipc_printf(buf, "UNKNOWN:%x",msg_type(msg)); in tipc_msg_dbg()
75 tipc_printf(buf, "NO(%u/%u):",msg_long_msgno(msg), in tipc_msg_dbg()
76 msg_fragm_no(msg)); in tipc_msg_dbg()
82 tipc_printf(buf, "DAT%u:", msg_user(msg)); in tipc_msg_dbg()
83 if (msg_short(msg)) { in tipc_msg_dbg()
87 switch (msg_type(msg)) { in tipc_msg_dbg()
[all …]
Dnet.c187 struct tipc_msg *msg = buf_msg(buf); in net_route_named_msg() local
191 if (!msg_named(msg)) { in net_route_named_msg()
192 msg_dbg(msg, "tipc_net->drop_nam:"); in net_route_named_msg()
197 dnode = addr_domain(msg_lookup_scope(msg)); in net_route_named_msg()
198 dport = tipc_nametbl_translate(msg_nametype(msg), msg_nameinst(msg), &dnode); in net_route_named_msg()
200 msg_nametype(msg), msg_nameinst(msg), dport, dnode); in net_route_named_msg()
202 msg_set_destnode(msg, dnode); in net_route_named_msg()
203 msg_set_destport(msg, dport); in net_route_named_msg()
207 msg_dbg(msg, "tipc_net->rej:NO NAME: "); in net_route_named_msg()
213 struct tipc_msg *msg; in tipc_net_route_msg() local
[all …]
Dport.c165 struct tipc_msg* msg; in tipc_port_recv_mcast() local
170 msg = buf_msg(buf); in tipc_port_recv_mcast()
175 tipc_nametbl_mc_translate(msg_nametype(msg), in tipc_port_recv_mcast()
176 msg_namelower(msg), in tipc_port_recv_mcast()
177 msg_nameupper(msg), in tipc_port_recv_mcast()
187 msg_set_destport(msg, dp->ports[0]); in tipc_port_recv_mcast()
198 msg_dbg(msg, "LOST:"); in tipc_port_recv_mcast()
225 struct tipc_msg *msg; in tipc_createport_raw() local
243 msg = &p_ptr->publ.phdr; in tipc_createport_raw()
244 msg_init(msg, importance, TIPC_NAMED_MSG, LONG_H_SIZE, 0); in tipc_createport_raw()
[all …]
Dlink.c161 #define dbg_link_msg(msg, txt) \ argument
164 tipc_msg_dbg(&l_ptr->print_buf, msg, txt); \
378 struct tipc_msg *msg = buf_msg(l_ptr->first_out); in link_timeout() local
379 u32 length = msg_size(msg); in link_timeout()
381 if ((msg_user(msg) == MSG_FRAGMENTER) in link_timeout()
382 && (msg_type(msg) == FIRST_FRAGMENT)) { in link_timeout()
383 length = msg_size(msg_get_wrapped(msg)); in link_timeout()
435 struct tipc_msg *msg; in tipc_link_create() local
470 msg = l_ptr->pmsg; in tipc_link_create()
471 msg_init(msg, LINK_PROTOCOL, RESET_MSG, INT_H_SIZE, l_ptr->addr); in tipc_link_create()
[all …]
Dsocket.c770 static int auto_connect(struct socket *sock, struct tipc_msg *msg) in auto_connect() argument
774 if (msg_errcode(msg)) { in auto_connect()
779 tsock->peer_name.ref = msg_origport(msg); in auto_connect()
780 tsock->peer_name.node = msg_orignode(msg); in auto_connect()
782 tipc_set_portimportance(tsock->p->ref, msg_importance(msg)); in auto_connect()
795 static void set_orig_addr(struct msghdr *m, struct tipc_msg *msg) in set_orig_addr() argument
802 addr->addr.id.ref = msg_origport(msg); in set_orig_addr()
803 addr->addr.id.node = msg_orignode(msg); in set_orig_addr()
821 static int anc_data_recv(struct msghdr *m, struct tipc_msg *msg, in anc_data_recv() argument
835 err = msg ? msg_errcode(msg) : 0; in anc_data_recv()
[all …]
Dcluster.c236 struct tipc_msg *msg; in tipc_cltr_prepare_routing_msg() local
239 msg = buf_msg(buf); in tipc_cltr_prepare_routing_msg()
240 memset((char *)msg, 0, size); in tipc_cltr_prepare_routing_msg()
241 msg_init(msg, ROUTE_DISTRIBUTOR, 0, INT_H_SIZE, dest); in tipc_cltr_prepare_routing_msg()
250 struct tipc_msg *msg; in tipc_cltr_bcast_new_route() local
253 msg = buf_msg(buf); in tipc_cltr_bcast_new_route()
254 msg_set_remote_node(msg, dest); in tipc_cltr_bcast_new_route()
255 msg_set_type(msg, ROUTE_ADDITION); in tipc_cltr_bcast_new_route()
266 struct tipc_msg *msg; in tipc_cltr_bcast_lost_route() local
269 msg = buf_msg(buf); in tipc_cltr_bcast_lost_route()
[all …]
Dbcast.c270 struct tipc_msg *msg; in bclink_send_nack() local
277 msg = buf_msg(buf); in bclink_send_nack()
278 msg_init(msg, BCAST_PROTOCOL, STATE_MSG, in bclink_send_nack()
280 msg_set_mc_netid(msg, tipc_net_id); in bclink_send_nack()
281 msg_set_bcast_ack(msg, mod(n_ptr->bclink.last_in)); in bclink_send_nack()
282 msg_set_bcgap_after(msg, n_ptr->bclink.gap_after); in bclink_send_nack()
283 msg_set_bcgap_to(msg, n_ptr->bclink.gap_to); in bclink_send_nack()
284 msg_set_bcast_tag(msg, tipc_own_tag); in bclink_send_nack()
420 struct tipc_msg *msg = buf_msg(buf); in tipc_bclink_recv_pkt() local
421 struct tipc_node* node = tipc_node_find(msg_prevnode(msg)); in tipc_bclink_recv_pkt()
[all …]
Ddiscover.c119 struct tipc_msg *msg; in tipc_disc_init_msg() local
122 msg = buf_msg(buf); in tipc_disc_init_msg()
123 msg_init(msg, LINK_CONFIG, type, DSC_H_SIZE, dest_domain); in tipc_disc_init_msg()
124 msg_set_non_seq(msg, 1); in tipc_disc_init_msg()
125 msg_set_req_links(msg, req_links); in tipc_disc_init_msg()
126 msg_set_dest_domain(msg, dest_domain); in tipc_disc_init_msg()
127 msg_set_bc_netid(msg, tipc_net_id); in tipc_disc_init_msg()
128 msg_set_media_addr(msg, &b_ptr->publ.addr); in tipc_disc_init_msg()
165 struct tipc_msg *msg = buf_msg(buf); in tipc_disc_recv_msg() local
166 u32 dest = msg_dest_domain(msg); in tipc_disc_recv_msg()
[all …]
Dname_distr.c102 struct tipc_msg *msg; in named_prepare_buf() local
105 msg = buf_msg(buf); in named_prepare_buf()
106 msg_init(msg, NAME_DISTRIBUTOR, type, LONG_H_SIZE, dest); in named_prepare_buf()
107 msg_set_size(msg, LONG_H_SIZE + size); in named_prepare_buf()
246 struct tipc_msg *msg = buf_msg(buf); in tipc_named_recv() local
247 struct distr_item *item = (struct distr_item *)msg_data(msg); in tipc_named_recv()
248 u32 count = msg_data_sz(msg) / ITEM_SIZE; in tipc_named_recv()
252 if (msg_type(msg) == PUBLICATION) { in tipc_named_recv()
260 msg_orignode(msg), in tipc_named_recv()
265 msg_orignode(msg), in tipc_named_recv()
[all …]
/net/sctp/
Dchunk.c54 static void sctp_datamsg_init(struct sctp_datamsg *msg) in sctp_datamsg_init() argument
56 atomic_set(&msg->refcnt, 1); in sctp_datamsg_init()
57 msg->send_failed = 0; in sctp_datamsg_init()
58 msg->send_error = 0; in sctp_datamsg_init()
59 msg->can_abandon = 0; in sctp_datamsg_init()
60 msg->expires_at = 0; in sctp_datamsg_init()
61 INIT_LIST_HEAD(&msg->chunks); in sctp_datamsg_init()
67 struct sctp_datamsg *msg; in sctp_datamsg_new() local
68 msg = kmalloc(sizeof(struct sctp_datamsg), gfp); in sctp_datamsg_new()
69 if (msg) { in sctp_datamsg_new()
[all …]
/net/atm/
Dsignaling.c58 static void modify_qos(struct atm_vcc *vcc,struct atmsvc_msg *msg) in modify_qos() argument
65 msg->type = as_error; in modify_qos()
66 if (!vcc->dev->ops->change_qos) msg->reply = -EOPNOTSUPP; in modify_qos()
69 msg->reply = vcc->dev->ops->change_qos(vcc,&msg->qos, in modify_qos()
70 msg->reply); in modify_qos()
71 if (!msg->reply) msg->type = as_okay; in modify_qos()
79 *(struct atmsvc_msg *) skb_put(skb,sizeof(struct atmsvc_msg)) = *msg; in modify_qos()
86 struct atmsvc_msg *msg; in sigd_send() local
90 msg = (struct atmsvc_msg *) skb->data; in sigd_send()
92 vcc = *(struct atm_vcc **) &msg->vcc; in sigd_send()
[all …]
Dmpoa_caches.c126 struct k_message msg; in cache_hit() local
134 msg.type = SND_MPOA_RES_RQST; in cache_hit()
135 msg.content.in_info = entry->ctrl_info; in cache_hit()
136 memcpy(msg.MPS_ctrl, mpc->mps_ctrl_addr, ATM_ESA_LEN); in cache_hit()
138 if (qos != NULL) msg.qos = qos->qos; in cache_hit()
139 msg_to_mpoad(&msg, mpc); in cache_hit()
156 msg.type = SND_MPOA_RES_RQST; in cache_hit()
157 memcpy(msg.MPS_ctrl, mpc->mps_ctrl_addr, ATM_ESA_LEN ); in cache_hit()
158 msg.content.in_info = entry->ctrl_info; in cache_hit()
160 if (qos != NULL) msg.qos = qos->qos; in cache_hit()
[all …]
/net/core/
Dscm.c133 int __scm_send(struct socket *sock, struct msghdr *msg, struct scm_cookie *p) in __scm_send() argument
138 for (cmsg = CMSG_FIRSTHDR(msg); cmsg; cmsg = CMSG_NXTHDR(msg, cmsg)) in __scm_send()
150 if (!CMSG_OK(msg, cmsg)) in __scm_send()
188 int put_cmsg(struct msghdr * msg, int level, int type, int len, void *data) in put_cmsg() argument
191 = (__force struct cmsghdr __user *)msg->msg_control; in put_cmsg()
196 if (MSG_CMSG_COMPAT & msg->msg_flags) in put_cmsg()
197 return put_cmsg_compat(msg, level, type, len, data); in put_cmsg()
199 if (cm==NULL || msg->msg_controllen < sizeof(*cm)) { in put_cmsg()
200 msg->msg_flags |= MSG_CTRUNC; in put_cmsg()
203 if (msg->msg_controllen < cmlen) { in put_cmsg()
[all …]
/net/wireless/
Dnl80211.c120 static int nl80211_send_wiphy(struct sk_buff *msg, u32 pid, u32 seq, int flags, in nl80211_send_wiphy() argument
134 hdr = nl80211hdr_put(msg, pid, seq, flags, NL80211_CMD_NEW_WIPHY); in nl80211_send_wiphy()
138 NLA_PUT_U32(msg, NL80211_ATTR_WIPHY, dev->idx); in nl80211_send_wiphy()
139 NLA_PUT_STRING(msg, NL80211_ATTR_WIPHY_NAME, wiphy_name(&dev->wiphy)); in nl80211_send_wiphy()
141 nl_modes = nla_nest_start(msg, NL80211_ATTR_SUPPORTED_IFTYPES); in nl80211_send_wiphy()
148 NLA_PUT_FLAG(msg, i); in nl80211_send_wiphy()
153 nla_nest_end(msg, nl_modes); in nl80211_send_wiphy()
155 nl_bands = nla_nest_start(msg, NL80211_ATTR_WIPHY_BANDS); in nl80211_send_wiphy()
163 nl_band = nla_nest_start(msg, band); in nl80211_send_wiphy()
169 NLA_PUT(msg, NL80211_BAND_ATTR_HT_MCS_SET, in nl80211_send_wiphy()
[all …]
/net/decnet/
Ddn_nsp_out.c487 struct nsp_conn_ack_msg *msg; in dn_send_conn_ack() local
492 msg = (struct nsp_conn_ack_msg *)skb_put(skb, 3); in dn_send_conn_ack()
493 msg->msgflg = 0x24; in dn_send_conn_ack()
494 msg->dstaddr = scp->addrrem; in dn_send_conn_ack()
524 struct nsp_conn_init_msg *msg; in dn_send_conn_conf() local
530 msg = (struct nsp_conn_init_msg *)skb_put(skb, sizeof(*msg)); in dn_send_conn_conf()
531 msg->msgflg = 0x28; in dn_send_conn_conf()
532 msg->dstaddr = scp->addrrem; in dn_send_conn_conf()
533 msg->srcaddr = scp->addrloc; in dn_send_conn_conf()
534 msg->services = scp->services_loc; in dn_send_conn_conf()
[all …]
/net/rxrpc/
Dar-output.c24 struct msghdr *msg, size_t len);
29 static int rxrpc_sendmsg_cmsg(struct rxrpc_sock *rx, struct msghdr *msg, in rxrpc_sendmsg_cmsg() argument
40 if (msg->msg_controllen == 0) in rxrpc_sendmsg_cmsg()
43 for (cmsg = CMSG_FIRSTHDR(msg); cmsg; cmsg = CMSG_NXTHDR(msg, cmsg)) { in rxrpc_sendmsg_cmsg()
44 if (!CMSG_OK(msg, cmsg)) in rxrpc_sendmsg_cmsg()
56 if (msg->msg_flags & MSG_CMSG_COMPAT) { in rxrpc_sendmsg_cmsg()
128 struct rxrpc_transport *trans, struct msghdr *msg, in rxrpc_client_sendmsg() argument
144 ret = rxrpc_sendmsg_cmsg(rx, msg, &user_call_ID, &cmd, &abort_code, in rxrpc_client_sendmsg()
152 if (msg->msg_name) { in rxrpc_client_sendmsg()
154 (struct sockaddr_rxrpc *) msg->msg_name; in rxrpc_client_sendmsg()
[all …]
Dar-recvmsg.c46 struct msghdr *msg, size_t len, int flags) in rxrpc_recvmsg() argument
63 ullen = msg->msg_flags & MSG_CMSG_COMPAT ? 4 : sizeof(unsigned long); in rxrpc_recvmsg()
66 msg->msg_flags |= MSG_MORE; in rxrpc_recvmsg()
89 (msg->msg_flags & MSG_PEEK || timeo == 0)) in rxrpc_recvmsg()
145 if (msg->msg_name && msg->msg_namelen > 0) in rxrpc_recvmsg()
146 memcpy(msg->msg_name, in rxrpc_recvmsg()
149 sock_recv_timestamp(msg, &rx->sk, skb); in rxrpc_recvmsg()
161 ret = put_cmsg(msg, SOL_RXRPC, RXRPC_USER_CALL_ID, in rxrpc_recvmsg()
181 msg->msg_iov, copy); in rxrpc_recvmsg()
184 msg->msg_iov); in rxrpc_recvmsg()
[all …]
/net/phonet/
Ddatagram.c72 struct msghdr *msg, size_t len) in pn_sendmsg() argument
78 if (msg->msg_flags & MSG_OOB) in pn_sendmsg()
81 if (msg->msg_name == NULL) in pn_sendmsg()
84 if (msg->msg_namelen < sizeof(struct sockaddr_pn)) in pn_sendmsg()
87 target = (struct sockaddr_pn *)msg->msg_name; in pn_sendmsg()
92 msg->msg_flags & MSG_DONTWAIT, &err); in pn_sendmsg()
97 err = memcpy_fromiovec((void *)skb_put(skb, len), msg->msg_iov, len); in pn_sendmsg()
114 struct msghdr *msg, size_t len, int noblock, in pn_recvmsg() argument
136 msg->msg_flags |= MSG_TRUNC; in pn_recvmsg()
140 rval = skb_copy_datagram_iovec(skb, 0, msg->msg_iov, copylen); in pn_recvmsg()
[all …]
/net/
Dsocket.c553 struct msghdr *msg, size_t size) in __sock_sendmsg() argument
560 si->msg = msg; in __sock_sendmsg()
563 err = security_socket_sendmsg(sock, msg, size); in __sock_sendmsg()
567 err = sock->ops->sendmsg(iocb, sock, msg, size); in __sock_sendmsg()
575 int sock_sendmsg(struct socket *sock, struct msghdr *msg, size_t size) in sock_sendmsg() argument
583 ret = __sock_sendmsg(&iocb, sock, msg, size); in sock_sendmsg()
589 int kernel_sendmsg(struct socket *sock, struct msghdr *msg, in kernel_sendmsg() argument
600 msg->msg_iov = (struct iovec *)vec; in kernel_sendmsg()
601 msg->msg_iovlen = num; in kernel_sendmsg()
602 result = sock_sendmsg(sock, msg, size); in kernel_sendmsg()
[all …]
/net/iucv/
Diucv.c942 int iucv_message_purge(struct iucv_path *path, struct iucv_message *msg, in iucv_message_purge() argument
952 parm->purge.ipmsgid = msg->id; in iucv_message_purge()
957 msg->audit = (*(u32 *) &parm->purge.ipaudit) >> 8; in iucv_message_purge()
958 msg->tag = parm->purge.ipmsgtag; in iucv_message_purge()
978 struct iucv_message *msg, in iucv_message_receive_iprmdata() argument
992 rmmsg = msg->rmmsg; in iucv_message_receive_iprmdata()
1027 int __iucv_message_receive(struct iucv_path *path, struct iucv_message *msg, in __iucv_message_receive() argument
1033 if (msg->flags & IUCV_IPRMDATA) in __iucv_message_receive()
1034 return iucv_message_receive_iprmdata(path, msg, flags, in __iucv_message_receive()
1040 parm->db.ipmsgid = msg->id; in __iucv_message_receive()
[all …]
/net/netfilter/
Dnf_conntrack_pptp.c271 u_int16_t msg; in pptp_inbound_pkt() local
275 msg = ntohs(ctlh->messageType); in pptp_inbound_pkt()
276 pr_debug("inbound control message %s\n", pptp_msg_name[msg]); in pptp_inbound_pkt()
278 switch (msg) { in pptp_inbound_pkt()
311 pr_debug("%s, CID=%X, PCID=%X\n", pptp_msg_name[msg], in pptp_inbound_pkt()
328 pr_debug("%s, CID=%X\n", pptp_msg_name[msg], ntohs(cid)); in pptp_inbound_pkt()
347 pr_debug("%s, PCID=%X\n", pptp_msg_name[msg], ntohs(pcid)); in pptp_inbound_pkt()
357 pr_debug("%s, CID=%X\n", pptp_msg_name[msg], ntohs(cid)); in pptp_inbound_pkt()
382 msg <= PPTP_MSG_MAX ? pptp_msg_name[msg] : pptp_msg_name[0], in pptp_inbound_pkt()
383 msg, ntohs(cid), ntohs(pcid), info->cstate, info->sstate, in pptp_inbound_pkt()
[all …]
/net/irda/
Dirnetlink.c82 struct sk_buff *msg; in irda_nl_get_mode() local
90 msg = nlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL); in irda_nl_get_mode()
91 if (!msg) { in irda_nl_get_mode()
102 hdr = genlmsg_put(msg, info->snd_pid, info->snd_seq, in irda_nl_get_mode()
109 if(nla_put_string(msg, IRDA_NL_ATTR_IFNAME, in irda_nl_get_mode()
113 if(nla_put_u32(msg, IRDA_NL_ATTR_MODE, irlap->mode)) in irda_nl_get_mode()
116 genlmsg_end(msg, hdr); in irda_nl_get_mode()
118 return genlmsg_unicast(msg, info->snd_pid); in irda_nl_get_mode()
121 nlmsg_free(msg); in irda_nl_get_mode()
/net/ipv4/
Dip_sockglue.c57 static void ip_cmsg_recv_pktinfo(struct msghdr *msg, struct sk_buff *skb) in ip_cmsg_recv_pktinfo() argument
71 put_cmsg(msg, SOL_IP, IP_PKTINFO, sizeof(info), &info); in ip_cmsg_recv_pktinfo()
74 static void ip_cmsg_recv_ttl(struct msghdr *msg, struct sk_buff *skb) in ip_cmsg_recv_ttl() argument
77 put_cmsg(msg, SOL_IP, IP_TTL, sizeof(int), &ttl); in ip_cmsg_recv_ttl()
80 static void ip_cmsg_recv_tos(struct msghdr *msg, struct sk_buff *skb) in ip_cmsg_recv_tos() argument
82 put_cmsg(msg, SOL_IP, IP_TOS, 1, &ip_hdr(skb)->tos); in ip_cmsg_recv_tos()
85 static void ip_cmsg_recv_opts(struct msghdr *msg, struct sk_buff *skb) in ip_cmsg_recv_opts() argument
90 put_cmsg(msg, SOL_IP, IP_RECVOPTS, IPCB(skb)->opt.optlen, in ip_cmsg_recv_opts()
95 static void ip_cmsg_recv_retopts(struct msghdr *msg, struct sk_buff *skb) in ip_cmsg_recv_retopts() argument
104 msg->msg_flags |= MSG_CTRUNC; in ip_cmsg_recv_retopts()
[all …]
/net/sunrpc/
Drpc_pipe.c43 struct rpc_pipe_msg *msg; in rpc_purge_list() local
48 msg = list_entry(head->next, struct rpc_pipe_msg, list); in rpc_purge_list()
49 list_del(&msg->list); in rpc_purge_list()
50 msg->errno = err; in rpc_purge_list()
51 destroy_msg(msg); in rpc_purge_list()
90 rpc_queue_upcall(struct inode *inode, struct rpc_pipe_msg *msg) in rpc_queue_upcall() argument
99 list_add_tail(&msg->list, &rpci->pipe); in rpc_queue_upcall()
100 rpci->pipelen += msg->len; in rpc_queue_upcall()
107 list_add_tail(&msg->list, &rpci->pipe); in rpc_queue_upcall()
108 rpci->pipelen += msg->len; in rpc_queue_upcall()
[all …]
Drpcb_clnt.c180 u32 version, struct rpc_message *msg) in rpcb_register_call() argument
185 msg->rpc_resp = &result; in rpcb_register_call()
189 error = rpc_call_sync(rpcb_clnt, msg, 0); in rpcb_register_call()
245 struct rpc_message msg = { in rpcb_register() local
253 msg.rpc_proc = &rpcb_procedures2[RPCBPROC_UNSET]; in rpcb_register()
255 msg.rpc_proc = &rpcb_procedures2[RPCBPROC_SET]; in rpcb_register()
259 RPCBVERS_2, &msg); in rpcb_register()
266 struct rpc_message *msg) in rpcb_register_netid4() argument
268 struct rpcbind_args *map = msg->rpc_argp; in rpcb_register_netid4()
283 msg->rpc_proc = &rpcb_procedures4[RPCBPROC_UNSET]; in rpcb_register_netid4()
[all …]

12345