]> andersk Git - openssh.git/blob - monitor_fdpass.c
- (dtucker) [monitor_fdpass.c] Reduce diff vs OpenBSD by moving some
[openssh.git] / monitor_fdpass.c
1 /* $OpenBSD: monitor_fdpass.c,v 1.17 2008/03/24 16:11:07 deraadt Exp $ */
2 /*
3  * Copyright 2001 Niels Provos <provos@citi.umich.edu>
4  * All rights reserved.
5  *
6  * Redistribution and use in source and binary forms, with or without
7  * modification, are permitted provided that the following conditions
8  * are met:
9  * 1. Redistributions of source code must retain the above copyright
10  *    notice, this list of conditions and the following disclaimer.
11  * 2. Redistributions in binary form must reproduce the above copyright
12  *    notice, this list of conditions and the following disclaimer in the
13  *    documentation and/or other materials provided with the distribution.
14  *
15  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
16  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
17  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
18  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
19  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
20  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
21  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
22  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
23  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
24  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
25  */
26
27 #include "includes.h"
28
29 #include <sys/types.h>
30 #include <sys/socket.h>
31 #include <sys/uio.h>
32 #ifdef HAVE_SYS_UN_H
33 #include <sys/un.h>
34 #endif
35
36 #include <errno.h>
37 #include <string.h>
38 #include <stdarg.h>
39
40 #include "log.h"
41 #include "monitor_fdpass.h"
42
43 int
44 mm_send_fd(int sock, int fd)
45 {
46 #if defined(HAVE_SENDMSG) && (defined(HAVE_ACCRIGHTS_IN_MSGHDR) || defined(HAVE_CONTROL_IN_MSGHDR))
47         struct msghdr msg;
48 #ifndef HAVE_ACCRIGHTS_IN_MSGHDR
49         union {
50                 struct cmsghdr hdr;
51                 char buf[CMSG_SPACE(sizeof(int))];
52         } cmsgbuf;
53         struct cmsghdr *cmsg;
54 #endif
55         struct iovec vec;
56         char ch = '\0';
57         ssize_t n;
58
59         memset(&msg, 0, sizeof(msg));
60 #ifdef HAVE_ACCRIGHTS_IN_MSGHDR
61         msg.msg_accrights = (caddr_t)&fd;
62         msg.msg_accrightslen = sizeof(fd);
63 #else
64         msg.msg_control = (caddr_t)&cmsgbuf.buf;
65         msg.msg_controllen = sizeof(cmsgbuf.buf);
66         cmsg = CMSG_FIRSTHDR(&msg);
67         cmsg->cmsg_len = CMSG_LEN(sizeof(int));
68         cmsg->cmsg_level = SOL_SOCKET;
69         cmsg->cmsg_type = SCM_RIGHTS;
70         *(int *)CMSG_DATA(cmsg) = fd;
71 #endif
72
73         vec.iov_base = &ch;
74         vec.iov_len = 1;
75         msg.msg_iov = &vec;
76         msg.msg_iovlen = 1;
77
78         if ((n = sendmsg(sock, &msg, 0)) == -1) {
79                 error("%s: sendmsg(%d): %s", __func__, fd,
80                     strerror(errno));
81                 return -1;
82         }
83
84         if (n != 1) {
85                 error("%s: sendmsg: expected sent 1 got %ld",
86                     __func__, (long)n);
87                 return -1;
88         }
89         return 0;
90 #else
91         error("%s: file descriptor passing not supported", __func__);
92         return -1;
93 #endif
94 }
95
96 int
97 mm_receive_fd(int sock)
98 {
99 #if defined(HAVE_RECVMSG) && (defined(HAVE_ACCRIGHTS_IN_MSGHDR) || defined(HAVE_CONTROL_IN_MSGHDR))
100         struct msghdr msg;
101 #ifndef HAVE_ACCRIGHTS_IN_MSGHDR
102         union {
103                 struct cmsghdr hdr;
104                 char buf[CMSG_SPACE(sizeof(int))];
105         } cmsgbuf;
106         struct cmsghdr *cmsg;
107 #endif
108         struct iovec vec;
109         ssize_t n;
110         char ch;
111         int fd;
112
113         memset(&msg, 0, sizeof(msg));
114         vec.iov_base = &ch;
115         vec.iov_len = 1;
116         msg.msg_iov = &vec;
117         msg.msg_iovlen = 1;
118 #ifdef HAVE_ACCRIGHTS_IN_MSGHDR
119         msg.msg_accrights = (caddr_t)&fd;
120         msg.msg_accrightslen = sizeof(fd);
121 #else
122         msg.msg_control = &cmsgbuf.buf;
123         msg.msg_controllen = sizeof(cmsgbuf.buf);
124 #endif
125
126         if ((n = recvmsg(sock, &msg, 0)) == -1) {
127                 error("%s: recvmsg: %s", __func__, strerror(errno));
128                 return -1;
129         }
130
131         if (n != 1) {
132                 error("%s: recvmsg: expected received 1 got %ld",
133                     __func__, (long)n);
134                 return -1;
135         }
136
137 #ifdef HAVE_ACCRIGHTS_IN_MSGHDR
138         if (msg.msg_accrightslen != sizeof(fd)) {
139                 error("%s: no fd", __func__);
140                 return -1;
141         }
142 #else
143         cmsg = CMSG_FIRSTHDR(&msg);
144         if (cmsg == NULL) {
145                 error("%s: no message header", __func__);
146                 return -1;
147         }
148
149 #ifndef BROKEN_CMSG_TYPE
150         if (cmsg->cmsg_type != SCM_RIGHTS) {
151                 error("%s: expected type %d got %d", __func__,
152                     SCM_RIGHTS, cmsg->cmsg_type);
153                 return -1;
154         }
155 #endif
156         fd = (*(int *)CMSG_DATA(cmsg));
157 #endif
158         return fd;
159 #else
160         error("%s: file descriptor passing not supported", __func__);
161         return -1;
162 #endif
163 }
This page took 0.314134 seconds and 5 git commands to generate.