mirror of https://github.com/etcd-io/bbolt.git
test: rename runOperation to executeOperation
Signed-off-by: Benjamin Wang <wachao@vmware.com>pull/471/head
parent
b312285496
commit
ec3ff470f6
|
@ -266,7 +266,7 @@ func (w *worker) run() (historyRecords, error) {
|
||||||
}
|
}
|
||||||
|
|
||||||
op := w.pickOperation()
|
op := w.pickOperation()
|
||||||
rec, err := runOperation(op, w.db, w.bucket, w.keys, w.conf)
|
rec, err := executeOperation(op, w.db, w.bucket, w.keys, w.conf)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
readErr := fmt.Errorf("[%s: %s]: %w", w.name(), op, err)
|
readErr := fmt.Errorf("[%s: %s]: %w", w.name(), op, err)
|
||||||
w.t.Error(readErr)
|
w.t.Error(readErr)
|
||||||
|
@ -294,7 +294,7 @@ func (w *worker) pickOperation() OperationType {
|
||||||
panic("unexpected")
|
panic("unexpected")
|
||||||
}
|
}
|
||||||
|
|
||||||
func runOperation(op OperationType, db *btesting.DB, bucket []byte, keys []string, conf concurrentConfig) (historyRecord, error) {
|
func executeOperation(op OperationType, db *btesting.DB, bucket []byte, keys []string, conf concurrentConfig) (historyRecord, error) {
|
||||||
switch op {
|
switch op {
|
||||||
case Read:
|
case Read:
|
||||||
return executeRead(db, bucket, keys, conf.readInterval)
|
return executeRead(db, bucket, keys, conf.readInterval)
|
||||||
|
|
Loading…
Reference in New Issue