slirp: Cleanup resources on instance removal

Close & free sockets when shutting down a slirp instance, also release
all buffers.

CC: Michael S. Tsirkin <mst@redhat.com>
Signed-off-by: Jan Kiszka <jan.kiszka@siemens.com>
This commit is contained in:
Jan Kiszka 2012-02-29 19:14:23 +01:00
parent f373431977
commit a68adc2206
10 changed files with 58 additions and 0 deletions

View File

@ -66,6 +66,13 @@ void icmp_init(Slirp *slirp)
slirp->icmp_last_so = &slirp->icmp; slirp->icmp_last_so = &slirp->icmp;
} }
void icmp_cleanup(Slirp *slirp)
{
while (slirp->icmp.so_next != &slirp->icmp) {
icmp_detach(slirp->icmp.so_next);
}
}
static int icmp_send(struct socket *so, struct mbuf *m, int hlen) static int icmp_send(struct socket *so, struct mbuf *m, int hlen)
{ {
struct ip *ip = mtod(m, struct ip *); struct ip *ip = mtod(m, struct ip *);

View File

@ -154,6 +154,7 @@ struct icmp {
(type) == ICMP_MASKREQ || (type) == ICMP_MASKREPLY) (type) == ICMP_MASKREQ || (type) == ICMP_MASKREPLY)
void icmp_init(Slirp *slirp); void icmp_init(Slirp *slirp);
void icmp_cleanup(Slirp *slirp);
void icmp_input(struct mbuf *, int); void icmp_input(struct mbuf *, int);
void icmp_error(struct mbuf *msrc, u_char type, u_char code, int minsize, void icmp_error(struct mbuf *msrc, u_char type, u_char code, int minsize,
const char *message); const char *message);

View File

@ -61,6 +61,13 @@ ip_init(Slirp *slirp)
icmp_init(slirp); icmp_init(slirp);
} }
void ip_cleanup(Slirp *slirp)
{
udp_cleanup(slirp);
tcp_cleanup(slirp);
icmp_cleanup(slirp);
}
/* /*
* Ip input routine. Checksum and byte swap header. If fragmented * Ip input routine. Checksum and byte swap header. If fragmented
* try to reassemble. Process options. Pass to next level. * try to reassemble. Process options. Pass to next level.

View File

@ -32,6 +32,27 @@ m_init(Slirp *slirp)
slirp->m_usedlist.m_next = slirp->m_usedlist.m_prev = &slirp->m_usedlist; slirp->m_usedlist.m_next = slirp->m_usedlist.m_prev = &slirp->m_usedlist;
} }
void m_cleanup(Slirp *slirp)
{
struct mbuf *m, *next;
m = slirp->m_usedlist.m_next;
while (m != &slirp->m_usedlist) {
next = m->m_next;
if (m->m_flags & M_EXT) {
free(m->m_ext);
}
free(m);
m = next;
}
m = slirp->m_freelist.m_next;
while (m != &slirp->m_freelist) {
next = m->m_next;
free(m);
m = next;
}
}
/* /*
* Get an mbuf from the free list, if there are none * Get an mbuf from the free list, if there are none
* malloc one * malloc one

View File

@ -116,6 +116,7 @@ struct mbuf {
* it rather than putting it on the free list */ * it rather than putting it on the free list */
void m_init(Slirp *); void m_init(Slirp *);
void m_cleanup(Slirp *slirp);
struct mbuf * m_get(Slirp *); struct mbuf * m_get(Slirp *);
void m_free(struct mbuf *); void m_free(struct mbuf *);
void m_cat(register struct mbuf *, register struct mbuf *); void m_cat(register struct mbuf *, register struct mbuf *);

View File

@ -246,6 +246,9 @@ void slirp_cleanup(Slirp *slirp)
unregister_savevm(NULL, "slirp", slirp); unregister_savevm(NULL, "slirp", slirp);
ip_cleanup(slirp);
m_cleanup(slirp);
g_free(slirp->tftp_prefix); g_free(slirp->tftp_prefix);
g_free(slirp->bootp_filename); g_free(slirp->bootp_filename);
g_free(slirp); g_free(slirp);

View File

@ -315,6 +315,7 @@ void if_output(struct socket *, struct mbuf *);
/* ip_input.c */ /* ip_input.c */
void ip_init(Slirp *); void ip_init(Slirp *);
void ip_cleanup(Slirp *);
void ip_input(struct mbuf *); void ip_input(struct mbuf *);
void ip_slowtimo(Slirp *); void ip_slowtimo(Slirp *);
void ip_stripoptions(register struct mbuf *, struct mbuf *); void ip_stripoptions(register struct mbuf *, struct mbuf *);
@ -332,6 +333,7 @@ void tcp_setpersist(register struct tcpcb *);
/* tcp_subr.c */ /* tcp_subr.c */
void tcp_init(Slirp *); void tcp_init(Slirp *);
void tcp_cleanup(Slirp *);
void tcp_template(struct tcpcb *); void tcp_template(struct tcpcb *);
void tcp_respond(struct tcpcb *, register struct tcpiphdr *, register struct mbuf *, tcp_seq, tcp_seq, int); void tcp_respond(struct tcpcb *, register struct tcpiphdr *, register struct mbuf *, tcp_seq, tcp_seq, int);
struct tcpcb * tcp_newtcpcb(struct socket *); struct tcpcb * tcp_newtcpcb(struct socket *);

View File

@ -55,6 +55,13 @@ tcp_init(Slirp *slirp)
slirp->tcp_last_so = &slirp->tcb; slirp->tcp_last_so = &slirp->tcb;
} }
void tcp_cleanup(Slirp *slirp)
{
while (slirp->tcb.so_next != &slirp->tcb) {
tcp_close(sototcpcb(slirp->tcb.so_next));
}
}
/* /*
* Create template to be used to send tcp packets on a connection. * Create template to be used to send tcp packets on a connection.
* Call after host entry created, fills * Call after host entry created, fills

View File

@ -49,6 +49,14 @@ udp_init(Slirp *slirp)
slirp->udb.so_next = slirp->udb.so_prev = &slirp->udb; slirp->udb.so_next = slirp->udb.so_prev = &slirp->udb;
slirp->udp_last_so = &slirp->udb; slirp->udp_last_so = &slirp->udb;
} }
void udp_cleanup(Slirp *slirp)
{
while (slirp->udb.so_next != &slirp->udb) {
udp_detach(slirp->udb.so_next);
}
}
/* m->m_data points at ip packet header /* m->m_data points at ip packet header
* m->m_len length ip packet * m->m_len length ip packet
* ip->ip_len length data (IPDU) * ip->ip_len length data (IPDU)

View File

@ -74,6 +74,7 @@ struct udpiphdr {
struct mbuf; struct mbuf;
void udp_init(Slirp *); void udp_init(Slirp *);
void udp_cleanup(Slirp *);
void udp_input(register struct mbuf *, int); void udp_input(register struct mbuf *, int);
int udp_output(struct socket *, struct mbuf *, struct sockaddr_in *); int udp_output(struct socket *, struct mbuf *, struct sockaddr_in *);
int udp_attach(struct socket *); int udp_attach(struct socket *);