motorhead/qemu
1
0
Fork 0
mirror of https://github.com/Motorhead1991/qemu.git synced 2025-08-04 08:13:54 -06:00
Code Issues Projects Releases Packages Wiki Activity Actions

slirp: add unregister_poll_fd() callback

Browse source 
Add a counter-part to register_poll_fd() for completeness.

(so far, register_poll_fd() is called only on struct socket fd)

Suggested-by: Paolo Bonzini <pbonzini@redhat.com>
Signed-off-by: Marc-André Lureau <marcandre.lureau@redhat.com>
Signed-off-by: Samuel Thibault <samuel.thibault@ens-lyon.org>
This commit is contained in:
Marc-André Lureau 2019-01-17 15:43:42 +04:00 • committed by Samuel Thibault
parent 848c7092ba
commit f6e5aa366f
6 changed files with 14 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
net/slirp.c
View file

@ -191,6 +191,11 @@ static void net_slirp_register_poll_fd(int fd)
qemu_fd_register(fd); qemu_fd_register(fd);
} }
static void net_slirp_unregister_poll_fd(int fd)
{
/* no qemu_fd_unregister */
}
static const SlirpCb slirp_cb = { static const SlirpCb slirp_cb = {
.output = net_slirp_output, .output = net_slirp_output,
.guest_error = net_slirp_guest_error, .guest_error = net_slirp_guest_error,
@ -199,6 +204,7 @@ static const SlirpCb slirp_cb = {
.timer_free = net_slirp_timer_free, .timer_free = net_slirp_timer_free,
.timer_mod = net_slirp_timer_mod, .timer_mod = net_slirp_timer_mod,
.register_poll_fd = net_slirp_register_poll_fd, .register_poll_fd = net_slirp_register_poll_fd,
.unregister_poll_fd = net_slirp_unregister_poll_fd,
}; };
static int net_slirp_init(NetClientState *peer, const char *model, static int net_slirp_init(NetClientState *peer, const char *model,

1
slirp/ip_icmp.c
View file

@ -114,6 +114,7 @@ static int icmp_send(struct socket *so, struct mbuf *m, int hlen)
void icmp_detach(struct socket *so) void icmp_detach(struct socket *so)
{ {
so->slirp->cb->unregister_poll_fd(so->s);
slirp_closesocket(so->s); slirp_closesocket(so->s);
sofree(so); sofree(so);
} }

2
slirp/libslirp.h
View file

@ -29,6 +29,8 @@ typedef struct SlirpCb {
void (*timer_mod)(void *timer, int64_t expire_time); void (*timer_mod)(void *timer, int64_t expire_time);
/* Register a fd for future polling */ /* Register a fd for future polling */
void (*register_poll_fd)(int fd); void (*register_poll_fd)(int fd);
/* Unregister a fd */
void (*unregister_poll_fd)(int fd);
} SlirpCb; } SlirpCb;

3
slirp/slirp.c
View file

@ -1015,7 +1015,8 @@ int slirp_remove_hostfwd(Slirp *slirp, int is_udp, struct in_addr host_addr,
getsockname(so->s, (struct sockaddr *)&addr, &addr_len) == 0 && getsockname(so->s, (struct sockaddr *)&addr, &addr_len) == 0 &&
addr.sin_addr.s_addr == host_addr.s_addr && addr.sin_addr.s_addr == host_addr.s_addr &&
addr.sin_port == port) { addr.sin_port == port) {
close(so->s); so->slirp->cb->unregister_poll_fd(so->s);
slirp_closesocket(so->s);
sofree(so); sofree(so);
return 0; return 0;
} }

2
slirp/tcp_subr.c
View file

@ -337,6 +337,7 @@ tcp_close(struct tcpcb *tp)
/* clobber input socket cache if we're closing the cached connection */ /* clobber input socket cache if we're closing the cached connection */
if (so == slirp->tcp_last_so) if (so == slirp->tcp_last_so)
slirp->tcp_last_so = &slirp->tcb; slirp->tcp_last_so = &slirp->tcb;
so->slirp->cb->unregister_poll_fd(so->s);
slirp_closesocket(so->s); slirp_closesocket(so->s);
sbfree(&so->so_rcv); sbfree(&so->so_rcv);
sbfree(&so->so_snd); sbfree(&so->so_snd);
@ -498,6 +499,7 @@ void tcp_connect(struct socket *inso)
/* Close the accept() socket, set right state */ /* Close the accept() socket, set right state */
if (inso->so_state & SS_FACCEPTONCE) { if (inso->so_state & SS_FACCEPTONCE) {
/* If we only accept once, close the accept() socket */ /* If we only accept once, close the accept() socket */
so->slirp->cb->unregister_poll_fd(so->s);
slirp_closesocket(so->s); slirp_closesocket(so->s);
/* Don't select it yet, even though we have an FD */ /* Don't select it yet, even though we have an FD */

1
slirp/udp.c
View file

@ -292,6 +292,7 @@ udp_attach(struct socket *so, unsigned short af)
void void
udp_detach(struct socket *so) udp_detach(struct socket *so)
{ {
so->slirp->cb->unregister_poll_fd(so->s);
slirp_closesocket(so->s); slirp_closesocket(so->s);
sofree(so); sofree(so);
} }