diff options
| author | Mark Kettenis <kettenis@cvs.openbsd.org> | 2012-12-07 21:56:07 +0000 |
|---|---|---|
| committer | Mark Kettenis <kettenis@cvs.openbsd.org> | 2012-12-07 21:56:07 +0000 |
| commit | 6a28b9dd55d3c8423e876a36d64602bb610e6cad (patch) | |
| tree | c7242e93fcbe9207ad7aa5da70bbc02faa8c167c /sys/arch/sparc64/dev/vnet.c | |
| parent | 1956bc82c6e63d1e18199c20f9db2700fee5ce45 (diff) | |
Use a timeout to do a delayed handshake if the receive queue of the LDC
channel transitions into the "up" state.
Diffstat (limited to 'sys/arch/sparc64/dev/vnet.c')
| -rw-r--r-- | sys/arch/sparc64/dev/vnet.c | 22 |
1 files changed, 21 insertions, 1 deletions
diff --git a/sys/arch/sparc64/dev/vnet.c b/sys/arch/sparc64/dev/vnet.c index 70c995e044f..614c137ff3e 100644 --- a/sys/arch/sparc64/dev/vnet.c +++ b/sys/arch/sparc64/dev/vnet.c @@ -1,4 +1,4 @@ -/* $OpenBSD: vnet.c,v 1.27 2012/11/24 23:06:16 kettenis Exp $ */ +/* $OpenBSD: vnet.c,v 1.28 2012/12/07 21:56:06 kettenis Exp $ */ /* * Copyright (c) 2009 Mark Kettenis * @@ -24,6 +24,7 @@ #include <sys/socket.h> #include <sys/sockio.h> #include <sys/systm.h> +#include <sys/timeout.h> #include <machine/autoconf.h> #include <machine/hypervisor.h> @@ -152,6 +153,8 @@ struct vnet_softc { #define VIO_ACK_RDX 0x0400 #define VIO_RCV_RDX 0x0800 + struct timeout sc_handshake_to; + uint8_t sc_xfer_mode; uint32_t sc_local_sid; @@ -191,6 +194,7 @@ struct cfdriver vnet_cd = { int vnet_tx_intr(void *); int vnet_rx_intr(void *); +void vnet_handshake(void *); void vio_rx_data(struct ldc_conn *, struct ldc_pkt *); void vnet_rx_vio_ctrl(struct vnet_softc *, struct vio_msg *); @@ -279,6 +283,8 @@ vnet_attach(struct device *parent, struct device *self, void *aux) lc->lc_start = vnet_ldc_start; lc->lc_rx_data = vio_rx_data; + timeout_set(&sc->sc_handshake_to, vnet_handshake, sc); + lc->lc_txq = ldc_queue_alloc(sc->sc_dmatag, VNET_TX_ENTRIES); if (lc->lc_txq == NULL) { printf(", can't allocate tx queue\n"); @@ -377,6 +383,7 @@ vnet_rx_intr(void *arg) break; case LDC_CHANNEL_UP: DPRINTF(("Rx link up\n")); + timeout_add_msec(&sc->sc_handshake_to, 500); break; case LDC_CHANNEL_RESET: DPRINTF(("Rx link reset\n")); @@ -389,6 +396,9 @@ vnet_rx_intr(void *arg) return (1); } + if (rx_head == rx_tail) + return (0); + lp = (struct ldc_pkt *)(lc->lc_rxq->lq_va + rx_head); switch (lp->type) { case LDC_CTRL: @@ -419,6 +429,14 @@ vnet_rx_intr(void *arg) } void +vnet_handshake(void *arg) +{ + struct vnet_softc *sc = arg; + + ldc_send_vers(&sc->sc_lc); +} + +void vio_rx_data(struct ldc_conn *lc, struct ldc_pkt *lp) { struct vio_msg *vm = (struct vio_msg *)lp; @@ -885,6 +903,7 @@ vnet_ldc_reset(struct ldc_conn *lc) { struct vnet_softc *sc = lc->lc_sc; + timeout_del(&sc->sc_handshake_to); sc->sc_tx_cnt = sc->sc_tx_prod = sc->sc_tx_cons = 0; sc->sc_vio_state = 0; vnet_link_state(sc); @@ -895,6 +914,7 @@ vnet_ldc_start(struct ldc_conn *lc) { struct vnet_softc *sc = lc->lc_sc; + timeout_del(&sc->sc_handshake_to); vnet_send_ver_info(sc, VNET_MAJOR, VNET_MINOR); } |