/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/prometheus/prometheus/tsdb/ |
H A D | isolation.go | 182 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 D | isolation.go | 205 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 D | isolation.go | 205 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 D | isolation.go | 205 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 D | isolation.go | 205 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 D | ixv.c | 1044 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 D | ixgbe.c | 1595 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 D | bnxt_xdp.c | 32 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 D | bnxt_xdp.c | 32 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 D | bnxt_xdp.c | 32 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 D | qca_spi.c | 287 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 D | qca_debug.c | 79 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 D | qca_spi.c | 287 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 D | qca_debug.c | 79 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 D | qca_spi.c | 287 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 D | qca_debug.c | 79 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 D | tx_buffer.go | 78 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 D | tx_buffer.go | 78 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 D | tx_buffer.go | 57 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 D | tx_buffer.go | 57 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 D | tx_buffer.go | 57 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 D | tx_buffer.go | 57 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 D | tx_buffer.go | 57 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 D | i2c_master_top.v | 127 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 D | i2c_master_top.v | 127 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 ),
|