1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
#ifdef __MINGW32__
#include "io_internal.h"
#include <errno.h>
int io_passfd(int64 sock,int64 fd) {
errno=EINVAL;
return -1;
}
#else
#ifdef __NetBSD__
#define _NETBSD_SOURCE
#endif
#define _XOPEN_SOURCE
#define _XOPEN_SOURCE_EXTENDED 1
#include <stddef.h>
#include <sys/types.h>
#include <sys/time.h>
#include <sys/socket.h>
#include <sys/uio.h>
#include <errno.h>
#include <string.h>
#include "io_internal.h"
union fdmsg {
struct cmsghdr h;
/* on NetBSD, CMSG_SPACE is not constant */
/* char buf[CMSG_SPACE(sizeof(int))]; */
char buf[1000];
};
int io_passfd(int64 sock,int64 fd) {
struct msghdr msg;
struct iovec iov;
#ifdef CMSG_FIRSTHDR
struct cmsghdr *cmsg;
#ifndef CMSG_SPACE
#define CMSG_SPACE(x) x+100
#endif
char buf[CMSG_SPACE(sizeof(int))];
memset(buf,0,sizeof(buf));
#endif
memset(&msg,0,sizeof(msg));
iov.iov_len=1;
iov.iov_base="x";
msg.msg_iov=&iov;
msg.msg_iovlen=1;
msg.msg_name=0;
msg.msg_namelen=0;
#ifdef CMSG_FIRSTHDR
msg.msg_control = buf;
msg.msg_controllen = sizeof(buf);
cmsg = CMSG_FIRSTHDR(&msg);
cmsg->cmsg_level = SOL_SOCKET;
cmsg->cmsg_type = SCM_RIGHTS;
#ifndef CMSG_LEN
#define CMSG_LEN(x) x
#endif
cmsg->cmsg_len = CMSG_LEN(sizeof(int));
msg.msg_controllen = cmsg->cmsg_len;
*((int*)CMSG_DATA(cmsg))=fd;
#else
msg.msg_accrights = (char*)&fd;
msg.msg_accrightslen = sizeof(fd);
#endif
return sendmsg(sock,&msg,0)>=0?0:-1;
}
#endif
|
