Annotation of embedaddon/quagga/babeld/net.c, revision 1.1.1.1
1.1 misho 1: /*
2: * This file is free software: you may copy, redistribute and/or modify it
3: * under the terms of the GNU General Public License as published by the
4: * Free Software Foundation, either version 2 of the License, or (at your
5: * option) any later version.
6: *
7: * This file is distributed in the hope that it will be useful, but
8: * WITHOUT ANY WARRANTY; without even the implied warranty of
9: * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
10: * General Public License for more details.
11: *
12: * You should have received a copy of the GNU General Public License
13: * along with this program. If not, see <http://www.gnu.org/licenses/>.
14: *
15: * This file incorporates work covered by the following copyright and
16: * permission notice:
17: *
18: Copyright (c) 2007, 2008 by Juliusz Chroboczek
19:
20: Permission is hereby granted, free of charge, to any person obtaining a copy
21: of this software and associated documentation files (the "Software"), to deal
22: in the Software without restriction, including without limitation the rights
23: to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
24: copies of the Software, and to permit persons to whom the Software is
25: furnished to do so, subject to the following conditions:
26:
27: The above copyright notice and this permission notice shall be included in
28: all copies or substantial portions of the Software.
29:
30: THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
31: IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
32: FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
33: AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
34: LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
35: OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
36: THE SOFTWARE.
37: */
38:
39: #include <unistd.h>
40: #include <fcntl.h>
41: #include <string.h>
42: #include <sys/ioctl.h>
43: #include <sys/types.h>
44: #include <sys/uio.h>
45: #include <sys/socket.h>
46: #include <netinet/in.h>
47: #include <arpa/inet.h>
48: #include <errno.h>
49:
50: #include "babeld.h"
51: #include "util.h"
52: #include "net.h"
53:
54: int
55: babel_socket(int port)
56: {
57: struct sockaddr_in6 sin6;
58: int s, rc;
59: int saved_errno;
60: int one = 1, zero = 0;
61: const int ds = 0xc0; /* CS6 - Network Control */
62:
63: s = socket(PF_INET6, SOCK_DGRAM, 0);
64: if(s < 0)
65: return -1;
66:
67: rc = setsockopt(s, IPPROTO_IPV6, IPV6_V6ONLY, &one, sizeof(one));
68: if(rc < 0)
69: goto fail;
70:
71: rc = setsockopt(s, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(one));
72: if(rc < 0)
73: goto fail;
74:
75: rc = setsockopt(s, IPPROTO_IPV6, IPV6_MULTICAST_LOOP,
76: &zero, sizeof(zero));
77: if(rc < 0)
78: goto fail;
79:
80: rc = setsockopt(s, IPPROTO_IPV6, IPV6_UNICAST_HOPS,
81: &one, sizeof(one));
82: if(rc < 0)
83: goto fail;
84:
85: rc = setsockopt(s, IPPROTO_IPV6, IPV6_MULTICAST_HOPS,
86: &one, sizeof(one));
87: if(rc < 0)
88: goto fail;
89:
90: #ifdef IPV6_TCLASS
91: rc = setsockopt(s, IPPROTO_IPV6, IPV6_TCLASS, &ds, sizeof(ds));
92: #else
93: rc = -1;
94: errno = ENOSYS;
95: #endif
96: if(rc < 0)
97: perror("Couldn't set traffic class");
98:
99: rc = fcntl(s, F_GETFL, 0);
100: if(rc < 0)
101: goto fail;
102:
103: rc = fcntl(s, F_SETFL, (rc | O_NONBLOCK));
104: if(rc < 0)
105: goto fail;
106:
107: rc = fcntl(s, F_GETFD, 0);
108: if(rc < 0)
109: goto fail;
110:
111: rc = fcntl(s, F_SETFD, rc | FD_CLOEXEC);
112: if(rc < 0)
113: goto fail;
114:
115: memset(&sin6, 0, sizeof(sin6));
116: sin6.sin6_family = AF_INET6;
117: sin6.sin6_port = htons(port);
118: rc = bind(s, (struct sockaddr*)&sin6, sizeof(sin6));
119: if(rc < 0)
120: goto fail;
121:
122: return s;
123:
124: fail:
125: saved_errno = errno;
126: close(s);
127: errno = saved_errno;
128: return -1;
129: }
130:
131: int
132: babel_recv(int s, void *buf, int buflen, struct sockaddr *sin, int slen)
133: {
134: struct iovec iovec;
135: struct msghdr msg;
136: int rc;
137:
138: memset(&msg, 0, sizeof(msg));
139: iovec.iov_base = buf;
140: iovec.iov_len = buflen;
141: msg.msg_name = sin;
142: msg.msg_namelen = slen;
143: msg.msg_iov = &iovec;
144: msg.msg_iovlen = 1;
145:
146: rc = recvmsg(s, &msg, 0);
147: return rc;
148: }
149:
150: int
151: babel_send(int s,
152: void *buf1, int buflen1, void *buf2, int buflen2,
153: struct sockaddr *sin, int slen)
154: {
155: struct iovec iovec[2];
156: struct msghdr msg;
157: int rc;
158:
159: iovec[0].iov_base = buf1;
160: iovec[0].iov_len = buflen1;
161: iovec[1].iov_base = buf2;
162: iovec[1].iov_len = buflen2;
163: memset(&msg, 0, sizeof(msg));
164: msg.msg_name = (struct sockaddr*)sin;
165: msg.msg_namelen = slen;
166: msg.msg_iov = iovec;
167: msg.msg_iovlen = 2;
168:
169: again:
170: rc = sendmsg(s, &msg, 0);
171: if(rc < 0) {
172: if(errno == EINTR)
173: goto again;
174: else if(errno == EAGAIN) {
175: int rc2;
176: rc2 = wait_for_fd(1, s, 5);
177: if(rc2 > 0)
178: goto again;
179: errno = EAGAIN;
180: }
181: }
182: return rc;
183: }
184:
185: int
186: tcp_server_socket(int port, int local)
187: {
188: struct sockaddr_in6 sin6;
189: int s, rc, saved_errno;
190: int one = 1;
191:
192: s = socket(PF_INET6, SOCK_STREAM, 0);
193: if(s < 0)
194: return -1;
195:
196: rc = setsockopt(s, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(one));
197: if(rc < 0)
198: goto fail;
199:
200: rc = fcntl(s, F_GETFL, 0);
201: if(rc < 0)
202: goto fail;
203:
204: rc = fcntl(s, F_SETFL, (rc | O_NONBLOCK));
205: if(rc < 0)
206: goto fail;
207:
208: rc = fcntl(s, F_GETFD, 0);
209: if(rc < 0)
210: goto fail;
211:
212: rc = fcntl(s, F_SETFD, rc | FD_CLOEXEC);
213: if(rc < 0)
214: goto fail;
215:
216: memset(&sin6, 0, sizeof(sin6));
217: sin6.sin6_family = AF_INET6;
218: sin6.sin6_port = htons(port);
219: if(local) {
220: rc = inet_pton(AF_INET6, "::1", &sin6.sin6_addr);
221: if(rc < 0)
222: goto fail;
223: }
224: rc = bind(s, (struct sockaddr*)&sin6, sizeof(sin6));
225: if(rc < 0)
226: goto fail;
227:
228: rc = listen(s, 2);
229: if(rc < 0)
230: goto fail;
231:
232: return s;
233:
234: fail:
235: saved_errno = errno;
236: close(s);
237: errno = saved_errno;
238: return -1;
239: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to net.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / quagga / babeld