|
|
@ -77,8 +77,7 @@ func TestCheckHeadSizeLimit(t *testing.T) { |
|
|
|
assertGroupInfo(t, g.ReadGroupInfo(), 0, 0, 999000, 999000) |
|
|
|
|
|
|
|
// Write 1000 more bytes.
|
|
|
|
err := g.WriteLine(RandStr(999)) |
|
|
|
if err != nil { |
|
|
|
if err := g.WriteLine(RandStr(999)); err != nil { |
|
|
|
t.Fatal("Error appending to head", err) |
|
|
|
} |
|
|
|
g.Flush() |
|
|
@ -88,8 +87,7 @@ func TestCheckHeadSizeLimit(t *testing.T) { |
|
|
|
assertGroupInfo(t, g.ReadGroupInfo(), 0, 1, 1000000, 0) |
|
|
|
|
|
|
|
// Write 1000 more bytes.
|
|
|
|
err = g.WriteLine(RandStr(999)) |
|
|
|
if err != nil { |
|
|
|
if err := g.WriteLine(RandStr(999)); err != nil { |
|
|
|
t.Fatal("Error appending to head", err) |
|
|
|
} |
|
|
|
g.Flush() |
|
|
@ -112,7 +110,7 @@ func TestCheckHeadSizeLimit(t *testing.T) { |
|
|
|
assertGroupInfo(t, g.ReadGroupInfo(), 0, 2, 2000000, 0) |
|
|
|
|
|
|
|
// Write 1000 more bytes.
|
|
|
|
_, err = g.Head.Write([]byte(RandStr(999) + "\n")) |
|
|
|
_, err := g.Head.Write([]byte(RandStr(999) + "\n")) |
|
|
|
if err != nil { |
|
|
|
t.Fatal("Error appending to head", err) |
|
|
|
} |
|
|
|