goos: linux goarch: amd64 pkg: github.com/nats-io/nats-server/v2/test cpu: Intel(R) Xeon(R) E-2388G CPU @ 3.20GHz Benchmark______Pub0b_Payload Benchmark______Pub0b_Payload-16 40730048 74.23 ns/op 148.18 MB/s Benchmark______Pub0b_Payload-16 47230070 71.65 ns/op 153.53 MB/s Benchmark______Pub0b_Payload-16 47542951 71.70 ns/op 153.41 MB/s Benchmark______Pub0b_Payload-16 47469732 73.30 ns/op 150.08 MB/s Benchmark______Pub0b_Payload-16 47393584 71.99 ns/op 152.80 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 49676721 72.21 ns/op 263.12 MB/s Benchmark______Pub8b_Payload-16 49469138 74.05 ns/op 256.60 MB/s Benchmark______Pub8b_Payload-16 47129328 73.42 ns/op 258.78 MB/s Benchmark______Pub8b_Payload-16 47023780 72.39 ns/op 262.48 MB/s Benchmark______Pub8b_Payload-16 46284600 73.30 ns/op 259.21 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44439742 76.86 ns/op 572.44 MB/s Benchmark_____Pub32b_Payload-16 44279868 77.04 ns/op 571.17 MB/s Benchmark_____Pub32b_Payload-16 44291239 76.84 ns/op 572.59 MB/s Benchmark_____Pub32b_Payload-16 44484505 76.75 ns/op 573.30 MB/s Benchmark_____Pub32b_Payload-16 42125343 78.67 ns/op 559.33 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39418257 88.90 ns/op 1586.14 MB/s Benchmark____Pub128B_Payload-16 39182462 86.40 ns/op 1631.89 MB/s Benchmark____Pub128B_Payload-16 39518572 92.41 ns/op 1525.80 MB/s Benchmark____Pub128B_Payload-16 39010381 86.52 ns/op 1629.61 MB/s Benchmark____Pub128B_Payload-16 39689464 86.63 ns/op 1627.63 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35916865 99.95 ns/op 2691.41 MB/s Benchmark____Pub256B_Payload-16 35690739 95.59 ns/op 2814.01 MB/s Benchmark____Pub256B_Payload-16 36859760 96.15 ns/op 2797.73 MB/s Benchmark____Pub256B_Payload-16 31694758 96.38 ns/op 2791.01 MB/s Benchmark____Pub256B_Payload-16 35872683 94.54 ns/op 2845.38 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23579103 134.9 ns/op 7692.18 MB/s Benchmark______Pub1K_Payload-16 25231113 149.9 ns/op 6926.39 MB/s Benchmark______Pub1K_Payload-16 25104018 143.0 ns/op 7257.47 MB/s Benchmark______Pub1K_Payload-16 24204961 145.2 ns/op 7149.88 MB/s Benchmark______Pub1K_Payload-16 24101976 137.7 ns/op 7538.87 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5664214 615.3 ns/op 6679.97 MB/s Benchmark______Pub4K_Payload-16 5605352 622.8 ns/op 6599.22 MB/s Benchmark______Pub4K_Payload-16 5638158 615.6 ns/op 6676.92 MB/s Benchmark______Pub4K_Payload-16 5787075 631.5 ns/op 6507.87 MB/s Benchmark______Pub4K_Payload-16 5566423 616.4 ns/op 6668.19 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2805922 1278 ns/op 6423.34 MB/s Benchmark______Pub8K_Payload-16 2761855 1283 ns/op 6393.69 MB/s Benchmark______Pub8K_Payload-16 2775253 1270 ns/op 6459.90 MB/s Benchmark______Pub8K_Payload-16 2863364 1275 ns/op 6435.28 MB/s Benchmark______Pub8K_Payload-16 2773618 1272 ns/op 6452.42 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 543048 5541 ns/op 5916.02 MB/s Benchmark_____Pub32K_Payload-16 572682 5496 ns/op 5964.77 MB/s Benchmark_____Pub32K_Payload-16 661590 5430 ns/op 6037.00 MB/s Benchmark_____Pub32K_Payload-16 521264 6980 ns/op 4696.77 MB/s Benchmark_____Pub32K_Payload-16 655294 5445 ns/op 6020.57 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31922065 98.73 ns/op 111.41 MB/s Benchmark__AuthPub0b_Payload-16 33322908 94.75 ns/op 116.10 MB/s Benchmark__AuthPub0b_Payload-16 32089688 94.74 ns/op 116.11 MB/s Benchmark__AuthPub0b_Payload-16 37904985 96.01 ns/op 114.57 MB/s Benchmark__AuthPub0b_Payload-16 35908543 94.78 ns/op 116.06 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15578760 227.4 ns/op Benchmark_____________PubSub-16 15660002 227.0 ns/op Benchmark_____________PubSub-16 15691146 227.4 ns/op Benchmark_____________PubSub-16 15506530 227.8 ns/op Benchmark_____________PubSub-16 15593557 227.3 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15512619 225.8 ns/op Benchmark_____PubSubTwoConns-16 15674416 226.0 ns/op Benchmark_____PubSubTwoConns-16 15671368 225.3 ns/op Benchmark_____PubSubTwoConns-16 15622255 224.9 ns/op Benchmark_____PubSubTwoConns-16 15574364 225.9 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40154->127.0.0.1:40435: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51998->127.0.0.1:45897: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:45780->127.0.0.1:43485: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:36952->127.0.0.1:39949: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49746->127.0.0.1:34729: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 Benchmark___PubSubAccsImport bench_test.go:58: Failed read of PONG: -ERR 'Authorization Violation' --- FAIL: Benchmark___PubSubAccsImport Benchmark_____PubTwoQueueSub Benchmark_____PubTwoQueueSub-16 14352471 246.5 ns/op Benchmark_____PubTwoQueueSub-16 14390552 246.6 ns/op Benchmark_____PubTwoQueueSub-16 14548352 246.8 ns/op Benchmark_____PubTwoQueueSub-16 14549374 247.0 ns/op Benchmark_____PubTwoQueueSub-16 14432228 247.3 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14383046 246.9 ns/op Benchmark____PubFourQueueSub-16 14325979 247.1 ns/op Benchmark____PubFourQueueSub-16 14444895 247.0 ns/op Benchmark____PubFourQueueSub-16 14398554 246.1 ns/op Benchmark____PubFourQueueSub-16 14281802 247.3 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14561053 246.8 ns/op Benchmark___PubEightQueueSub-16 14664600 246.5 ns/op Benchmark___PubEightQueueSub-16 14497489 246.7 ns/op Benchmark___PubEightQueueSub-16 14313949 246.6 ns/op Benchmark___PubEightQueueSub-16 14472217 246.8 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23324 155313 ns/op Benchmark_PubSub512kTwoConns-16 23052 156936 ns/op Benchmark_PubSub512kTwoConns-16 22549 164411 ns/op Benchmark_PubSub512kTwoConns-16 23132 156073 ns/op Benchmark_PubSub512kTwoConns-16 23206 154945 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15357649 229.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15363361 229.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15304489 229.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15373442 229.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 15074323 229.4 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15258132 229.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 14889730 229.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15222247 230.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15158041 230.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15371906 229.6 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 10997281 317.5 ns/op Benchmark____RoutedPubSub_0b-16 11424148 317.8 ns/op Benchmark____RoutedPubSub_0b-16 10921953 315.3 ns/op Benchmark____RoutedPubSub_0b-16 10918299 317.5 ns/op Benchmark____RoutedPubSub_0b-16 11676424 316.7 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6789536 541.4 ns/op Benchmark____RoutedPubSub_1K-16 6789007 537.8 ns/op Benchmark____RoutedPubSub_1K-16 6629653 542.3 ns/op Benchmark____RoutedPubSub_1K-16 6637674 541.4 ns/op Benchmark____RoutedPubSub_1K-16 6694645 531.3 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85954 43003 ns/op Benchmark__RoutedPubSub_100K-16 83157 46123 ns/op Benchmark__RoutedPubSub_100K-16 82390 43102 ns/op Benchmark__RoutedPubSub_100K-16 84231 42234 ns/op Benchmark__RoutedPubSub_100K-16 83810 43091 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11362498 313.2 ns/op Benchmark____Routed2QueueSub-16 9707978 324.5 ns/op Benchmark____Routed2QueueSub-16 9707730 323.9 ns/op Benchmark____Routed2QueueSub-16 9511996 326.8 ns/op Benchmark____Routed2QueueSub-16 9343791 321.5 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9498108 325.6 ns/op Benchmark____Routed4QueueSub-16 9741907 314.2 ns/op Benchmark____Routed4QueueSub-16 9770535 318.6 ns/op Benchmark____Routed4QueueSub-16 9662370 318.4 ns/op Benchmark____Routed4QueueSub-16 9661921 319.3 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9268789 332.6 ns/op Benchmark____Routed8QueueSub-16 9199735 326.8 ns/op Benchmark____Routed8QueueSub-16 9405150 329.2 ns/op Benchmark____Routed8QueueSub-16 9302101 329.2 ns/op Benchmark____Routed8QueueSub-16 11072899 319.4 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8878675 342.3 ns/op Benchmark___Routed16QueueSub-16 8785620 344.8 ns/op Benchmark___Routed16QueueSub-16 10581967 340.9 ns/op Benchmark___Routed16QueueSub-16 9087958 337.7 ns/op Benchmark___Routed16QueueSub-16 8947557 343.0 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6593420 549.6 ns/op Benchmark____________RouteCompressOff-16 6361377 557.4 ns/op Benchmark____________RouteCompressOff-16 6411260 554.3 ns/op Benchmark____________RouteCompressOff-16 6332605 554.5 ns/op Benchmark____________RouteCompressOff-16 6458557 549.3 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6454868 559.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6469983 552.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6412088 545.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6594367 546.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6405903 551.4 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6399524 547.4 ns/op Benchmark_________RouteCompressS2Fast-16 6628144 542.9 ns/op Benchmark_________RouteCompressS2Fast-16 6474259 557.5 ns/op Benchmark_________RouteCompressS2Fast-16 6264800 547.5 ns/op Benchmark_________RouteCompressS2Fast-16 6502903 549.5 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6523141 549.0 ns/op Benchmark_______RouteCompressS2Better-16 6299455 542.2 ns/op Benchmark_______RouteCompressS2Better-16 6400797 551.0 ns/op Benchmark_______RouteCompressS2Better-16 6541413 548.7 ns/op Benchmark_______RouteCompressS2Better-16 6432903 543.4 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6594288 542.2 ns/op Benchmark_________RouteCompressS2Best-16 6362559 548.0 ns/op Benchmark_________RouteCompressS2Best-16 6388762 541.7 ns/op Benchmark_________RouteCompressS2Best-16 6580794 547.6 ns/op Benchmark_________RouteCompressS2Best-16 6506106 549.4 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4653166 762.7 ns/op 326.47 MB/s Benchmark______FanOut_8x1x10-16 4685983 768.0 ns/op 324.20 MB/s Benchmark______FanOut_8x1x10-16 4669236 772.6 ns/op 322.28 MB/s Benchmark______FanOut_8x1x10-16 4695090 770.6 ns/op 323.13 MB/s Benchmark______FanOut_8x1x10-16 4691770 766.5 ns/op 324.84 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 558328 6097 ns/op 380.35 MB/s Benchmark_____FanOut_8x1x100-16 545959 6086 ns/op 381.03 MB/s Benchmark_____FanOut_8x1x100-16 569038 6092 ns/op 380.64 MB/s Benchmark_____FanOut_8x1x100-16 533268 6089 ns/op 380.86 MB/s Benchmark_____FanOut_8x1x100-16 561878 6046 ns/op 383.59 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48354 74347 ns/op 309.62 MB/s Benchmark____FanOut_8x10x100-16 46981 74453 ns/op 309.17 MB/s Benchmark____FanOut_8x10x100-16 48387 75627 ns/op 304.37 MB/s Benchmark____FanOut_8x10x100-16 47302 74558 ns/op 308.74 MB/s Benchmark____FanOut_8x10x100-16 48024 75161 ns/op 306.26 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5976 593757 ns/op 404.24 MB/s Benchmark___FanOut_8x10x1000-16 6027 596419 ns/op 402.43 MB/s Benchmark___FanOut_8x10x1000-16 5806 594583 ns/op 403.68 MB/s Benchmark___FanOut_8x10x1000-16 5733 596431 ns/op 402.43 MB/s Benchmark___FanOut_8x10x1000-16 5780 595209 ns/op 403.25 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5013 705125 ns/op 326.21 MB/s Benchmark___FanOut_8x100x100-16 5006 710446 ns/op 323.77 MB/s Benchmark___FanOut_8x100x100-16 4946 706310 ns/op 325.66 MB/s Benchmark___FanOut_8x100x100-16 5056 707348 ns/op 325.19 MB/s Benchmark___FanOut_8x100x100-16 5067 704917 ns/op 326.31 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 582 6106029 ns/op 393.06 MB/s Benchmark__FanOut_8x100x1000-16 582 6274938 ns/op 382.48 MB/s Benchmark__FanOut_8x100x1000-16 588 6052299 ns/op 396.55 MB/s Benchmark__FanOut_8x100x1000-16 582 6127460 ns/op 391.68 MB/s Benchmark__FanOut_8x100x1000-16 579 6147042 ns/op 390.43 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 544 6709405 ns/op 372.61 MB/s Benchmark__FanOut_8x10x10000-16 534 6717352 ns/op 372.17 MB/s Benchmark__FanOut_8x10x10000-16 535 6661078 ns/op 375.32 MB/s Benchmark__FanOut_8x10x10000-16 530 6730596 ns/op 371.44 MB/s Benchmark__FanOut_8x10x10000-16 544 6782942 ns/op 368.57 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 945 3768493 ns/op 305.17 MB/s Benchmark___FanOut_8x500x100-16 938 3747645 ns/op 306.86 MB/s Benchmark___FanOut_8x500x100-16 948 3752451 ns/op 306.47 MB/s Benchmark___FanOut_8x500x100-16 957 3749910 ns/op 306.68 MB/s Benchmark___FanOut_8x500x100-16 957 3754259 ns/op 306.32 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 367513 9460 ns/op 1547.69 MB/s Benchmark___FanOut_128x1x100-16 364189 9404 ns/op 1556.83 MB/s Benchmark___FanOut_128x1x100-16 353707 9517 ns/op 1538.43 MB/s Benchmark___FanOut_128x1x100-16 366111 9428 ns/op 1552.86 MB/s Benchmark___FanOut_128x1x100-16 359385 9460 ns/op 1547.69 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32632 110864 ns/op 1309.19 MB/s Benchmark__FanOut_128x10x100-16 32424 110258 ns/op 1316.38 MB/s Benchmark__FanOut_128x10x100-16 32685 110172 ns/op 1317.40 MB/s Benchmark__FanOut_128x10x100-16 32451 110602 ns/op 1312.29 MB/s Benchmark__FanOut_128x10x100-16 32748 110596 ns/op 1312.36 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3862 860947 ns/op 1695.97 MB/s Benchmark_FanOut_128x10x1000-16 4029 867195 ns/op 1683.75 MB/s Benchmark_FanOut_128x10x1000-16 4176 872208 ns/op 1674.07 MB/s Benchmark_FanOut_128x10x1000-16 4107 865136 ns/op 1687.76 MB/s Benchmark_FanOut_128x10x1000-16 4144 879504 ns/op 1660.19 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3600 1002917 ns/op 1445.92 MB/s Benchmark_FanOut_128x100x100-16 3591 1006698 ns/op 1440.49 MB/s Benchmark_FanOut_128x100x100-16 3525 1004728 ns/op 1443.32 MB/s Benchmark_FanOut_128x100x100-16 3490 1005280 ns/op 1442.52 MB/s Benchmark_FanOut_128x100x100-16 3502 1004247 ns/op 1444.01 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 392 9134838 ns/op 1598.29 MB/s BenchmarkFanOut_128x100x1000-16 388 9204649 ns/op 1586.17 MB/s BenchmarkFanOut_128x100x1000-16 388 9379658 ns/op 1556.57 MB/s BenchmarkFanOut_128x100x1000-16 391 9146416 ns/op 1596.27 MB/s BenchmarkFanOut_128x100x1000-16 393 9202922 ns/op 1586.47 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 379 9549821 ns/op 1539.31 MB/s BenchmarkFanOut_128x10x10000-16 379 9569743 ns/op 1536.11 MB/s BenchmarkFanOut_128x10x10000-16 375 9536705 ns/op 1541.43 MB/s BenchmarkFanOut_128x10x10000-16 373 9569560 ns/op 1536.14 MB/s BenchmarkFanOut_128x10x10000-16 372 9589625 ns/op 1532.92 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 679 5224818 ns/op 1387.64 MB/s BenchmarkFanOut__128x500x100-16 668 5259475 ns/op 1378.49 MB/s BenchmarkFanOut__128x500x100-16 684 5234173 ns/op 1385.15 MB/s BenchmarkFanOut__128x500x100-16 668 5264994 ns/op 1377.05 MB/s BenchmarkFanOut__128x500x100-16 676 5252097 ns/op 1380.43 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1959 1842423 ns/op 2871.50 MB/s Benchmark_FanOut_512x100x100-16 1915 1841882 ns/op 2872.35 MB/s Benchmark_FanOut_512x100x100-16 1953 1841711 ns/op 2872.61 MB/s Benchmark_FanOut_512x100x100-16 1917 1840479 ns/op 2874.54 MB/s Benchmark_FanOut_512x100x100-16 1956 1823954 ns/op 2900.58 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 216 16583410 ns/op 3196.00 MB/s Benchmark__FanOut_512x100x1k-16 217 16457034 ns/op 3220.54 MB/s Benchmark__FanOut_512x100x1k-16 216 16495829 ns/op 3212.97 MB/s Benchmark__FanOut_512x100x1k-16 218 16767069 ns/op 3160.99 MB/s Benchmark__FanOut_512x100x1k-16 213 16653723 ns/op 3182.50 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3162 1138969 ns/op 9158.32 MB/s Benchmark____FanOut_1kx10x1k-16 2995 1143490 ns/op 9122.11 MB/s Benchmark____FanOut_1kx10x1k-16 2658 1138944 ns/op 9158.52 MB/s Benchmark____FanOut_1kx10x1k-16 3200 1145275 ns/op 9107.89 MB/s Benchmark____FanOut_1kx10x1k-16 2908 1150336 ns/op 9067.82 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2768 1259348 ns/op 8274.95 MB/s Benchmark__FanOut_1kx100x100-16 2812 1253136 ns/op 8315.97 MB/s Benchmark__FanOut_1kx100x100-16 2841 1255085 ns/op 8303.06 MB/s Benchmark__FanOut_1kx100x100-16 2836 1251447 ns/op 8327.19 MB/s Benchmark__FanOut_1kx100x100-16 2767 1255061 ns/op 8303.21 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4403686 767.1 ns/op 324.62 MB/s Benchmark_____RFanOut_8x1x10-16 4554892 791.5 ns/op 314.60 MB/s Benchmark_____RFanOut_8x1x10-16 4481336 795.5 ns/op 312.99 MB/s Benchmark_____RFanOut_8x1x10-16 4467694 769.3 ns/op 323.68 MB/s Benchmark_____RFanOut_8x1x10-16 4249954 801.9 ns/op 310.51 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 533959 6365 ns/op 364.34 MB/s Benchmark____RFanOut_8x1x100-16 525753 6328 ns/op 366.49 MB/s Benchmark____RFanOut_8x1x100-16 521667 6050 ns/op 383.27 MB/s Benchmark____RFanOut_8x1x100-16 523765 6136 ns/op 377.93 MB/s Benchmark____RFanOut_8x1x100-16 521588 6304 ns/op 367.86 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48045 74863 ns/op 307.48 MB/s Benchmark___RFanOut_8x10x100-16 48408 74786 ns/op 307.80 MB/s Benchmark___RFanOut_8x10x100-16 48097 74703 ns/op 308.14 MB/s Benchmark___RFanOut_8x10x100-16 48090 74960 ns/op 307.08 MB/s Benchmark___RFanOut_8x10x100-16 48098 74896 ns/op 307.35 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5917 604689 ns/op 396.93 MB/s Benchmark__RFanOut_8x10x1000-16 5904 597870 ns/op 401.46 MB/s Benchmark__RFanOut_8x10x1000-16 5976 602517 ns/op 398.36 MB/s Benchmark__RFanOut_8x10x1000-16 5874 596321 ns/op 402.50 MB/s Benchmark__RFanOut_8x10x1000-16 5889 602483 ns/op 398.38 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5007 710234 ns/op 323.86 MB/s Benchmark__RFanOut_8x100x100-16 4945 708762 ns/op 324.54 MB/s Benchmark__RFanOut_8x100x100-16 5038 708780 ns/op 324.53 MB/s Benchmark__RFanOut_8x100x100-16 4914 710999 ns/op 323.52 MB/s Benchmark__RFanOut_8x100x100-16 4927 711652 ns/op 323.22 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 579 6222116 ns/op 385.72 MB/s Benchmark_RFanOut_8x100x1000-16 582 6193358 ns/op 387.51 MB/s Benchmark_RFanOut_8x100x1000-16 571 6122223 ns/op 392.02 MB/s Benchmark_RFanOut_8x100x1000-16 583 6125859 ns/op 391.78 MB/s Benchmark_RFanOut_8x100x1000-16 571 6159181 ns/op 389.67 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 532 6759395 ns/op 369.86 MB/s Benchmark_RFanOut_8x10x10000-16 534 6695414 ns/op 373.39 MB/s Benchmark_RFanOut_8x10x10000-16 524 6724150 ns/op 371.80 MB/s Benchmark_RFanOut_8x10x10000-16 536 6716076 ns/op 372.24 MB/s Benchmark_RFanOut_8x10x10000-16 530 6691075 ns/op 373.63 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2940 1170282 ns/op 8913.27 MB/s Benchmark_RFanOut_1kx10x1000-16 3201 1153865 ns/op 9040.08 MB/s Benchmark_RFanOut_1kx10x1000-16 3097 1147967 ns/op 9086.53 MB/s Benchmark_RFanOut_1kx10x1000-16 3055 1149099 ns/op 9077.58 MB/s Benchmark_RFanOut_1kx10x1000-16 3138 1135854 ns/op 9183.43 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6995996 503.5 ns/op 4126.94 MB/s Benchmark_____FanIn_1kx100x1-16 6945670 503.3 ns/op 4128.88 MB/s Benchmark_____FanIn_1kx100x1-16 7003674 501.1 ns/op 4146.80 MB/s Benchmark_____FanIn_1kx100x1-16 6968800 503.7 ns/op 4125.15 MB/s Benchmark_____FanIn_1kx100x1-16 6967908 502.5 ns/op 4135.69 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2661939 1351 ns/op 6085.14 MB/s Benchmark_____FanIn_4kx100x1-16 2569096 1329 ns/op 6187.17 MB/s Benchmark_____FanIn_4kx100x1-16 2605204 1379 ns/op 5961.13 MB/s Benchmark_____FanIn_4kx100x1-16 2563339 1347 ns/op 6106.10 MB/s Benchmark_____FanIn_4kx100x1-16 2672455 1361 ns/op 6039.06 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1699069 2074 ns/op 7915.98 MB/s Benchmark_____FanIn_8kx100x1-16 1707888 2103 ns/op 7805.93 MB/s Benchmark_____FanIn_8kx100x1-16 1727490 2119 ns/op 7745.40 MB/s Benchmark_____FanIn_8kx100x1-16 1688882 2129 ns/op 7709.01 MB/s Benchmark_____FanIn_8kx100x1-16 1691218 2106 ns/op 7792.25 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 877064 4119 ns/op 7962.32 MB/s Benchmark____FanIn_16kx100x1-16 872743 4132 ns/op 7938.16 MB/s Benchmark____FanIn_16kx100x1-16 869071 4132 ns/op 7938.81 MB/s Benchmark____FanIn_16kx100x1-16 863870 4147 ns/op 7910.28 MB/s Benchmark____FanIn_16kx100x1-16 860931 4157 ns/op 7889.76 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 168148 19942 ns/op 6574.34 MB/s Benchmark____FanIn_64kx100x1-16 161784 19787 ns/op 6625.62 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7137213981 vs 11452109100 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60242->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 172467 20035 ns/op 6543.90 MB/s Benchmark____FanIn_64kx100x1-16 178688 20066 ns/op 6533.71 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 959578800 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49542->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 330477890 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51792->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51114->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 459732630 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53408->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53362->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 886168400 vs 11522811000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56198->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55876->127.0.0.1:5222: write: connection reset by peer bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 555428330 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39046->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5620777 641.1 ns/op 443.00 MB/s Benchmark___BumpPubCount_1x3-16 5579290 637.4 ns/op 445.55 MB/s Benchmark___BumpPubCount_1x3-16 5587672 637.9 ns/op 445.20 MB/s Benchmark___BumpPubCount_1x3-16 5555018 640.1 ns/op 443.68 MB/s Benchmark___BumpPubCount_1x3-16 5560155 639.2 ns/op 444.28 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5356806 671.5 ns/op 422.96 MB/s Benchmark___BumpPubCount_2x3-16 5390715 666.2 ns/op 426.27 MB/s Benchmark___BumpPubCount_2x3-16 5353383 666.8 ns/op 425.93 MB/s Benchmark___BumpPubCount_2x3-16 5346589 668.8 ns/op 424.67 MB/s Benchmark___BumpPubCount_2x3-16 5305236 667.4 ns/op 425.55 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5462559 641.8 ns/op 442.47 MB/s Benchmark___BumpPubCount_5x3-16 5227236 640.9 ns/op 443.10 MB/s Benchmark___BumpPubCount_5x3-16 5613042 638.9 ns/op 444.54 MB/s Benchmark___BumpPubCount_5x3-16 5296540 637.3 ns/op 445.60 MB/s Benchmark___BumpPubCount_5x3-16 5626113 639.0 ns/op 444.41 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5578119 640.8 ns/op 443.20 MB/s Benchmark__BumpPubCount_10x3-16 5605405 647.5 ns/op 438.63 MB/s Benchmark__BumpPubCount_10x3-16 5604469 642.7 ns/op 441.88 MB/s Benchmark__BumpPubCount_10x3-16 5585259 641.8 ns/op 442.48 MB/s Benchmark__BumpPubCount_10x3-16 5559140 641.6 ns/op 442.63 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11930494 288.5 ns/op 3604.69 MB/s Benchmark____GWs_Opt_1kx01x0-16 11876344 272.3 ns/op 3818.85 MB/s Benchmark____GWs_Opt_1kx01x0-16 11982685 275.8 ns/op 3771.37 MB/s Benchmark____GWs_Opt_1kx01x0-16 12478760 278.1 ns/op 3740.14 MB/s Benchmark____GWs_Opt_1kx01x0-16 12289665 274.0 ns/op 3795.83 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10508174 335.2 ns/op 6157.55 MB/s Benchmark____GWs_Opt_2kx01x0-16 9186564 341.0 ns/op 6052.08 MB/s Benchmark____GWs_Opt_2kx01x0-16 10803048 345.7 ns/op 5971.24 MB/s Benchmark____GWs_Opt_2kx01x0-16 10274874 323.2 ns/op 6386.41 MB/s Benchmark____GWs_Opt_2kx01x0-16 10447825 333.8 ns/op 6182.78 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5211644 611.0 ns/op 6729.87 MB/s Benchmark____GWs_Opt_4kx01x0-16 5582757 609.0 ns/op 6752.28 MB/s Benchmark____GWs_Opt_4kx01x0-16 5687257 628.7 ns/op 6540.56 MB/s Benchmark____GWs_Opt_4kx01x0-16 5889130 617.7 ns/op 6657.09 MB/s Benchmark____GWs_Opt_4kx01x0-16 5935256 702.8 ns/op 5851.27 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30481358 111.5 ns/op 9323.86 MB/s Benchmark____GWs_Opt_1kx10x0-16 32183554 112.3 ns/op 9262.91 MB/s Benchmark____GWs_Opt_1kx10x0-16 32568960 124.5 ns/op 8354.43 MB/s Benchmark____GWs_Opt_1kx10x0-16 31854225 112.8 ns/op 9223.33 MB/s Benchmark____GWs_Opt_1kx10x0-16 23138299 192.1 ns/op 5413.46 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 25040652 144.7 ns/op 14264.97 MB/s Benchmark____GWs_Opt_2kx10x0-16 25218838 146.8 ns/op 14055.64 MB/s Benchmark____GWs_Opt_2kx10x0-16 24368506 147.5 ns/op 13995.40 MB/s Benchmark____GWs_Opt_2kx10x0-16 24314316 147.0 ns/op 14036.88 MB/s Benchmark____GWs_Opt_2kx10x0-16 22742983 145.8 ns/op 14153.60 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11352895 341.6 ns/op 12039.13 MB/s Benchmark____GWs_Opt_4kx10x0-16 12750358 306.1 ns/op 13435.35 MB/s Benchmark____GWs_Opt_4kx10x0-16 12112016 290.1 ns/op 14172.84 MB/s Benchmark____GWs_Opt_4kx10x0-16 12577039 285.8 ns/op 14388.85 MB/s Benchmark____GWs_Opt_4kx10x0-16 10532434 320.8 ns/op 12817.44 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6499107 538.1 ns/op 5807.77 MB/s Benchmark____GWs_Opt_1kx01x1-16 6651650 565.8 ns/op 5523.51 MB/s Benchmark____GWs_Opt_1kx01x1-16 6440520 546.4 ns/op 5719.77 MB/s Benchmark____GWs_Opt_1kx01x1-16 6761025 546.4 ns/op 5719.17 MB/s Benchmark____GWs_Opt_1kx01x1-16 6576548 549.3 ns/op 5688.74 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4705364 767.6 ns/op 8072.95 MB/s Benchmark____GWs_Opt_2kx01x1-16 4853386 751.1 ns/op 8250.54 MB/s Benchmark____GWs_Opt_2kx01x1-16 4516424 746.5 ns/op 8301.54 MB/s Benchmark____GWs_Opt_2kx01x1-16 4766186 751.3 ns/op 8248.44 MB/s Benchmark____GWs_Opt_2kx01x1-16 4489821 756.6 ns/op 8190.57 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2685451 1370 ns/op 9008.47 MB/s Benchmark____GWs_Opt_4kx01x1-16 2615572 1401 ns/op 8807.51 MB/s Benchmark____GWs_Opt_4kx01x1-16 2608759 1362 ns/op 9061.07 MB/s Benchmark____GWs_Opt_4kx01x1-16 2663049 2333 ns/op 5289.35 MB/s Benchmark____GWs_Opt_4kx01x1-16 2640211 1578 ns/op 7818.25 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6614272 552.5 ns/op 5656.57 MB/s Benchmark____GWs_Opt_1kx10x1-16 6150801 543.6 ns/op 5749.00 MB/s Benchmark____GWs_Opt_1kx10x1-16 6548610 542.5 ns/op 5760.22 MB/s Benchmark____GWs_Opt_1kx10x1-16 6449860 554.6 ns/op 5635.00 MB/s Benchmark____GWs_Opt_1kx10x1-16 6269820 556.8 ns/op 5611.99 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4233656 851.2 ns/op 7280.65 MB/s Benchmark____GWs_Opt_2kx10x1-16 4129910 837.9 ns/op 7395.87 MB/s Benchmark____GWs_Opt_2kx10x1-16 4222815 915.9 ns/op 6765.67 MB/s Benchmark____GWs_Opt_2kx10x1-16 4390716 845.8 ns/op 7327.05 MB/s Benchmark____GWs_Opt_2kx10x1-16 4068099 841.3 ns/op 7366.36 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2116612 1511 ns/op 8167.96 MB/s Benchmark____GWs_Opt_4kx10x1-16 2344959 1515 ns/op 8147.29 MB/s Benchmark____GWs_Opt_4kx10x1-16 2330829 1534 ns/op 8046.45 MB/s Benchmark____GWs_Opt_4kx10x1-16 2324754 1529 ns/op 8073.80 MB/s Benchmark____GWs_Opt_4kx10x1-16 2257393 1536 ns/op 8033.85 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12296808 291.8 ns/op 3564.14 MB/s Benchmark____GWs_Int_1kx01x0-16 11804746 289.2 ns/op 3596.23 MB/s Benchmark____GWs_Int_1kx01x0-16 12625035 276.2 ns/op 3764.79 MB/s Benchmark____GWs_Int_1kx01x0-16 11885944 274.5 ns/op 3788.27 MB/s Benchmark____GWs_Int_1kx01x0-16 12386316 279.7 ns/op 3717.90 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10333640 346.2 ns/op 5961.82 MB/s Benchmark____GWs_Int_2kx01x0-16 9324105 361.2 ns/op 5713.86 MB/s Benchmark____GWs_Int_2kx01x0-16 9747337 369.7 ns/op 5582.24 MB/s Benchmark____GWs_Int_2kx01x0-16 10250158 340.0 ns/op 6070.38 MB/s Benchmark____GWs_Int_2kx01x0-16 9905816 363.5 ns/op 5677.37 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5882439 712.2 ns/op 5773.45 MB/s Benchmark____GWs_Int_4kx01x0-16 5723139 619.9 ns/op 6633.23 MB/s Benchmark____GWs_Int_4kx01x0-16 5658691 627.0 ns/op 6558.39 MB/s Benchmark____GWs_Int_4kx01x0-16 5456829 642.7 ns/op 6398.49 MB/s Benchmark____GWs_Int_4kx01x0-16 5788536 621.5 ns/op 6616.33 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32044138 112.6 ns/op 9234.96 MB/s Benchmark____GWs_Int_1kx10x0-16 27721857 115.1 ns/op 9036.44 MB/s Benchmark____GWs_Int_1kx10x0-16 31292301 109.7 ns/op 9479.42 MB/s Benchmark____GWs_Int_1kx10x0-16 31746020 108.4 ns/op 9590.39 MB/s Benchmark____GWs_Int_1kx10x0-16 29369622 127.4 ns/op 8164.80 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25890172 142.9 ns/op 14446.67 MB/s Benchmark____GWs_Int_2kx10x0-16 25799845 138.5 ns/op 14903.75 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:38726->127.0.0.1:43885: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 25496739 161.1 ns/op 12815.44 MB/s Benchmark____GWs_Int_2kx10x0-16 25487304 167.5 ns/op 12325.99 MB/s Benchmark____GWs_Int_4kx10x0 bench_test.go:55: Failed read: read tcp 127.0.0.1:38876->127.0.0.1:45165: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 12535046 279.5 ns/op 14709.66 MB/s Benchmark____GWs_Int_4kx10x0-16 8126770 375.0 ns/op 10966.27 MB/s Benchmark____GWs_Int_4kx10x0-16 13331293 286.0 ns/op 14375.38 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:58890->127.0.0.1:42237: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:44002->127.0.0.1:44645: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6270102 543.8 ns/op 5746.53 MB/s Benchmark____GWs_Int_1kx01x1-16 6690825 556.3 ns/op 5617.56 MB/s Benchmark____GWs_Int_1kx01x1-16 6521966 550.3 ns/op 5678.47 MB/s Benchmark____GWs_Int_1kx01x1-16 6292072 552.0 ns/op 5661.34 MB/s Benchmark____GWs_Int_1kx01x1-16 6700075 551.5 ns/op 5665.88 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4634367 763.9 ns/op 8111.96 MB/s Benchmark____GWs_Int_2kx01x1-16 4747456 754.1 ns/op 8217.48 MB/s Benchmark____GWs_Int_2kx01x1-16 4731880 758.3 ns/op 8172.25 MB/s Benchmark____GWs_Int_2kx01x1-16 4621350 757.4 ns/op 8181.98 MB/s Benchmark____GWs_Int_2kx01x1-16 4415250 764.2 ns/op 8109.36 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2669178 1375 ns/op 8977.24 MB/s Benchmark____GWs_Int_4kx01x1-16 2648965 1367 ns/op 9029.00 MB/s Benchmark____GWs_Int_4kx01x1-16 2657088 1386 ns/op 8903.18 MB/s Benchmark____GWs_Int_4kx01x1-16 2642901 1372 ns/op 8995.49 MB/s Benchmark____GWs_Int_4kx01x1-16 2693469 1448 ns/op 8525.63 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6149362 548.2 ns/op 5700.90 MB/s Benchmark____GWs_Int_1kx10x1-16 6578178 547.0 ns/op 5713.38 MB/s Benchmark____GWs_Int_1kx10x1-16 6555297 626.4 ns/op 4989.22 MB/s Benchmark____GWs_Int_1kx10x1-16 6400429 543.7 ns/op 5747.83 MB/s Benchmark____GWs_Int_1kx10x1-16 6602264 543.7 ns/op 5747.82 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4174149 829.9 ns/op 7467.48 MB/s Benchmark____GWs_Int_2kx10x1-16 4314550 838.0 ns/op 7395.06 MB/s Benchmark____GWs_Int_2kx10x1-16 3970629 842.1 ns/op 7359.08 MB/s Benchmark____GWs_Int_2kx10x1-16 4104717 839.1 ns/op 7384.99 MB/s Benchmark____GWs_Int_2kx10x1-16 4129002 909.8 ns/op 6811.33 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2330924 1528 ns/op 8074.17 MB/s Benchmark____GWs_Int_4kx10x1-16 2342373 1531 ns/op 8061.10 MB/s Benchmark____GWs_Int_4kx10x1-16 2444854 1442 ns/op 8557.63 MB/s Benchmark____GWs_Int_4kx10x1-16 2370838 1594 ns/op 7743.35 MB/s Benchmark____GWs_Int_4kx10x1-16 2159757 2985 ns/op 4134.99 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8380845 433.2 ns/op 235.48 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8178206 430.3 ns/op 237.05 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8263924 436.6 ns/op 233.62 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8436984 437.8 ns/op 232.96 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8388224 428.3 ns/op 238.17 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 618940 5093 ns/op 34.76 MB/s Benchmark__GWs_Reqs_1SubEach-16 772338 5167 ns/op 34.26 MB/s Benchmark__GWs_Reqs_1SubEach-16 763675 5209 ns/op 33.98 MB/s Benchmark__GWs_Reqs_1SubEach-16 734168 5269 ns/op 33.59 MB/s Benchmark__GWs_Reqs_1SubEach-16 707290 5239 ns/op 33.79 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2081.568s