Home
last modified time | relevance | path

Searched refs:txr (Results 1 – 25 of 424) sorted by relevance

12345678910>>...17

/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/prometheus/prometheus/tsdb/
H A Disolation.go182 if txr.txIDCount == len(txr.txIDs) {
185 idx := copy(newRing[:], txr.txIDs[txr.txIDFirst:])
186 copy(newRing[idx:], txr.txIDs[:txr.txIDFirst])
187 txr.txIDs = newRing
188 txr.txIDFirst = 0
191 txr.txIDs[(txr.txIDFirst+txr.txIDCount)%len(txr.txIDs)] = appendID
192 txr.txIDCount++
200 txr.txIDFirst++
201 txr.txIDCount--
212 txr.txIDFirst %= len(txr.txIDs)
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/prometheus/prometheus/tsdb/
H A Disolation.go205 if txr.txIDCount == len(txr.txIDs) {
208 idx := copy(newRing[:], txr.txIDs[txr.txIDFirst:])
209 copy(newRing[idx:], txr.txIDs[:txr.txIDFirst])
210 txr.txIDs = newRing
211 txr.txIDFirst = 0
214 txr.txIDs[(txr.txIDFirst+txr.txIDCount)%len(txr.txIDs)] = appendID
215 txr.txIDCount++
223 txr.txIDFirst++
224 txr.txIDCount--
235 txr.txIDFirst %= len(txr.txIDs)
[all …]
/dports/net-mgmt/prometheus2/prometheus-2.30.3/tsdb/
H A Disolation.go205 if txr.txIDCount == len(txr.txIDs) {
208 idx := copy(newRing[:], txr.txIDs[txr.txIDFirst:])
209 copy(newRing[idx:], txr.txIDs[:txr.txIDFirst])
210 txr.txIDs = newRing
211 txr.txIDFirst = 0
214 txr.txIDs[(txr.txIDFirst+txr.txIDCount)%len(txr.txIDs)] = appendID
215 txr.txIDCount++
223 txr.txIDFirst++
224 txr.txIDCount--
235 txr.txIDFirst %= len(txr.txIDs)
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/prometheus/prometheus/tsdb/
H A Disolation.go205 if txr.txIDCount == len(txr.txIDs) {
208 idx := copy(newRing[:], txr.txIDs[txr.txIDFirst:])
209 copy(newRing[idx:], txr.txIDs[:txr.txIDFirst])
210 txr.txIDs = newRing
211 txr.txIDFirst = 0
214 txr.txIDs[(txr.txIDFirst+txr.txIDCount)%len(txr.txIDs)] = appendID
215 txr.txIDCount++
223 txr.txIDFirst++
224 txr.txIDCount--
235 txr.txIDFirst %= len(txr.txIDs)
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/prometheus/prometheus/tsdb/
H A Disolation.go205 if txr.txIDCount == len(txr.txIDs) {
208 idx := copy(newRing[:], txr.txIDs[txr.txIDFirst:])
209 copy(newRing[idx:], txr.txIDs[:txr.txIDFirst])
210 txr.txIDs = newRing
211 txr.txIDFirst = 0
214 txr.txIDs[(txr.txIDFirst+txr.txIDCount)%len(txr.txIDs)] = appendID
215 txr.txIDCount++
223 txr.txIDFirst++
224 txr.txIDCount--
235 txr.txIDFirst %= len(txr.txIDs)
[all …]
/dports/misc/rump/buildrump.sh-b914579/src/sys/dev/pci/ixgbe/
H A Dixv.c1044 struct tx_ring *txr = que->txr; in ixv_handle_que() local
1082 struct tx_ring *txr = que->txr; in ixv_msix_que() local
1130 if ((txr->bytes) && (txr->packets)) in ixv_msix_que()
1131 newitr = txr->bytes/txr->packets; in ixv_msix_que()
1522 txr->me, txr->tx_avail, txr->next_to_clean); in ixv_local_timer1()
2148 txr->me = i; in ixv_allocate_queues()
2151 snprintf(txr->mtx_name, sizeof(txr->mtx_name), "%s:tx(%d)", in ixv_allocate_queues()
2236 for (txr = adapter->tx_rings; txconf > 0; txr++, txconf--) in ixv_allocate_queues()
2340 ixgbe_dmamap_sync(txr->txdma.dma_tag, txr->txdma.dma_map, in ixv_setup_transmit_ring()
2774 ixgbe_dmamap_sync(txr->txdma.dma_tag, txr->txdma.dma_map, in ixv_txeof()
[all …]
H A Dixgbe.c1595 struct tx_ring *txr = que->txr; local
1708 struct tx_ring *txr = que->txr; local
1758 if ((txr->bytes) && (txr->packets))
1759 newitr = txr->bytes/txr->packets;
2287 txr->me, txr->tx_avail, txr->next_to_clean);
2573 txr);
3215 txr->me = i;
3442 ixgbe_dmamap_sync(txr->txdma.dma_tag, txr->txdma.dma_map,
3953 bus_dmamap_sync(txr->txdma.dma_tag, txr->txdma.dma_map,
3978 if (txr->tx_avail == txr->num_desc) {
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/ethernet/broadcom/bnxt/
H A Dbnxt_xdp.c32 prod = txr->tx_prod; in bnxt_xmit_bd()
33 tx_buf = &txr->tx_buf_ring[prod]; in bnxt_xmit_bd()
43 txr->tx_prod = prod; in bnxt_xmit_bd()
77 u16 tx_cons = txr->tx_cons; in bnxt_tx_int_xdp()
100 txr->tx_cons = tx_cons; in bnxt_tx_int_xdp()
115 struct bnxt_tx_ring_info *txr; in bnxt_rx_xdp() local
135 txr = rxr->bnapi->tx_ring; in bnxt_rx_xdp()
218 struct bnxt_tx_ring_info *txr; in bnxt_xdp_xmit() local
230 txr = &bp->tx_ring[ring]; in bnxt_xdp_xmit()
235 if (!txr || !bnxt_tx_avail(bp, txr) || in bnxt_xdp_xmit()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/ethernet/broadcom/bnxt/
H A Dbnxt_xdp.c32 prod = txr->tx_prod; in bnxt_xmit_bd()
33 tx_buf = &txr->tx_buf_ring[prod]; in bnxt_xmit_bd()
43 txr->tx_prod = prod; in bnxt_xmit_bd()
77 u16 tx_cons = txr->tx_cons; in bnxt_tx_int_xdp()
100 txr->tx_cons = tx_cons; in bnxt_tx_int_xdp()
115 struct bnxt_tx_ring_info *txr; in bnxt_rx_xdp() local
135 txr = rxr->bnapi->tx_ring; in bnxt_rx_xdp()
218 struct bnxt_tx_ring_info *txr; in bnxt_xdp_xmit() local
230 txr = &bp->tx_ring[ring]; in bnxt_xdp_xmit()
235 if (!txr || !bnxt_tx_avail(bp, txr) || in bnxt_xdp_xmit()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/ethernet/broadcom/bnxt/
H A Dbnxt_xdp.c32 prod = txr->tx_prod; in bnxt_xmit_bd()
33 tx_buf = &txr->tx_buf_ring[prod]; in bnxt_xmit_bd()
43 txr->tx_prod = prod; in bnxt_xmit_bd()
77 u16 tx_cons = txr->tx_cons; in bnxt_tx_int_xdp()
100 txr->tx_cons = tx_cons; in bnxt_tx_int_xdp()
115 struct bnxt_tx_ring_info *txr; in bnxt_rx_xdp() local
135 txr = rxr->bnapi->tx_ring; in bnxt_rx_xdp()
218 struct bnxt_tx_ring_info *txr; in bnxt_xdp_xmit() local
230 txr = &bp->tx_ring[ring]; in bnxt_xdp_xmit()
235 if (!txr || !bnxt_tx_avail(bp, txr) || in bnxt_xdp_xmit()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/ethernet/qualcomm/
H A Dqca_spi.c287 if (qca->txr.skb[qca->txr.head] == NULL) in qcaspi_transmit()
300 while (qca->txr.skb[qca->txr.head]) { in qcaspi_transmit()
316 n_stats->tx_bytes += qca->txr.skb[qca->txr.head]->len; in qcaspi_transmit()
324 dev_kfree_skb(qca->txr.skb[qca->txr.head]); in qcaspi_transmit()
325 qca->txr.skb[qca->txr.head] = NULL; in qcaspi_transmit()
461 if (txr->skb[txr->tail]) in qcaspi_tx_ring_has_space()
577 (qca->txr.skb[qca->txr.head] == NULL) && in qcaspi_spi_thread()
585 qca->txr.skb[qca->txr.head]); in qcaspi_spi_thread()
730 if (qca->txr.skb[qca->txr.tail]) { in qcaspi_netdev_xmit()
770 qca->txr.skb[qca->txr.tail] = skb; in qcaspi_netdev_xmit()
[all …]
H A Dqca_debug.c79 if (qca->txr.skb[qca->txr.head] == NULL) in qcaspi_info_show()
81 else if (qca->txr.skb[qca->txr.tail]) in qcaspi_info_show()
89 qca->txr.size); in qcaspi_info_show()
255 ring->tx_pending = qca->txr.count; in qcaspi_get_ringparam()
272 qca->txr.count = max_t(u32, ring->tx_pending, TX_RING_MIN_LEN); in qcaspi_set_ringparam()
273 qca->txr.count = min_t(u16, qca->txr.count, TX_RING_MAX_LEN); in qcaspi_set_ringparam()
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/ethernet/qualcomm/
H A Dqca_spi.c287 if (qca->txr.skb[qca->txr.head] == NULL) in qcaspi_transmit()
300 while (qca->txr.skb[qca->txr.head]) { in qcaspi_transmit()
316 n_stats->tx_bytes += qca->txr.skb[qca->txr.head]->len; in qcaspi_transmit()
324 dev_kfree_skb(qca->txr.skb[qca->txr.head]); in qcaspi_transmit()
325 qca->txr.skb[qca->txr.head] = NULL; in qcaspi_transmit()
461 if (txr->skb[txr->tail]) in qcaspi_tx_ring_has_space()
577 (qca->txr.skb[qca->txr.head] == NULL) && in qcaspi_spi_thread()
585 qca->txr.skb[qca->txr.head]); in qcaspi_spi_thread()
730 if (qca->txr.skb[qca->txr.tail]) { in qcaspi_netdev_xmit()
770 qca->txr.skb[qca->txr.tail] = skb; in qcaspi_netdev_xmit()
[all …]
H A Dqca_debug.c79 if (qca->txr.skb[qca->txr.head] == NULL) in qcaspi_info_show()
81 else if (qca->txr.skb[qca->txr.tail]) in qcaspi_info_show()
89 qca->txr.size); in qcaspi_info_show()
255 ring->tx_pending = qca->txr.count; in qcaspi_get_ringparam()
272 qca->txr.count = max_t(u32, ring->tx_pending, TX_RING_MIN_LEN); in qcaspi_set_ringparam()
273 qca->txr.count = min_t(u16, qca->txr.count, TX_RING_MAX_LEN); in qcaspi_set_ringparam()
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/ethernet/qualcomm/
H A Dqca_spi.c287 if (qca->txr.skb[qca->txr.head] == NULL) in qcaspi_transmit()
300 while (qca->txr.skb[qca->txr.head]) { in qcaspi_transmit()
316 n_stats->tx_bytes += qca->txr.skb[qca->txr.head]->len; in qcaspi_transmit()
324 dev_kfree_skb(qca->txr.skb[qca->txr.head]); in qcaspi_transmit()
325 qca->txr.skb[qca->txr.head] = NULL; in qcaspi_transmit()
461 if (txr->skb[txr->tail]) in qcaspi_tx_ring_has_space()
577 (qca->txr.skb[qca->txr.head] == NULL) && in qcaspi_spi_thread()
585 qca->txr.skb[qca->txr.head]); in qcaspi_spi_thread()
730 if (qca->txr.skb[qca->txr.tail]) { in qcaspi_netdev_xmit()
770 qca->txr.skb[qca->txr.tail] = skb; in qcaspi_netdev_xmit()
[all …]
H A Dqca_debug.c79 if (qca->txr.skb[qca->txr.head] == NULL) in qcaspi_info_show()
81 else if (qca->txr.skb[qca->txr.tail]) in qcaspi_info_show()
89 qca->txr.size); in qcaspi_info_show()
255 ring->tx_pending = qca->txr.count; in qcaspi_get_ringparam()
272 qca->txr.count = max_t(u32, ring->tx_pending, TX_RING_MIN_LEN); in qcaspi_set_ringparam()
273 qca->txr.count = min_t(u16, qca->txr.count, TX_RING_MAX_LEN); in qcaspi_set_ringparam()
/dports/sysutils/kubectl/kubernetes-1.22.2/vendor/go.etcd.io/etcd/server/v3/mvcc/backend/
H A Dtx_buffer.go78 func (txw *txWriteBuffer) writeback(txr *txReadBuffer) {
80 rb, ok := txr.buckets[k]
83 txr.buckets[k] = wb
94 txr.bufVersion++
104 func (txr *txReadBuffer) Range(bucket Bucket, key, endKey []byte, limit int64) ([][]byte, [][]byte)…
105 if b := txr.buckets[bucket.ID()]; b != nil {
111 func (txr *txReadBuffer) ForEach(bucket Bucket, visitor func(k, v []byte) error) error {
112 if b := txr.buckets[bucket.ID()]; b != nil {
119 func (txr *txReadBuffer) unsafeCopy() txReadBuffer {
122 buckets: make(map[BucketID]*bucketBuffer, len(txr.txBuffer.buckets)),
[all …]
/dports/www/minio-client/etcd-3.5.0/server/mvcc/backend/
H A Dtx_buffer.go78 func (txw *txWriteBuffer) writeback(txr *txReadBuffer) {
80 rb, ok := txr.buckets[k]
83 txr.buckets[k] = wb
94 txr.bufVersion++
104 func (txr *txReadBuffer) Range(bucket Bucket, key, endKey []byte, limit int64) ([][]byte, [][]byte)…
105 if b := txr.buckets[bucket.ID()]; b != nil {
111 func (txr *txReadBuffer) ForEach(bucket Bucket, visitor func(k, v []byte) error) error {
112 if b := txr.buckets[bucket.ID()]; b != nil {
119 func (txr *txReadBuffer) unsafeCopy() txReadBuffer {
122 buckets: make(map[BucketID]*bucketBuffer, len(txr.txBuffer.buckets)),
[all …]
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/mvcc/backend/
H A Dtx_buffer.go57 func (txw *txWriteBuffer) writeback(txr *txReadBuffer) {
59 rb, ok := txr.buckets[k]
62 txr.buckets[k] = wb
77 func (txr *txReadBuffer) Range(bucketName, key, endKey []byte, limit int64) ([][]byte, [][]byte) {
78 if b := txr.buckets[string(bucketName)]; b != nil {
84 func (txr *txReadBuffer) ForEach(bucketName []byte, visitor func(k, v []byte) error) error {
85 if b := txr.buckets[string(bucketName)]; b != nil {
92 func (txr *txReadBuffer) unsafeCopy() txReadBuffer {
95 buckets: make(map[string]*bucketBuffer, len(txr.txBuffer.buckets)),
98 for bucketName, bucket := range txr.txBuffer.buckets {
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/mvcc/backend/
H A Dtx_buffer.go57 func (txw *txWriteBuffer) writeback(txr *txReadBuffer) {
59 rb, ok := txr.buckets[k]
62 txr.buckets[k] = wb
77 func (txr *txReadBuffer) Range(bucketName, key, endKey []byte, limit int64) ([][]byte, [][]byte) {
78 if b := txr.buckets[string(bucketName)]; b != nil {
84 func (txr *txReadBuffer) ForEach(bucketName []byte, visitor func(k, v []byte) error) error {
85 if b := txr.buckets[string(bucketName)]; b != nil {
92 func (txr *txReadBuffer) unsafeCopy() txReadBuffer {
95 buckets: make(map[string]*bucketBuffer, len(txr.txBuffer.buckets)),
98 for bucketName, bucket := range txr.txBuffer.buckets {
/dports/www/gitea/gitea-1.16.5/vendor/go.etcd.io/etcd/server/v3/mvcc/backend/
H A Dtx_buffer.go57 func (txw *txWriteBuffer) writeback(txr *txReadBuffer) {
59 rb, ok := txr.buckets[k]
62 txr.buckets[k] = wb
77 func (txr *txReadBuffer) Range(bucketName, key, endKey []byte, limit int64) ([][]byte, [][]byte) {
78 if b := txr.buckets[string(bucketName)]; b != nil {
84 func (txr *txReadBuffer) ForEach(bucketName []byte, visitor func(k, v []byte) error) error {
85 if b := txr.buckets[string(bucketName)]; b != nil {
92 func (txr *txReadBuffer) unsafeCopy() txReadBuffer {
95 buckets: make(map[string]*bucketBuffer, len(txr.txBuffer.buckets)),
98 for bucketName, bucket := range txr.txBuffer.buckets {
/dports/devel/etcd34/etcd-3.4.18/mvcc/backend/
H A Dtx_buffer.go57 func (txw *txWriteBuffer) writeback(txr *txReadBuffer) {
59 rb, ok := txr.buckets[k]
62 txr.buckets[k] = wb
77 func (txr *txReadBuffer) Range(bucketName, key, endKey []byte, limit int64) ([][]byte, [][]byte) {
78 if b := txr.buckets[string(bucketName)]; b != nil {
84 func (txr *txReadBuffer) ForEach(bucketName []byte, visitor func(k, v []byte) error) error {
85 if b := txr.buckets[string(bucketName)]; b != nil {
92 func (txr *txReadBuffer) unsafeCopy() txReadBuffer {
95 buckets: make(map[string]*bucketBuffer, len(txr.txBuffer.buckets)),
98 for bucketName, bucket := range txr.txBuffer.buckets {
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/mvcc/backend/
H A Dtx_buffer.go57 func (txw *txWriteBuffer) writeback(txr *txReadBuffer) {
59 rb, ok := txr.buckets[k]
62 txr.buckets[k] = wb
77 func (txr *txReadBuffer) Range(bucketName, key, endKey []byte, limit int64) ([][]byte, [][]byte) {
78 if b := txr.buckets[string(bucketName)]; b != nil {
84 func (txr *txReadBuffer) ForEach(bucketName []byte, visitor func(k, v []byte) error) error {
85 if b := txr.buckets[string(bucketName)]; b != nil {
92 func (txr *txReadBuffer) unsafeCopy() txReadBuffer {
95 buckets: make(map[string]*bucketBuffer, len(txr.txBuffer.buckets)),
98 for bucketName, bucket := range txr.txBuffer.buckets {
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/fpga/usrp3/lib/wishbone/
H A Di2c_master_top.v127 reg [ 7:0] txr; // transmit register register
171 3'b101: wb_dat_o <= #1 txr;
183 txr <= #1 8'h0;
189 txr <= #1 8'h0;
197 3'b011 : txr <= #1 wb_dat_i;
246 .din ( txr ),
/dports/comms/uhd/uhd-90ce6062b6b5df2eddeee723777be85108e4e7c7/fpga/usrp2/opencores/i2c/rtl/verilog/
H A Di2c_master_top.v127 reg [ 7:0] txr; // transmit register register
171 3'b101: wb_dat_o <= #1 txr;
183 txr <= #1 8'h0;
189 txr <= #1 8'h0;
197 3'b011 : txr <= #1 wb_dat_i;
246 .din ( txr ),

12345678910>>...17