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 49373377 72.50 ns/op 151.73 MB/s Benchmark______Pub0b_Payload-16 47096629 72.47 ns/op 151.80 MB/s Benchmark______Pub0b_Payload-16 42612376 72.53 ns/op 151.66 MB/s Benchmark______Pub0b_Payload-16 46893213 72.67 ns/op 151.36 MB/s Benchmark______Pub0b_Payload-16 46833621 72.41 ns/op 151.91 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46175328 76.09 ns/op 249.71 MB/s Benchmark______Pub8b_Payload-16 46082268 73.55 ns/op 258.31 MB/s Benchmark______Pub8b_Payload-16 46529934 73.19 ns/op 259.61 MB/s Benchmark______Pub8b_Payload-16 46257192 73.08 ns/op 259.98 MB/s Benchmark______Pub8b_Payload-16 46213536 73.26 ns/op 259.37 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44274160 77.46 ns/op 568.05 MB/s Benchmark_____Pub32b_Payload-16 44190594 77.13 ns/op 570.49 MB/s Benchmark_____Pub32b_Payload-16 44191873 77.49 ns/op 567.82 MB/s Benchmark_____Pub32b_Payload-16 44110197 77.12 ns/op 570.52 MB/s Benchmark_____Pub32b_Payload-16 44274710 77.37 ns/op 568.72 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 40493283 86.20 ns/op 1635.79 MB/s Benchmark____Pub128B_Payload-16 41444696 85.28 ns/op 1653.31 MB/s Benchmark____Pub128B_Payload-16 39345226 86.16 ns/op 1636.51 MB/s Benchmark____Pub128B_Payload-16 38836750 85.93 ns/op 1640.86 MB/s Benchmark____Pub128B_Payload-16 39764192 88.50 ns/op 1593.20 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36633559 93.99 ns/op 2862.10 MB/s Benchmark____Pub256B_Payload-16 35482310 93.42 ns/op 2879.44 MB/s Benchmark____Pub256B_Payload-16 36962391 98.35 ns/op 2735.25 MB/s Benchmark____Pub256B_Payload-16 35306398 93.72 ns/op 2870.14 MB/s Benchmark____Pub256B_Payload-16 35729002 95.06 ns/op 2829.76 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24431203 143.3 ns/op 7245.37 MB/s Benchmark______Pub1K_Payload-16 21856476 151.9 ns/op 6832.78 MB/s Benchmark______Pub1K_Payload-16 23901588 134.2 ns/op 7732.91 MB/s Benchmark______Pub1K_Payload-16 23749156 143.7 ns/op 7225.42 MB/s Benchmark______Pub1K_Payload-16 24426662 144.5 ns/op 7181.96 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5689130 640.1 ns/op 6420.61 MB/s Benchmark______Pub4K_Payload-16 5418687 611.1 ns/op 6725.19 MB/s Benchmark______Pub4K_Payload-16 5736369 636.5 ns/op 6457.61 MB/s Benchmark______Pub4K_Payload-16 5493310 612.1 ns/op 6714.74 MB/s Benchmark______Pub4K_Payload-16 5673303 621.7 ns/op 6610.55 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2757518 1282 ns/op 6403.39 MB/s Benchmark______Pub8K_Payload-16 2729306 1281 ns/op 6404.55 MB/s Benchmark______Pub8K_Payload-16 2761675 1291 ns/op 6357.93 MB/s Benchmark______Pub8K_Payload-16 2745573 1280 ns/op 6411.49 MB/s Benchmark______Pub8K_Payload-16 2807494 1267 ns/op 6478.99 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 599826 5520 ns/op 5938.97 MB/s Benchmark_____Pub32K_Payload-16 525220 10357 ns/op 3165.24 MB/s Benchmark_____Pub32K_Payload-16 646623 5378 ns/op 6095.82 MB/s Benchmark_____Pub32K_Payload-16 611193 5427 ns/op 6040.18 MB/s Benchmark_____Pub32K_Payload-16 662998 5538 ns/op 5919.13 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32019432 95.05 ns/op 115.73 MB/s Benchmark__AuthPub0b_Payload-16 30021454 102.5 ns/op 107.33 MB/s Benchmark__AuthPub0b_Payload-16 35603142 93.88 ns/op 117.17 MB/s Benchmark__AuthPub0b_Payload-16 36739254 93.80 ns/op 117.27 MB/s Benchmark__AuthPub0b_Payload-16 36717451 93.91 ns/op 117.13 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15372195 226.5 ns/op Benchmark_____________PubSub-16 15642408 227.5 ns/op Benchmark_____________PubSub-16 15549464 229.6 ns/op Benchmark_____________PubSub-16 15684586 228.2 ns/op Benchmark_____________PubSub-16 15429916 228.3 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15459661 226.0 ns/op Benchmark_____PubSubTwoConns-16 15716618 225.9 ns/op Benchmark_____PubSubTwoConns-16 15524449 224.9 ns/op Benchmark_____PubSubTwoConns-16 15414814 226.3 ns/op Benchmark_____PubSubTwoConns-16 15650947 227.6 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:47710->127.0.0.1:42535: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42470->127.0.0.1:34391: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:56988->127.0.0.1:43671: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50698->127.0.0.1:38369: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:39166->127.0.0.1:45427: 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 14484921 244.5 ns/op Benchmark_____PubTwoQueueSub-16 14261653 244.7 ns/op Benchmark_____PubTwoQueueSub-16 14557904 245.2 ns/op Benchmark_____PubTwoQueueSub-16 14514127 244.2 ns/op Benchmark_____PubTwoQueueSub-16 14640208 244.7 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14337558 245.8 ns/op Benchmark____PubFourQueueSub-16 14436933 246.4 ns/op Benchmark____PubFourQueueSub-16 14567547 247.1 ns/op Benchmark____PubFourQueueSub-16 14389905 243.8 ns/op Benchmark____PubFourQueueSub-16 14555420 244.9 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14592595 246.4 ns/op Benchmark___PubEightQueueSub-16 14451975 244.9 ns/op Benchmark___PubEightQueueSub-16 14463868 245.9 ns/op Benchmark___PubEightQueueSub-16 14342720 246.0 ns/op Benchmark___PubEightQueueSub-16 14547872 244.7 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23485 152879 ns/op Benchmark_PubSub512kTwoConns-16 23353 152837 ns/op Benchmark_PubSub512kTwoConns-16 23553 153294 ns/op Benchmark_PubSub512kTwoConns-16 22990 153984 ns/op Benchmark_PubSub512kTwoConns-16 23400 156377 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15260641 228.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15417909 228.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15199155 230.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15244557 230.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 15107834 228.7 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15153621 228.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15230918 229.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15186450 229.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15274053 227.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15101863 227.9 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11379594 308.7 ns/op Benchmark____RoutedPubSub_0b-16 11679109 304.3 ns/op Benchmark____RoutedPubSub_0b-16 11140663 317.6 ns/op Benchmark____RoutedPubSub_0b-16 11533632 313.7 ns/op Benchmark____RoutedPubSub_0b-16 11168488 309.6 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6637744 541.0 ns/op Benchmark____RoutedPubSub_1K-16 6170526 536.7 ns/op Benchmark____RoutedPubSub_1K-16 6622118 580.5 ns/op Benchmark____RoutedPubSub_1K-16 6743970 540.0 ns/op Benchmark____RoutedPubSub_1K-16 6558799 542.6 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85837 42160 ns/op Benchmark__RoutedPubSub_100K-16 86389 42227 ns/op Benchmark__RoutedPubSub_100K-16 85303 42398 ns/op Benchmark__RoutedPubSub_100K-16 83449 41623 ns/op Benchmark__RoutedPubSub_100K-16 84555 41972 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11208520 315.9 ns/op Benchmark____Routed2QueueSub-16 9443038 320.4 ns/op Benchmark____Routed2QueueSub-16 9805462 321.4 ns/op Benchmark____Routed2QueueSub-16 9752379 322.9 ns/op Benchmark____Routed2QueueSub-16 9580632 317.5 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9632151 325.0 ns/op Benchmark____Routed4QueueSub-16 9411613 323.3 ns/op Benchmark____Routed4QueueSub-16 11200875 321.5 ns/op Benchmark____Routed4QueueSub-16 9412765 321.7 ns/op Benchmark____Routed4QueueSub-16 9575962 316.8 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 10984383 337.0 ns/op Benchmark____Routed8QueueSub-16 8995038 335.2 ns/op Benchmark____Routed8QueueSub-16 9170397 335.6 ns/op Benchmark____Routed8QueueSub-16 10694318 342.1 ns/op Benchmark____Routed8QueueSub-16 9119860 334.7 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8769040 345.9 ns/op Benchmark___Routed16QueueSub-16 8739975 353.0 ns/op Benchmark___Routed16QueueSub-16 8861216 349.3 ns/op Benchmark___Routed16QueueSub-16 8733764 353.6 ns/op Benchmark___Routed16QueueSub-16 8991104 353.8 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6486340 554.9 ns/op Benchmark____________RouteCompressOff-16 6497144 549.8 ns/op Benchmark____________RouteCompressOff-16 6489978 558.6 ns/op Benchmark____________RouteCompressOff-16 6457014 549.9 ns/op Benchmark____________RouteCompressOff-16 6439248 555.6 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6452730 548.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6465819 468.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6403849 470.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6492728 548.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6321943 549.9 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6262341 550.0 ns/op Benchmark_________RouteCompressS2Fast-16 6321228 560.1 ns/op Benchmark_________RouteCompressS2Fast-16 6455065 561.7 ns/op Benchmark_________RouteCompressS2Fast-16 6408778 517.4 ns/op Benchmark_________RouteCompressS2Fast-16 6404067 550.6 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6418454 551.8 ns/op Benchmark_______RouteCompressS2Better-16 6434277 554.6 ns/op Benchmark_______RouteCompressS2Better-16 6424249 549.9 ns/op Benchmark_______RouteCompressS2Better-16 6507130 555.5 ns/op Benchmark_______RouteCompressS2Better-16 6578594 554.7 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6472291 554.1 ns/op Benchmark_________RouteCompressS2Best-16 6434648 659.1 ns/op Benchmark_________RouteCompressS2Best-16 6258960 556.3 ns/op Benchmark_________RouteCompressS2Best-16 6238366 551.0 ns/op Benchmark_________RouteCompressS2Best-16 6275740 551.2 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4617243 767.7 ns/op 324.36 MB/s Benchmark______FanOut_8x1x10-16 4671012 773.2 ns/op 322.03 MB/s Benchmark______FanOut_8x1x10-16 4688607 772.1 ns/op 322.50 MB/s Benchmark______FanOut_8x1x10-16 4470126 770.9 ns/op 323.02 MB/s Benchmark______FanOut_8x1x10-16 4662049 772.2 ns/op 322.48 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 535840 6222 ns/op 372.73 MB/s Benchmark_____FanOut_8x1x100-16 558984 6155 ns/op 376.76 MB/s Benchmark_____FanOut_8x1x100-16 536096 6267 ns/op 370.02 MB/s Benchmark_____FanOut_8x1x100-16 543856 6275 ns/op 369.57 MB/s Benchmark_____FanOut_8x1x100-16 545896 6221 ns/op 372.75 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 46624 76568 ns/op 300.63 MB/s Benchmark____FanOut_8x10x100-16 47235 76311 ns/op 301.65 MB/s Benchmark____FanOut_8x10x100-16 47040 76084 ns/op 302.55 MB/s Benchmark____FanOut_8x10x100-16 46712 76258 ns/op 301.86 MB/s Benchmark____FanOut_8x10x100-16 46978 77750 ns/op 296.06 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5848 614024 ns/op 390.90 MB/s Benchmark___FanOut_8x10x1000-16 5523 614801 ns/op 390.40 MB/s Benchmark___FanOut_8x10x1000-16 5768 616890 ns/op 389.08 MB/s Benchmark___FanOut_8x10x1000-16 5716 611430 ns/op 392.55 MB/s Benchmark___FanOut_8x10x1000-16 5641 614304 ns/op 390.72 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4980 728429 ns/op 315.77 MB/s Benchmark___FanOut_8x100x100-16 4869 730150 ns/op 315.03 MB/s Benchmark___FanOut_8x100x100-16 4899 722412 ns/op 318.40 MB/s Benchmark___FanOut_8x100x100-16 4872 734432 ns/op 313.19 MB/s Benchmark___FanOut_8x100x100-16 4804 724601 ns/op 317.44 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 566 6374834 ns/op 376.48 MB/s Benchmark__FanOut_8x100x1000-16 526 6305751 ns/op 380.61 MB/s Benchmark__FanOut_8x100x1000-16 554 6318944 ns/op 379.81 MB/s Benchmark__FanOut_8x100x1000-16 556 6374230 ns/op 376.52 MB/s Benchmark__FanOut_8x100x1000-16 536 6370737 ns/op 376.73 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 525 6886100 ns/op 363.05 MB/s Benchmark__FanOut_8x10x10000-16 522 6816232 ns/op 366.77 MB/s Benchmark__FanOut_8x10x10000-16 526 6857660 ns/op 364.56 MB/s Benchmark__FanOut_8x10x10000-16 514 6878598 ns/op 363.45 MB/s Benchmark__FanOut_8x10x10000-16 516 6868532 ns/op 363.98 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 936 3839682 ns/op 299.51 MB/s Benchmark___FanOut_8x500x100-16 934 3836881 ns/op 299.73 MB/s Benchmark___FanOut_8x500x100-16 924 3825163 ns/op 300.65 MB/s Benchmark___FanOut_8x500x100-16 933 3829348 ns/op 300.32 MB/s Benchmark___FanOut_8x500x100-16 924 3823542 ns/op 300.77 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 366314 9577 ns/op 1528.77 MB/s Benchmark___FanOut_128x1x100-16 370836 9551 ns/op 1533.00 MB/s Benchmark___FanOut_128x1x100-16 351494 9550 ns/op 1533.05 MB/s Benchmark___FanOut_128x1x100-16 364848 9533 ns/op 1535.90 MB/s Benchmark___FanOut_128x1x100-16 351375 9645 ns/op 1517.96 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32013 112049 ns/op 1295.33 MB/s Benchmark__FanOut_128x10x100-16 31992 112305 ns/op 1292.38 MB/s Benchmark__FanOut_128x10x100-16 32004 111898 ns/op 1297.08 MB/s Benchmark__FanOut_128x10x100-16 32042 111854 ns/op 1297.59 MB/s Benchmark__FanOut_128x10x100-16 32088 112419 ns/op 1291.07 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3841 893415 ns/op 1634.34 MB/s Benchmark_FanOut_128x10x1000-16 3814 886003 ns/op 1648.01 MB/s Benchmark_FanOut_128x10x1000-16 3946 892545 ns/op 1635.93 MB/s Benchmark_FanOut_128x10x1000-16 3960 890513 ns/op 1639.66 MB/s Benchmark_FanOut_128x10x1000-16 4060 896844 ns/op 1628.09 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3513 1025648 ns/op 1413.88 MB/s Benchmark_FanOut_128x100x100-16 3532 1026160 ns/op 1413.17 MB/s Benchmark_FanOut_128x100x100-16 3506 1030760 ns/op 1406.87 MB/s Benchmark_FanOut_128x100x100-16 3432 1030304 ns/op 1407.49 MB/s Benchmark_FanOut_128x100x100-16 3447 1028919 ns/op 1409.38 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 375 9461261 ns/op 1543.15 MB/s BenchmarkFanOut_128x100x1000-16 387 9454808 ns/op 1544.20 MB/s BenchmarkFanOut_128x100x1000-16 384 9389653 ns/op 1554.92 MB/s BenchmarkFanOut_128x100x1000-16 378 9389757 ns/op 1554.90 MB/s BenchmarkFanOut_128x100x1000-16 372 9448870 ns/op 1545.17 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 361 9786470 ns/op 1502.09 MB/s BenchmarkFanOut_128x10x10000-16 366 9778711 ns/op 1503.28 MB/s BenchmarkFanOut_128x10x10000-16 358 9837129 ns/op 1494.35 MB/s BenchmarkFanOut_128x10x10000-16 368 9758934 ns/op 1506.33 MB/s BenchmarkFanOut_128x10x10000-16 367 9804290 ns/op 1499.36 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 662 5351342 ns/op 1354.83 MB/s BenchmarkFanOut__128x500x100-16 656 5375569 ns/op 1348.72 MB/s BenchmarkFanOut__128x500x100-16 661 5360087 ns/op 1352.62 MB/s BenchmarkFanOut__128x500x100-16 666 5415839 ns/op 1338.69 MB/s BenchmarkFanOut__128x500x100-16 666 5389052 ns/op 1345.35 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1914 1858882 ns/op 2846.08 MB/s Benchmark_FanOut_512x100x100-16 1898 1866824 ns/op 2833.97 MB/s Benchmark_FanOut_512x100x100-16 1903 1869897 ns/op 2829.31 MB/s Benchmark_FanOut_512x100x100-16 1898 1874404 ns/op 2822.51 MB/s Benchmark_FanOut_512x100x100-16 1924 1865154 ns/op 2836.51 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16736478 ns/op 3166.77 MB/s Benchmark__FanOut_512x100x1k-16 214 16666599 ns/op 3180.04 MB/s Benchmark__FanOut_512x100x1k-16 213 16877403 ns/op 3140.32 MB/s Benchmark__FanOut_512x100x1k-16 214 16938117 ns/op 3129.07 MB/s Benchmark__FanOut_512x100x1k-16 214 16768162 ns/op 3160.78 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3009 1131028 ns/op 9222.62 MB/s Benchmark____FanOut_1kx10x1k-16 2868 1135333 ns/op 9187.64 MB/s Benchmark____FanOut_1kx10x1k-16 2955 1161741 ns/op 8978.80 MB/s Benchmark____FanOut_1kx10x1k-16 3016 1148334 ns/op 9083.63 MB/s Benchmark____FanOut_1kx10x1k-16 3319 1151843 ns/op 9055.95 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2716 1268761 ns/op 8213.55 MB/s Benchmark__FanOut_1kx100x100-16 2782 1269122 ns/op 8211.22 MB/s Benchmark__FanOut_1kx100x100-16 2751 1269344 ns/op 8209.78 MB/s Benchmark__FanOut_1kx100x100-16 2700 1272105 ns/op 8191.96 MB/s Benchmark__FanOut_1kx100x100-16 2710 1275810 ns/op 8168.18 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4394176 790.4 ns/op 315.02 MB/s Benchmark_____RFanOut_8x1x10-16 4421820 780.0 ns/op 319.24 MB/s Benchmark_____RFanOut_8x1x10-16 4466115 805.8 ns/op 309.01 MB/s Benchmark_____RFanOut_8x1x10-16 4472816 798.0 ns/op 312.03 MB/s Benchmark_____RFanOut_8x1x10-16 4254045 789.5 ns/op 315.38 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 540938 6291 ns/op 368.65 MB/s Benchmark____RFanOut_8x1x100-16 517317 6219 ns/op 372.86 MB/s Benchmark____RFanOut_8x1x100-16 529221 6219 ns/op 372.88 MB/s Benchmark____RFanOut_8x1x100-16 514736 6250 ns/op 371.02 MB/s Benchmark____RFanOut_8x1x100-16 543427 6330 ns/op 366.37 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46458 76670 ns/op 300.23 MB/s Benchmark___RFanOut_8x10x100-16 46803 76114 ns/op 302.43 MB/s Benchmark___RFanOut_8x10x100-16 47583 78343 ns/op 293.82 MB/s Benchmark___RFanOut_8x10x100-16 46510 77380 ns/op 297.48 MB/s Benchmark___RFanOut_8x10x100-16 46719 76154 ns/op 302.27 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5767 618944 ns/op 387.79 MB/s Benchmark__RFanOut_8x10x1000-16 5664 612281 ns/op 392.01 MB/s Benchmark__RFanOut_8x10x1000-16 5576 618344 ns/op 388.16 MB/s Benchmark__RFanOut_8x10x1000-16 5806 610515 ns/op 393.14 MB/s Benchmark__RFanOut_8x10x1000-16 5414 605774 ns/op 396.22 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4951 715934 ns/op 321.29 MB/s Benchmark__RFanOut_8x100x100-16 4780 716440 ns/op 321.06 MB/s Benchmark__RFanOut_8x100x100-16 4928 715973 ns/op 321.27 MB/s Benchmark__RFanOut_8x100x100-16 4892 715371 ns/op 321.54 MB/s Benchmark__RFanOut_8x100x100-16 4964 725004 ns/op 317.27 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 559 6320659 ns/op 379.71 MB/s Benchmark_RFanOut_8x100x1000-16 565 6362864 ns/op 377.19 MB/s Benchmark_RFanOut_8x100x1000-16 560 6408960 ns/op 374.48 MB/s Benchmark_RFanOut_8x100x1000-16 562 6274180 ns/op 382.52 MB/s Benchmark_RFanOut_8x100x1000-16 559 6264151 ns/op 383.14 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 525 6833747 ns/op 365.83 MB/s Benchmark_RFanOut_8x10x10000-16 519 6783101 ns/op 368.57 MB/s Benchmark_RFanOut_8x10x10000-16 534 6705001 ns/op 372.86 MB/s Benchmark_RFanOut_8x10x10000-16 529 6821206 ns/op 366.51 MB/s Benchmark_RFanOut_8x10x10000-16 534 6743191 ns/op 370.75 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3079 1144755 ns/op 9112.03 MB/s Benchmark_RFanOut_1kx10x1000-16 2869 1155307 ns/op 9028.80 MB/s Benchmark_RFanOut_1kx10x1000-16 3021 1154045 ns/op 9038.68 MB/s Benchmark_RFanOut_1kx10x1000-16 2773 1170746 ns/op 8909.74 MB/s Benchmark_RFanOut_1kx10x1000-16 3226 1163575 ns/op 8964.64 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6937509 507.8 ns/op 4092.17 MB/s Benchmark_____FanIn_1kx100x1-16 6943158 506.8 ns/op 4100.58 MB/s Benchmark_____FanIn_1kx100x1-16 6928754 504.7 ns/op 4117.32 MB/s Benchmark_____FanIn_1kx100x1-16 6948616 507.4 ns/op 4095.66 MB/s Benchmark_____FanIn_1kx100x1-16 6910750 505.4 ns/op 4111.60 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2616744 1360 ns/op 6047.16 MB/s Benchmark_____FanIn_4kx100x1-16 2596260 1352 ns/op 6080.29 MB/s Benchmark_____FanIn_4kx100x1-16 2603782 1385 ns/op 5937.95 MB/s Benchmark_____FanIn_4kx100x1-16 2569698 1375 ns/op 5980.78 MB/s Benchmark_____FanIn_4kx100x1-16 2611651 1369 ns/op 6005.40 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1714885 2098 ns/op 7822.42 MB/s Benchmark_____FanIn_8kx100x1-16 1693660 2139 ns/op 7675.35 MB/s Benchmark_____FanIn_8kx100x1-16 1685089 2110 ns/op 7779.00 MB/s Benchmark_____FanIn_8kx100x1-16 1714455 2127 ns/op 7717.80 MB/s Benchmark_____FanIn_8kx100x1-16 1685998 2128 ns/op 7715.01 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 868590 4136 ns/op 7930.20 MB/s Benchmark____FanIn_16kx100x1-16 873908 4178 ns/op 7851.36 MB/s Benchmark____FanIn_16kx100x1-16 863329 4168 ns/op 7868.58 MB/s Benchmark____FanIn_16kx100x1-16 801722 4168 ns/op 7870.40 MB/s Benchmark____FanIn_16kx100x1-16 863215 4159 ns/op 7887.12 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 167038 19950 ns/op 6571.60 MB/s Benchmark____FanIn_64kx100x1-16 163508 19994 ns/op 6557.30 MB/s Benchmark____FanIn_64kx100x1-16 170709 19933 ns/op 6577.28 MB/s Benchmark____FanIn_64kx100x1-16 157519 19748 ns/op 6638.76 MB/s Benchmark____FanIn_64kx100x1-16 165872 19830 ns/op 6611.52 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 415817480 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55306->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: 472186180 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57114->127.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:57304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56424->127.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:56722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56986->127.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:57140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56972->127.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:56710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56578->127.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:56546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56952->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:56664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56856->127.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:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 132794170 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58572->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:59104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59018->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: 726369690 vs 9097646000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33018->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:33088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33336->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: 611010490 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34786->127.0.0.1:5222: write: broken pipe --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35136->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5518182 645.3 ns/op 440.10 MB/s Benchmark___BumpPubCount_1x3-16 5526847 647.9 ns/op 438.33 MB/s Benchmark___BumpPubCount_1x3-16 5560560 640.2 ns/op 443.59 MB/s Benchmark___BumpPubCount_1x3-16 5502835 643.6 ns/op 441.25 MB/s Benchmark___BumpPubCount_1x3-16 5542108 649.4 ns/op 437.31 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5288934 673.9 ns/op 421.45 MB/s Benchmark___BumpPubCount_2x3-16 5333422 672.3 ns/op 422.45 MB/s Benchmark___BumpPubCount_2x3-16 5267306 679.6 ns/op 417.90 MB/s Benchmark___BumpPubCount_2x3-16 5208145 675.7 ns/op 420.32 MB/s Benchmark___BumpPubCount_2x3-16 5284526 673.3 ns/op 421.81 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5543408 649.8 ns/op 437.08 MB/s Benchmark___BumpPubCount_5x3-16 5282336 647.0 ns/op 438.93 MB/s Benchmark___BumpPubCount_5x3-16 5508285 647.0 ns/op 438.98 MB/s Benchmark___BumpPubCount_5x3-16 5239488 651.6 ns/op 435.85 MB/s Benchmark___BumpPubCount_5x3-16 5496291 661.5 ns/op 429.31 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5549833 650.4 ns/op 436.67 MB/s Benchmark__BumpPubCount_10x3-16 5558248 646.5 ns/op 439.30 MB/s Benchmark__BumpPubCount_10x3-16 5546930 649.5 ns/op 437.23 MB/s Benchmark__BumpPubCount_10x3-16 5576877 649.8 ns/op 437.04 MB/s Benchmark__BumpPubCount_10x3-16 5556296 650.1 ns/op 436.84 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11944562 280.7 ns/op 3704.78 MB/s Benchmark____GWs_Opt_1kx01x0-16 13282426 280.9 ns/op 3702.67 MB/s Benchmark____GWs_Opt_1kx01x0-16 13044382 278.8 ns/op 3730.39 MB/s Benchmark____GWs_Opt_1kx01x0-16 12228702 274.8 ns/op 3784.13 MB/s Benchmark____GWs_Opt_1kx01x0-16 12049642 279.6 ns/op 3719.70 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 11021920 339.4 ns/op 6081.71 MB/s Benchmark____GWs_Opt_2kx01x0-16 8930233 345.2 ns/op 5979.85 MB/s Benchmark____GWs_Opt_2kx01x0-16 9659822 355.7 ns/op 5802.17 MB/s Benchmark____GWs_Opt_2kx01x0-16 10173927 346.4 ns/op 5958.65 MB/s Benchmark____GWs_Opt_2kx01x0-16 10149586 331.1 ns/op 6233.18 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5650297 638.7 ns/op 6438.33 MB/s Benchmark____GWs_Opt_4kx01x0-16 5609167 629.0 ns/op 6537.42 MB/s Benchmark____GWs_Opt_4kx01x0-16 5683928 608.8 ns/op 6754.06 MB/s Benchmark____GWs_Opt_4kx01x0-16 5888397 672.5 ns/op 6114.72 MB/s Benchmark____GWs_Opt_4kx01x0-16 5770022 628.1 ns/op 6546.67 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29074821 109.8 ns/op 9473.54 MB/s Benchmark____GWs_Opt_1kx10x0-16 29198498 116.6 ns/op 8916.04 MB/s Benchmark____GWs_Opt_1kx10x0-16 32421201 113.1 ns/op 9195.79 MB/s Benchmark____GWs_Opt_1kx10x0-16 31513459 108.7 ns/op 9565.93 MB/s Benchmark____GWs_Opt_1kx10x0-16 32331523 110.1 ns/op 9450.14 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 22692806 138.3 ns/op 14923.54 MB/s Benchmark____GWs_Opt_2kx10x0-16 24738007 149.3 ns/op 13824.30 MB/s Benchmark____GWs_Opt_2kx10x0-16 25635164 143.4 ns/op 14391.64 MB/s Benchmark____GWs_Opt_2kx10x0-16 23502469 139.1 ns/op 14840.92 MB/s Benchmark____GWs_Opt_2kx10x0-16 24997857 156.5 ns/op 13186.49 MB/s Benchmark____GWs_Opt_4kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:44280->127.0.0.1:42161: 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:53054->127.0.0.1:45083: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 13007671 284.8 ns/op 14436.72 MB/s Benchmark____GWs_Opt_4kx10x0-16 11015392 294.5 ns/op 13964.60 MB/s Benchmark____GWs_Opt_4kx10x0-16 7028144 484.6 ns/op 8485.74 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:49898->127.0.0.1:35815: 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:43592->127.0.0.1:34371: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6483248 554.6 ns/op 5635.10 MB/s Benchmark____GWs_Opt_1kx01x1-16 6227173 550.6 ns/op 5675.28 MB/s Benchmark____GWs_Opt_1kx01x1-16 6351324 545.8 ns/op 5725.33 MB/s Benchmark____GWs_Opt_1kx01x1-16 6390548 547.6 ns/op 5707.15 MB/s Benchmark____GWs_Opt_1kx01x1-16 6577221 547.5 ns/op 5707.76 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4650043 770.5 ns/op 8042.69 MB/s Benchmark____GWs_Opt_2kx01x1-16 4609873 774.3 ns/op 8003.37 MB/s Benchmark____GWs_Opt_2kx01x1-16 4739874 763.2 ns/op 8119.60 MB/s Benchmark____GWs_Opt_2kx01x1-16 4575637 760.5 ns/op 8148.79 MB/s Benchmark____GWs_Opt_2kx01x1-16 4714155 758.9 ns/op 8166.26 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2644972 1382 ns/op 8928.27 MB/s Benchmark____GWs_Opt_4kx01x1-16 2673271 1360 ns/op 9074.86 MB/s Benchmark____GWs_Opt_4kx01x1-16 2604034 2247 ns/op 5492.43 MB/s Benchmark____GWs_Opt_4kx01x1-16 2566292 1361 ns/op 9066.41 MB/s Benchmark____GWs_Opt_4kx01x1-16 2589301 1386 ns/op 8901.11 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6435538 558.1 ns/op 5598.96 MB/s Benchmark____GWs_Opt_1kx10x1-16 6135706 582.9 ns/op 5361.41 MB/s Benchmark____GWs_Opt_1kx10x1-16 6188025 561.5 ns/op 5565.18 MB/s Benchmark____GWs_Opt_1kx10x1-16 6233694 559.3 ns/op 5587.49 MB/s Benchmark____GWs_Opt_1kx10x1-16 6426594 558.4 ns/op 5596.17 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4108213 851.9 ns/op 7273.99 MB/s Benchmark____GWs_Opt_2kx10x1-16 4248266 847.3 ns/op 7313.94 MB/s Benchmark____GWs_Opt_2kx10x1-16 3924712 874.5 ns/op 7086.19 MB/s Benchmark____GWs_Opt_2kx10x1-16 4132842 861.8 ns/op 7191.00 MB/s Benchmark____GWs_Opt_2kx10x1-16 4234844 856.5 ns/op 7235.54 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2275132 1550 ns/op 7963.98 MB/s Benchmark____GWs_Opt_4kx10x1-16 2333592 1531 ns/op 8059.85 MB/s Benchmark____GWs_Opt_4kx10x1-16 2320912 1547 ns/op 7978.11 MB/s Benchmark____GWs_Opt_4kx10x1-16 2281244 1534 ns/op 8044.74 MB/s Benchmark____GWs_Opt_4kx10x1-16 2305766 1559 ns/op 7918.05 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 11820390 279.9 ns/op 3715.22 MB/s Benchmark____GWs_Int_1kx01x0-16 11904582 305.2 ns/op 3407.14 MB/s Benchmark____GWs_Int_1kx01x0-16 11731339 288.4 ns/op 3606.47 MB/s Benchmark____GWs_Int_1kx01x0-16 12786286 294.8 ns/op 3527.96 MB/s Benchmark____GWs_Int_1kx01x0-16 12618914 291.6 ns/op 3566.05 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10092537 343.7 ns/op 6004.77 MB/s Benchmark____GWs_Int_2kx01x0-16 9978210 366.7 ns/op 5628.09 MB/s Benchmark____GWs_Int_2kx01x0-16 10115078 358.9 ns/op 5750.75 MB/s Benchmark____GWs_Int_2kx01x0-16 10362156 369.3 ns/op 5588.86 MB/s Benchmark____GWs_Int_2kx01x0-16 10201863 354.4 ns/op 5823.83 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5700225 622.8 ns/op 6602.75 MB/s Benchmark____GWs_Int_4kx01x0-16 5630954 640.3 ns/op 6422.29 MB/s Benchmark____GWs_Int_4kx01x0-16 5699354 637.5 ns/op 6449.89 MB/s Benchmark____GWs_Int_4kx01x0-16 5795918 638.1 ns/op 6444.59 MB/s Benchmark____GWs_Int_4kx01x0-16 5648432 631.2 ns/op 6514.09 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30816542 115.5 ns/op 9005.57 MB/s Benchmark____GWs_Int_1kx10x0-16 32545654 110.2 ns/op 9435.64 MB/s Benchmark____GWs_Int_1kx10x0-16 30469822 111.6 ns/op 9318.65 MB/s Benchmark____GWs_Int_1kx10x0-16 33485941 109.8 ns/op 9470.83 MB/s Benchmark____GWs_Int_1kx10x0-16 28214101 115.8 ns/op 8979.27 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25857697 146.5 ns/op 14084.43 MB/s Benchmark____GWs_Int_2kx10x0-16 23973874 137.1 ns/op 15056.58 MB/s Benchmark____GWs_Int_2kx10x0-16 23744432 142.3 ns/op 14501.70 MB/s Benchmark____GWs_Int_2kx10x0-16 25493544 144.3 ns/op 14306.68 MB/s Benchmark____GWs_Int_2kx10x0-16 25975695 147.6 ns/op 13982.26 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 11047404 331.3 ns/op 12412.85 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:44832->127.0.0.1:46189: 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:43408->127.0.0.1:37033: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 11597916 1390 ns/op 2958.23 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:33590->127.0.0.1:44425: 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:60402->127.0.0.1:41149: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 11065599 294.6 ns/op 13957.20 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6447032 569.1 ns/op 5491.30 MB/s Benchmark____GWs_Int_1kx01x1-16 6488634 553.5 ns/op 5645.86 MB/s Benchmark____GWs_Int_1kx01x1-16 6484652 558.4 ns/op 5596.60 MB/s Benchmark____GWs_Int_1kx01x1-16 6421676 564.3 ns/op 5537.78 MB/s Benchmark____GWs_Int_1kx01x1-16 6450081 573.9 ns/op 5444.97 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4661768 779.0 ns/op 7954.64 MB/s Benchmark____GWs_Int_2kx01x1-16 4351359 772.0 ns/op 8027.39 MB/s Benchmark____GWs_Int_2kx01x1-16 4731495 767.3 ns/op 8076.81 MB/s Benchmark____GWs_Int_2kx01x1-16 4546474 798.2 ns/op 7763.93 MB/s Benchmark____GWs_Int_2kx01x1-16 4638270 764.7 ns/op 8103.87 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2585950 1368 ns/op 9020.33 MB/s Benchmark____GWs_Int_4kx01x1-16 2611765 1370 ns/op 9007.68 MB/s Benchmark____GWs_Int_4kx01x1-16 2627134 1372 ns/op 8996.99 MB/s Benchmark____GWs_Int_4kx01x1-16 2604068 1351 ns/op 9131.44 MB/s Benchmark____GWs_Int_4kx01x1-16 2656720 1366 ns/op 9035.68 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6184030 557.7 ns/op 5603.83 MB/s Benchmark____GWs_Int_1kx10x1-16 6191482 565.0 ns/op 5530.89 MB/s Benchmark____GWs_Int_1kx10x1-16 6235986 561.6 ns/op 5564.85 MB/s Benchmark____GWs_Int_1kx10x1-16 6135285 564.8 ns/op 5532.60 MB/s Benchmark____GWs_Int_1kx10x1-16 6338962 562.1 ns/op 5559.82 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4106052 883.4 ns/op 7015.20 MB/s Benchmark____GWs_Int_2kx10x1-16 4087906 845.0 ns/op 7333.62 MB/s Benchmark____GWs_Int_2kx10x1-16 4050186 849.3 ns/op 7296.71 MB/s Benchmark____GWs_Int_2kx10x1-16 4090464 841.7 ns/op 7362.43 MB/s Benchmark____GWs_Int_2kx10x1-16 4099452 853.1 ns/op 7264.19 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2311827 1502 ns/op 8215.40 MB/s Benchmark____GWs_Int_4kx10x1-16 2544852 1584 ns/op 7788.79 MB/s Benchmark____GWs_Int_4kx10x1-16 2420096 1497 ns/op 8241.52 MB/s Benchmark____GWs_Int_4kx10x1-16 2331938 1626 ns/op 7587.83 MB/s Benchmark____GWs_Int_4kx10x1-16 2531736 1533 ns/op 8047.77 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8673711 441.4 ns/op 231.10 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8544558 440.6 ns/op 231.48 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7788849 435.7 ns/op 234.13 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8097745 441.9 ns/op 230.81 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7688809 437.7 ns/op 233.02 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 615204 5086 ns/op 34.80 MB/s Benchmark__GWs_Reqs_1SubEach-16 784159 5278 ns/op 33.54 MB/s Benchmark__GWs_Reqs_1SubEach-16 745854 5293 ns/op 33.44 MB/s Benchmark__GWs_Reqs_1SubEach-16 719017 5325 ns/op 33.24 MB/s Benchmark__GWs_Reqs_1SubEach-16 737170 5353 ns/op 33.07 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2204.640s