| /f-stack/app/redis-5.0.5/src/ |
| H A D | t_stream.c | 56 s->last_id.ms = 0; in streamNew()
57 s->last_id.seq = 0; in streamNew()
76 if (ms > last_id->ms) { in streamNextID()
80 new_id->ms = last_id->ms; in streamNextID()
355 s->last_id = id; in streamAppendItem()
1629 cg->last_id = *id; in streamCreateCG()
1800 id = s->last_id; in xgroupCommand()
1804 cg->last_id = id; in xgroupCommand()
1862 s->last_id = id; in xsetidCommand()
2203 if (streamCompareID(&last_id,&group->last_id) > 0) { in xclaimCommand()
[all …]
|
| H A D | stream.h | 19 streamID last_id; /* Zero if there are yet no items. */ member
52 streamID last_id; /* Last delivered (not acknowledged) ID for this member
|
| H A D | blocked.c | 416 *gt = group->last_id; in handleClientsBlockedOnKeys()
420 if (streamCompareID(&s->last_id, gt) > 0) { in handleClientsBlockedOnKeys()
|
| H A D | rdb.c | 923 if ((n = rdbSaveLen(rdb,s->last_id.ms)) == -1) return -1; in rdbSaveObject()
925 if ((n = rdbSaveLen(rdb,s->last_id.seq)) == -1) return -1; in rdbSaveObject()
949 if ((n = rdbSaveLen(rdb,cg->last_id.ms)) == -1) return -1; in rdbSaveObject()
951 if ((n = rdbSaveLen(rdb,cg->last_id.seq)) == -1) return -1; in rdbSaveObject()
1679 s->last_id.ms = rdbLoadLen(rdb,NULL); in rdbLoadObject()
1680 s->last_id.seq = rdbLoadLen(rdb,NULL); in rdbLoadObject()
|
| H A D | aof.c | 1197 if (rioWriteBulkStreamID(r,&s->last_id) == 0) return 0; in rewriteStreamObject()
1207 if (rioWriteBulkStreamID(r,&s->last_id) == 0) return 0; in rewriteStreamObject()
1223 if (rioWriteBulkStreamID(r,&group->last_id) == 0) return 0; in rewriteStreamObject()
|
| /f-stack/dpdk/drivers/net/fm10k/ |
| H A D | fm10k_rxtx.c | 580 uint16_t last_id; in tx_xmit_pkt() local
586 last_id = q->next_free + mb->nb_segs - 1; in tx_xmit_pkt()
587 if (last_id >= q->nb_desc) in tx_xmit_pkt()
588 last_id = last_id - q->nb_desc; in tx_xmit_pkt()
594 fifo_insert(&q->rs_tracker, last_id); in tx_xmit_pkt()
653 q->hw_ring[last_id].flags |= flags; in tx_xmit_pkt()
|
| /f-stack/dpdk/drivers/net/igc/ |
| H A D | igc_txrx.c | 184 uint16_t last_id; /**< Index of last scattered descriptor. */ member
1718 tx_end = sw_ring[tx_last].last_id; in igc_xmit_pkts()
1729 tx_end = sw_ring[tx_end].last_id; in igc_xmit_pkts()
1793 txe->last_id = tx_last; in igc_xmit_pkts()
1827 txe->last_id = tx_last; in igc_xmit_pkts()
1926 txe[i].last_id = i; in igc_reset_tx_queue()
2082 tx_first = sw_ring[txq->tx_tail].last_id; in eth_igc_tx_done_cleanup()
2096 tx_last = sw_ring[tx_id].last_id; in eth_igc_tx_done_cleanup()
2113 sw_ring[tx_id].last_id = tx_id; in eth_igc_tx_done_cleanup()
|
| /f-stack/freebsd/net/route/ |
| H A D | nhgrp_ctl.c | 452 uint32_t last_id = 0; in get_nhgrp() local
454 if (wn[i].nh->nh_priv->nh_idx == last_id) { in get_nhgrp()
458 last_id = wn[i].nh->nh_priv->nh_idx; in get_nhgrp()
|
| /f-stack/dpdk/drivers/raw/ntb/ |
| H A D | ntb.h | 163 uint16_t last_id; member
|
| H A D | ntb.c | 436 txq->sw_ring[i].last_id = i; in ntb_txq_setup()
682 sw_ring[txq->last_used].last_id = tx_last; in ntb_enqueue_bufs()
|
| /f-stack/app/redis-5.0.5/tests/unit/type/ |
| H A D | stream.tcl | 129 set last_id "-"
132 set elements [r xrange mystream $last_id + COUNT 100]
138 set last_id [streamNextID [lindex $elements end 0]]
|
| /f-stack/dpdk/drivers/net/ixgbe/ |
| H A D | ixgbe_rxtx.h | 84 uint16_t last_id; /**< Index of last scattered descriptor. */ member
|
| H A D | ixgbe_rxtx.c | 583 desc_to_clean_to = sw_ring[desc_to_clean_to].last_id; in ixgbe_xmit_cleanup()
866 txe->last_id = tx_last; in ixgbe_xmit_pkts()
908 txe->last_id = tx_last; in ixgbe_xmit_pkts()
2348 pkt_cnt += (swr_ring[tx_id].last_id == tx_id); in ixgbe_tx_done_cleanup_full()
2467 txe[i].last_id = i; in ixgbe_reset_tx_queue()
|
| /f-stack/dpdk/drivers/net/e1000/ |
| H A D | igb_rxtx.c | 79 uint16_t last_id; /**< Index of last scattered descriptor. */ member
484 tx_end = sw_ring[tx_last].last_id; in eth_igb_xmit_pkts()
495 tx_end = sw_ring[tx_end].last_id; in eth_igb_xmit_pkts()
556 txe->last_id = tx_last; in eth_igb_xmit_pkts()
587 txe->last_id = tx_last; in eth_igb_xmit_pkts()
1314 tx_first = sw_ring[txq->tx_tail].last_id; in igb_tx_done_cleanup()
1327 tx_last = sw_ring[tx_id].last_id; in igb_tx_done_cleanup()
1348 sw_ring[tx_id].last_id = tx_id; in igb_tx_done_cleanup()
1440 txe[i].last_id = i; in igb_reset_tx_queue()
|
| H A D | em_rxtx.c | 81 uint16_t last_id; /**< Index of last scattered descriptor. */ member
311 desc_to_clean_to = sw_ring[desc_to_clean_to].last_id; in em_xmit_cleanup()
535 txe->last_id = tx_last; in eth_em_xmit_pkts()
567 txe->last_id = tx_last; in eth_em_xmit_pkts()
1147 txq->sw_ring[i].last_id = i; in em_reset_tx_queue()
|
| /f-stack/dpdk/drivers/net/ice/ |
| H A D | ice_rxtx.h | 96 uint16_t last_id; member
|
| H A D | ice_rxtx.c | 903 txe[i].last_id = i; in ice_reset_tx_queue()
2402 desc_to_clean_to = sw_ring[desc_to_clean_to].last_id; in ice_xmit_cleanup()
2640 txe->last_id = tx_last; in ice_xmit_pkts()
2672 txe->last_id = tx_last; in ice_xmit_pkts()
2687 txe->last_id = tx_last; in ice_xmit_pkts()
2795 pkt_cnt += (swr_ring[tx_id].last_id == tx_id); in ice_tx_done_cleanup_full()
|
| H A D | ice_dcf_ethdev.c | 358 txe[i].last_id = i; in reset_tx_queue()
|
| /f-stack/dpdk/drivers/net/txgbe/ |
| H A D | txgbe_rxtx.h | 266 uint16_t last_id; /**< Index of last scattered descriptor. */ member
|
| H A D | txgbe_rxtx.c | 600 desc_to_clean_to = sw_ring[desc_to_clean_to].last_id; in txgbe_xmit_cleanup()
900 txe->last_id = tx_last; in txgbe_xmit_pkts()
936 txe->last_id = tx_last; in txgbe_xmit_pkts()
1983 pkt_cnt += (swr_ring[tx_id].last_id == tx_id); in txgbe_tx_done_cleanup_full()
2079 txe[i].last_id = i; in txgbe_reset_tx_queue()
|
| /f-stack/dpdk/drivers/net/iavf/ |
| H A D | iavf_rxtx.c | 223 txe[i].last_id = i; in reset_tx_queue()
1940 desc_to_clean_to = sw_ring[desc_to_clean_to].last_id; in iavf_xmit_cleanup()
2192 txe->last_id = tx_last; in iavf_xmit_pkts()
2216 txe->last_id = tx_last; in iavf_xmit_pkts()
2512 pkt_cnt += (swr_ring[tx_id].last_id == tx_id); in iavf_tx_done_cleanup_full()
|
| H A D | iavf_rxtx.h | 203 uint16_t last_id; member
|
| /f-stack/dpdk/drivers/net/i40e/ |
| H A D | i40e_rxtx.c | 346 desc_to_clean_to = sw_ring[desc_to_clean_to].last_id; in i40e_xmit_cleanup()
1171 txe->last_id = tx_last; in i40e_xmit_pkts()
1201 txe->last_id = tx_last; in i40e_xmit_pkts()
1219 txe->last_id = tx_last; in i40e_xmit_pkts()
2568 pkt_cnt += (swr_ring[tx_id].last_id == tx_id); in i40e_tx_done_cleanup_full()
2661 txe[i].last_id = i; in i40e_reset_tx_queue()
|
| H A D | i40e_rxtx.h | 129 uint16_t last_id; member
|
| /f-stack/dpdk/drivers/net/atlantic/ |
| H A D | atl_rxtx.c | 46 uint16_t last_id; member
|