[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [Xen-changelog] Define new notify_remote_via_irq() interface which is a
# HG changeset patch # User kaf24@xxxxxxxxxxxxxxxxxxxx # Node ID 8c23b56f39540f63eeebb1ffc667c8ac0a264211 # Parent 559ad1abb3d502079ff5bbd39e2979f0a637549e Define new notify_remote_via_irq() interface which is a safe version for drivers to use that is aware of save/restore. Post-restore notifications are silently dropped, in the expectation that xenbus will eventually get round to telling the driver it needs to reconnect. Signed-off-by: Keir Fraser <keir@xxxxxxxxxxxxx> diff -r 559ad1abb3d5 -r 8c23b56f3954 linux-2.6-xen-sparse/arch/xen/i386/kernel/smp.c --- a/linux-2.6-xen-sparse/arch/xen/i386/kernel/smp.c Thu Sep 29 14:14:03 2005 +++ b/linux-2.6-xen-sparse/arch/xen/i386/kernel/smp.c Thu Sep 29 14:49:54 2005 @@ -133,7 +133,7 @@ { int evtchn = per_cpu(ipi_to_evtchn, cpu)[vector]; BUG_ON(evtchn < 0); - notify_via_evtchn(evtchn); + notify_remote_via_evtchn(evtchn); } void __send_IPI_shortcut(unsigned int shortcut, int vector) diff -r 559ad1abb3d5 -r 8c23b56f3954 linux-2.6-xen-sparse/arch/xen/kernel/evtchn.c --- a/linux-2.6-xen-sparse/arch/xen/kernel/evtchn.c Thu Sep 29 14:14:03 2005 +++ b/linux-2.6-xen-sparse/arch/xen/kernel/evtchn.c Thu Sep 29 14:49:54 2005 @@ -622,6 +622,14 @@ synch_set_bit(evtchn, &s->evtchn_pending[0]); } +void notify_remote_via_irq(int irq) +{ + int evtchn = irq_to_evtchn[irq]; + + if (VALID_EVTCHN(evtchn)) + notify_remote_via_evtchn(evtchn); +} + void irq_resume(void) { evtchn_op_t op; diff -r 559ad1abb3d5 -r 8c23b56f3954 linux-2.6-xen-sparse/arch/xen/x86_64/kernel/genapic_xen.c --- a/linux-2.6-xen-sparse/arch/xen/x86_64/kernel/genapic_xen.c Thu Sep 29 14:14:03 2005 +++ b/linux-2.6-xen-sparse/arch/xen/x86_64/kernel/genapic_xen.c Thu Sep 29 14:49:54 2005 @@ -33,7 +33,7 @@ { int evtchn = per_cpu(ipi_to_evtchn, cpu)[vector]; BUG_ON(evtchn < 0); - notify_via_evtchn(evtchn); + notify_remote_via_evtchn(evtchn); } void xen_send_IPI_shortcut(unsigned int shortcut, int vector, unsigned int dest) diff -r 559ad1abb3d5 -r 8c23b56f3954 linux-2.6-xen-sparse/drivers/xen/blkback/blkback.c --- a/linux-2.6-xen-sparse/drivers/xen/blkback/blkback.c Thu Sep 29 14:14:03 2005 +++ b/linux-2.6-xen-sparse/drivers/xen/blkback/blkback.c Thu Sep 29 14:49:54 2005 @@ -481,7 +481,7 @@ spin_unlock_irqrestore(&blkif->blk_ring_lock, flags); /* Kick the relevant domain. */ - notify_via_evtchn(blkif->evtchn); + notify_remote_via_irq(blkif->irq); } void blkif_deschedule(blkif_t *blkif) diff -r 559ad1abb3d5 -r 8c23b56f3954 linux-2.6-xen-sparse/drivers/xen/blkfront/blkfront.c --- a/linux-2.6-xen-sparse/drivers/xen/blkfront/blkfront.c Thu Sep 29 14:14:03 2005 +++ b/linux-2.6-xen-sparse/drivers/xen/blkfront/blkfront.c Thu Sep 29 14:49:54 2005 @@ -84,7 +84,7 @@ static inline void flush_requests(struct blkfront_info *info) { RING_PUSH_REQUESTS(&info->ring); - notify_via_evtchn(info->evtchn); + notify_remote_via_irq(info->irq); } static void kick_pending_request_queues(struct blkfront_info *info) diff -r 559ad1abb3d5 -r 8c23b56f3954 linux-2.6-xen-sparse/drivers/xen/blktap/blktap.c --- a/linux-2.6-xen-sparse/drivers/xen/blktap/blktap.c Thu Sep 29 14:14:03 2005 +++ b/linux-2.6-xen-sparse/drivers/xen/blktap/blktap.c Thu Sep 29 14:49:54 2005 @@ -842,7 +842,7 @@ spin_unlock_irqrestore(&blkif->blk_ring_lock, flags); /* Kick the relevant domain. */ - notify_via_evtchn(blkif->evtchn); + notify_remote_via_irq(blkif->irq); } static struct miscdevice blktap_miscdev = { diff -r 559ad1abb3d5 -r 8c23b56f3954 linux-2.6-xen-sparse/drivers/xen/console/xencons_ring.c --- a/linux-2.6-xen-sparse/drivers/xen/console/xencons_ring.c Thu Sep 29 14:14:03 2005 +++ b/linux-2.6-xen-sparse/drivers/xen/console/xencons_ring.c Thu Sep 29 14:49:54 2005 @@ -46,7 +46,8 @@ /* don't block - write as much as possible and return */ -static int __xencons_ring_send(struct ring_head *ring, const char *data, unsigned len) +static int __xencons_ring_send( + struct ring_head *ring, const char *data, unsigned len) { int copied = 0; @@ -63,13 +64,9 @@ int xencons_ring_send(const char *data, unsigned len) { - struct ring_head *out = outring(); - int sent = 0; - - sent = __xencons_ring_send(out, data, len); - notify_via_evtchn(xen_start_info->console_evtchn); + int sent = __xencons_ring_send(outring(), data, len); + notify_remote_via_irq(xencons_irq); return sent; - } diff -r 559ad1abb3d5 -r 8c23b56f3954 linux-2.6-xen-sparse/drivers/xen/netback/netback.c --- a/linux-2.6-xen-sparse/drivers/xen/netback/netback.c Thu Sep 29 14:14:03 2005 +++ b/linux-2.6-xen-sparse/drivers/xen/netback/netback.c Thu Sep 29 14:49:54 2005 @@ -42,7 +42,7 @@ static mmu_update_t rx_mmu[NETIF_RX_RING_SIZE]; static gnttab_transfer_t grant_rx_op[MAX_PENDING_REQS]; -static unsigned char rx_notify[NR_EVENT_CHANNELS]; +static unsigned char rx_notify[NR_IRQS]; /* Don't currently gate addition of an interface to the tx scheduling list. */ #define tx_work_exists(_if) (1) @@ -209,7 +209,7 @@ { netif_t *netif = NULL; s8 status; - u16 size, id, evtchn; + u16 size, id, irq; multicall_entry_t *mcl; mmu_update_t *mmu; gnttab_transfer_t *gop; @@ -320,16 +320,16 @@ gop->status, netif->domid); /* XXX SMH: should free 'old_mfn' here */ status = NETIF_RSP_ERROR; - } - evtchn = netif->evtchn; + } + irq = netif->irq; id = netif->rx->ring[ MASK_NETIF_RX_IDX(netif->rx_resp_prod)].req.id; if (make_rx_response(netif, id, status, (unsigned long)skb->data & ~PAGE_MASK, size, skb->proto_csum_valid) && - (rx_notify[evtchn] == 0)) { - rx_notify[evtchn] = 1; - notify_list[notify_nr++] = evtchn; + (rx_notify[irq] == 0)) { + rx_notify[irq] = 1; + notify_list[notify_nr++] = irq; } netif_put(netif); @@ -339,9 +339,9 @@ } while (notify_nr != 0) { - evtchn = notify_list[--notify_nr]; - rx_notify[evtchn] = 0; - notify_via_evtchn(evtchn); + irq = notify_list[--notify_nr]; + rx_notify[irq] = 0; + notify_remote_via_irq(irq); } /* More work to do? */ @@ -717,7 +717,7 @@ mb(); /* Update producer before checking event threshold. */ if (i == netif->tx->event) - notify_via_evtchn(netif->evtchn); + notify_remote_via_irq(netif->irq); } static int make_rx_response(netif_t *netif, diff -r 559ad1abb3d5 -r 8c23b56f3954 linux-2.6-xen-sparse/drivers/xen/netfront/netfront.c --- a/linux-2.6-xen-sparse/drivers/xen/netfront/netfront.c Thu Sep 29 14:14:03 2005 +++ b/linux-2.6-xen-sparse/drivers/xen/netfront/netfront.c Thu Sep 29 14:49:54 2005 @@ -457,7 +457,7 @@ /* Only notify Xen if we really have to. */ mb(); if (np->tx->TX_TEST_IDX == i) - notify_via_evtchn(np->evtchn); + notify_remote_via_irq(np->irq); return 0; @@ -776,7 +776,7 @@ */ np->backend_state = BEST_CONNECTED; wmb(); - notify_via_evtchn(np->evtchn); + notify_remote_via_irq(np->irq); network_tx_buf_gc(dev); if (np->user_state == UST_OPEN) diff -r 559ad1abb3d5 -r 8c23b56f3954 linux-2.6-xen-sparse/drivers/xen/tpmback/tpmback.c --- a/linux-2.6-xen-sparse/drivers/xen/tpmback/tpmback.c Thu Sep 29 14:14:03 2005 +++ b/linux-2.6-xen-sparse/drivers/xen/tpmback/tpmback.c Thu Sep 29 14:49:54 2005 @@ -308,7 +308,7 @@ rc = offset; DPRINTK("Notifying frontend via event channel %d\n", tpmif->evtchn); - notify_via_evtchn(tpmif->evtchn); + notify_remote_via_irq(tpmif->irq); return rc; } diff -r 559ad1abb3d5 -r 8c23b56f3954 linux-2.6-xen-sparse/drivers/xen/tpmfront/tpmfront.c --- a/linux-2.6-xen-sparse/drivers/xen/tpmfront/tpmfront.c Thu Sep 29 14:14:03 2005 +++ b/linux-2.6-xen-sparse/drivers/xen/tpmfront/tpmfront.c Thu Sep 29 14:49:54 2005 @@ -682,7 +682,7 @@ DPRINTK("Notifying backend via event channel %d\n", tp->evtchn); - notify_via_evtchn(tp->evtchn); + notify_remote_via_irq(tp->irq); spin_unlock_irq(&tp->tx_lock); return offset; diff -r 559ad1abb3d5 -r 8c23b56f3954 linux-2.6-xen-sparse/drivers/xen/xenbus/xenbus_comms.c --- a/linux-2.6-xen-sparse/drivers/xen/xenbus/xenbus_comms.c Thu Sep 29 14:14:03 2005 +++ b/linux-2.6-xen-sparse/drivers/xen/xenbus/xenbus_comms.c Thu Sep 29 14:49:54 2005 @@ -147,7 +147,7 @@ data += avail; len -= avail; update_output_chunk(out, avail); - notify_via_evtchn(xen_start_info->store_evtchn); + notify_remote_via_irq(xenbus_irq); } while (len != 0); return 0; @@ -192,7 +192,7 @@ pr_debug("Finished read of %i bytes (%i to go)\n", avail, len); /* If it was full, tell them we've taken some. */ if (was_full) - notify_via_evtchn(xen_start_info->store_evtchn); + notify_remote_via_irq(xenbus_irq); } /* If we left something, wake watch thread to deal with it. */ diff -r 559ad1abb3d5 -r 8c23b56f3954 linux-2.6-xen-sparse/include/asm-xen/evtchn.h --- a/linux-2.6-xen-sparse/include/asm-xen/evtchn.h Thu Sep 29 14:14:03 2005 +++ b/linux-2.6-xen-sparse/include/asm-xen/evtchn.h Thu Sep 29 14:49:54 2005 @@ -75,6 +75,12 @@ void *dev_id); extern void unbind_evtchn_from_irqhandler(unsigned int irq, void *dev_id); +/* + * Unlike notify_remote_via_evtchn(), this is safe to use across + * save/restore. Notifications on a broken connection are silently dropped. + */ +void notify_remote_via_irq(int irq); + extern void irq_resume(void); /* Entry point for notifications into Linux subsystems. */ @@ -115,12 +121,12 @@ synch_clear_bit(port, &s->evtchn_pending[0]); } -static inline int notify_via_evtchn(int port) +static inline void notify_remote_via_evtchn(int port) { evtchn_op_t op; op.cmd = EVTCHNOP_send; op.u.send.local_port = port; - return HYPERVISOR_event_channel_op(&op); + (void)HYPERVISOR_event_channel_op(&op); } /* _______________________________________________ Xen-changelog mailing list Xen-changelog@xxxxxxxxxxxxxxxxxxx http://lists.xensource.com/xen-changelog
|
![]() |
Lists.xenproject.org is hosted with RackSpace, monitoring our |