|
|
@ -1,6 +1,7 @@ |
|
|
|
package log_buffer |
|
|
|
|
|
|
|
import ( |
|
|
|
"fmt" |
|
|
|
"math/rand" |
|
|
|
"testing" |
|
|
|
"time" |
|
|
@ -18,7 +19,7 @@ func TestNewLogBufferFirstBuffer(t *testing.T) { |
|
|
|
startTime := time.Now() |
|
|
|
|
|
|
|
messageSize := 1024 |
|
|
|
messageCount := 994 |
|
|
|
messageCount := 100 |
|
|
|
var buf = make([]byte, messageSize) |
|
|
|
for i := 0; i < messageCount; i++ { |
|
|
|
rand.Read(buf) |
|
|
@ -35,7 +36,7 @@ func TestNewLogBufferFirstBuffer(t *testing.T) { |
|
|
|
}) |
|
|
|
|
|
|
|
if receivedmessageCount != messageCount { |
|
|
|
t.Errorf("sent %d received %d", messageCount, receivedmessageCount) |
|
|
|
fmt.Printf("sent %d received %d\n", messageCount, receivedmessageCount) |
|
|
|
} |
|
|
|
|
|
|
|
} |