vitalif
/
etcd
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merge pull request #6298 from sinsharat/master 

store: added missing test case scenerio for scan of de-queued entries
release-3.1
Xiang Li 2016-08-29 13:55:55 -07:00 committed by GitHub
parent 452dedf8ab 4f150b06e5
commit f4c30425c0
1 changed files with 25 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
store/event_test.go
View File

@ -14,7 +14,11 @@
package store
import "testing"
import (
"testing"
etcdErr "github.com/coreos/etcd/error"
)
// TestEventQueue tests a queue with capacity = 100
// Add 200 events into that queue, and test if the
@ -86,6 +90,26 @@ func TestScanHistory(t *testing.T) {
}
}
func TestEventIndexHistoryCleared(t *testing.T) {
eh := newEventHistory(5)
// Add
eh.addEvent(newEvent(Create, "/foo", 1, 1))
eh.addEvent(newEvent(Create, "/foo/bar", 2, 2))
eh.addEvent(newEvent(Create, "/foo/foo", 3, 3))
eh.addEvent(newEvent(Create, "/foo/bar/bar", 4, 4))
eh.addEvent(newEvent(Create, "/foo/foo/foo", 5, 5))
// Add a new event which will replace/de-queue the first entry
eh.addEvent(newEvent(Create, "/foo/bar/bar/bar", 6, 6))
// test for the event which has been replaced.
_, err := eh.scan("/foo", false, 1)
if err == nil || err.ErrorCode != etcdErr.EcodeEventIndexCleared {
t.Fatalf("scan error cleared index should return err with %d got (%v)", etcdErr.EcodeEventIndexCleared, err)
}
}
// TestFullEventQueue tests a queue with capacity = 10
// Add 1000 events into that queue, and test if scanning
// works still for previous events.