/src/dist/pf/sbin/pflogd/ |
privsep_fdpass.c | 55 struct cmsghdr *cmsg; local in function:send_fd 65 cmsg = CMSG_FIRSTHDR(&msg); 66 cmsg->cmsg_len = CMSG_LEN(sizeof(int)); 67 cmsg->cmsg_level = SOL_SOCKET; 68 cmsg->cmsg_type = SCM_RIGHTS; 69 *(int *)CMSG_DATA(cmsg) = fd; 91 struct cmsghdr *cmsg; local in function:receive_fd 111 cmsg = CMSG_FIRSTHDR(&msg); 112 if (cmsg == NULL) { 116 if (cmsg->cmsg_type != SCM_RIGHTS [all...] |
/src/lib/libc/rpc/ |
rpc_callmsg.c | 69 xdr_callmsg(XDR *xdrs, struct rpc_msg *cmsg) 75 _DIAGASSERT(cmsg != NULL); 78 if (cmsg->rm_call.cb_cred.oa_length > MAX_AUTH_BYTES) { 81 if (cmsg->rm_call.cb_verf.oa_length > MAX_AUTH_BYTES) { 85 + RNDUP(cmsg->rm_call.cb_cred.oa_length) 87 + RNDUP(cmsg->rm_call.cb_verf.oa_length)); 89 IXDR_PUT_INT32(buf, cmsg->rm_xid); 90 IXDR_PUT_ENUM(buf, cmsg->rm_direction); 91 if (cmsg->rm_direction != CALL) { 94 IXDR_PUT_INT32(buf, cmsg->rm_call.cb_rpcvers) [all...] |
rpc_prot.c | 204 xdr_callhdr(XDR *xdrs, struct rpc_msg *cmsg) 208 _DIAGASSERT(cmsg != NULL); 210 cmsg->rm_direction = CALL; 211 cmsg->rm_call.cb_rpcvers = RPC_MSG_VERSION; 214 xdr_u_int32_t(xdrs, &(cmsg->rm_xid)) && 215 xdr_enum(xdrs, (enum_t *)(void *)&(cmsg->rm_direction)) && 216 xdr_u_int32_t(xdrs, &(cmsg->rm_call.cb_rpcvers)) && 217 xdr_u_int32_t(xdrs, &(cmsg->rm_call.cb_prog)) ) 218 return (xdr_u_int32_t(xdrs, &(cmsg->rm_call.cb_vers)));
|
/src/sys/external/bsd/libnv/dist/ |
msgio.c | 76 msghdr_add_fd(struct cmsghdr *cmsg, int fd) 86 cmsg->cmsg_level = SOL_SOCKET; 87 cmsg->cmsg_type = SCM_RIGHTS; 88 cmsg->cmsg_len = CMSG_LEN(sizeof(fd)); 89 bcopy(&fd, CMSG_DATA(cmsg), sizeof(fd)); 95 msghdr_get_fd(struct cmsghdr *cmsg) 99 if (cmsg == NULL || cmsg->cmsg_level != SOL_SOCKET || 100 cmsg->cmsg_type != SCM_RIGHTS || 101 cmsg->cmsg_len != CMSG_LEN(sizeof(fd))) 183 struct cmsghdr *cmsg; local in function:cred_send 223 struct cmsghdr *cmsg; local in function:cred_recv 259 struct cmsghdr *cmsg; local in function:fd_package_send 308 struct cmsghdr *cmsg; local in function:fd_package_recv [all...] |
/src/lib/libc/net/ |
ip6opt.c | 126 inet6_option_append(struct cmsghdr *cmsg, const uint8_t *typep, int multx, 133 _DIAGASSERT(cmsg != NULL); 136 bp = (uint8_t *)(void *)cmsg + cmsg->cmsg_len; 137 eh = (struct ip6_ext *)(void *)CMSG_DATA(cmsg); 152 cmsg->cmsg_len += 2; 163 _DIAGASSERT(__type_fit(socklen_t, padlen + cmsg->cmsg_len)); 164 cmsg->cmsg_len += (socklen_t)padlen; 174 _DIAGASSERT(__type_fit(socklen_t, optlen + cmsg->cmsg_len)); 175 cmsg->cmsg_len += (socklen_t)optlen [all...] |
sctp_sys_calls.c | 383 struct cmsghdr *cmsg; local in function:sctp_sendmsg 436 cmsg = (struct cmsghdr *)controlVector; 438 cmsg->cmsg_level = IPPROTO_SCTP; 439 cmsg->cmsg_type = SCTP_SNDRCV; 440 cmsg->cmsg_len = CMSG_LEN (sizeof(struct sctp_sndrcvinfo) ); 441 s_info = (struct sctp_sndrcvinfo *)CMSG_DATA(cmsg); 451 msg.msg_controllen = cmsg->cmsg_len; 485 struct cmsghdr *cmsg; local in function:sctp_send 498 cmsg = (struct cmsghdr *)controlVector; 500 cmsg->cmsg_level = IPPROTO_SCTP 609 struct cmsghdr *cmsg; local in function:sctp_recvmsg 661 struct cmsghdr *cmsg; local in function:sctp_recvv 754 struct cmsghdr *cmsg; local in function:sctp_sendv [all...] |
rthdr.c | 114 inet6_rthdr_add(struct cmsghdr *cmsg, const struct in6_addr *addr, u_int flags) 118 _DIAGASSERT(cmsg != NULL); 121 rthdr = (struct ip6_rthdr *)(void *)CMSG_DATA(cmsg); 140 cmsg->cmsg_len = (socklen_t)len; 151 inet6_rthdr_lasthop(struct cmsghdr *cmsg, unsigned int flags) 155 _DIAGASSERT(cmsg != NULL); 157 rthdr = (struct ip6_rthdr *)(void *)CMSG_DATA(cmsg); 186 inet6_rthdr_segments(const struct cmsghdr *cmsg) 190 _DIAGASSERT(cmsg != NULL); 192 rthdr = __UNCONST(CCMSG_DATA(cmsg)); [all...] |
/src/tests/net/fdpass/ |
fdpass.c | 54 struct cmsghdr *cmsg; local in function:send_fd 67 cmsg = CMSG_FIRSTHDR(&msg); 68 cmsg->cmsg_len = CMSG_LEN(sizeof(int)); 69 cmsg->cmsg_level = SOL_SOCKET; 70 cmsg->cmsg_type = SCM_RIGHTS; 71 *(int *)CMSG_DATA(cmsg) = fd; 72 msg.msg_controllen = cmsg->cmsg_len; 106 struct cmsghdr *cmsg; local in function:recv_fd 141 cmsg = CMSG_FIRSTHDR(&msg); 142 if (cmsg == NULL [all...] |
/src/tests/net/net/ |
t_pktinfo.c | 102 struct cmsghdr *cmsg; local in function:receive 123 for (cmsg = CMSG_FIRSTHDR(&msg); cmsg != NULL; 124 cmsg = CMSG_NXTHDR(&msg, cmsg)) { 125 if (cmsg->cmsg_level != IPPROTO_IP) 126 ERRX("bad level %d", cmsg->cmsg_level); 128 switch (cmsg->cmsg_type) { 137 ERRX("bad type %d", cmsg->cmsg_type); 139 ipi = (void *)CMSG_DATA(cmsg); [all...] |
t_pktinfo_send.c | 118 struct cmsghdr *cmsg; local in function:sendto_pktinfo 136 cmsg = (struct cmsghdr *)cmsgbuf; 140 cmsg->cmsg_len = CMSG_LEN(sizeof(struct in_pktinfo)); 141 cmsg->cmsg_level = IPPROTO_IP; 142 cmsg->cmsg_type = IP_PKTINFO; 144 pi = (struct in_pktinfo *)CMSG_DATA(cmsg);
|
/src/sys/fs/puffs/ |
puffs_compat.c | 216 struct puffs50_##name *cmsg; \ 219 cmsg = (struct puffs50_##name *)creq; \ 223 cmsg->field = omsg->field; 240 memcpy(cmsg->pvfsr_data, omsg->pvfsr_data, cmsg->pvfsr_dsize); 261 vattr_to_50(&omsg->pvnr_va, &cmsg->pvnr_va); 273 vattr_to_50(&omsg->pvnr_va, &cmsg->pvnr_va); 285 vattr_to_50(&omsg->pvnr_va, &cmsg->pvnr_va); 297 vattr_to_50(&omsg->pvnr_va, &cmsg->pvnr_va); 298 memcpy(cmsg->pvnr_link, omsg->pvnr_link [all...] |
/src/sys/compat/netbsd32/ |
netbsd32_socket.c | 57 #define CMSG32_DATA(cmsg) (__CASTV(u_char *, cmsg) + CMSG32_ASIZE) 80 struct cmsghdr *cmsg, cmsg32; local in function:copyout32_msg_control_mbuf 85 cmsg = mtod(m, struct cmsghdr *); 87 if ((char *)cmsg == mtod(m, char *) + m->m_len) 89 if ((char *)cmsg > mtod(m, char *) + m->m_len - sizeof(*cmsg)) 91 cmsg32 = *cmsg; 92 j = cmsg->cmsg_len - CMSG_LEN(0); 96 if (cmsg->cmsg_level == SOL_SOCKE 385 struct cmsghdr *cmsg, cmsg32, *cc; local in function:copyin32_msg_control [all...] |
netbsd32_compat_43.c | 469 struct cmsghdr *cmsg = mtod(control, void *); local in function:compat_43_netbsd32_orecvmsg 471 if (cmsg->cmsg_level == SOL_SOCKET 472 && cmsg->cmsg_type == SCM_RIGHTS 473 && cmsg->cmsg_len < omsg.msg_accrightslen 474 && copyout(CMSG_DATA(cmsg), 476 cmsg->cmsg_len) == 0) { 477 omsg.msg_accrightslen = cmsg->cmsg_len;
|
/src/sbin/mount_portal/ |
activate.c | 113 struct cmsghdr *cmsg; local in function:send_reply 145 cmsg = (struct cmsghdr *) ctl; 146 cmsg->cmsg_len = CMSG_LEN(sizeof(int)); 147 cmsg->cmsg_level = SOL_SOCKET; 148 cmsg->cmsg_type = SCM_RIGHTS; 150 files = (int *)CMSG_DATA(cmsg);
|
/src/sys/compat/common/ |
uipc_syscalls_43.c | 250 struct cmsghdr *cmsg = mtod(control, struct cmsghdr *); local in function:compat_43_sys_recvmsg 252 if (cmsg->cmsg_level == SOL_SOCKET 253 && cmsg->cmsg_type == SCM_RIGHTS 254 && cmsg->cmsg_len < omsg.msg_accrightslen 255 && copyout(CMSG_DATA(cmsg), omsg.msg_accrights, 256 cmsg->cmsg_len) == 0) { 257 omsg.msg_accrightslen = cmsg->cmsg_len; 305 struct cmsghdr *cmsg; local in function:compat43_set_accrights 323 cmsg = mtod(ctl, struct cmsghdr *); 324 cmsg->cmsg_len = CMSG_SPACE(accrightslen) [all...] |
/src/dist/pf/libexec/tftp-proxy/ |
tftp-proxy.c | 92 struct cmsghdr *cmsg; local in function:main 212 for (cmsg = CMSG_FIRSTHDR(&msg); cmsg != NULL; 213 cmsg = CMSG_NXTHDR(&msg, cmsg)) { 214 if (cmsg->cmsg_level == IPPROTO_IP && 215 cmsg->cmsg_type == IP_RECVDSTADDR) { 217 CMSG_DATA(cmsg), sizeof(struct in_addr));
|
/src/sys/external/bsd/compiler_rt/dist/lib/tsan/rtl/ |
tsan_platform_linux.cc | 320 // see 'man recvmsg' and 'man 3 cmsg'. 324 struct cmsghdr *cmsg = CMSG_FIRSTHDR(msg); local in function:__tsan::ExtractRecvmsgFDs 325 for (; cmsg; cmsg = CMSG_NXTHDR(msg, cmsg)) { 326 if (cmsg->cmsg_level != SOL_SOCKET || cmsg->cmsg_type != SCM_RIGHTS) 328 int n = (cmsg->cmsg_len - CMSG_LEN(0)) / sizeof(fds[0]); 330 fds[res++] = ((int*)CMSG_DATA(cmsg))[i];
|
/src/sys/sys/ |
socket.h | 536 * Alignment requirement for CMSG struct manipulation. 551 #define __CMSG_MSGNEXT(cmsg) \ 552 (__CASTV(char *, cmsg) + __CMSG_ALIGN((cmsg)->cmsg_len)) 557 #define CMSG_DATA(cmsg) (__CASTV(unsigned char *, cmsg) + __CMSG_ASIZE) 558 #define CCMSG_DATA(cmsg) (__CASTCV(const unsigned char *, cmsg) + __CMSG_ASIZE) 561 #define CMSG_NXTHDR(mhdr, cmsg) \ 563 __CMSG_MSGNEXT(cmsg) + __CMSG_ASIZE > __CMSG_MSGEND(mhdr) ? 0 : [all...] |
/src/usr.sbin/inetd/ |
inetd.c | 984 struct cmsghdr *cmsg; local in function:recvfromto 1012 for (cmsg = (struct cmsghdr *)CMSG_FIRSTHDR(&msg); cmsg != NULL; 1013 cmsg = (struct cmsghdr *)CMSG_NXTHDR(&msg, cmsg)) { 1014 if (cmsg->cmsg_level == IPPROTO_IP && 1015 cmsg->cmsg_type == IP_RECVDSTADDR) { 1016 struct in_addr *dst = (struct in_addr *)CMSG_DATA(cmsg); 1024 if (cmsg->cmsg_level == IPPROTO_IP && 1025 cmsg->cmsg_type == IP_PKTINFO) 1075 struct cmsghdr *cmsg; local in function:sendfromto [all...] |
/src/sys/compat/linux/common/ |
linux_socket.h | 179 * Linux alignment requirement for CMSG struct manipulation. 194 /* Linux either uses this, or &((cmsg)->__cmsg_data) */ 195 #define LINUX_CMSG_DATA(cmsg) \ 196 ((u_char *)((struct linux_cmsghdr *)(cmsg) + 1))
|
linux_socket.c | 507 * Handle cmsg if there is any. 511 struct cmsghdr *cmsg; local in function:linux_sys_sendmsg 596 cmsg = (void *)&control[cidx]; 597 cmsg->cmsg_len = l_cmsg.cmsg_len + LINUX_CMSG_ALIGN_DELTA; 598 cmsg->cmsg_level = l_cmsg.cmsg_level; 599 cmsg->cmsg_type = l_cmsg.cmsg_type; 602 memset(cmsg + 1, 0, 603 CMSG_ALIGN(sizeof(*cmsg)) - sizeof(*cmsg)); 607 CMSG_DATA(cmsg), 679 struct cmsghdr *cmsg; local in function:linux_copyout_msg_control [all...] |
/src/usr.bin/msgs/ |
msgs.c | 741 int n, cmsg; local in function:ask 759 cmsg = prevmsg; 761 cmsg = atoi(&inbuf[1]); 763 cmsg = msg; 764 snprintf(fname, sizeof (fname), "%s/%d", _PATH_MSGS, cmsg); 770 printf("Message %d not found\n", cmsg); 814 printf("Message %d saved in \"%s\"\n", cmsg, fname);
|
/src/sys/kern/ |
uipc_syscalls.c | 824 struct cmsghdr *cmsg; local in function:free_control_mbuf 828 cmsg = mtod(control, struct cmsghdr *); 831 if (do_free_rights && cmsg->cmsg_level == SOL_SOCKET 832 && cmsg->cmsg_type == SCM_RIGHTS) 840 /* Copy socket control/CMSG data to user buffer, frees the mbuf */ 845 struct cmsghdr *cmsg; local in function:copyout_msg_control 859 cmsg = mtod(m, struct cmsghdr *); 863 if (cmsg->cmsg_level == SOL_SOCKET 864 && cmsg->cmsg_type == SCM_RIGHTS) 870 ktrkuser(mbuftypes[MT_CONTROL], cmsg, cmsg->cmsg_len) 1616 for (struct cmsghdr *cmsg = CMSG_FIRSTHDR(&mhdr); cmsg; local in function:sockargs [all...] |
/src/usr.sbin/sdpd/ |
server.c | 88 /* number of groups we allocate space for in cmsg */ 115 log_crit("Malloc cmsg buffer (len=%zu) failed.", srv->ctllen); 414 struct cmsghdr *cmsg; local in function:server_process_request 458 if ((cmsg = CMSG_FIRSTHDR(&msg)) != NULL 459 && cmsg->cmsg_level == SOL_SOCKET 460 && cmsg->cmsg_type == SCM_CREDS 461 && cmsg->cmsg_len >= CMSG_LEN(SOCKCREDSIZE(0))) 462 srv->fdidx[fd].priv = server_auth_check(srv, CMSG_DATA(cmsg));
|
/src/usr.sbin/perfused/ |
msg.c | 118 struct cmsghdr *cmsg = (struct cmsghdr *)(void *)&cmsg_buf; local in function:perfused_recv_early 119 struct sockcred *sc = (struct sockcred *)(void *)(cmsg + 1); 133 msg.msg_control = cmsg; 142 if (cmsg->cmsg_type != SCM_CREDS) { 149 MIN(cmsg->cmsg_len - sizeof(*cmsg), sockcred_len));
|