mirror of
https://github.com/Control-D-Inc/ctrld.git
synced 2026-08-10 13:20:33 +02:00
cmd/cli: correct log writer initial size
This commit is contained in:
@@ -16,7 +16,7 @@ import (
|
|||||||
|
|
||||||
const (
|
const (
|
||||||
logWriterSize = 1024 * 1024 * 5 // 5 MB
|
logWriterSize = 1024 * 1024 * 5 // 5 MB
|
||||||
logWriterInitialSize = 32 // 32 B
|
logWriterInitialSize = 32 * 1024 // 32 KB
|
||||||
logSentInterval = time.Minute
|
logSentInterval = time.Minute
|
||||||
logTruncatedMarker = "...\n"
|
logTruncatedMarker = "...\n"
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -7,7 +7,7 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
func Test_logWriter_Write(t *testing.T) {
|
func Test_logWriter_Write(t *testing.T) {
|
||||||
size := 64
|
size := 64 * 1024
|
||||||
lw := &logWriter{size: size}
|
lw := &logWriter{size: size}
|
||||||
lw.buf.Grow(lw.size)
|
lw.buf.Grow(lw.size)
|
||||||
data := strings.Repeat("A", size)
|
data := strings.Repeat("A", size)
|
||||||
@@ -22,8 +22,8 @@ func Test_logWriter_Write(t *testing.T) {
|
|||||||
t.Fatalf("unexpected new buf content: %v", lw.buf.String())
|
t.Fatalf("unexpected new buf content: %v", lw.buf.String())
|
||||||
}
|
}
|
||||||
|
|
||||||
bigData := strings.Repeat("B", 256)
|
bigData := strings.Repeat("B", 256*1024)
|
||||||
expected := halfData + strings.Repeat("B", 16)
|
expected := halfData + strings.Repeat("B", 16*1024)
|
||||||
lw.Write([]byte(bigData))
|
lw.Write([]byte(bigData))
|
||||||
if lw.buf.String() != expected {
|
if lw.buf.String() != expected {
|
||||||
t.Fatalf("unexpected big buf content: %v", lw.buf.String())
|
t.Fatalf("unexpected big buf content: %v", lw.buf.String())
|
||||||
@@ -31,7 +31,7 @@ func Test_logWriter_Write(t *testing.T) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func Test_logWriter_ConcurrentWrite(t *testing.T) {
|
func Test_logWriter_ConcurrentWrite(t *testing.T) {
|
||||||
size := 64
|
size := 64 * 1024
|
||||||
lw := &logWriter{size: size}
|
lw := &logWriter{size: size}
|
||||||
n := 10
|
n := 10
|
||||||
var wg sync.WaitGroup
|
var wg sync.WaitGroup
|
||||||
|
|||||||
Reference in New Issue
Block a user