pkts
uint32_t pkts)
pkts <= MVPP2_OCCUPIED_THRESH_MASK ?
pkts : MVPP2_OCCUPIED_THRESH_MASK;
uint32_t pkts)
pkts <= MVPP2_TRANSMITTED_THRESH_MASK ?
pkts : MVPP2_TRANSMITTED_THRESH_MASK;
int pkts = 0;
pkts++;
if (pkts == 0)
int pkts = 0, error;
pkts++;
if (pkts == 0)
struct bwfm_pci_buf *pkts;
bwfm_pci_pktid_avail(struct bwfm_pci_softc *sc, struct bwfm_pci_pkts *pkts)
idx = pkts->last + 1;
for (i = 0; i < pkts->npkt; i++) {
if (idx == pkts->npkt)
if (pkts->pkts[idx].bb_m == NULL)
bwfm_pci_pktid_new(struct bwfm_pci_softc *sc, struct bwfm_pci_pkts *pkts,
idx = pkts->last + 1;
for (i = 0; i < pkts->npkt; i++) {
if (idx == pkts->npkt)
if (pkts->pkts[idx].bb_m == NULL) {
pkts->pkts[idx].bb_map, m, BUS_DMA_NOWAIT) != 0) {
pkts->pkts[idx].bb_map, m, BUS_DMA_NOWAIT) != 0)
bus_dmamap_sync(sc->sc_dmat, pkts->pkts[idx].bb_map,
0, pkts->pkts[idx].bb_map->dm_mapsize,
pkts->last = idx;
pkts->pkts[idx].bb_m = m;
*paddr = pkts->pkts[idx].bb_map->dm_segs[0].ds_addr;
bwfm_pci_pktid_free(struct bwfm_pci_softc *sc, struct bwfm_pci_pkts *pkts,
if (pktid >= pkts->npkt || pkts->pkts[pktid].bb_m == NULL)
bus_dmamap_sync(sc->sc_dmat, pkts->pkts[pktid].bb_map, 0,
pkts->pkts[pktid].bb_map->dm_mapsize,
bus_dmamap_unload(sc->sc_dmat, pkts->pkts[pktid].bb_map);
m = pkts->pkts[pktid].bb_m;
pkts->pkts[pktid].bb_m = NULL;
sc->sc_rx_pkts.pkts = malloc(BWFM_NUM_RX_PKTIDS *
&sc->sc_rx_pkts.pkts[i].bb_map);
sc->sc_tx_pkts.pkts = malloc(BWFM_NUM_TX_PKTIDS
&sc->sc_tx_pkts.pkts[i].bb_map);
sc->sc_ioctl_pkts.pkts = malloc(BWFM_NUM_IOCTL_PKTIDS
&sc->sc_ioctl_pkts.pkts[i].bb_map);
bus_dmamap_destroy(sc->sc_dmat, sc->sc_rx_pkts.pkts[i].bb_map);
if (sc->sc_rx_pkts.pkts[i].bb_m)
m_freem(sc->sc_rx_pkts.pkts[i].bb_m);
free(sc->sc_rx_pkts.pkts, M_DEVBUF, BWFM_NUM_RX_PKTIDS *
bus_dmamap_destroy(sc->sc_dmat, sc->sc_tx_pkts.pkts[i].bb_map);
if (sc->sc_tx_pkts.pkts[i].bb_m)
m_freem(sc->sc_tx_pkts.pkts[i].bb_m);
free(sc->sc_tx_pkts.pkts, M_DEVBUF, BWFM_NUM_TX_PKTIDS *
bus_dmamap_destroy(sc->sc_dmat, sc->sc_ioctl_pkts.pkts[i].bb_map);
if (sc->sc_ioctl_pkts.pkts[i].bb_m)
m_freem(sc->sc_ioctl_pkts.pkts[i].bb_m);
free(sc->sc_ioctl_pkts.pkts, M_DEVBUF, BWFM_NUM_IOCTL_PKTIDS *
int16_t pkts;
pkts = m->m_pkthdr.ph_mss;
if (pkts > 1) {
tcpstat_add(tcps_inpktlro, pkts);
if (ext.tcp && paylen >= pkts) {
m->m_pkthdr.ph_mss = paylen / pkts;
int pkts = 0;
pkts++;
if (pkts == 0)
int pkts = 0;
pkts++;
if (pkts == 0)
int pkts = 0;
pkts++;
if (pkts)
uint32_t pkts;
pkts = m->m_pkthdr.ph_mss;
if (pkts > 1) {
tcpstat_add(tcps_inpktlro, pkts);
if (ext.tcp && paylen >= pkts) {
m->m_pkthdr.ph_mss = paylen / pkts;
int pkts = 0;
pkts++;
if (pkts > 0) {
size_t pkts = 0;
pkts++;
(*pr)("%s total packets %zu\n", indent, pkts);
struct kstat_kv pkts;
kstat_kv_u64(&pk->protos[proto].pkts) =
kstat_kv_unit_init(&pk->protos[proto].pkts,
if(!nz->pkts[i].dest) continue;
nz->pkts[i].dest->ip_address_spec))
zone->apex_str, zone->pkts[index].dest->ip_address_spec);
if(ID(packet) != zone->pkts[index].notify_query_id) {
zone->apex_str, zone->pkts[index].dest->ip_address_spec);
zone->pkts[index].dest->ip_address_spec);
zone->apex_str, zone->pkts[index].dest->ip_address_spec));
zone->pkts[index].dest = NULL;
zone->pkts[index].notify_retry = 0;
zone->pkts[index].send_time = 0;
zone->pkts[index].notify_query_id = 0;
if(++zone->pkts[index].notify_retry >=
zone->pkts[index].dest->ip_address_spec);
if(!zone->pkts[i].dest)
if(!cmp_addr_equal(src, srclen, zone->pkts[i].dest))
if(!zone->pkts[index].dest) return 0;
zone->pkts[index].notify_query_id = ID(packet);
if(zone->pkts[index].dest->key_options) {
xfrd_tsig_sign_request(packet, &zone->notify_tsig, zone->pkts[index].dest);
if((zone->pkts[index].dest->is_ipv6
(!zone->pkts[index].dest->is_ipv6
int fd = xfrd_send_udp(zone->pkts[index].dest, packet,
zone->apex_str, zone->pkts[index].notify_retry,
zone->pkts[index].dest->ip_address_spec);
if(zone->pkts[index].dest->is_ipv6)
zone->pkts[index].dest, &to);
if(zone->pkts[index].dest->is_ipv6
zone->pkts[index].dest->ip_address_spec,
zone->pkts[index].dest->ip_address_spec,
zone->pkts[index].send_time = time(NULL);
zone->apex_str, zone->pkts[index].notify_retry,
zone->pkts[index].dest->ip_address_spec));
if(!zone->pkts[i].dest)
if(now >= zone->pkts[i].send_time + XFRD_NOTIFY_RETRY_TIMOUT) {
while(zone->pkts[i].dest==NULL && zone->notify_current) {
zone->pkts[i].dest = zone->notify_current;
zone->pkts[i].notify_retry = 0;
zone->pkts[i].notify_query_id = 0;
zone->pkts[i].send_time = 0;
memset(zone->pkts, 0, sizeof(zone->pkts));
struct notify_pkt pkts[NOTIFY_CONCURRENT_MAX];