Lines Matching defs:msg
2599 /* Return true iff msg->msg_controllen is valid, cmsgh is a valid
2600 pointer in msg->msg_control with at least "space" bytes after it,
2603 cmsg_min_space(struct msghdr *msg, struct cmsghdr *cmsgh, size_t space)
2610 if (cmsgh == NULL || msg->msg_control == NULL)
2625 if (msg->msg_controllen < 0)
2635 cmsg_offset = (char *)cmsgh - (char *)msg->msg_control;
2637 cmsg_offset + space <= msg->msg_controllen);
2640 /* If pointer CMSG_DATA(cmsgh) is in buffer msg->msg_control, set
2642 true; otherwise, return false. Assumes cmsgh, msg->msg_control and
2643 msg->msg_controllen are valid. */
2645 get_cmsg_data_space(struct msghdr *msg, struct cmsghdr *cmsgh, size_t *space)
2652 data_offset = data_ptr - (char *)msg->msg_control;
2653 if (data_offset > msg->msg_controllen)
2655 *space = msg->msg_controllen - data_offset;
2660 msg->msg_control, return -1. If cmsgh is valid and its associated
2667 get_cmsg_data_len(struct msghdr *msg, struct cmsghdr *cmsgh, size_t *data_len)
2671 if (!cmsg_min_space(msg, cmsgh, CMSG_LEN(0)) ||
2675 if (!get_cmsg_data_space(msg, cmsgh, &space))
3839 struct msghdr *msg;
3849 ctx->result = recvmsg(s->sock_fd, ctx->msg, ctx->flags);
3870 struct msghdr msg = {0};
3903 msg.msg_name = SAS2SA(&addrbuf);
3904 msg.msg_namelen = addrbuflen;
3905 msg.msg_iov = iov;
3906 msg.msg_iovlen = iovlen;
3907 msg.msg_control = controlbuf;
3908 msg.msg_controllen = controllen;
3910 ctx.msg = &msg;
3920 for (cmsgh = ((msg.msg_controllen > 0) ? CMSG_FIRSTHDR(&msg) : NULL);
3921 cmsgh != NULL; cmsgh = CMSG_NXTHDR(&msg, cmsgh)) {
3925 cmsg_status = get_cmsg_data_len(&msg, cmsgh, &cmsgdatalen);
3957 (int)msg.msg_flags,
3959 ((msg.msg_namelen > addrbuflen) ?
3960 addrbuflen : msg.msg_namelen),
3973 for (cmsgh = ((msg.msg_controllen > 0) ? CMSG_FIRSTHDR(&msg) : NULL);
3974 cmsgh != NULL; cmsgh = CMSG_NXTHDR(&msg, cmsgh)) {
3975 cmsg_status = get_cmsg_data_len(&msg, cmsgh, &cmsgdatalen);
4400 struct msghdr *msg;
4407 struct msghdr *msg,
4430 msg->msg_iovlen = ndataparts;
4437 msg->msg_iov = iovs;
4467 ctx->result = sendmsg(s->sock_fd, ctx->msg, ctx->flags);
4479 struct msghdr msg;
4497 memset(&msg, 0, sizeof(msg));
4509 msg.msg_name = &addrbuf;
4510 msg.msg_namelen = addrlen;
4519 if (sock_sendmsg_iovec(s, data_arg, &msg, &databufs, &ndatabufs) == -1) {
4584 msg.msg_control = controlbuf;
4586 msg.msg_controllen = controllen;
4600 cmsgh = (i == 0) ? CMSG_FIRSTHDR(&msg) : CMSG_NXTHDR(&msg, cmsgh);
4612 if (cmsg_min_space(&msg, cmsgh, msg_len)) {
4616 if (get_cmsg_data_space(&msg, cmsgh, &space))
4637 ctx.msg = &msg;
4650 PyMem_Free(msg.msg_iov);
4697 struct msghdr msg;
4703 static char *keywords[] = {"msg", "op", "iv", "assoclen", "flags", 0};
4719 memset(&msg, 0, sizeof(msg));
4759 msg.msg_controllen = controllen;
4760 msg.msg_control = controlbuf;
4765 if (sock_sendmsg_iovec(self, data_arg, &msg, &databufs, &ndatabufs) == -1) {
4771 header = CMSG_FIRSTHDR(&msg);
4785 header = CMSG_NXTHDR(&msg, header);
4801 header = CMSG_NXTHDR(&msg, header);
4814 ctx.msg = &msg;
4827 PyMem_Free(msg.msg_iov);
4836 "sendmsg_afalg([msg], *, op[, iv[, assoclen[, flags=MSG_MORE]]])\n\