Commit 5813cd0b authored by Cyrill Gorcunov's avatar Cyrill Gorcunov Committed by Pavel Emelyanov

util-net: Switch send_fd/recv_fd to use scm_fdset structure

To be able to use scm_fdset structure the two helpers
added scm_fdset_init_chunk and scm_fdset_init.
Signed-off-by: 's avatarCyrill Gorcunov <gorcunov@openvz.org>
Signed-off-by: 's avatarPavel Emelyanov <xemul@parallels.com>
parent 333ce8fc
#include <sys/socket.h> #include <sys/socket.h>
#include <sys/un.h> #include <sys/un.h>
#include <errno.h>
#include "compiler.h"
#include "types.h"
#include "syscall.h" #include "syscall.h"
int send_fd(int sock, struct sockaddr_un *saddr, int len, int fd) #include "util-net.h"
static void scm_fdset_init_chunk(struct scm_fdset *fdset, int nr_fds)
{ {
char cmsgbuf[CMSG_SPACE(sizeof(int))]; struct cmsghdr *cmsg;
struct msghdr hdr = { };
struct iovec data = { }; fdset->hdr.msg_controllen = CMSG_LEN(sizeof(int) * nr_fds);
struct cmsghdr* cmsg;
int *cmsg_data; cmsg = CMSG_FIRSTHDR(&fdset->hdr);
char dummy = '*'; cmsg->cmsg_len = fdset->hdr.msg_controllen;
}
static int *scm_fdset_init(struct scm_fdset *fdset, struct sockaddr_un *saddr, int saddr_len)
{
struct cmsghdr *cmsg;
BUILD_BUG_ON(CR_SCM_MAX_FD > SCM_MAX_FD);
BUILD_BUG_ON(sizeof(fdset->msg_buf) < (CMSG_SPACE(sizeof(int) * CR_SCM_MAX_FD)));
fdset->msg = '*';
fdset->iov.iov_base = &fdset->msg;
fdset->iov.iov_len = sizeof(fdset->msg);
fdset->hdr.msg_iov = &fdset->iov;
fdset->hdr.msg_iovlen = 1;
fdset->hdr.msg_name = (struct sockaddr *)saddr;
fdset->hdr.msg_namelen = saddr_len;
data.iov_base = &dummy; fdset->hdr.msg_control = &fdset->msg_buf;
data.iov_len = sizeof(dummy); fdset->hdr.msg_controllen = CMSG_LEN(sizeof(int) * CR_SCM_MAX_FD);
hdr.msg_name = (struct sockaddr *)saddr; cmsg = CMSG_FIRSTHDR(&fdset->hdr);
hdr.msg_namelen = len; cmsg->cmsg_len = fdset->hdr.msg_controllen;
hdr.msg_iov = &data; cmsg->cmsg_level = SOL_SOCKET;
hdr.msg_iovlen = 1; cmsg->cmsg_type = SCM_RIGHTS;
hdr.msg_control = &cmsgbuf; return (int *)CMSG_DATA(cmsg);
hdr.msg_controllen = CMSG_LEN(sizeof(int)); }
cmsg = CMSG_FIRSTHDR(&hdr); int send_fd(int sock, struct sockaddr_un *saddr, int len, int fd)
cmsg->cmsg_len = hdr.msg_controllen; {
cmsg->cmsg_level = SOL_SOCKET; struct scm_fdset fdset;
cmsg->cmsg_type = SCM_RIGHTS; int *cmsg_data;
cmsg_data = (int *)CMSG_DATA(cmsg); cmsg_data = scm_fdset_init(&fdset, saddr, len);
scm_fdset_init_chunk(&fdset, 1);
*cmsg_data = fd; *cmsg_data = fd;
return sys_sendmsg(sock, &hdr, 0); return sys_sendmsg(sock, &fdset.hdr, 0);
} }
int recv_fd(int sock) int recv_fd(int sock)
{ {
char ccmsg[CMSG_SPACE(sizeof(int))]; struct scm_fdset fdset;
struct msghdr msg = { };
struct iovec iov = { };
struct cmsghdr *cmsg; struct cmsghdr *cmsg;
int *cmsg_data; int *cmsg_data;
char buf[1];
int ret; int ret;
iov.iov_base = buf; cmsg_data = scm_fdset_init(&fdset, NULL, 0);
iov.iov_len = 1; scm_fdset_init_chunk(&fdset, 1);
msg.msg_iov = &iov;
msg.msg_iovlen = 1;
msg.msg_control = ccmsg;
msg.msg_controllen = sizeof(ccmsg);
ret = sys_recvmsg(sock, &msg, 0); ret = sys_recvmsg(sock, &fdset.hdr, 0);
if (ret < 0) if (ret < 0)
return ret; return ret;
cmsg = CMSG_FIRSTHDR(&msg); cmsg = CMSG_FIRSTHDR(&fdset.hdr);
if (!cmsg || (cmsg->cmsg_type != SCM_RIGHTS)) if (!cmsg || (cmsg->cmsg_type != SCM_RIGHTS))
return -2; return -2;
cmsg_data = (int *)CMSG_DATA(cmsg);
return *cmsg_data; return *cmsg_data;
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment