@@ -27,15 +27,9 @@ package main
27
27
28
28
import (
29
29
"bytes"
30
- "code.google.com/p/go-uuid/uuid"
31
- "code.google.com/p/gogoprotobuf/proto"
32
30
"crypto/tls"
33
31
"flag"
34
32
"fmt"
35
- "github.com/bbangert/toml"
36
- "github.com/mozilla-services/heka/client"
37
- "github.com/mozilla-services/heka/message"
38
- "github.com/mozilla-services/heka/plugins/tcp"
39
33
"io"
40
34
"math"
41
35
"math/rand"
@@ -45,6 +39,13 @@ import (
45
39
"runtime/pprof"
46
40
"syscall"
47
41
"time"
42
+
43
+ "github.com/bbangert/toml"
44
+ "github.com/gogo/protobuf/proto"
45
+ "github.com/mozilla-services/heka/client"
46
+ "github.com/mozilla-services/heka/message"
47
+ "github.com/mozilla-services/heka/plugins/tcp"
48
+ "github.com/pborman/uuid"
48
49
)
49
50
50
51
type FloodTest struct {
@@ -272,7 +273,7 @@ func makeFixedMessage(encoder client.StreamEncoder, size uint64,
272
273
return ma
273
274
}
274
275
275
- func createSender (test FloodTest )(sender * client.NetworkSender , err error ) {
276
+ func createSender (test FloodTest ) (sender * client.NetworkSender , err error ) {
276
277
if test .UseTls {
277
278
var goTlsConfig * tls.Config
278
279
goTlsConfig , err = tcp .CreateGoTlsConfig (& test .Tls )
@@ -347,7 +348,7 @@ func main() {
347
348
message .SetMaxMessageSize (test .MaxMessageSize )
348
349
}
349
350
if test .ReconnectInterval < 1 {
350
- test .ReconnectInterval = 5
351
+ test .ReconnectInterval = 5
351
352
}
352
353
353
354
retryIntervalDuration := time .Duration (test .ReconnectInterval ) * time .Second
@@ -370,7 +371,6 @@ func main() {
370
371
}
371
372
}
372
373
373
-
374
374
unsignedEncoder := client .NewProtobufEncoder (nil )
375
375
signedEncoder := client .NewProtobufEncoder (& test .Signer )
376
376
oversizedEncoder := & OversizedEncoder {}
@@ -414,7 +414,6 @@ func main() {
414
414
test .SignedPercentage /= 100.0
415
415
test .OversizedPercentage /= 100.0
416
416
417
-
418
417
var buf []byte
419
418
for gotsigint := false ; ! gotsigint ; {
420
419
runtime .Gosched ()
0 commit comments