etcd-io
/
dbtester
mirror of https://github.com/etcd-io/dbtester.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

control: add more logging, Zk get with prefix "/"

This commit is contained in:
Gyu-Ho Lee 2016-11-09 11:46:39 -08:00
parent 5ee7f269a6
commit b5f822798f
No known key found for this signature in database
GPG Key ID: 1DDD39C7EB70C24C
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
control/io.go
View File

@ -17,6 +17,8 @@ package control
import (
"errors"
"fmt"
clientv2 "github.com/coreos/etcd/client"
"github.com/coreos/etcd/clientv3"
consulapi "github.com/hashicorp/consul/api"
@ -84,14 +86,17 @@ func newGetZK(conn *zk.Conn) ReqHandler {
return func(ctx context.Context, req *request) error {
errt := ""
if !req.zkOp.staleRead {
_, err := conn.Sync(req.zkOp.key)
_, err := conn.Sync("/" + req.zkOp.key)
if err != nil {
errt += err.Error()
}
}
_, _, err := conn.Get(req.zkOp.key)
_, _, err := conn.Get("/" + req.zkOp.key)
if err != nil {
errt += ";" + err.Error()
if errt != "" {
errt += "; "
}
errt += fmt.Sprintf("%q while getting %q", err.Error(), "/"+req.zkOp.key)
}
if errt != "" {
return errors.New(errt)