![[BACK]](/icons/back.gif){kind=icon}
Return to sock.c CVS log ![[TXT]](/icons/text.gif){kind=icon}
![[DIR]](/icons/dir.gif){kind=icon}
Up to [local] / src / usr.bin / cvs|
Return to sock.c CVS log | Up to [local] / src / usr.bin / cvs |
1.1 jfb 1: /* $OpenBSD$ */
2: /*
3: * Copyright (c) 2004 Jean-Francois Brousseau <jfb@openbsd.org>
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: *
10: * 1. Redistributions of source code must retain the above copyright
11: * notice, this list of conditions and the following disclaimer.
12: * 2. The name of the author may not be used to endorse or promote products
13: * derived from this software without specific prior written permission.
14: *
15: * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES,
16: * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
17: * AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
18: * THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
19: * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
20: * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
21: * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
22: * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
23: * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
24: * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
25: */
26:
27: #include <sys/types.h>
28: #include <sys/socket.h>
29: #include <sys/un.h>
30:
31: #include <poll.h>
32: #include <stdlib.h>
33: #include <stdio.h>
34: #include <unistd.h>
35: #include <errno.h>
36: #include <string.h>
37:
38: #include "log.h"
39: #include "sock.h"
40: #include "cvsd.h"
41: #include "event.h"
42:
43:
44: volatile sig_atomic_t cvs_sock_doloop;
45:
46:
47: char *cvsd_sock_path = CVSD_SOCK_PATH;
48:
49:
50:
51: /* daemon API */
52: static int cvsd_sock = -1;
53: static struct sockaddr_un cvsd_sun;
54:
55: /* for client API */
56: static int cvs_sock = -1;
57: static struct sockaddr_un cvs_sun;
58:
59:
60: /*
61: * cvsd_sock_open()
62: *
63: * Open the daemon's local socket.
64: */
65:
66: int
67: cvsd_sock_open(void)
68: {
69: cvsd_sun.sun_family = AF_LOCAL;
70: strlcpy(cvsd_sun.sun_path, cvsd_sock_path, sizeof(cvsd_sun.sun_path));
71:
72: cvsd_sock = socket(AF_LOCAL, SOCK_STREAM, 0);
73: if (cvsd_sock == -1) {
74: cvs_log(LP_ERRNO, "failed to open socket");
75: return (-1);
76: }
77:
78: if (bind(cvsd_sock, (struct sockaddr *)&cvsd_sun,
79: SUN_LEN(&cvsd_sun)) == -1) {
80: cvs_log(LP_ERRNO, "failed to bind local socket to `%s'",
81: cvsd_sock_path);
82: (void)close(cvsd_sock);
83: return (-1);
84: }
85:
86: listen(cvsd_sock, 10);
87:
88: if (chmod(cvsd_sock_path, CVSD_SOCK_PERMS) == -1) {
89: cvs_log(LP_ERRNO, "failed to change mode of `%s'",
90: cvsd_sock_path);
91: (void)close(cvsd_sock);
92: (void)unlink(cvsd_sock_path);
93: return (-1);
94: }
95:
96: cvs_log(LP_DEBUG, "opened local socket `%s'", cvsd_sock_path);
97:
98: return (0);
99: }
100:
101:
102: /*
103: * cvsd_sock_close()
104: *
105: * Close the local socket.
106: */
107:
108: void
109: cvsd_sock_close(void)
110: {
111: cvs_log(LP_DEBUG, "closing local socket `%s'", CVSD_SOCK_PATH);
112: if (close(cvsd_sock) == -1) {
113: cvs_log(LP_ERRNO, "failed to close local socket");
114: }
115: if (unlink(cvsd_sock_path) == -1)
116: cvs_log(LP_ERRNO, "failed to unlink local socket `%s'",
117: CVSD_SOCK_PATH);
118: }
119:
120:
121: /*
122: * cvsd_sock_loop()
123: *
124: */
125:
126: void
127: cvsd_sock_loop(void)
128: {
129: int nfds, sock;
130: socklen_t slen;
131: struct sockaddr_un sun;
132: struct pollfd pfd[1];
133:
134: cvs_sock_doloop = 1;
135:
136: while (cvs_sock_doloop) {
137: pfd[0].fd = cvsd_sock;
138: pfd[0].events = POLLIN;
139:
140: nfds = poll(pfd, 1, INFTIM);
141: if (nfds == -1) {
142: if (errno == EINTR)
143: continue;
144: cvs_log(LP_ERR, "failed to poll local socket");
145: }
146:
147: if ((nfds == 0) || !(pfd[0].revents & POLLIN))
148: continue;
149:
150: sock = accept(pfd[0].fd, (struct sockaddr *)&sun, &slen);
151: if (sock == -1) {
152: cvs_log(LP_ERRNO, "failed to accept connection");
153: }
154: cvs_log(LP_DEBUG, "accepted connection");
155:
156: cvsd_sock_hdl(sock);
157: }
158:
159:
160: }
161:
162:
163: /*
164: * cvsd_sock_hdl()
165: *
166: * Handle the events for a single connection.
167: */
168:
169: int
170: cvsd_sock_hdl(int fd)
171: {
172: uid_t uid;
173: gid_t gid;
174: struct cvs_event ev;
175:
176: /* don't trust what the other end put in */
177: if (getpeereid(fd, &uid, &gid) == -1) {
178: cvs_log(LP_ERR, "failed to get peer credentials");
179: (void)close(fd);
180: return (-1);
181: }
182:
183: if (read(fd, &ev, sizeof(ev)) == -1) {
184: cvs_log(LP_ERR, "failed to read cvs event");
185: return (-1);
186: }
187:
188: return (0);
189: }
190:
191:
192: /*
193: * cvs_sock_connect()
194: *
195: * Open a connection to the CVS server's local socket.
196: */
197:
198: int
199: cvs_sock_connect(const char *cvsroot)
200: {
201: cvs_sun.sun_family = AF_LOCAL;
202: snprintf(cvs_sun.sun_path, sizeof(cvs_sun.sun_path), "%s/%s",
203: cvsroot, CVSD_SOCK_PATH);
204:
205: cvs_log(LP_INFO, "connecting to CVS server socket `%s'",
206: cvs_sun.sun_path);
207:
208: cvs_sock = socket(AF_LOCAL, SOCK_STREAM, 0);
209: if (cvs_sock == -1) {
210: cvs_log(LP_ERRNO, "failed to open local socket");
211: return (-1);
212: }
213:
214: if (connect(cvs_sock, (struct sockaddr *)&cvs_sun,
215: SUN_LEN(&cvs_sun)) == -1) {
216: cvs_log(LP_ERRNO, "failed to connect to server socket `%s'",
217: cvs_sun.sun_path);
218: (void)close(cvs_sock);
219: return (-1);
220: }
221:
222: return (0);
223: }
224:
225:
226: /*
227: * cvs_sock_disconnect()
228: *
229: * Disconnect from the open socket to the CVS server.
230: */
231:
232: void
233: cvs_sock_disconnect(void)
234: {
235: if (close(cvs_sock) == -1)
236: cvs_log(LP_ERRNO, "failed to close local socket");
237: }