From c09b667d5764b9d4854e53ee68965f2897b8ade0 Mon Sep 17 00:00:00 2001 From: Cong Ding Date: Sat, 22 Aug 2015 12:07:53 -0500 Subject: [PATCH] *: fix go vet reported issues --- etcdserver/api/v3rpc/key.go | 1 - pkg/testutil/pauseable_handler.go | 2 -- raft/rafttest/network_test.go | 2 +- storage/key_index.go | 2 +- storage/key_index_test.go | 4 ++-- storage/kv_test.go | 2 +- 6 files changed, 5 insertions(+), 8 deletions(-) diff --git a/etcdserver/api/v3rpc/key.go b/etcdserver/api/v3rpc/key.go index 5376eb1ef..93891ade0 100644 --- a/etcdserver/api/v3rpc/key.go +++ b/etcdserver/api/v3rpc/key.go @@ -50,5 +50,4 @@ func (h *handler) Txn(ctx context.Context, r *pb.TxnRequest) (*pb.TxnResponse, e func (h *handler) Compact(ctx context.Context, r *pb.CompactionRequest) (*pb.CompactionResponse, error) { panic("not implemented") - return nil, nil } diff --git a/pkg/testutil/pauseable_handler.go b/pkg/testutil/pauseable_handler.go index 2850872c9..995828102 100644 --- a/pkg/testutil/pauseable_handler.go +++ b/pkg/testutil/pauseable_handler.go @@ -35,12 +35,10 @@ func (ph *PauseableHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) { hj, ok := w.(http.Hijacker) if !ok { panic("webserver doesn't support hijacking") - return } conn, _, err := hj.Hijack() if err != nil { panic(err.Error()) - return } conn.Close() } diff --git a/raft/rafttest/network_test.go b/raft/rafttest/network_test.go index 068a67084..6a2c88116 100644 --- a/raft/rafttest/network_test.go +++ b/raft/rafttest/network_test.go @@ -32,7 +32,7 @@ func TestNetworkDrop(t *testing.T) { drop := sent - received if drop > int((droprate+0.1)*float64(sent)) || drop < int((droprate-0.1)*float64(sent)) { - t.Errorf("drop = %d, want around %d", drop, droprate*float64(sent)) + t.Errorf("drop = %d, want around %.2f", drop, droprate*float64(sent)) } } diff --git a/storage/key_index.go b/storage/key_index.go index 1d83e91eb..180b607c0 100644 --- a/storage/key_index.go +++ b/storage/key_index.go @@ -130,7 +130,7 @@ func (ki *keyIndex) get(atRev int64) (modified, created revision, ver int64, err // If a generation becomes empty during compaction, it will be removed. func (ki *keyIndex) compact(atRev int64, available map[revision]struct{}) { if ki.isEmpty() { - log.Panic("store.keyindex: unexpected compact on empty keyIndex %s", string(ki.key)) + log.Panicf("store.keyindex: unexpected compact on empty keyIndex %s", string(ki.key)) } // walk until reaching the first revision that has an revision smaller or equal to diff --git a/storage/key_index_test.go b/storage/key_index_test.go index 568789ead..6f82b5c59 100644 --- a/storage/key_index_test.go +++ b/storage/key_index_test.go @@ -293,14 +293,14 @@ func TestKeyIndexCompact(t *testing.T) { // Jump Compaction for i, tt := range tests { - if (i%2 == 0 && i < 6) && (i%2 == 1 && i > 6) { + if (i%2 == 0 && i < 6) || (i%2 == 1 && i > 6) { am := make(map[revision]struct{}) ki.compact(tt.compact, am) if !reflect.DeepEqual(ki, tt.wki) { t.Errorf("#%d: ki = %+v, want %+v", i, ki, tt.wki) } if !reflect.DeepEqual(am, tt.wam) { - t.Errorf("#%d: am = %+v, want %+v", am, tt.wam) + t.Errorf("#%d: am = %+v, want %+v", i, am, tt.wam) } } } diff --git a/storage/kv_test.go b/storage/kv_test.go index b39934d2f..bb5173247 100644 --- a/storage/kv_test.go +++ b/storage/kv_test.go @@ -42,7 +42,7 @@ func TestWorkflow(t *testing.T) { // check existing keys kvs, rev, err := s.Range([]byte("bar"), []byte("bas"), 0, 0) if err != nil { - t.Errorf("#%d: range error (%v)", err) + t.Errorf("#%d: range error (%v)", i, err) } if len(kvs) != len(wkvs) { t.Fatalf("#%d: len(kvs) = %d, want %d", i, len(kvs), len(wkvs))