re
/
ledisdb
forked from mirror/ledisdb
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add more log for travis test failed

This commit is contained in:
siddontang 2014-11-06 15:25:26 +08:00
parent b564cfbb7e
commit f2d11e8ef7
2 changed files with 17 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
rpl/file_table.go
View File

@ -289,8 +289,14 @@ func (t *tableReader) openTable() error {
} }
if t.m == nil { if t.m == nil {
if t.f == nil {
return fmt.Errorf("invalid fd")
}
t.f.Seek(0, os.SEEK_SET)
if t.m, err = mmap.MapRegion(t.f, int(t.offsetLen), mmap.RDONLY, 0, t.offsetStartPos); err != nil { if t.m, err = mmap.MapRegion(t.f, int(t.offsetLen), mmap.RDONLY, 0, t.offsetStartPos); err != nil {
return fmt.Errorf("mmap %s error %s", t.name, err.Error()) return fmt.Errorf("mmap %s error %s, %d, %d", t.name, err.Error(), t.offsetLen, t.offsetStartPos)
} }
} }

20
rpl/file_table_test.go
View File

@ -70,16 +70,6 @@ func TestFileTable(t *testing.T) {
t.Fatal("must nil") t.Fatal("must nil")
} }
for i := 0; i < 10; i++ {
if err := w.GetLog(uint64(i+1), &ll); err != nil {
t.Fatal(err)
} else if len(ll.Data) != 4096 {
t.Fatal(len(ll.Data))
} else if ll.Data[0] != byte(i+1) {
t.Fatal(ll.Data[0])
}
}
var r *tableReader var r *tableReader
name := w.name name := w.name
@ -107,6 +97,16 @@ func TestFileTable(t *testing.T) {
defer r.Close() defer r.Close()
for i := 0; i < 10; i++ {
if err := r.GetLog(uint64(i+1), &ll); err != nil {
t.Fatal(err)
} else if len(ll.Data) != 4096 {
t.Fatal(len(ll.Data))
} else if ll.Data[0] != byte(i+1) {
t.Fatal(ll.Data[0])
}
}
if err := r.GetLog(12, &ll); err == nil { if err := r.GetLog(12, &ll); err == nil {
t.Fatal("must nil") t.Fatal("must nil")
} }