4 * Copyright (c) 2004-2008 Fabrice Bellard
6 * Permission is hereby granted, free of charge, to any person obtaining a copy
7 * of this software and associated documentation files (the "Software"), to deal
8 * in the Software without restriction, including without limitation the rights
9 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10 * copies of the Software, and to permit persons to whom the Software is
11 * furnished to do so, subject to the following conditions:
13 * The above copyright notice and this permission notice shall be included in
14 * all copies or substantial portions of the Software.
16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
19 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
24 #include "qemu-common.h"
25 #include "qemu-timer.h"
26 #include "qemu-char.h"
30 /* host loopback address */
31 struct in_addr loopback_addr
;
33 /* emulated hosts use the MAC addr 52:55:IP:IP:IP:IP */
34 static const uint8_t special_ethaddr
[ETH_ALEN
] = {
35 0x52, 0x55, 0x00, 0x00, 0x00, 0x00
38 static const uint8_t zero_ethaddr
[ETH_ALEN
] = { 0, 0, 0, 0, 0, 0 };
40 /* XXX: suppress those select globals */
41 fd_set
*global_readfds
, *global_writefds
, *global_xfds
;
44 static u_int time_fasttimo
, last_slowtimo
;
45 static int do_slowtimo
;
47 static QTAILQ_HEAD(slirp_instances
, Slirp
) slirp_instances
=
48 QTAILQ_HEAD_INITIALIZER(slirp_instances
);
50 static struct in_addr dns_addr
;
51 static u_int dns_addr_time
;
55 int get_dns_addr(struct in_addr
*pdns_addr
)
57 FIXED_INFO
*FixedInfo
=NULL
;
60 IP_ADDR_STRING
*pIPAddr
;
61 struct in_addr tmp_addr
;
63 if (dns_addr
.s_addr
!= 0 && (curtime
- dns_addr_time
) < 1000) {
64 *pdns_addr
= dns_addr
;
68 FixedInfo
= (FIXED_INFO
*)GlobalAlloc(GPTR
, sizeof(FIXED_INFO
));
69 BufLen
= sizeof(FIXED_INFO
);
71 if (ERROR_BUFFER_OVERFLOW
== GetNetworkParams(FixedInfo
, &BufLen
)) {
73 GlobalFree(FixedInfo
);
76 FixedInfo
= GlobalAlloc(GPTR
, BufLen
);
79 if ((ret
= GetNetworkParams(FixedInfo
, &BufLen
)) != ERROR_SUCCESS
) {
80 printf("GetNetworkParams failed. ret = %08x\n", (u_int
)ret
);
82 GlobalFree(FixedInfo
);
88 pIPAddr
= &(FixedInfo
->DnsServerList
);
89 inet_aton(pIPAddr
->IpAddress
.String
, &tmp_addr
);
90 *pdns_addr
= tmp_addr
;
92 dns_addr_time
= curtime
;
94 GlobalFree(FixedInfo
);
100 static void winsock_cleanup(void)
107 static struct stat dns_addr_stat
;
109 int get_dns_addr(struct in_addr
*pdns_addr
)
115 struct in_addr tmp_addr
;
117 if (dns_addr
.s_addr
!= 0) {
118 struct stat old_stat
;
119 if ((curtime
- dns_addr_time
) < 1000) {
120 *pdns_addr
= dns_addr
;
123 old_stat
= dns_addr_stat
;
124 if (stat("/etc/resolv.conf", &dns_addr_stat
) != 0)
126 if ((dns_addr_stat
.st_dev
== old_stat
.st_dev
)
127 && (dns_addr_stat
.st_ino
== old_stat
.st_ino
)
128 && (dns_addr_stat
.st_size
== old_stat
.st_size
)
129 && (dns_addr_stat
.st_mtime
== old_stat
.st_mtime
)) {
130 *pdns_addr
= dns_addr
;
135 f
= fopen("/etc/resolv.conf", "r");
140 lprint("IP address of your DNS(s): ");
142 while (fgets(buff
, 512, f
) != NULL
) {
143 if (sscanf(buff
, "nameserver%*[ \t]%256s", buff2
) == 1) {
144 if (!inet_aton(buff2
, &tmp_addr
))
146 /* If it's the first one, set it to dns_addr */
148 *pdns_addr
= tmp_addr
;
150 dns_addr_time
= curtime
;
164 lprint("%s", inet_ntoa(tmp_addr
));
176 static void slirp_init_once(void)
178 static int initialized
;
189 WSAStartup(MAKEWORD(2,0), &Data
);
190 atexit(winsock_cleanup
);
193 loopback_addr
.s_addr
= htonl(INADDR_LOOPBACK
);
196 static void slirp_state_save(QEMUFile
*f
, void *opaque
);
197 static int slirp_state_load(QEMUFile
*f
, void *opaque
, int version_id
);
199 Slirp
*slirp_init(int restricted
, struct in_addr vnetwork
,
200 struct in_addr vnetmask
, struct in_addr vhost
,
201 const char *vhostname
, const char *tftp_path
,
202 const char *bootfile
, struct in_addr vdhcp_start
,
203 struct in_addr vnameserver
, void *opaque
)
205 Slirp
*slirp
= qemu_mallocz(sizeof(Slirp
));
209 slirp
->restricted
= restricted
;
214 /* Initialise mbufs *after* setting the MTU */
217 slirp
->vnetwork_addr
= vnetwork
;
218 slirp
->vnetwork_mask
= vnetmask
;
219 slirp
->vhost_addr
= vhost
;
221 pstrcpy(slirp
->client_hostname
, sizeof(slirp
->client_hostname
),
225 slirp
->tftp_prefix
= qemu_strdup(tftp_path
);
228 slirp
->bootp_filename
= qemu_strdup(bootfile
);
230 slirp
->vdhcp_startaddr
= vdhcp_start
;
231 slirp
->vnameserver_addr
= vnameserver
;
233 slirp
->opaque
= opaque
;
235 register_savevm(NULL
, "slirp", 0, 3,
236 slirp_state_save
, slirp_state_load
, slirp
);
238 QTAILQ_INSERT_TAIL(&slirp_instances
, slirp
, entry
);
243 void slirp_cleanup(Slirp
*slirp
)
245 QTAILQ_REMOVE(&slirp_instances
, slirp
, entry
);
247 unregister_savevm(NULL
, "slirp", slirp
);
249 qemu_free(slirp
->tftp_prefix
);
250 qemu_free(slirp
->bootp_filename
);
254 #define CONN_CANFSEND(so) (((so)->so_state & (SS_FCANTSENDMORE|SS_ISFCONNECTED)) == SS_ISFCONNECTED)
255 #define CONN_CANFRCV(so) (((so)->so_state & (SS_FCANTRCVMORE|SS_ISFCONNECTED)) == SS_ISFCONNECTED)
256 #define UPD_NFDS(x) if (nfds < (x)) nfds = (x)
258 void slirp_select_fill(int *pnfds
,
259 fd_set
*readfds
, fd_set
*writefds
, fd_set
*xfds
)
262 struct socket
*so
, *so_next
;
265 if (QTAILQ_EMPTY(&slirp_instances
)) {
270 global_readfds
= NULL
;
271 global_writefds
= NULL
;
280 QTAILQ_FOREACH(slirp
, &slirp_instances
, entry
) {
282 * *_slowtimo needs calling if there are IP fragments
283 * in the fragment queue, or there are TCP connections active
285 do_slowtimo
|= ((slirp
->tcb
.so_next
!= &slirp
->tcb
) ||
286 (&slirp
->ipq
.ip_link
!= slirp
->ipq
.ip_link
.next
));
288 for (so
= slirp
->tcb
.so_next
; so
!= &slirp
->tcb
;
290 so_next
= so
->so_next
;
293 * See if we need a tcp_fasttimo
295 if (time_fasttimo
== 0 && so
->so_tcpcb
->t_flags
& TF_DELACK
)
296 time_fasttimo
= curtime
; /* Flag when we want a fasttimo */
299 * NOFDREF can include still connecting to local-host,
300 * newly socreated() sockets etc. Don't want to select these.
302 if (so
->so_state
& SS_NOFDREF
|| so
->s
== -1)
306 * Set for reading sockets which are accepting
308 if (so
->so_state
& SS_FACCEPTCONN
) {
309 FD_SET(so
->s
, readfds
);
315 * Set for writing sockets which are connecting
317 if (so
->so_state
& SS_ISFCONNECTING
) {
318 FD_SET(so
->s
, writefds
);
324 * Set for writing if we are connected, can send more, and
325 * we have something to send
327 if (CONN_CANFSEND(so
) && so
->so_rcv
.sb_cc
) {
328 FD_SET(so
->s
, writefds
);
333 * Set for reading (and urgent data) if we are connected, can
334 * receive more, and we have room for it XXX /2 ?
336 if (CONN_CANFRCV(so
) && (so
->so_snd
.sb_cc
< (so
->so_snd
.sb_datalen
/2))) {
337 FD_SET(so
->s
, readfds
);
346 for (so
= slirp
->udb
.so_next
; so
!= &slirp
->udb
;
348 so_next
= so
->so_next
;
351 * See if it's timed out
354 if (so
->so_expire
<= curtime
) {
358 do_slowtimo
= 1; /* Let socket expire */
362 * When UDP packets are received from over the
363 * link, they're sendto()'d straight away, so
364 * no need for setting for writing
365 * Limit the number of packets queued by this session
366 * to 4. Note that even though we try and limit this
367 * to 4 packets, the session could have more queued
368 * if the packets needed to be fragmented
371 if ((so
->so_state
& SS_ISFCONNECTED
) && so
->so_queued
<= 4) {
372 FD_SET(so
->s
, readfds
);
380 for (so
= slirp
->icmp
.so_next
; so
!= &slirp
->icmp
;
382 so_next
= so
->so_next
;
385 * See if it's timed out
388 if (so
->so_expire
<= curtime
) {
392 do_slowtimo
= 1; /* Let socket expire */
396 if (so
->so_state
& SS_ISFCONNECTED
) {
397 FD_SET(so
->s
, readfds
);
406 void slirp_select_poll(fd_set
*readfds
, fd_set
*writefds
, fd_set
*xfds
,
410 struct socket
*so
, *so_next
;
413 if (QTAILQ_EMPTY(&slirp_instances
)) {
417 global_readfds
= readfds
;
418 global_writefds
= writefds
;
421 curtime
= qemu_get_clock_ms(rt_clock
);
423 QTAILQ_FOREACH(slirp
, &slirp_instances
, entry
) {
425 * See if anything has timed out
427 if (time_fasttimo
&& ((curtime
- time_fasttimo
) >= 2)) {
431 if (do_slowtimo
&& ((curtime
- last_slowtimo
) >= 499)) {
434 last_slowtimo
= curtime
;
444 for (so
= slirp
->tcb
.so_next
; so
!= &slirp
->tcb
;
446 so_next
= so
->so_next
;
449 * FD_ISSET is meaningless on these sockets
450 * (and they can crash the program)
452 if (so
->so_state
& SS_NOFDREF
|| so
->s
== -1)
457 * This will soread as well, so no need to
458 * test for readfds below if this succeeds
460 if (FD_ISSET(so
->s
, xfds
))
463 * Check sockets for reading
465 else if (FD_ISSET(so
->s
, readfds
)) {
467 * Check for incoming connections
469 if (so
->so_state
& SS_FACCEPTCONN
) {
475 /* Output it if we read something */
477 tcp_output(sototcpcb(so
));
481 * Check sockets for writing
483 if (FD_ISSET(so
->s
, writefds
)) {
485 * Check for non-blocking, still-connecting sockets
487 if (so
->so_state
& SS_ISFCONNECTING
) {
489 so
->so_state
&= ~SS_ISFCONNECTING
;
491 ret
= send(so
->s
, (const void *) &ret
, 0, 0);
493 /* XXXXX Must fix, zero bytes is a NOP */
494 if (errno
== EAGAIN
|| errno
== EWOULDBLOCK
||
495 errno
== EINPROGRESS
|| errno
== ENOTCONN
)
499 so
->so_state
&= SS_PERSISTENT_MASK
;
500 so
->so_state
|= SS_NOFDREF
;
502 /* else so->so_state &= ~SS_ISFCONNECTING; */
507 tcp_input((struct mbuf
*)NULL
, sizeof(struct ip
), so
);
512 * XXXXX If we wrote something (a lot), there
513 * could be a need for a window update.
514 * In the worst case, the remote will send
515 * a window probe to get things going again
520 * Probe a still-connecting, non-blocking socket
521 * to check if it's still alive
524 if (so
->so_state
& SS_ISFCONNECTING
) {
525 ret
= qemu_recv(so
->s
, &ret
, 0,0);
529 if (errno
== EAGAIN
|| errno
== EWOULDBLOCK
||
530 errno
== EINPROGRESS
|| errno
== ENOTCONN
)
531 continue; /* Still connecting, continue */
534 so
->so_state
&= SS_PERSISTENT_MASK
;
535 so
->so_state
|= SS_NOFDREF
;
537 /* tcp_input will take care of it */
539 ret
= send(so
->s
, &ret
, 0,0);
542 if (errno
== EAGAIN
|| errno
== EWOULDBLOCK
||
543 errno
== EINPROGRESS
|| errno
== ENOTCONN
)
546 so
->so_state
&= SS_PERSISTENT_MASK
;
547 so
->so_state
|= SS_NOFDREF
;
549 so
->so_state
&= ~SS_ISFCONNECTING
;
552 tcp_input((struct mbuf
*)NULL
, sizeof(struct ip
),so
);
553 } /* SS_ISFCONNECTING */
559 * Incoming packets are sent straight away, they're not buffered.
560 * Incoming UDP data isn't buffered either.
562 for (so
= slirp
->udb
.so_next
; so
!= &slirp
->udb
;
564 so_next
= so
->so_next
;
566 if (so
->s
!= -1 && FD_ISSET(so
->s
, readfds
)) {
572 * Check incoming ICMP relies.
574 for (so
= slirp
->icmp
.so_next
; so
!= &slirp
->icmp
;
576 so_next
= so
->so_next
;
578 if (so
->s
!= -1 && FD_ISSET(so
->s
, readfds
)) {
585 * See if we can start outputting
587 if (slirp
->if_queued
) {
592 /* clear global file descriptor sets.
593 * these reside on the stack in vl.c
594 * so they're unusable if we're not in
595 * slirp_select_fill or slirp_select_poll.
597 global_readfds
= NULL
;
598 global_writefds
= NULL
;
602 static void arp_input(Slirp
*slirp
, const uint8_t *pkt
, int pkt_len
)
604 struct arphdr
*ah
= (struct arphdr
*)(pkt
+ ETH_HLEN
);
605 uint8_t arp_reply
[max(ETH_HLEN
+ sizeof(struct arphdr
), 64)];
606 struct ethhdr
*reh
= (struct ethhdr
*)arp_reply
;
607 struct arphdr
*rah
= (struct arphdr
*)(arp_reply
+ ETH_HLEN
);
609 struct ex_list
*ex_ptr
;
611 ar_op
= ntohs(ah
->ar_op
);
614 if (ah
->ar_tip
== ah
->ar_sip
) {
616 arp_table_add(slirp
, ah
->ar_sip
, ah
->ar_sha
);
620 if ((ah
->ar_tip
& slirp
->vnetwork_mask
.s_addr
) ==
621 slirp
->vnetwork_addr
.s_addr
) {
622 if (ah
->ar_tip
== slirp
->vnameserver_addr
.s_addr
||
623 ah
->ar_tip
== slirp
->vhost_addr
.s_addr
)
625 for (ex_ptr
= slirp
->exec_list
; ex_ptr
; ex_ptr
= ex_ptr
->ex_next
) {
626 if (ex_ptr
->ex_addr
.s_addr
== ah
->ar_tip
)
631 memset(arp_reply
, 0, sizeof(arp_reply
));
633 arp_table_add(slirp
, ah
->ar_sip
, ah
->ar_sha
);
635 /* ARP request for alias/dns mac address */
636 memcpy(reh
->h_dest
, pkt
+ ETH_ALEN
, ETH_ALEN
);
637 memcpy(reh
->h_source
, special_ethaddr
, ETH_ALEN
- 4);
638 memcpy(&reh
->h_source
[2], &ah
->ar_tip
, 4);
639 reh
->h_proto
= htons(ETH_P_ARP
);
641 rah
->ar_hrd
= htons(1);
642 rah
->ar_pro
= htons(ETH_P_IP
);
643 rah
->ar_hln
= ETH_ALEN
;
645 rah
->ar_op
= htons(ARPOP_REPLY
);
646 memcpy(rah
->ar_sha
, reh
->h_source
, ETH_ALEN
);
647 rah
->ar_sip
= ah
->ar_tip
;
648 memcpy(rah
->ar_tha
, ah
->ar_sha
, ETH_ALEN
);
649 rah
->ar_tip
= ah
->ar_sip
;
650 slirp_output(slirp
->opaque
, arp_reply
, sizeof(arp_reply
));
654 arp_table_add(slirp
, ah
->ar_sip
, ah
->ar_sha
);
661 void slirp_input(Slirp
*slirp
, const uint8_t *pkt
, int pkt_len
)
666 if (pkt_len
< ETH_HLEN
)
669 proto
= ntohs(*(uint16_t *)(pkt
+ 12));
672 arp_input(slirp
, pkt
, pkt_len
);
678 /* Note: we add to align the IP header */
679 if (M_FREEROOM(m
) < pkt_len
+ 2) {
680 m_inc(m
, pkt_len
+ 2);
682 m
->m_len
= pkt_len
+ 2;
683 memcpy(m
->m_data
+ 2, pkt
, pkt_len
);
685 m
->m_data
+= 2 + ETH_HLEN
;
686 m
->m_len
-= 2 + ETH_HLEN
;
695 /* Output the IP packet to the ethernet device. Returns 0 if the packet must be
698 int if_encap(Slirp
*slirp
, struct mbuf
*ifm
)
701 struct ethhdr
*eh
= (struct ethhdr
*)buf
;
702 uint8_t ethaddr
[ETH_ALEN
];
703 const struct ip
*iph
= (const struct ip
*)ifm
->m_data
;
705 if (ifm
->m_len
+ ETH_HLEN
> sizeof(buf
)) {
709 if (!arp_table_search(slirp
, iph
->ip_dst
.s_addr
, ethaddr
)) {
710 uint8_t arp_req
[ETH_HLEN
+ sizeof(struct arphdr
)];
711 struct ethhdr
*reh
= (struct ethhdr
*)arp_req
;
712 struct arphdr
*rah
= (struct arphdr
*)(arp_req
+ ETH_HLEN
);
714 if (!ifm
->arp_requested
) {
715 /* If the client addr is not known, send an ARP request */
716 memset(reh
->h_dest
, 0xff, ETH_ALEN
);
717 memcpy(reh
->h_source
, special_ethaddr
, ETH_ALEN
- 4);
718 memcpy(&reh
->h_source
[2], &slirp
->vhost_addr
, 4);
719 reh
->h_proto
= htons(ETH_P_ARP
);
720 rah
->ar_hrd
= htons(1);
721 rah
->ar_pro
= htons(ETH_P_IP
);
722 rah
->ar_hln
= ETH_ALEN
;
724 rah
->ar_op
= htons(ARPOP_REQUEST
);
727 memcpy(rah
->ar_sha
, special_ethaddr
, ETH_ALEN
- 4);
728 memcpy(&rah
->ar_sha
[2], &slirp
->vhost_addr
, 4);
731 rah
->ar_sip
= slirp
->vhost_addr
.s_addr
;
733 /* target hw addr (none) */
734 memset(rah
->ar_tha
, 0, ETH_ALEN
);
737 rah
->ar_tip
= iph
->ip_dst
.s_addr
;
738 slirp
->client_ipaddr
= iph
->ip_dst
;
739 slirp_output(slirp
->opaque
, arp_req
, sizeof(arp_req
));
740 ifm
->arp_requested
= true;
744 memcpy(eh
->h_dest
, ethaddr
, ETH_ALEN
);
745 memcpy(eh
->h_source
, special_ethaddr
, ETH_ALEN
- 4);
746 /* XXX: not correct */
747 memcpy(&eh
->h_source
[2], &slirp
->vhost_addr
, 4);
748 eh
->h_proto
= htons(ETH_P_IP
);
749 memcpy(buf
+ sizeof(struct ethhdr
), ifm
->m_data
, ifm
->m_len
);
750 slirp_output(slirp
->opaque
, buf
, ifm
->m_len
+ ETH_HLEN
);
755 /* Drop host forwarding rule, return 0 if found. */
756 int slirp_remove_hostfwd(Slirp
*slirp
, int is_udp
, struct in_addr host_addr
,
760 struct socket
*head
= (is_udp
? &slirp
->udb
: &slirp
->tcb
);
761 struct sockaddr_in addr
;
762 int port
= htons(host_port
);
765 for (so
= head
->so_next
; so
!= head
; so
= so
->so_next
) {
766 addr_len
= sizeof(addr
);
767 if ((so
->so_state
& SS_HOSTFWD
) &&
768 getsockname(so
->s
, (struct sockaddr
*)&addr
, &addr_len
) == 0 &&
769 addr
.sin_addr
.s_addr
== host_addr
.s_addr
&&
770 addr
.sin_port
== port
) {
780 int slirp_add_hostfwd(Slirp
*slirp
, int is_udp
, struct in_addr host_addr
,
781 int host_port
, struct in_addr guest_addr
, int guest_port
)
783 if (!guest_addr
.s_addr
) {
784 guest_addr
= slirp
->vdhcp_startaddr
;
787 if (!udp_listen(slirp
, host_addr
.s_addr
, htons(host_port
),
788 guest_addr
.s_addr
, htons(guest_port
), SS_HOSTFWD
))
791 if (!tcp_listen(slirp
, host_addr
.s_addr
, htons(host_port
),
792 guest_addr
.s_addr
, htons(guest_port
), SS_HOSTFWD
))
798 int slirp_add_exec(Slirp
*slirp
, int do_pty
, const void *args
,
799 struct in_addr
*guest_addr
, int guest_port
)
801 if (!guest_addr
->s_addr
) {
802 guest_addr
->s_addr
= slirp
->vnetwork_addr
.s_addr
|
803 (htonl(0x0204) & ~slirp
->vnetwork_mask
.s_addr
);
805 if ((guest_addr
->s_addr
& slirp
->vnetwork_mask
.s_addr
) !=
806 slirp
->vnetwork_addr
.s_addr
||
807 guest_addr
->s_addr
== slirp
->vhost_addr
.s_addr
||
808 guest_addr
->s_addr
== slirp
->vnameserver_addr
.s_addr
) {
811 return add_exec(&slirp
->exec_list
, do_pty
, (char *)args
, *guest_addr
,
815 ssize_t
slirp_send(struct socket
*so
, const void *buf
, size_t len
, int flags
)
817 if (so
->s
== -1 && so
->extra
) {
818 qemu_chr_write(so
->extra
, buf
, len
);
822 return send(so
->s
, buf
, len
, flags
);
825 static struct socket
*
826 slirp_find_ctl_socket(Slirp
*slirp
, struct in_addr guest_addr
, int guest_port
)
830 for (so
= slirp
->tcb
.so_next
; so
!= &slirp
->tcb
; so
= so
->so_next
) {
831 if (so
->so_faddr
.s_addr
== guest_addr
.s_addr
&&
832 htons(so
->so_fport
) == guest_port
) {
839 size_t slirp_socket_can_recv(Slirp
*slirp
, struct in_addr guest_addr
,
845 so
= slirp_find_ctl_socket(slirp
, guest_addr
, guest_port
);
847 if (!so
|| so
->so_state
& SS_NOFDREF
)
850 if (!CONN_CANFRCV(so
) || so
->so_snd
.sb_cc
>= (so
->so_snd
.sb_datalen
/2))
853 return sopreprbuf(so
, iov
, NULL
);
856 void slirp_socket_recv(Slirp
*slirp
, struct in_addr guest_addr
, int guest_port
,
857 const uint8_t *buf
, int size
)
860 struct socket
*so
= slirp_find_ctl_socket(slirp
, guest_addr
, guest_port
);
865 ret
= soreadbuf(so
, (const char *)buf
, size
);
868 tcp_output(sototcpcb(so
));
871 static void slirp_tcp_save(QEMUFile
*f
, struct tcpcb
*tp
)
875 qemu_put_sbe16(f
, tp
->t_state
);
876 for (i
= 0; i
< TCPT_NTIMERS
; i
++)
877 qemu_put_sbe16(f
, tp
->t_timer
[i
]);
878 qemu_put_sbe16(f
, tp
->t_rxtshift
);
879 qemu_put_sbe16(f
, tp
->t_rxtcur
);
880 qemu_put_sbe16(f
, tp
->t_dupacks
);
881 qemu_put_be16(f
, tp
->t_maxseg
);
882 qemu_put_sbyte(f
, tp
->t_force
);
883 qemu_put_be16(f
, tp
->t_flags
);
884 qemu_put_be32(f
, tp
->snd_una
);
885 qemu_put_be32(f
, tp
->snd_nxt
);
886 qemu_put_be32(f
, tp
->snd_up
);
887 qemu_put_be32(f
, tp
->snd_wl1
);
888 qemu_put_be32(f
, tp
->snd_wl2
);
889 qemu_put_be32(f
, tp
->iss
);
890 qemu_put_be32(f
, tp
->snd_wnd
);
891 qemu_put_be32(f
, tp
->rcv_wnd
);
892 qemu_put_be32(f
, tp
->rcv_nxt
);
893 qemu_put_be32(f
, tp
->rcv_up
);
894 qemu_put_be32(f
, tp
->irs
);
895 qemu_put_be32(f
, tp
->rcv_adv
);
896 qemu_put_be32(f
, tp
->snd_max
);
897 qemu_put_be32(f
, tp
->snd_cwnd
);
898 qemu_put_be32(f
, tp
->snd_ssthresh
);
899 qemu_put_sbe16(f
, tp
->t_idle
);
900 qemu_put_sbe16(f
, tp
->t_rtt
);
901 qemu_put_be32(f
, tp
->t_rtseq
);
902 qemu_put_sbe16(f
, tp
->t_srtt
);
903 qemu_put_sbe16(f
, tp
->t_rttvar
);
904 qemu_put_be16(f
, tp
->t_rttmin
);
905 qemu_put_be32(f
, tp
->max_sndwnd
);
906 qemu_put_byte(f
, tp
->t_oobflags
);
907 qemu_put_byte(f
, tp
->t_iobc
);
908 qemu_put_sbe16(f
, tp
->t_softerror
);
909 qemu_put_byte(f
, tp
->snd_scale
);
910 qemu_put_byte(f
, tp
->rcv_scale
);
911 qemu_put_byte(f
, tp
->request_r_scale
);
912 qemu_put_byte(f
, tp
->requested_s_scale
);
913 qemu_put_be32(f
, tp
->ts_recent
);
914 qemu_put_be32(f
, tp
->ts_recent_age
);
915 qemu_put_be32(f
, tp
->last_ack_sent
);
918 static void slirp_sbuf_save(QEMUFile
*f
, struct sbuf
*sbuf
)
922 qemu_put_be32(f
, sbuf
->sb_cc
);
923 qemu_put_be32(f
, sbuf
->sb_datalen
);
924 off
= (uint32_t)(sbuf
->sb_wptr
- sbuf
->sb_data
);
925 qemu_put_sbe32(f
, off
);
926 off
= (uint32_t)(sbuf
->sb_rptr
- sbuf
->sb_data
);
927 qemu_put_sbe32(f
, off
);
928 qemu_put_buffer(f
, (unsigned char*)sbuf
->sb_data
, sbuf
->sb_datalen
);
931 static void slirp_socket_save(QEMUFile
*f
, struct socket
*so
)
933 qemu_put_be32(f
, so
->so_urgc
);
934 qemu_put_be32(f
, so
->so_faddr
.s_addr
);
935 qemu_put_be32(f
, so
->so_laddr
.s_addr
);
936 qemu_put_be16(f
, so
->so_fport
);
937 qemu_put_be16(f
, so
->so_lport
);
938 qemu_put_byte(f
, so
->so_iptos
);
939 qemu_put_byte(f
, so
->so_emu
);
940 qemu_put_byte(f
, so
->so_type
);
941 qemu_put_be32(f
, so
->so_state
);
942 slirp_sbuf_save(f
, &so
->so_rcv
);
943 slirp_sbuf_save(f
, &so
->so_snd
);
944 slirp_tcp_save(f
, so
->so_tcpcb
);
947 static void slirp_bootp_save(QEMUFile
*f
, Slirp
*slirp
)
951 for (i
= 0; i
< NB_BOOTP_CLIENTS
; i
++) {
952 qemu_put_be16(f
, slirp
->bootp_clients
[i
].allocated
);
953 qemu_put_buffer(f
, slirp
->bootp_clients
[i
].macaddr
, 6);
957 static void slirp_state_save(QEMUFile
*f
, void *opaque
)
959 Slirp
*slirp
= opaque
;
960 struct ex_list
*ex_ptr
;
962 for (ex_ptr
= slirp
->exec_list
; ex_ptr
; ex_ptr
= ex_ptr
->ex_next
)
963 if (ex_ptr
->ex_pty
== 3) {
965 so
= slirp_find_ctl_socket(slirp
, ex_ptr
->ex_addr
,
966 ntohs(ex_ptr
->ex_fport
));
970 qemu_put_byte(f
, 42);
971 slirp_socket_save(f
, so
);
975 qemu_put_be16(f
, slirp
->ip_id
);
977 slirp_bootp_save(f
, slirp
);
980 static void slirp_tcp_load(QEMUFile
*f
, struct tcpcb
*tp
)
984 tp
->t_state
= qemu_get_sbe16(f
);
985 for (i
= 0; i
< TCPT_NTIMERS
; i
++)
986 tp
->t_timer
[i
] = qemu_get_sbe16(f
);
987 tp
->t_rxtshift
= qemu_get_sbe16(f
);
988 tp
->t_rxtcur
= qemu_get_sbe16(f
);
989 tp
->t_dupacks
= qemu_get_sbe16(f
);
990 tp
->t_maxseg
= qemu_get_be16(f
);
991 tp
->t_force
= qemu_get_sbyte(f
);
992 tp
->t_flags
= qemu_get_be16(f
);
993 tp
->snd_una
= qemu_get_be32(f
);
994 tp
->snd_nxt
= qemu_get_be32(f
);
995 tp
->snd_up
= qemu_get_be32(f
);
996 tp
->snd_wl1
= qemu_get_be32(f
);
997 tp
->snd_wl2
= qemu_get_be32(f
);
998 tp
->iss
= qemu_get_be32(f
);
999 tp
->snd_wnd
= qemu_get_be32(f
);
1000 tp
->rcv_wnd
= qemu_get_be32(f
);
1001 tp
->rcv_nxt
= qemu_get_be32(f
);
1002 tp
->rcv_up
= qemu_get_be32(f
);
1003 tp
->irs
= qemu_get_be32(f
);
1004 tp
->rcv_adv
= qemu_get_be32(f
);
1005 tp
->snd_max
= qemu_get_be32(f
);
1006 tp
->snd_cwnd
= qemu_get_be32(f
);
1007 tp
->snd_ssthresh
= qemu_get_be32(f
);
1008 tp
->t_idle
= qemu_get_sbe16(f
);
1009 tp
->t_rtt
= qemu_get_sbe16(f
);
1010 tp
->t_rtseq
= qemu_get_be32(f
);
1011 tp
->t_srtt
= qemu_get_sbe16(f
);
1012 tp
->t_rttvar
= qemu_get_sbe16(f
);
1013 tp
->t_rttmin
= qemu_get_be16(f
);
1014 tp
->max_sndwnd
= qemu_get_be32(f
);
1015 tp
->t_oobflags
= qemu_get_byte(f
);
1016 tp
->t_iobc
= qemu_get_byte(f
);
1017 tp
->t_softerror
= qemu_get_sbe16(f
);
1018 tp
->snd_scale
= qemu_get_byte(f
);
1019 tp
->rcv_scale
= qemu_get_byte(f
);
1020 tp
->request_r_scale
= qemu_get_byte(f
);
1021 tp
->requested_s_scale
= qemu_get_byte(f
);
1022 tp
->ts_recent
= qemu_get_be32(f
);
1023 tp
->ts_recent_age
= qemu_get_be32(f
);
1024 tp
->last_ack_sent
= qemu_get_be32(f
);
1028 static int slirp_sbuf_load(QEMUFile
*f
, struct sbuf
*sbuf
)
1030 uint32_t off
, sb_cc
, sb_datalen
;
1032 sb_cc
= qemu_get_be32(f
);
1033 sb_datalen
= qemu_get_be32(f
);
1035 sbreserve(sbuf
, sb_datalen
);
1037 if (sbuf
->sb_datalen
!= sb_datalen
)
1040 sbuf
->sb_cc
= sb_cc
;
1042 off
= qemu_get_sbe32(f
);
1043 sbuf
->sb_wptr
= sbuf
->sb_data
+ off
;
1044 off
= qemu_get_sbe32(f
);
1045 sbuf
->sb_rptr
= sbuf
->sb_data
+ off
;
1046 qemu_get_buffer(f
, (unsigned char*)sbuf
->sb_data
, sbuf
->sb_datalen
);
1051 static int slirp_socket_load(QEMUFile
*f
, struct socket
*so
)
1053 if (tcp_attach(so
) < 0)
1056 so
->so_urgc
= qemu_get_be32(f
);
1057 so
->so_faddr
.s_addr
= qemu_get_be32(f
);
1058 so
->so_laddr
.s_addr
= qemu_get_be32(f
);
1059 so
->so_fport
= qemu_get_be16(f
);
1060 so
->so_lport
= qemu_get_be16(f
);
1061 so
->so_iptos
= qemu_get_byte(f
);
1062 so
->so_emu
= qemu_get_byte(f
);
1063 so
->so_type
= qemu_get_byte(f
);
1064 so
->so_state
= qemu_get_be32(f
);
1065 if (slirp_sbuf_load(f
, &so
->so_rcv
) < 0)
1067 if (slirp_sbuf_load(f
, &so
->so_snd
) < 0)
1069 slirp_tcp_load(f
, so
->so_tcpcb
);
1074 static void slirp_bootp_load(QEMUFile
*f
, Slirp
*slirp
)
1078 for (i
= 0; i
< NB_BOOTP_CLIENTS
; i
++) {
1079 slirp
->bootp_clients
[i
].allocated
= qemu_get_be16(f
);
1080 qemu_get_buffer(f
, slirp
->bootp_clients
[i
].macaddr
, 6);
1084 static int slirp_state_load(QEMUFile
*f
, void *opaque
, int version_id
)
1086 Slirp
*slirp
= opaque
;
1087 struct ex_list
*ex_ptr
;
1089 while (qemu_get_byte(f
)) {
1091 struct socket
*so
= socreate(slirp
);
1096 ret
= slirp_socket_load(f
, so
);
1101 if ((so
->so_faddr
.s_addr
& slirp
->vnetwork_mask
.s_addr
) !=
1102 slirp
->vnetwork_addr
.s_addr
) {
1105 for (ex_ptr
= slirp
->exec_list
; ex_ptr
; ex_ptr
= ex_ptr
->ex_next
) {
1106 if (ex_ptr
->ex_pty
== 3 &&
1107 so
->so_faddr
.s_addr
== ex_ptr
->ex_addr
.s_addr
&&
1108 so
->so_fport
== ex_ptr
->ex_fport
) {
1115 so
->extra
= (void *)ex_ptr
->ex_exec
;
1118 if (version_id
>= 2) {
1119 slirp
->ip_id
= qemu_get_be16(f
);
1122 if (version_id
>= 3) {
1123 slirp_bootp_load(f
, slirp
);