/dports/java/berkeley-db/je-6.2.31/test/standalone/ |
H A D | ReplicaReading.java | 107 private int txnOps = 10; field in ReplicaReading 259 if (key % txnOps == 0) { in doDeleteWork() 262 beginKey += txnOps; in doDeleteWork() 296 if (key % txnOps == 0) { in doPutWork() 309 endKey += txnOps; in doPutWork() 353 if (txnOps >= dbSize || dbSize % txnOps != 0) { in parseArgs() 445 deleteStart += txnOps; in shift() 446 deleteEnd += txnOps; in shift() 447 updateStart += txnOps; in shift() 448 updateEnd += txnOps; in shift() [all …]
|
/dports/sysutils/consul/consul-1.10.3/agent/consul/ |
H A D | leader_intentions.go | 463 var txnOps structs.TxnOps 469 txnOps = append(txnOps, &structs.TxnOp{Intention: deleteOp}) 477 txnOps = append(txnOps, &structs.TxnOp{Intention: updateOp}) 482 for batchStart := 0; batchStart < len(txnOps); { 486 for ; batchEnd < len(txnOps) && batchSize < maxIntentionTxnSize; batchEnd += 1 { 487 batchSize += txnOps[batchEnd].Intention.Intention.LegacyEstimateSize() 490 batchedOps = append(batchedOps, txnOps[batchStart:batchEnd])
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/hashicorp/consul/agent/consul/ |
H A D | leader_intentions.go | 463 var txnOps structs.TxnOps 469 txnOps = append(txnOps, &structs.TxnOp{Intention: deleteOp}) 477 txnOps = append(txnOps, &structs.TxnOp{Intention: updateOp}) 482 for batchStart := 0; batchStart < len(txnOps); { 486 for ; batchEnd < len(txnOps) && batchSize < maxIntentionTxnSize; batchEnd += 1 { 487 batchSize += txnOps[batchEnd].Intention.Intention.LegacyEstimateSize() 490 batchedOps = append(batchedOps, txnOps[batchStart:batchEnd])
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/hashicorp/consul/agent/consul/ |
H A D | leader_intentions.go | 463 var txnOps structs.TxnOps 469 txnOps = append(txnOps, &structs.TxnOp{Intention: deleteOp}) 477 txnOps = append(txnOps, &structs.TxnOp{Intention: updateOp}) 482 for batchStart := 0; batchStart < len(txnOps); { 486 for ; batchEnd < len(txnOps) && batchSize < maxIntentionTxnSize; batchEnd += 1 { 487 batchSize += txnOps[batchEnd].Intention.Intention.LegacyEstimateSize() 490 batchedOps = append(batchedOps, txnOps[batchStart:batchEnd])
|
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/functional/tester/ |
H A D | stresser_key.go | 269 func newStressTxn(cli *clientv3.Client, keyTxnSuffixRange, txnOps int) stressFunc { 274 return writeTxn(cli, keys, txnOps) 277 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { 279 ks := make(map[string]struct{}, txnOps) 280 for len(ks) != txnOps { 283 selected := make([]string, 0, txnOps) 290 for i := 1; i < txnOps; i++ { // nested txns 306 return err, int64(txnOps)
|
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/functional/tester/ |
H A D | stresser_key.go | 252 func newStressTxn(cli *clientv3.Client, keyTxnSuffixRange, txnOps int) stressFunc { 257 return writeTxn(cli, keys, txnOps) 260 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { 262 ks := make(map[string]struct{}, txnOps) 263 for len(ks) != txnOps { 266 selected := make([]string, 0, txnOps) 273 for i := 1; i < txnOps; i++ { // nested txns 289 return err, int64(txnOps)
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/functional/tester/ |
H A D | stresser_key.go | 251 func newStressTxn(cli *clientv3.Client, keyTxnSuffixRange, txnOps int) stressFunc { 256 return writeTxn(cli, keys, txnOps) 259 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { 261 ks := make(map[string]struct{}, txnOps) 262 for len(ks) != txnOps { 265 selected := make([]string, 0, txnOps) 272 for i := 1; i < txnOps; i++ { // nested txns 288 return err, int64(txnOps)
|
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/functional/tester/ |
H A D | stresser_key.go | 269 func newStressTxn(cli *clientv3.Client, keyTxnSuffixRange, txnOps int) stressFunc { 274 return writeTxn(cli, keys, txnOps) 277 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { 279 ks := make(map[string]struct{}, txnOps) 280 for len(ks) != txnOps { 283 selected := make([]string, 0, txnOps) 290 for i := 1; i < txnOps; i++ { // nested txns 306 return err, int64(txnOps)
|
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/functional/tester/ |
H A D | stresser_key.go | 251 func newStressTxn(cli *clientv3.Client, keyTxnSuffixRange, txnOps int) stressFunc { 256 return writeTxn(cli, keys, txnOps) 259 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { 261 ks := make(map[string]struct{}, txnOps) 262 for len(ks) != txnOps { 265 selected := make([]string, 0, txnOps) 272 for i := 1; i < txnOps; i++ { // nested txns 288 return err, int64(txnOps)
|
/dports/www/minio-client/etcd-3.5.0/tests/functional/tester/ |
H A D | stresser_key.go | 269 func newStressTxn(cli *clientv3.Client, keyTxnSuffixRange, txnOps int) stressFunc { 274 return writeTxn(cli, keys, txnOps) 277 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { 279 ks := make(map[string]struct{}, txnOps) 280 for len(ks) != txnOps { 283 selected := make([]string, 0, txnOps) 290 for i := 1; i < txnOps; i++ { // nested txns 306 return int64(txnOps), err
|
/dports/devel/etcd33/etcd-3.3.23/functional/tester/ |
H A D | stresser_key.go | 251 func newStressTxn(cli *clientv3.Client, keyTxnSuffixRange, txnOps int) stressFunc { 256 return writeTxn(cli, keys, txnOps) 259 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { 261 ks := make(map[string]struct{}, txnOps) 262 for len(ks) != txnOps { 265 selected := make([]string, 0, txnOps) 272 for i := 1; i < txnOps; i++ { // nested txns 288 return err, int64(txnOps)
|
/dports/devel/etcd34/etcd-3.4.18/functional/tester/ |
H A D | stresser_key.go | 269 func newStressTxn(cli *clientv3.Client, keyTxnSuffixRange, txnOps int) stressFunc { 274 return writeTxn(cli, keys, txnOps) 277 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { 279 ks := make(map[string]struct{}, txnOps) 280 for len(ks) != txnOps { 283 selected := make([]string, 0, txnOps) 290 for i := 1; i < txnOps; i++ { // nested txns 306 return err, int64(txnOps)
|
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/functional/tester/ |
H A D | stresser_key.go | 269 func newStressTxn(cli *clientv3.Client, keyTxnSuffixRange, txnOps int) stressFunc { 274 return writeTxn(cli, keys, txnOps) 277 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { 279 ks := make(map[string]struct{}, txnOps) 280 for len(ks) != txnOps { 283 selected := make([]string, 0, txnOps) 290 for i := 1; i < txnOps; i++ { // nested txns 306 return err, int64(txnOps)
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/consul/agent/consul/ |
H A D | leader_connect.go | 899 var txnOps structs.TxnOps 905 txnOps = append(txnOps, &structs.TxnOp{Intention: deleteOp}) 913 txnOps = append(txnOps, &structs.TxnOp{Intention: updateOp}) 918 for batchStart := 0; batchStart < len(txnOps); { 922 for ; batchEnd < len(txnOps) && batchSize < maxIntentionTxnSize; batchEnd += 1 { 923 batchSize += txnOps[batchEnd].Intention.Intention.EstimateSize() 926 batchedOps = append(batchedOps, txnOps[batchStart:batchEnd])
|
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/consul/agent/consul/ |
H A D | leader_connect.go | 906 var txnOps structs.TxnOps 912 txnOps = append(txnOps, &structs.TxnOp{Intention: deleteOp}) 920 txnOps = append(txnOps, &structs.TxnOp{Intention: updateOp}) 925 for batchStart := 0; batchStart < len(txnOps); { 929 for ; batchEnd < len(txnOps) && batchSize < maxIntentionTxnSize; batchEnd += 1 { 930 batchSize += txnOps[batchEnd].Intention.Intention.EstimateSize() 933 batchedOps = append(batchedOps, txnOps[batchStart:batchEnd])
|