mirror/freebsd
1
0
Fork 0
mirror of https://git.FreeBSD.org/src.git synced 2025-01-01 12:19:28 +00:00
Code Issues Releases Activity

add some definition and driver changes in preparation for

Browse Source 
two upcoming features:

semi-transparent mode:
    when a device is opened in this mode, the
    user program will be able to mark slots that must be forwarded
    to the "other" side (i.e. from NIC to host stack, or viceversa),
    and the forwarding will occur automatically at the next netmap syscall.
    This saves the need to open another file descriptor and do
    the forwarding manually.

direct-forwarding mode:
    when operating with a VALE port, the user can specify in the slot
    the actual destination port, overriding the forwarding decision
    made by a lookup of the destination MAC. This can be useful to
    implement packet dispatchers.

No API changes will be introduced.
No new functionality in this patch yet.
This commit is contained in:
Luigi Rizzo 2013-01-17 22:14:58 +00:00
parent f876ffeae3
commit 1dce924d25
Notes: svn2git 2020-12-20 02:59:44 +00:00 
svn path=/head/; revision=245579
6 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
sys/dev/netmap/if_em_netmap.h
View File

@ -292,6 +292,8 @@ em_netmap_rxsync(struct ifnet *ifp, u_int ring_nr, int do_lock)
l = rxr->next_to_check; l = rxr->next_to_check;
j = netmap_idx_n2k(kring, l); j = netmap_idx_n2k(kring, l);
if (netmap_no_pendintr || force_update) { if (netmap_no_pendintr || force_update) {
uint16_t slot_flags = kring->nkr_slot_flags;
for (n = 0; ; n++) { for (n = 0; ; n++) {
struct e1000_rx_desc *curr = &rxr->rx_base[l]; struct e1000_rx_desc *curr = &rxr->rx_base[l];
uint32_t staterr = le32toh(curr->status); uint32_t staterr = le32toh(curr->status);
@ -299,6 +301,7 @@ em_netmap_rxsync(struct ifnet *ifp, u_int ring_nr, int do_lock)
if ((staterr & E1000_RXD_STAT_DD) == 0) if ((staterr & E1000_RXD_STAT_DD) == 0)
break; break;
ring->slot[j].len = le16toh(curr->length); ring->slot[j].len = le16toh(curr->length);
ring->slot[j].flags = slot_flags;
bus_dmamap_sync(rxr->rxtag, rxr->rx_buffers[l].map, bus_dmamap_sync(rxr->rxtag, rxr->rx_buffers[l].map,
BUS_DMASYNC_POSTREAD); BUS_DMASYNC_POSTREAD);
j = (j == lim) ? 0 : j + 1; j = (j == lim) ? 0 : j + 1;

3
sys/dev/netmap/if_igb_netmap.h
View File

@ -263,6 +263,8 @@ igb_netmap_rxsync(struct ifnet *ifp, u_int ring_nr, int do_lock)
l = rxr->next_to_check; l = rxr->next_to_check;
j = netmap_idx_n2k(kring, l); j = netmap_idx_n2k(kring, l);
if (netmap_no_pendintr || force_update) { if (netmap_no_pendintr || force_update) {
uint16_t slot_flags = kring->nkr_slot_flags;
for (n = 0; ; n++) { for (n = 0; ; n++) {
union e1000_adv_rx_desc *curr = &rxr->rx_base[l]; union e1000_adv_rx_desc *curr = &rxr->rx_base[l];
uint32_t staterr = le32toh(curr->wb.upper.status_error); uint32_t staterr = le32toh(curr->wb.upper.status_error);
@ -270,6 +272,7 @@ igb_netmap_rxsync(struct ifnet *ifp, u_int ring_nr, int do_lock)
if ((staterr & E1000_RXD_STAT_DD) == 0) if ((staterr & E1000_RXD_STAT_DD) == 0)
break; break;
ring->slot[j].len = le16toh(curr->wb.upper.length); ring->slot[j].len = le16toh(curr->wb.upper.length);
ring->slot[j].flags = slot_flags;
bus_dmamap_sync(rxr->ptag, bus_dmamap_sync(rxr->ptag,
rxr->rx_buffers[l].pmap, BUS_DMASYNC_POSTREAD); rxr->rx_buffers[l].pmap, BUS_DMASYNC_POSTREAD);
j = (j == lim) ? 0 : j + 1; j = (j == lim) ? 0 : j + 1;

3
sys/dev/netmap/if_lem_netmap.h
View File

@ -253,6 +253,8 @@ lem_netmap_rxsync(struct ifnet *ifp, u_int ring_nr, int do_lock)
l = adapter->next_rx_desc_to_check; l = adapter->next_rx_desc_to_check;
j = netmap_idx_n2k(kring, l); j = netmap_idx_n2k(kring, l);
if (netmap_no_pendintr || force_update) { if (netmap_no_pendintr || force_update) {
uint16_t slot_flags = kring->nkr_slot_flags;
for (n = 0; ; n++) { for (n = 0; ; n++) {
struct e1000_rx_desc *curr = &adapter->rx_desc_base[l]; struct e1000_rx_desc *curr = &adapter->rx_desc_base[l];
uint32_t staterr = le32toh(curr->status); uint32_t staterr = le32toh(curr->status);
@ -266,6 +268,7 @@ lem_netmap_rxsync(struct ifnet *ifp, u_int ring_nr, int do_lock)
len = 0; len = 0;
} }
ring->slot[j].len = len; ring->slot[j].len = len;
ring->slot[j].flags = slot_flags;
bus_dmamap_sync(adapter->rxtag, bus_dmamap_sync(adapter->rxtag,
adapter->rx_buffer_area[l].map, adapter->rx_buffer_area[l].map,
BUS_DMASYNC_POSTREAD); BUS_DMASYNC_POSTREAD);

3
sys/dev/netmap/if_re_netmap.h
View File

@ -245,6 +245,8 @@ re_netmap_rxsync(struct ifnet *ifp, u_int ring_nr, int do_lock)
l = sc->rl_ldata.rl_rx_prodidx; /* next pkt to check */ l = sc->rl_ldata.rl_rx_prodidx; /* next pkt to check */
j = netmap_idx_n2k(kring, l); /* the kring index */ j = netmap_idx_n2k(kring, l); /* the kring index */
if (netmap_no_pendintr || force_update) { if (netmap_no_pendintr || force_update) {
uint16_t slot_flags = kring->nkr_slot_flags;
for (n = kring->nr_hwavail; n < lim ; n++) { for (n = kring->nr_hwavail; n < lim ; n++) {
struct rl_desc *cur_rx = &sc->rl_ldata.rl_rx_list[l]; struct rl_desc *cur_rx = &sc->rl_ldata.rl_rx_list[l];
uint32_t rxstat = le32toh(cur_rx->rl_cmdstat); uint32_t rxstat = le32toh(cur_rx->rl_cmdstat);
@ -256,6 +258,7 @@ re_netmap_rxsync(struct ifnet *ifp, u_int ring_nr, int do_lock)
/* XXX subtract crc */ /* XXX subtract crc */
total_len = (total_len < 4) ? 0 : total_len - 4; total_len = (total_len < 4) ? 0 : total_len - 4;
kring->ring->slot[j].len = total_len; kring->ring->slot[j].len = total_len;
kring->ring->slot[j].flags = slot_flags;
/* sync was in re_newbuf() */ /* sync was in re_newbuf() */
bus_dmamap_sync(sc->rl_ldata.rl_rx_mtag, bus_dmamap_sync(sc->rl_ldata.rl_rx_mtag,
rxd[l].rx_dmamap, BUS_DMASYNC_POSTREAD); rxd[l].rx_dmamap, BUS_DMASYNC_POSTREAD);

2
sys/dev/netmap/ixgbe_netmap.h
View File

@ -483,6 +483,7 @@ ixgbe_netmap_rxsync(struct ifnet *ifp, u_int ring_nr, int do_lock)
*/ */
if (netmap_no_pendintr || force_update) { if (netmap_no_pendintr || force_update) {
int crclen = ix_crcstrip ? 0 : 4; int crclen = ix_crcstrip ? 0 : 4;
uint16_t slot_flags = kring->nkr_slot_flags;
l = rxr->next_to_check; l = rxr->next_to_check;
j = netmap_idx_n2k(kring, l); j = netmap_idx_n2k(kring, l);
@ -494,6 +495,7 @@ ixgbe_netmap_rxsync(struct ifnet *ifp, u_int ring_nr, int do_lock)
if ((staterr & IXGBE_RXD_STAT_DD) == 0) if ((staterr & IXGBE_RXD_STAT_DD) == 0)
break; break;
ring->slot[j].len = le16toh(curr->wb.upper.length) - crclen; ring->slot[j].len = le16toh(curr->wb.upper.length) - crclen;
ring->slot[j].flags = slot_flags;
bus_dmamap_sync(rxr->ptag, bus_dmamap_sync(rxr->ptag,
rxr->rx_buffers[l].pmap, BUS_DMASYNC_POSTREAD); rxr->rx_buffers[l].pmap, BUS_DMASYNC_POSTREAD);
j = (j == lim) ? 0 : j + 1; j = (j == lim) ? 0 : j + 1;

5
sys/dev/netmap/netmap_kern.h
View File

@ -119,6 +119,10 @@ struct netmap_adapter;
* RX rings: the next empty buffer (hwcur + hwavail + hwofs) coincides with * RX rings: the next empty buffer (hwcur + hwavail + hwofs) coincides with
* the next empty buffer as known by the hardware (next_to_check or so). * the next empty buffer as known by the hardware (next_to_check or so).
* TX rings: hwcur + hwofs coincides with next_to_send * TX rings: hwcur + hwofs coincides with next_to_send
*
* For received packets, slot->flags is set to nkr_slot_flags
* so we can provide a proper initial value (e.g. set NS_FORWARD
* when operating in 'transparent' mode).
*/ */
struct netmap_kring { struct netmap_kring {
struct netmap_ring *ring; struct netmap_ring *ring;
@ -128,6 +132,7 @@ struct netmap_kring {
#define NKR_PENDINTR 0x1 // Pending interrupt. #define NKR_PENDINTR 0x1 // Pending interrupt.
u_int nkr_num_slots; u_int nkr_num_slots;
uint16_t nkr_slot_flags; /* initial value for flags */
int nkr_hwofs; /* offset between NIC and netmap ring */ int nkr_hwofs; /* offset between NIC and netmap ring */
struct netmap_adapter *na; struct netmap_adapter *na;
NM_SELINFO_T si; /* poll/select wait queue */ NM_SELINFO_T si; /* poll/select wait queue */