Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

e2e: compact with latest rev in alarm test

Browse Source 
Fix https://github.com/coreos/etcd/issues/6677.
This commit is contained in:
Gyu-Ho Lee 2016-10-20 11:06:30 -07:00
parent a47797fdf1
commit 9bfbc12d7d
1 changed files with 22 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
e2e/ctl_v3_alarm_test.go
View File

@ -18,6 +18,10 @@ import (
"os"
"strings"
"testing"
"time"
"github.com/coreos/etcd/clientv3"
"golang.org/x/net/context"
)
func TestCtlV3Alarm(t *testing.T) {
@ -34,8 +38,7 @@ func alarmTest(cx ctlCtx) {
// write some chunks to fill up the database
buf := strings.Repeat("b", int(os.Getpagesize()))
var rev int64
for ; ; rev++ {
for {
if err := ctlV3Put(cx, "2nd_test", buf, ""); err != nil {
if !strings.Contains(err.Error(), "etcdserver: mvcc: database space exceeded") {
cx.t.Fatal(err)
@ -56,8 +59,24 @@ func alarmTest(cx ctlCtx) {
}
}
eps := cx.epc.grpcEndpoints()
// get latest revision to compact
cli, err := clientv3.New(clientv3.Config{
Endpoints: eps,
DialTimeout: 3 * time.Second,
})
if err != nil {
cx.t.Fatal(err)
}
defer cli.Close()
sresp, err := cli.Status(context.TODO(), eps[0])
if err != nil {
cx.t.Fatal(err)
}
// make some space
if err := ctlV3Compact(cx, rev, true); err != nil {
if err := ctlV3Compact(cx, sresp.Header.Revision, true); err != nil {
cx.t.Fatal(err)
}
if err := ctlV3Defrag(cx); err != nil {