VirtualBox

source: vbox/trunk/src/VBox/Devices/Network/slirp/udp.c@ 15685

Last change on this file since 15685 was 15636, checked in by vboxsync, 16 years ago

slirp:icmp: Get rid of old ICMP implementation

  • Property svn:eol-style set to native
File size: 21.9 KB
Line 
1/*
2 * Copyright (c) 1982, 1986, 1988, 1990, 1993
3 * The Regents of the University of California. All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
7 * are met:
8 * 1. Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright
11 * notice, this list of conditions and the following disclaimer in the
12 * documentation and/or other materials provided with the distribution.
13 * 3. All advertising materials mentioning features or use of this software
14 * must display the following acknowledgement:
15 * This product includes software developed by the University of
16 * California, Berkeley and its contributors.
17 * 4. Neither the name of the University nor the names of its contributors
18 * may be used to endorse or promote products derived from this software
19 * without specific prior written permission.
20 *
21 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
22 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
23 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
24 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
25 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
26 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
27 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
28 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
29 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
30 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31 * SUCH DAMAGE.
32 *
33 * @(#)udp_usrreq.c 8.4 (Berkeley) 1/21/94
34 * udp_usrreq.c,v 1.4 1994/10/02 17:48:45 phk Exp
35 */
36
37/*
38 * Changes and additions relating to SLiRP
39 * Copyright (c) 1995 Danny Gasparovski.
40 *
41 * Please read the file COPYRIGHT for the
42 * terms and conditions of the copyright.
43 */
44
45#include <slirp.h>
46#include "ip_icmp.h"
47
48
49/*
50 * UDP protocol implementation.
51 * Per RFC 768, August, 1980.
52 */
53#define udpcksum 1
54
55void
56udp_init(PNATState pData)
57{
58 udp_last_so = &udb;
59 udb.so_next = udb.so_prev = &udb;
60}
61
62/* m->m_data points at ip packet header
63 * m->m_len length ip packet
64 * ip->ip_len length data (IPDU)
65 */
66void
67udp_input(PNATState pData, register struct mbuf *m, int iphlen)
68{
69 register struct ip *ip;
70 register struct udphdr *uh;
71 int len;
72 struct ip save_ip;
73 struct socket *so;
74 int ret;
75 int ttl;
76
77 DEBUG_CALL("udp_input");
78 DEBUG_ARG("m = %lx", (long)m);
79 DEBUG_ARG("iphlen = %d", iphlen);
80
81 udpstat.udps_ipackets++;
82
83 /*
84 * Strip IP options, if any; should skip this,
85 * make available to user, and use on returned packets,
86 * but we don't yet have a way to check the checksum
87 * with options still present.
88 */
89 if (iphlen > sizeof(struct ip))
90 {
91 ip_stripoptions(m, (struct mbuf *)0);
92 iphlen = sizeof(struct ip);
93 }
94
95 /*
96 * Get IP and UDP header together in first mbuf.
97 */
98 ip = mtod(m, struct ip *);
99 uh = (struct udphdr *)((caddr_t)ip + iphlen);
100
101 /*
102 * Make mbuf data length reflect UDP length.
103 * If not enough data to reflect UDP length, drop.
104 */
105 len = ntohs((u_int16_t)uh->uh_ulen);
106
107 if (ip->ip_len != len)
108 {
109 if (len > ip->ip_len)
110 {
111 udpstat.udps_badlen++;
112 goto bad;
113 }
114 m_adj(m, len - ip->ip_len);
115 ip->ip_len = len;
116 }
117
118 /*
119 * Save a copy of the IP header in case we want restore it
120 * for sending an ICMP error message in response.
121 */
122 save_ip = *ip;
123 save_ip.ip_len+= iphlen; /* tcp_input subtracts this */
124
125 /*
126 * Checksum extended UDP header and data.
127 */
128 if (udpcksum && uh->uh_sum)
129 {
130 memset(((struct ipovly *)ip)->ih_x1, 0, 9);
131 ((struct ipovly *)ip)->ih_len = uh->uh_ulen;
132#if 0
133 /* keep uh_sum for ICMP reply */
134 uh->uh_sum = cksum(m, len + sizeof (struct ip));
135 if (uh->uh_sum)
136 {
137
138#endif
139 if(cksum(m, len + sizeof(struct ip)))
140 {
141 udpstat.udps_badsum++;
142 goto bad;
143 }
144 }
145#if 0
146 }
147#endif
148
149 /*
150 * handle DHCP/BOOTP
151 */
152 if (ntohs(uh->uh_dport) == BOOTP_SERVER)
153 {
154 bootp_input(pData, m);
155 goto bad;
156 }
157
158 /*
159 * handle TFTP
160 */
161 if (ntohs(uh->uh_dport) == TFTP_SERVER)
162 {
163 tftp_input(pData, m);
164 goto bad;
165 }
166
167 /*
168 * Locate pcb for datagram.
169 */
170 so = udp_last_so;
171 if ( so->so_lport != uh->uh_sport
172 || so->so_laddr.s_addr != ip->ip_src.s_addr)
173 {
174 struct socket *tmp;
175
176 for (tmp = udb.so_next; tmp != &udb; tmp = tmp->so_next)
177 {
178 if ( tmp->so_lport == uh->uh_sport
179 && tmp->so_laddr.s_addr == ip->ip_src.s_addr)
180 {
181 so = tmp;
182 break;
183 }
184 }
185 if (tmp == &udb)
186 so = NULL;
187 else
188 {
189 udpstat.udpps_pcbcachemiss++;
190 udp_last_so = so;
191 }
192 }
193
194 if (so == NULL)
195 {
196 /*
197 * If there's no socket for this packet,
198 * create one
199 */
200 if ((so = socreate()) == NULL)
201 goto bad;
202 if (udp_attach(pData, so) == -1)
203 {
204 DEBUG_MISC((dfd," udp_attach errno = %d-%s\n",
205 errno,strerror(errno)));
206 sofree(pData, so);
207 goto bad;
208 }
209
210 /*
211 * Setup fields
212 */
213 /* udp_last_so = so; */
214 so->so_laddr = ip->ip_src;
215 so->so_lport = uh->uh_sport;
216
217 if ((so->so_iptos = udp_tos(so)) == 0)
218 so->so_iptos = ip->ip_tos;
219
220 /*
221 * XXXXX Here, check if it's in udpexec_list,
222 * and if it is, do the fork_exec() etc.
223 */
224 }
225
226 so->so_faddr = ip->ip_dst; /* XXX */
227 so->so_fport = uh->uh_dport; /* XXX */
228
229 iphlen += sizeof(struct udphdr);
230 m->m_len -= iphlen;
231 m->m_data += iphlen;
232
233 /*
234 * Now we sendto() the packet.
235 */
236 if (so->so_emu)
237 udp_emu(pData, so, m);
238
239 ttl = ip->ip_ttl = save_ip.ip_ttl;
240 ret = setsockopt(so->s, IPPROTO_IP, IP_TTL, &ttl, sizeof(ttl));
241 if (ret < 0) {
242 LogRel(("NAT: Error (%s) occurred while setting TTL(%d) attribute of IP packet to socket %R[natsock]\n", strerror(errno), ip->ip_ttl, so));
243 }
244
245 if (sosendto(pData, so, m) == -1)
246 {
247 m->m_len += iphlen;
248 m->m_data -= iphlen;
249 *ip = save_ip;
250 DEBUG_MISC((dfd,"udp tx errno = %d-%s\n", errno, strerror(errno)));
251 icmp_error(pData, m, ICMP_UNREACH,ICMP_UNREACH_NET, 0, strerror(errno));
252 }
253
254 m_free(pData, so->so_m); /* used for ICMP if error on sorecvfrom */
255
256 /* restore the orig mbuf packet */
257 m->m_len += iphlen;
258 m->m_data -= iphlen;
259 *ip = save_ip;
260 so->so_m = m; /* ICMP backup */
261
262 return;
263
264bad:
265 m_freem(pData, m);
266 return;
267}
268
269int udp_output2(PNATState pData, struct socket *so, struct mbuf *m,
270 struct sockaddr_in *saddr, struct sockaddr_in *daddr,
271 int iptos)
272{
273 register struct udpiphdr *ui;
274 int error = 0;
275
276 DEBUG_CALL("udp_output");
277 DEBUG_ARG("so = %lx", (long)so);
278 DEBUG_ARG("m = %lx", (long)m);
279 DEBUG_ARG("saddr = %lx", (long)saddr->sin_addr.s_addr);
280 DEBUG_ARG("daddr = %lx", (long)daddr->sin_addr.s_addr);
281
282 /*
283 * Adjust for header
284 */
285 m->m_data -= sizeof(struct udpiphdr);
286 m->m_len += sizeof(struct udpiphdr);
287
288 /*
289 * Fill in mbuf with extended UDP header
290 * and addresses and length put into network format.
291 */
292 ui = mtod(m, struct udpiphdr *);
293 memset(ui->ui_x1, 0, 9);
294 ui->ui_pr = IPPROTO_UDP;
295 ui->ui_len = htons(m->m_len - sizeof(struct ip)); /* + sizeof (struct udphdr)); */
296 /* XXXXX Check for from-one-location sockets, or from-any-location sockets */
297 ui->ui_src = saddr->sin_addr;
298 ui->ui_dst = daddr->sin_addr;
299 ui->ui_sport = saddr->sin_port;
300 ui->ui_dport = daddr->sin_port;
301 ui->ui_ulen = ui->ui_len;
302
303 /*
304 * Stuff checksum and output datagram.
305 */
306 ui->ui_sum = 0;
307 if (udpcksum)
308 {
309 if ((ui->ui_sum = cksum(m, /* sizeof (struct udpiphdr) + */ m->m_len)) == 0)
310 ui->ui_sum = 0xffff;
311 }
312 ((struct ip *)ui)->ip_len = m->m_len;
313 ((struct ip *)ui)->ip_ttl = ip_defttl;
314 ((struct ip *)ui)->ip_tos = iptos;
315
316 udpstat.udps_opackets++;
317
318 error = ip_output(pData, so, m);
319
320 return error;
321}
322
323int udp_output(PNATState pData, struct socket *so, struct mbuf *m,
324 struct sockaddr_in *addr)
325{
326 struct sockaddr_in saddr, daddr;
327
328 saddr = *addr;
329 if ((so->so_faddr.s_addr & htonl(pData->netmask)) == special_addr.s_addr)
330 {
331 saddr.sin_addr.s_addr = so->so_faddr.s_addr;
332 if ((so->so_faddr.s_addr & htonl(~pData->netmask)) == htonl(~pData->netmask))
333 saddr.sin_addr.s_addr = alias_addr.s_addr;
334 }
335
336 /* Any UDP packet to the loopback address must be translated to be from
337 * the forwarding address, i.e. 10.0.2.2. */
338 if ( (saddr.sin_addr.s_addr & htonl(IN_CLASSA_NET))
339 == htonl(INADDR_LOOPBACK & IN_CLASSA_NET))
340 saddr.sin_addr.s_addr = alias_addr.s_addr;
341
342 daddr.sin_addr = so->so_laddr;
343 daddr.sin_port = so->so_lport;
344
345 return udp_output2(pData, so, m, &saddr, &daddr, so->so_iptos);
346}
347
348int
349udp_attach(PNATState pData, struct socket *so)
350{
351 struct sockaddr_in addr;
352 struct sockaddr sa_addr;
353 socklen_t socklen = sizeof(struct sockaddr);
354 int status;
355
356 if ((so->s = socket(AF_INET,SOCK_DGRAM,0)) != -1)
357 {
358 /*
359 * Here, we bind() the socket. Although not really needed
360 * (sendto() on an unbound socket will bind it), it's done
361 * here so that emulation of ytalk etc. don't have to do it
362 */
363 addr.sin_family = AF_INET;
364 addr.sin_port = 0;
365 addr.sin_addr.s_addr = INADDR_ANY;
366 if (bind(so->s, (struct sockaddr *)&addr, sizeof(addr)) < 0)
367 {
368 int lasterrno = errno;
369 closesocket(so->s);
370 so->s = -1;
371#ifdef RT_OS_WINDOWS
372 WSASetLastError(lasterrno);
373#else
374 errno = lasterrno;
375#endif
376 }
377 else
378 {
379 int opt = 1;
380 /* success, insert in queue */
381 so->so_expire = curtime + SO_EXPIRE;
382 /* enable broadcast for later use */
383 setsockopt(so->s, SOL_SOCKET, SO_BROADCAST, (const char *)&opt, sizeof(opt));
384 insque(pData, so,&udb);
385 status = getsockname(so->s, &sa_addr, &socklen);
386 Assert(status == 0 && sa_addr.sa_family == AF_INET);
387 so->so_hlport = ((struct sockaddr_in *)&sa_addr)->sin_port;
388 so->so_hladdr.s_addr = ((struct sockaddr_in *)&sa_addr)->sin_addr.s_addr;
389 }
390 }
391 return so->s;
392}
393
394void
395udp_detach(PNATState pData, struct socket *so)
396{
397 if (so != &pData->icmp_socket)
398 {
399 closesocket(so->s);
400 sofree(pData, so);
401 }
402}
403
404static const struct tos_t udptos[] =
405{
406 { 0, 53, IPTOS_LOWDELAY, 0 }, /* DNS */
407 { 517, 517, IPTOS_LOWDELAY, EMU_TALK }, /* talk */
408 { 518, 518, IPTOS_LOWDELAY, EMU_NTALK }, /* ntalk */
409 { 0, 7648, IPTOS_LOWDELAY, EMU_CUSEEME }, /* Cu-Seeme */
410 { 0, 0, 0, 0 }
411};
412
413u_int8_t
414udp_tos(struct socket *so)
415{
416 int i = 0;
417
418 while(udptos[i].tos)
419 {
420 if ( (udptos[i].fport && ntohs(so->so_fport) == udptos[i].fport)
421 || (udptos[i].lport && ntohs(so->so_lport) == udptos[i].lport))
422 {
423 so->so_emu = udptos[i].emu;
424 return udptos[i].tos;
425 }
426 i++;
427 }
428
429 return 0;
430}
431
432#ifdef EMULATE_TALK
433#include "talkd.h"
434#endif
435
436/*
437 * Here, talk/ytalk/ntalk requests must be emulated
438 */
439void
440udp_emu(PNATState pData, struct socket *so, struct mbuf *m)
441{
442 struct sockaddr_in addr;
443 socklen_t addrlen = sizeof(addr);
444#ifdef EMULATE_TALK
445 CTL_MSG_OLD *omsg;
446 CTL_MSG *nmsg;
447 char buff[sizeof(CTL_MSG)];
448 u_char type;
449
450 struct talk_request
451 {
452 struct talk_request *next;
453 struct socket *udp_so;
454 struct socket *tcp_so;
455 } *req;
456
457 static struct talk_request *req_tbl = 0;
458
459#endif
460
461 struct cu_header
462 {
463 uint16_t d_family; /* destination family */
464 uint16_t d_port; /* destination port */
465 uint32_t d_addr; /* destination address */
466 uint16_t s_family; /* source family */
467 uint16_t s_port; /* source port */
468 uint32_t so_addr; /* source address */
469 uint32_t seqn; /* sequence number */
470 uint16_t message; /* message */
471 uint16_t data_type; /* data type */
472 uint16_t pkt_len; /* packet length */
473 } *cu_head;
474
475 switch(so->so_emu)
476 {
477#ifdef EMULATE_TALK
478 case EMU_TALK:
479 case EMU_NTALK:
480 /*
481 * Talk emulation. We always change the ctl_addr to get
482 * some answers from the daemon. When an ANNOUNCE comes,
483 * we send LEAVE_INVITE to the local daemons. Also when a
484 * DELETE comes, we send copies to the local daemons.
485 */
486 if (getsockname(so->s, (struct sockaddr *)&addr, &addrlen) < 0)
487 return;
488
489#define IS_OLD (so->so_emu == EMU_TALK)
490
491#define COPY_MSG(dest, src) \
492 do { \
493 dest->type = src->type; \
494 dest->id_num = src->id_num; \
495 dest->pid = src->pid; \
496 dest->addr = src->addr; \
497 dest->ctl_addr = src->ctl_addr; \
498 memcpy(&dest->l_name, &src->l_name, NAME_SIZE_OLD); \
499 memcpy(&dest->r_name, &src->r_name, NAME_SIZE_OLD); \
500 memcpy(&dest->r_tty, &src->r_tty, TTY_SIZE);
501 } while (0)
502
503#define OTOSIN(ptr, field) ((struct sockaddr_in *)&ptr->field)
504/* old_sockaddr to sockaddr_in */
505
506
507 if (IS_OLD)
508 {
509 /* old talk */
510 omsg = mtod(m, CTL_MSG_OLD*);
511 nmsg = (CTL_MSG *) buff;
512 type = omsg->type;
513 OTOSIN(omsg, ctl_addr)->sin_port = addr.sin_port;
514 OTOSIN(omsg, ctl_addr)->sin_addr = our_addr;
515 strncpy(omsg->l_name, getlogin(), NAME_SIZE_OLD);
516 }
517 else
518 {
519 /* new talk */
520 omsg = (CTL_MSG_OLD *) buff;
521 nmsg = mtod(m, CTL_MSG *);
522 type = nmsg->type;
523 OTOSIN(nmsg, ctl_addr)->sin_port = addr.sin_port;
524 OTOSIN(nmsg, ctl_addr)->sin_addr = our_addr;
525 strncpy(nmsg->l_name, getlogin(), NAME_SIZE_OLD);
526 }
527
528 if (type == LOOK_UP)
529 return; /* for LOOK_UP this is enough */
530
531 if (IS_OLD)
532 {
533 /* make a copy of the message */
534 COPY_MSG(nmsg, omsg);
535 nmsg->vers = 1;
536 nmsg->answer = 0;
537 }
538 else
539 COPY_MSG(omsg, nmsg);
540
541 /*
542 * If if is an ANNOUNCE message, we go through the
543 * request table to see if a tcp port has already
544 * been redirected for this socket. If not, we solisten()
545 * a new socket and add this entry to the table.
546 * The port number of the tcp socket and our IP
547 * are put to the addr field of the message structures.
548 * Then a LEAVE_INVITE is sent to both local daemon
549 * ports, 517 and 518. This is why we have two copies
550 * of the message, one in old talk and one in new talk
551 * format.
552 */
553
554 if (type == ANNOUNCE)
555 {
556 int s;
557 u_short temp_port;
558
559 for(req = req_tbl; req; req = req->next)
560 if (so == req->udp_so)
561 break; /* found it */
562
563 if (!req)
564 {
565 /* no entry for so, create new */
566 req = (struct talk_request *)malloc(sizeof(struct talk_request));
567 req->udp_so = so;
568 req->tcp_so = solisten(0,
569 OTOSIN(omsg, addr)->sin_addr.s_addr,
570 OTOSIN(omsg, addr)->sin_port,
571 SS_FACCEPTONCE);
572 req->next = req_tbl;
573 req_tbl = req;
574 }
575
576 /* replace port number in addr field */
577 addrlen = sizeof(addr);
578 getsockname(req->tcp_so->s, (struct sockaddr *) &addr, &addrlen);
579 OTOSIN(omsg, addr)->sin_port = addr.sin_port;
580 OTOSIN(omsg, addr)->sin_addr = our_addr;
581 OTOSIN(nmsg, addr)->sin_port = addr.sin_port;
582 OTOSIN(nmsg, addr)->sin_addr = our_addr;
583
584 /* send LEAVE_INVITEs */
585 temp_port = OTOSIN(omsg, ctl_addr)->sin_port;
586 OTOSIN(omsg, ctl_addr)->sin_port = 0;
587 OTOSIN(nmsg, ctl_addr)->sin_port = 0;
588 omsg->type = nmsg->type = LEAVE_INVITE;
589
590 s = socket(AF_INET, SOCK_DGRAM, IPPROTO_IP);
591 addr.sin_addr = our_addr;
592 addr.sin_family = AF_INET;
593 addr.sin_port = htons(517);
594 sendto(s, (char *)omsg, sizeof(*omsg), 0,
595 (struct sockaddr *)&addr, sizeof(addr));
596 addr.sin_port = htons(518);
597 sendto(s, (char *)nmsg, sizeof(*nmsg), 0,
598 (struct sockaddr *) &addr, sizeof(addr));
599 closesocket(s) ;
600
601 omsg->type = nmsg->type = ANNOUNCE;
602 OTOSIN(omsg, ctl_addr)->sin_port = temp_port;
603 OTOSIN(nmsg, ctl_addr)->sin_port = temp_port;
604 }
605
606 /*
607 * If it is a DELETE message, we send a copy to the
608 * local daemons. Then we delete the entry corresponding
609 * to our socket from the request table.
610 */
611
612 if (type == DELETE)
613 {
614 struct talk_request *temp_req, *req_next;
615 int s;
616 u_short temp_port;
617
618 temp_port = OTOSIN(omsg, ctl_addr)->sin_port;
619 OTOSIN(omsg, ctl_addr)->sin_port = 0;
620 OTOSIN(nmsg, ctl_addr)->sin_port = 0;
621
622 s = socket(AF_INET, SOCK_DGRAM, IPPROTO_IP);
623 addr.sin_addr = our_addr;
624 addr.sin_family = AF_INET;
625 addr.sin_port = htons(517);
626 sendto(s, (char *)omsg, sizeof(*omsg), 0,
627 (struct sockaddr *)&addr, sizeof(addr));
628 addr.sin_port = htons(518);
629 sendto(s, (char *)nmsg, sizeof(*nmsg), 0,
630 (struct sockaddr *)&addr, sizeof(addr));
631 closesocket(s);
632
633 OTOSIN(omsg, ctl_addr)->sin_port = temp_port;
634 OTOSIN(nmsg, ctl_addr)->sin_port = temp_port;
635
636 /* delete table entry */
637 if (so == req_tbl->udp_so)
638 {
639 temp_req = req_tbl;
640 req_tbl = req_tbl->next;
641 free(temp_req);
642 }
643 else
644 {
645 temp_req = req_tbl;
646 for (req = req_tbl->next; req; req = req_next)
647 {
648 req_next = req->next;
649 if (so == req->udp_so)
650 {
651 temp_req->next = req_next;
652 free(req);
653 break;
654 }
655 else
656 temp_req = req;
657 }
658 }
659 }
660
661 return;
662#endif
663
664 case EMU_CUSEEME:
665 /*
666 * Cu-SeeMe emulation.
667 * Hopefully the packet is more that 16 bytes long. We don't
668 * do any other tests, just replace the address and port
669 * fields.
670 */
671 if (m->m_len >= sizeof (*cu_head))
672 {
673 if (getsockname(so->s, (struct sockaddr *)&addr, &addrlen) < 0)
674 return;
675 cu_head = mtod(m, struct cu_header *);
676 cu_head->s_port = addr.sin_port;
677 cu_head->so_addr = our_addr.s_addr;
678 }
679 return;
680 }
681}
682
683struct socket *
684udp_listen(PNATState pData, u_int port, u_int32_t laddr, u_int lport, int flags)
685{
686 struct sockaddr_in addr;
687 struct socket *so;
688 socklen_t addrlen = sizeof(struct sockaddr_in);
689 int opt = 1;
690
691 if ((so = socreate()) == NULL)
692 return NULL;
693
694 so->s = socket(AF_INET,SOCK_DGRAM,0);
695 so->so_expire = curtime + SO_EXPIRE;
696 insque(pData, so,&udb);
697
698 addr.sin_family = AF_INET;
699 addr.sin_addr.s_addr = INADDR_ANY;
700 addr.sin_port = port;
701
702 if (bind(so->s,(struct sockaddr *)&addr, addrlen) < 0)
703 {
704 udp_detach(pData, so);
705 return NULL;
706 }
707 setsockopt(so->s,SOL_SOCKET,SO_REUSEADDR,(char *)&opt,sizeof(int));
708/* setsockopt(so->s,SOL_SOCKET,SO_OOBINLINE,(char *)&opt,sizeof(int)); */
709
710 getsockname(so->s,(struct sockaddr *)&addr,&addrlen);
711 so->so_fport = addr.sin_port;
712 /* The original check was completely broken, as the commented out
713 * if statement was always true (INADDR_ANY=0). */
714 /* if (addr.sin_addr.s_addr == 0 || addr.sin_addr.s_addr == loopback_addr.s_addr) */
715 if (1 == 0) /* always use the else part */
716 so->so_faddr = alias_addr;
717 else
718 so->so_faddr = addr.sin_addr;
719
720 so->so_lport = lport;
721 so->so_laddr.s_addr = laddr;
722 if (flags != SS_FACCEPTONCE)
723 so->so_expire = 0;
724
725 so->so_state = SS_ISFCONNECTED;
726
727 return so;
728}
Note: See TracBrowser for help on using the repository browser.

© 2024 Oracle Support Privacy / Do Not Sell My Info Terms of Use Trademark Policy Automated Access Etiquette