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 50096720 76.02 ns/op 144.70 MB/s Benchmark______Pub0b_Payload-16 42134714 71.85 ns/op 153.10 MB/s Benchmark______Pub0b_Payload-16 50174870 71.83 ns/op 153.14 MB/s Benchmark______Pub0b_Payload-16 47590144 71.78 ns/op 153.25 MB/s Benchmark______Pub0b_Payload-16 47434006 71.85 ns/op 153.10 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46891665 73.82 ns/op 257.39 MB/s Benchmark______Pub8b_Payload-16 46984288 72.40 ns/op 262.42 MB/s Benchmark______Pub8b_Payload-16 46937812 72.40 ns/op 262.45 MB/s Benchmark______Pub8b_Payload-16 43670041 72.60 ns/op 261.72 MB/s Benchmark______Pub8b_Payload-16 46559690 72.56 ns/op 261.86 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 47043211 77.19 ns/op 570.01 MB/s Benchmark_____Pub32b_Payload-16 44552779 79.24 ns/op 555.30 MB/s Benchmark_____Pub32b_Payload-16 46532833 84.05 ns/op 523.49 MB/s Benchmark_____Pub32b_Payload-16 38490901 81.10 ns/op 542.53 MB/s Benchmark_____Pub32b_Payload-16 44564347 76.45 ns/op 575.57 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39652897 85.69 ns/op 1645.50 MB/s Benchmark____Pub128B_Payload-16 34180482 92.90 ns/op 1517.84 MB/s Benchmark____Pub128B_Payload-16 41555054 85.92 ns/op 1641.05 MB/s Benchmark____Pub128B_Payload-16 38798840 85.46 ns/op 1649.88 MB/s Benchmark____Pub128B_Payload-16 41903431 86.38 ns/op 1632.27 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35295688 93.15 ns/op 2887.83 MB/s Benchmark____Pub256B_Payload-16 38206255 93.44 ns/op 2878.92 MB/s Benchmark____Pub256B_Payload-16 37305916 94.58 ns/op 2844.27 MB/s Benchmark____Pub256B_Payload-16 38421771 93.50 ns/op 2877.07 MB/s Benchmark____Pub256B_Payload-16 31755594 103.8 ns/op 2592.18 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 22767560 134.3 ns/op 7727.64 MB/s Benchmark______Pub1K_Payload-16 25779727 140.0 ns/op 7413.60 MB/s Benchmark______Pub1K_Payload-16 22233710 157.8 ns/op 6578.01 MB/s Benchmark______Pub1K_Payload-16 25957635 136.1 ns/op 7626.20 MB/s Benchmark______Pub1K_Payload-16 24063618 134.4 ns/op 7722.67 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5356759 619.3 ns/op 6636.81 MB/s Benchmark______Pub4K_Payload-16 5519811 624.7 ns/op 6579.64 MB/s Benchmark______Pub4K_Payload-16 5257567 627.0 ns/op 6555.13 MB/s Benchmark______Pub4K_Payload-16 5672863 621.9 ns/op 6608.63 MB/s Benchmark______Pub4K_Payload-16 5287876 628.1 ns/op 6543.42 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2747544 1270 ns/op 6458.95 MB/s Benchmark______Pub8K_Payload-16 2737357 1286 ns/op 6381.02 MB/s Benchmark______Pub8K_Payload-16 2785598 1278 ns/op 6421.89 MB/s Benchmark______Pub8K_Payload-16 2783968 1270 ns/op 6461.61 MB/s Benchmark______Pub8K_Payload-16 2770214 1290 ns/op 6360.37 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 665677 5437 ns/op 6029.31 MB/s Benchmark_____Pub32K_Payload-16 565927 5484 ns/op 5977.56 MB/s Benchmark_____Pub32K_Payload-16 658501 5476 ns/op 5987.10 MB/s Benchmark_____Pub32K_Payload-16 653913 5477 ns/op 5985.06 MB/s Benchmark_____Pub32K_Payload-16 642220 5629 ns/op 5823.45 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32887021 91.98 ns/op 119.59 MB/s Benchmark__AuthPub0b_Payload-16 37263926 92.45 ns/op 118.98 MB/s Benchmark__AuthPub0b_Payload-16 37217520 92.33 ns/op 119.14 MB/s Benchmark__AuthPub0b_Payload-16 35107594 92.24 ns/op 119.26 MB/s Benchmark__AuthPub0b_Payload-16 37030713 92.03 ns/op 119.53 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15590756 227.5 ns/op Benchmark_____________PubSub-16 15528577 227.7 ns/op Benchmark_____________PubSub-16 15530683 228.3 ns/op Benchmark_____________PubSub-16 15454606 229.8 ns/op Benchmark_____________PubSub-16 15651007 229.5 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15377007 227.8 ns/op Benchmark_____PubSubTwoConns-16 15551708 227.7 ns/op Benchmark_____PubSubTwoConns-16 15590847 226.0 ns/op Benchmark_____PubSubTwoConns-16 15695769 226.0 ns/op Benchmark_____PubSubTwoConns-16 15709987 225.8 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51236->127.0.0.1:39597: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:33182->127.0.0.1:43587: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:60508->127.0.0.1:40003: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:43052->127.0.0.1:35859: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46334->127.0.0.1:45463: 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 14433879 247.7 ns/op Benchmark_____PubTwoQueueSub-16 14338652 246.8 ns/op Benchmark_____PubTwoQueueSub-16 14373589 247.1 ns/op Benchmark_____PubTwoQueueSub-16 14270404 246.7 ns/op Benchmark_____PubTwoQueueSub-16 14187967 247.2 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14243764 247.9 ns/op Benchmark____PubFourQueueSub-16 14071178 246.7 ns/op Benchmark____PubFourQueueSub-16 14317444 246.4 ns/op Benchmark____PubFourQueueSub-16 14130538 246.7 ns/op Benchmark____PubFourQueueSub-16 14323212 247.6 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14133170 247.6 ns/op Benchmark___PubEightQueueSub-16 14281131 248.3 ns/op Benchmark___PubEightQueueSub-16 14451774 246.8 ns/op Benchmark___PubEightQueueSub-16 14528259 249.1 ns/op Benchmark___PubEightQueueSub-16 14151523 248.4 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 22500 154081 ns/op Benchmark_PubSub512kTwoConns-16 23646 153561 ns/op Benchmark_PubSub512kTwoConns-16 23642 152485 ns/op Benchmark_PubSub512kTwoConns-16 23415 153095 ns/op Benchmark_PubSub512kTwoConns-16 22059 154036 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15172066 229.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15098984 229.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 14878520 230.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15185074 229.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 15138931 229.5 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15067078 232.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15284821 231.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15032566 229.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15177146 230.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15119774 230.0 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11208982 316.5 ns/op Benchmark____RoutedPubSub_0b-16 11093570 319.3 ns/op Benchmark____RoutedPubSub_0b-16 10923848 316.6 ns/op Benchmark____RoutedPubSub_0b-16 11041694 319.9 ns/op Benchmark____RoutedPubSub_0b-16 11107778 316.8 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6557108 540.8 ns/op Benchmark____RoutedPubSub_1K-16 6570598 538.7 ns/op Benchmark____RoutedPubSub_1K-16 6612498 537.3 ns/op Benchmark____RoutedPubSub_1K-16 6746842 536.9 ns/op Benchmark____RoutedPubSub_1K-16 6623632 531.1 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84372 43224 ns/op Benchmark__RoutedPubSub_100K-16 82830 42702 ns/op Benchmark__RoutedPubSub_100K-16 85502 41235 ns/op Benchmark__RoutedPubSub_100K-16 87340 40767 ns/op Benchmark__RoutedPubSub_100K-16 85334 42158 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9752866 328.4 ns/op Benchmark____Routed2QueueSub-16 9756212 319.5 ns/op Benchmark____Routed2QueueSub-16 9758820 315.0 ns/op Benchmark____Routed2QueueSub-16 9796353 326.9 ns/op Benchmark____Routed2QueueSub-16 9997447 319.3 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9527998 324.6 ns/op Benchmark____Routed4QueueSub-16 9651177 320.1 ns/op Benchmark____Routed4QueueSub-16 9194337 327.4 ns/op Benchmark____Routed4QueueSub-16 9453926 326.2 ns/op Benchmark____Routed4QueueSub-16 9463780 328.1 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9349551 328.6 ns/op Benchmark____Routed8QueueSub-16 9167746 331.9 ns/op Benchmark____Routed8QueueSub-16 9378008 334.5 ns/op Benchmark____Routed8QueueSub-16 9432838 334.4 ns/op Benchmark____Routed8QueueSub-16 9213576 339.0 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 10575028 346.0 ns/op Benchmark___Routed16QueueSub-16 8606324 348.7 ns/op Benchmark___Routed16QueueSub-16 10390042 348.9 ns/op Benchmark___Routed16QueueSub-16 10520986 345.5 ns/op Benchmark___Routed16QueueSub-16 8655267 357.3 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6255634 557.8 ns/op Benchmark____________RouteCompressOff-16 6342752 550.3 ns/op Benchmark____________RouteCompressOff-16 6410750 547.7 ns/op Benchmark____________RouteCompressOff-16 6430519 550.1 ns/op Benchmark____________RouteCompressOff-16 6366138 551.5 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6446198 552.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6357309 551.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6428092 558.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6413208 543.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6453886 558.6 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6479167 555.1 ns/op Benchmark_________RouteCompressS2Fast-16 6399160 562.1 ns/op Benchmark_________RouteCompressS2Fast-16 6399787 553.1 ns/op Benchmark_________RouteCompressS2Fast-16 6466520 557.3 ns/op Benchmark_________RouteCompressS2Fast-16 6410593 548.0 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6504294 548.9 ns/op Benchmark_______RouteCompressS2Better-16 6271015 549.0 ns/op Benchmark_______RouteCompressS2Better-16 6433455 547.6 ns/op Benchmark_______RouteCompressS2Better-16 6563055 550.0 ns/op Benchmark_______RouteCompressS2Better-16 6592806 555.1 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6626726 556.6 ns/op Benchmark_________RouteCompressS2Best-16 6549243 549.0 ns/op Benchmark_________RouteCompressS2Best-16 6531471 549.8 ns/op Benchmark_________RouteCompressS2Best-16 6494420 550.9 ns/op Benchmark_________RouteCompressS2Best-16 6434557 550.2 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4634835 777.8 ns/op 320.12 MB/s Benchmark______FanOut_8x1x10-16 4631108 778.8 ns/op 319.73 MB/s Benchmark______FanOut_8x1x10-16 4626567 774.4 ns/op 321.55 MB/s Benchmark______FanOut_8x1x10-16 4636730 772.9 ns/op 322.16 MB/s Benchmark______FanOut_8x1x10-16 4586132 774.1 ns/op 321.67 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 548983 6296 ns/op 368.34 MB/s Benchmark_____FanOut_8x1x100-16 541831 6194 ns/op 374.39 MB/s Benchmark_____FanOut_8x1x100-16 516945 6308 ns/op 367.62 MB/s Benchmark_____FanOut_8x1x100-16 558086 6244 ns/op 371.41 MB/s Benchmark_____FanOut_8x1x100-16 518871 6172 ns/op 375.72 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 46470 77151 ns/op 298.36 MB/s Benchmark____FanOut_8x10x100-16 46468 76989 ns/op 298.99 MB/s Benchmark____FanOut_8x10x100-16 46255 77967 ns/op 295.24 MB/s Benchmark____FanOut_8x10x100-16 46138 77181 ns/op 298.25 MB/s Benchmark____FanOut_8x10x100-16 46700 77735 ns/op 296.12 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5514 626830 ns/op 382.91 MB/s Benchmark___FanOut_8x10x1000-16 5400 626151 ns/op 383.32 MB/s Benchmark___FanOut_8x10x1000-16 5544 622170 ns/op 385.78 MB/s Benchmark___FanOut_8x10x1000-16 5586 622422 ns/op 385.62 MB/s Benchmark___FanOut_8x10x1000-16 5721 627312 ns/op 382.62 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4807 750794 ns/op 306.37 MB/s Benchmark___FanOut_8x100x100-16 4870 734491 ns/op 313.17 MB/s Benchmark___FanOut_8x100x100-16 4860 738326 ns/op 311.54 MB/s Benchmark___FanOut_8x100x100-16 4869 733947 ns/op 313.40 MB/s Benchmark___FanOut_8x100x100-16 4815 743129 ns/op 309.53 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 546 6480014 ns/op 370.37 MB/s Benchmark__FanOut_8x100x1000-16 542 6460474 ns/op 371.49 MB/s Benchmark__FanOut_8x100x1000-16 553 6513263 ns/op 368.48 MB/s Benchmark__FanOut_8x100x1000-16 550 6540624 ns/op 366.94 MB/s Benchmark__FanOut_8x100x1000-16 544 6499890 ns/op 369.24 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 522 6986985 ns/op 357.81 MB/s Benchmark__FanOut_8x10x10000-16 525 6978802 ns/op 358.23 MB/s Benchmark__FanOut_8x10x10000-16 507 7048452 ns/op 354.69 MB/s Benchmark__FanOut_8x10x10000-16 500 7071314 ns/op 353.54 MB/s Benchmark__FanOut_8x10x10000-16 508 7108039 ns/op 351.72 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 918 3903413 ns/op 294.62 MB/s Benchmark___FanOut_8x500x100-16 919 3863291 ns/op 297.68 MB/s Benchmark___FanOut_8x500x100-16 916 3851288 ns/op 298.61 MB/s Benchmark___FanOut_8x500x100-16 928 3857890 ns/op 298.10 MB/s Benchmark___FanOut_8x500x100-16 934 3854439 ns/op 298.36 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 352089 9609 ns/op 1523.61 MB/s Benchmark___FanOut_128x1x100-16 358444 9595 ns/op 1525.95 MB/s Benchmark___FanOut_128x1x100-16 359084 9681 ns/op 1512.40 MB/s Benchmark___FanOut_128x1x100-16 363304 9670 ns/op 1514.00 MB/s Benchmark___FanOut_128x1x100-16 355226 9604 ns/op 1524.51 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 31960 113340 ns/op 1280.58 MB/s Benchmark__FanOut_128x10x100-16 31989 112753 ns/op 1287.24 MB/s Benchmark__FanOut_128x10x100-16 31908 113562 ns/op 1278.07 MB/s Benchmark__FanOut_128x10x100-16 31926 112520 ns/op 1289.91 MB/s Benchmark__FanOut_128x10x100-16 31816 112918 ns/op 1285.37 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3900 903662 ns/op 1615.80 MB/s Benchmark_FanOut_128x10x1000-16 3985 913016 ns/op 1599.25 MB/s Benchmark_FanOut_128x10x1000-16 3920 892693 ns/op 1635.66 MB/s Benchmark_FanOut_128x10x1000-16 3922 898936 ns/op 1624.30 MB/s Benchmark_FanOut_128x10x1000-16 3980 892617 ns/op 1635.80 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3436 1027684 ns/op 1411.08 MB/s Benchmark_FanOut_128x100x100-16 3392 1033394 ns/op 1403.28 MB/s Benchmark_FanOut_128x100x100-16 3460 1031061 ns/op 1406.46 MB/s Benchmark_FanOut_128x100x100-16 3367 1032283 ns/op 1404.79 MB/s Benchmark_FanOut_128x100x100-16 3396 1036361 ns/op 1399.26 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 375 9631848 ns/op 1515.82 MB/s BenchmarkFanOut_128x100x1000-16 375 9603164 ns/op 1520.35 MB/s BenchmarkFanOut_128x100x1000-16 362 9559927 ns/op 1527.22 MB/s BenchmarkFanOut_128x100x1000-16 379 9556687 ns/op 1527.74 MB/s BenchmarkFanOut_128x100x1000-16 369 9489914 ns/op 1538.49 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 357 9902381 ns/op 1484.51 MB/s BenchmarkFanOut_128x10x10000-16 361 9896226 ns/op 1485.43 MB/s BenchmarkFanOut_128x10x10000-16 361 10068609 ns/op 1460.00 MB/s BenchmarkFanOut_128x10x10000-16 363 10119530 ns/op 1452.65 MB/s BenchmarkFanOut_128x10x10000-16 360 9895646 ns/op 1485.52 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 652 5408498 ns/op 1340.51 MB/s BenchmarkFanOut__128x500x100-16 656 5414922 ns/op 1338.92 MB/s BenchmarkFanOut__128x500x100-16 664 5379360 ns/op 1347.77 MB/s BenchmarkFanOut__128x500x100-16 645 5398858 ns/op 1342.90 MB/s BenchmarkFanOut__128x500x100-16 663 5385257 ns/op 1346.29 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1893 1862772 ns/op 2840.14 MB/s Benchmark_FanOut_512x100x100-16 1912 1868048 ns/op 2832.11 MB/s Benchmark_FanOut_512x100x100-16 1908 1844616 ns/op 2868.09 MB/s Benchmark_FanOut_512x100x100-16 1897 1863635 ns/op 2838.82 MB/s Benchmark_FanOut_512x100x100-16 1902 1861779 ns/op 2841.65 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 211 17082590 ns/op 3102.60 MB/s Benchmark__FanOut_512x100x1k-16 211 17184016 ns/op 3084.29 MB/s Benchmark__FanOut_512x100x1k-16 208 17041951 ns/op 3110.00 MB/s Benchmark__FanOut_512x100x1k-16 211 17196616 ns/op 3082.03 MB/s Benchmark__FanOut_512x100x1k-16 208 17058694 ns/op 3106.95 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3201 1174320 ns/op 8882.62 MB/s Benchmark____FanOut_1kx10x1k-16 3073 1167022 ns/op 8938.17 MB/s Benchmark____FanOut_1kx10x1k-16 3109 1160429 ns/op 8988.95 MB/s Benchmark____FanOut_1kx10x1k-16 2823 1156982 ns/op 9015.73 MB/s Benchmark____FanOut_1kx10x1k-16 2976 1162224 ns/op 8975.07 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2794 1281234 ns/op 8133.59 MB/s Benchmark__FanOut_1kx100x100-16 2802 1279222 ns/op 8146.39 MB/s Benchmark__FanOut_1kx100x100-16 2768 1276849 ns/op 8161.53 MB/s Benchmark__FanOut_1kx100x100-16 2700 1279961 ns/op 8141.68 MB/s Benchmark__FanOut_1kx100x100-16 2780 1275409 ns/op 8170.74 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4517320 788.1 ns/op 315.95 MB/s Benchmark_____RFanOut_8x1x10-16 4464957 788.0 ns/op 315.98 MB/s Benchmark_____RFanOut_8x1x10-16 4474812 789.3 ns/op 315.49 MB/s Benchmark_____RFanOut_8x1x10-16 4353314 781.7 ns/op 318.56 MB/s Benchmark_____RFanOut_8x1x10-16 4281766 805.0 ns/op 309.33 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 531762 6257 ns/op 370.62 MB/s Benchmark____RFanOut_8x1x100-16 535570 6408 ns/op 361.87 MB/s Benchmark____RFanOut_8x1x100-16 549529 6240 ns/op 371.65 MB/s Benchmark____RFanOut_8x1x100-16 513402 6269 ns/op 369.91 MB/s Benchmark____RFanOut_8x1x100-16 528994 6272 ns/op 369.72 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46101 78720 ns/op 292.42 MB/s Benchmark___RFanOut_8x10x100-16 46712 77766 ns/op 296.00 MB/s Benchmark___RFanOut_8x10x100-16 45332 79272 ns/op 290.38 MB/s Benchmark___RFanOut_8x10x100-16 45937 78430 ns/op 293.50 MB/s Benchmark___RFanOut_8x10x100-16 46126 77760 ns/op 296.03 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5462 636712 ns/op 376.97 MB/s Benchmark__RFanOut_8x10x1000-16 5260 636974 ns/op 376.81 MB/s Benchmark__RFanOut_8x10x1000-16 5476 625752 ns/op 383.57 MB/s Benchmark__RFanOut_8x10x1000-16 5636 638073 ns/op 376.16 MB/s Benchmark__RFanOut_8x10x1000-16 5640 624667 ns/op 384.23 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4765 732327 ns/op 314.09 MB/s Benchmark__RFanOut_8x100x100-16 4885 738352 ns/op 311.53 MB/s Benchmark__RFanOut_8x100x100-16 4863 740987 ns/op 310.42 MB/s Benchmark__RFanOut_8x100x100-16 4826 729966 ns/op 315.11 MB/s Benchmark__RFanOut_8x100x100-16 4770 736396 ns/op 312.36 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 529 6531046 ns/op 367.48 MB/s Benchmark_RFanOut_8x100x1000-16 540 6592431 ns/op 364.06 MB/s Benchmark_RFanOut_8x100x1000-16 552 6670189 ns/op 359.81 MB/s Benchmark_RFanOut_8x100x1000-16 543 6510541 ns/op 368.64 MB/s Benchmark_RFanOut_8x100x1000-16 544 6590851 ns/op 364.14 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 502 6961539 ns/op 359.12 MB/s Benchmark_RFanOut_8x10x10000-16 510 7112874 ns/op 351.48 MB/s Benchmark_RFanOut_8x10x10000-16 512 6865560 ns/op 364.14 MB/s Benchmark_RFanOut_8x10x10000-16 502 7181947 ns/op 348.10 MB/s Benchmark_RFanOut_8x10x10000-16 506 6913960 ns/op 361.59 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2929 1178678 ns/op 8849.78 MB/s Benchmark_RFanOut_1kx10x1000-16 3115 1179293 ns/op 8845.16 MB/s Benchmark_RFanOut_1kx10x1000-16 3015 1163905 ns/op 8962.10 MB/s Benchmark_RFanOut_1kx10x1000-16 3124 1164986 ns/op 8953.78 MB/s Benchmark_RFanOut_1kx10x1000-16 2835 1176404 ns/op 8866.89 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7013473 519.1 ns/op 4003.37 MB/s Benchmark_____FanIn_1kx100x1-16 6902724 507.3 ns/op 4095.79 MB/s Benchmark_____FanIn_1kx100x1-16 6915402 505.9 ns/op 4107.73 MB/s Benchmark_____FanIn_1kx100x1-16 6914228 505.4 ns/op 4111.51 MB/s Benchmark_____FanIn_1kx100x1-16 6884106 504.8 ns/op 4116.26 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2624325 1369 ns/op 6007.13 MB/s Benchmark_____FanIn_4kx100x1-16 2556530 1361 ns/op 6043.30 MB/s Benchmark_____FanIn_4kx100x1-16 2637212 1386 ns/op 5931.37 MB/s Benchmark_____FanIn_4kx100x1-16 2611002 1388 ns/op 5925.12 MB/s Benchmark_____FanIn_4kx100x1-16 2635868 1369 ns/op 6004.92 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1717849 2103 ns/op 7805.00 MB/s Benchmark_____FanIn_8kx100x1-16 1726611 2114 ns/op 7765.26 MB/s Benchmark_____FanIn_8kx100x1-16 1684710 2111 ns/op 7776.03 MB/s Benchmark_____FanIn_8kx100x1-16 1704049 2110 ns/op 7777.52 MB/s Benchmark_____FanIn_8kx100x1-16 1682655 2145 ns/op 7651.41 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 882034 4146 ns/op 7910.90 MB/s Benchmark____FanIn_16kx100x1-16 857268 4152 ns/op 7899.93 MB/s Benchmark____FanIn_16kx100x1-16 865021 4166 ns/op 7872.84 MB/s Benchmark____FanIn_16kx100x1-16 868719 4181 ns/op 7845.66 MB/s Benchmark____FanIn_16kx100x1-16 870271 4210 ns/op 7790.59 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 173677 19891 ns/op 6591.24 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 6409968999 vs 10809689700 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55200->127.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:55622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55280->127.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:55882->127.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: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:55956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55658->127.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:55816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55384->127.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: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:55542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55844->127.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:55466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55352->127.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: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:55474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55324->127.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:55946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55364->127.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:55170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55976->127.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:55574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55712->127.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:55608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55826->127.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:55220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56010->127.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 --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 167792 19882 ns/op 6594.10 MB/s Benchmark____FanIn_64kx100x1-16 166665 20080 ns/op 6528.95 MB/s Benchmark____FanIn_64kx100x1-16 169766 19977 ns/op 6562.89 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 321301590 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40562->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:41336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:41034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40776->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: 554641790 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42576->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: 551233450 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:45034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44648->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:44396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44214->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: 130303460 vs 11404830000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47142->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: 192964480 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48996->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5596606 640.4 ns/op 443.48 MB/s Benchmark___BumpPubCount_1x3-16 5550967 642.0 ns/op 442.36 MB/s Benchmark___BumpPubCount_1x3-16 5594378 639.6 ns/op 444.00 MB/s Benchmark___BumpPubCount_1x3-16 5596045 640.5 ns/op 443.41 MB/s Benchmark___BumpPubCount_1x3-16 5622662 640.8 ns/op 443.17 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5328492 674.5 ns/op 421.05 MB/s Benchmark___BumpPubCount_2x3-16 5284388 676.6 ns/op 419.76 MB/s Benchmark___BumpPubCount_2x3-16 5277148 675.5 ns/op 420.45 MB/s Benchmark___BumpPubCount_2x3-16 5252274 675.0 ns/op 420.72 MB/s Benchmark___BumpPubCount_2x3-16 5296442 677.5 ns/op 419.21 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5545036 646.9 ns/op 439.03 MB/s Benchmark___BumpPubCount_5x3-16 5412627 647.3 ns/op 438.74 MB/s Benchmark___BumpPubCount_5x3-16 5123253 646.7 ns/op 439.14 MB/s Benchmark___BumpPubCount_5x3-16 5225707 647.5 ns/op 438.64 MB/s Benchmark___BumpPubCount_5x3-16 5359318 650.6 ns/op 436.50 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5566102 644.1 ns/op 440.92 MB/s Benchmark__BumpPubCount_10x3-16 5561192 642.6 ns/op 441.96 MB/s Benchmark__BumpPubCount_10x3-16 5569234 646.0 ns/op 439.65 MB/s Benchmark__BumpPubCount_10x3-16 5574478 644.3 ns/op 440.80 MB/s Benchmark__BumpPubCount_10x3-16 5557639 646.2 ns/op 439.51 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12016885 270.0 ns/op 3851.67 MB/s Benchmark____GWs_Opt_1kx01x0-16 13037524 277.1 ns/op 3753.01 MB/s Benchmark____GWs_Opt_1kx01x0-16 13130732 270.5 ns/op 3844.06 MB/s Benchmark____GWs_Opt_1kx01x0-16 11589325 275.2 ns/op 3779.65 MB/s Benchmark____GWs_Opt_1kx01x0-16 12777388 274.7 ns/op 3785.28 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10419508 312.6 ns/op 6603.71 MB/s Benchmark____GWs_Opt_2kx01x0-16 10323218 342.2 ns/op 6032.16 MB/s Benchmark____GWs_Opt_2kx01x0-16 10335019 322.1 ns/op 6408.92 MB/s Benchmark____GWs_Opt_2kx01x0-16 10541553 324.8 ns/op 6355.57 MB/s Benchmark____GWs_Opt_2kx01x0-16 9513538 322.4 ns/op 6401.40 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5747833 622.7 ns/op 6603.80 MB/s Benchmark____GWs_Opt_4kx01x0-16 5898367 621.4 ns/op 6617.68 MB/s Benchmark____GWs_Opt_4kx01x0-16 5728140 621.8 ns/op 6613.25 MB/s Benchmark____GWs_Opt_4kx01x0-16 5779090 598.4 ns/op 6872.17 MB/s Benchmark____GWs_Opt_4kx01x0-16 5821586 607.2 ns/op 6772.09 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28420014 111.3 ns/op 9339.97 MB/s Benchmark____GWs_Opt_1kx10x0-16 26969072 143.4 ns/op 7253.72 MB/s Benchmark____GWs_Opt_1kx10x0-16 30880570 111.2 ns/op 9354.03 MB/s Benchmark____GWs_Opt_1kx10x0-16 31187203 112.3 ns/op 9264.07 MB/s Benchmark____GWs_Opt_1kx10x0-16 32978926 113.9 ns/op 9129.44 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23733714 155.7 ns/op 13252.43 MB/s Benchmark____GWs_Opt_2kx10x0-16 24413631 151.5 ns/op 13627.93 MB/s Benchmark____GWs_Opt_2kx10x0-16 23816772 158.0 ns/op 13059.64 MB/s Benchmark____GWs_Opt_2kx10x0-16 24374280 148.2 ns/op 13927.88 MB/s Benchmark____GWs_Opt_2kx10x0-16 26175987 148.1 ns/op 13937.12 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 9195915 357.1 ns/op 11513.39 MB/s Benchmark____GWs_Opt_4kx10x0-16 11622298 295.8 ns/op 13900.93 MB/s Benchmark____GWs_Opt_4kx10x0-16 10777346 290.0 ns/op 14180.29 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:42368->127.0.0.1:34913: 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:34978->127.0.0.1:33893: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 5635959 535.3 ns/op 7681.39 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6551557 548.8 ns/op 5694.28 MB/s Benchmark____GWs_Opt_1kx01x1-16 6400436 549.9 ns/op 5682.83 MB/s Benchmark____GWs_Opt_1kx01x1-16 6658603 551.8 ns/op 5662.93 MB/s Benchmark____GWs_Opt_1kx01x1-16 6730491 555.2 ns/op 5628.19 MB/s Benchmark____GWs_Opt_1kx01x1-16 6471381 546.5 ns/op 5718.58 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4628840 833.5 ns/op 7435.25 MB/s Benchmark____GWs_Opt_2kx01x1-16 4762027 755.9 ns/op 8198.46 MB/s Benchmark____GWs_Opt_2kx01x1-16 4576182 880.6 ns/op 7037.55 MB/s Benchmark____GWs_Opt_2kx01x1-16 4659303 755.9 ns/op 8198.04 MB/s Benchmark____GWs_Opt_2kx01x1-16 4742176 759.7 ns/op 8157.57 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2629134 1359 ns/op 9083.02 MB/s Benchmark____GWs_Opt_4kx01x1-16 2367598 1345 ns/op 9175.24 MB/s Benchmark____GWs_Opt_4kx01x1-16 2566778 1368 ns/op 9021.45 MB/s Benchmark____GWs_Opt_4kx01x1-16 2647735 1594 ns/op 7740.06 MB/s Benchmark____GWs_Opt_4kx01x1-16 2575304 1373 ns/op 8988.16 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6589903 561.8 ns/op 5562.42 MB/s Benchmark____GWs_Opt_1kx10x1-16 6162745 555.5 ns/op 5625.29 MB/s Benchmark____GWs_Opt_1kx10x1-16 6014402 560.6 ns/op 5574.64 MB/s Benchmark____GWs_Opt_1kx10x1-16 6247928 554.5 ns/op 5635.89 MB/s Benchmark____GWs_Opt_1kx10x1-16 6209701 559.1 ns/op 5589.01 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4099236 837.9 ns/op 7396.09 MB/s Benchmark____GWs_Opt_2kx10x1-16 4055024 839.2 ns/op 7384.29 MB/s Benchmark____GWs_Opt_2kx10x1-16 4487115 857.8 ns/op 7224.04 MB/s Benchmark____GWs_Opt_2kx10x1-16 4112905 807.1 ns/op 7678.45 MB/s Benchmark____GWs_Opt_2kx10x1-16 4138620 843.4 ns/op 7347.76 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2287012 1524 ns/op 8097.19 MB/s Benchmark____GWs_Opt_4kx10x1-16 2329140 1525 ns/op 8093.95 MB/s Benchmark____GWs_Opt_4kx10x1-16 2218726 1518 ns/op 8130.87 MB/s Benchmark____GWs_Opt_4kx10x1-16 2379428 1528 ns/op 8078.23 MB/s Benchmark____GWs_Opt_4kx10x1-16 2418590 1527 ns/op 8080.68 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12193197 281.7 ns/op 3692.51 MB/s Benchmark____GWs_Int_1kx01x0-16 12792370 285.0 ns/op 3648.56 MB/s Benchmark____GWs_Int_1kx01x0-16 12382556 278.2 ns/op 3738.96 MB/s Benchmark____GWs_Int_1kx01x0-16 12023060 281.6 ns/op 3693.47 MB/s Benchmark____GWs_Int_1kx01x0-16 12490828 291.9 ns/op 3563.09 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9899637 371.7 ns/op 5552.78 MB/s Benchmark____GWs_Int_2kx01x0-16 9835862 351.6 ns/op 5870.86 MB/s Benchmark____GWs_Int_2kx01x0-16 9960230 350.2 ns/op 5893.89 MB/s Benchmark____GWs_Int_2kx01x0-16 9426016 365.5 ns/op 5647.63 MB/s Benchmark____GWs_Int_2kx01x0-16 9030042 374.2 ns/op 5515.94 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5746558 627.5 ns/op 6553.44 MB/s Benchmark____GWs_Int_4kx01x0-16 5700584 617.2 ns/op 6662.04 MB/s Benchmark____GWs_Int_4kx01x0-16 5209392 812.5 ns/op 5061.08 MB/s Benchmark____GWs_Int_4kx01x0-16 5831865 614.6 ns/op 6691.04 MB/s Benchmark____GWs_Int_4kx01x0-16 5743708 647.8 ns/op 6347.70 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31258256 117.3 ns/op 8866.16 MB/s Benchmark____GWs_Int_1kx10x0-16 29353627 111.1 ns/op 9359.59 MB/s Benchmark____GWs_Int_1kx10x0-16 31100401 113.8 ns/op 9142.51 MB/s Benchmark____GWs_Int_1kx10x0-16 31172187 108.9 ns/op 9548.20 MB/s Benchmark____GWs_Int_1kx10x0-16 29929584 111.7 ns/op 9308.72 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25898523 142.3 ns/op 14508.73 MB/s Benchmark____GWs_Int_2kx10x0-16 25439454 152.3 ns/op 13553.76 MB/s Benchmark____GWs_Int_2kx10x0-16 23662390 146.8 ns/op 14059.04 MB/s Benchmark____GWs_Int_2kx10x0-16 24454315 138.0 ns/op 14952.66 MB/s Benchmark____GWs_Int_2kx10x0-16 26377737 140.5 ns/op 14691.22 MB/s Benchmark____GWs_Int_4kx10x0 bench_test.go:55: Failed read: read tcp 127.0.0.1:34902->127.0.0.1:39675: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 11362396 291.3 ns/op 14118.29 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:54708->127.0.0.1:37903: 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:33078->127.0.0.1:34719: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 bench_test.go:55: Failed read: read tcp 127.0.0.1:57578->127.0.0.1:34163: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 5423850 589.9 ns/op 6970.46 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6296469 557.4 ns/op 5606.89 MB/s Benchmark____GWs_Int_1kx01x1-16 6280506 551.1 ns/op 5670.75 MB/s Benchmark____GWs_Int_1kx01x1-16 6260901 563.5 ns/op 5545.41 MB/s Benchmark____GWs_Int_1kx01x1-16 6425229 554.7 ns/op 5633.72 MB/s Benchmark____GWs_Int_1kx01x1-16 6382521 566.7 ns/op 5514.06 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4604104 767.0 ns/op 8079.79 MB/s Benchmark____GWs_Int_2kx01x1-16 4668997 762.6 ns/op 8126.36 MB/s Benchmark____GWs_Int_2kx01x1-16 4776655 779.3 ns/op 7951.59 MB/s Benchmark____GWs_Int_2kx01x1-16 4759903 764.5 ns/op 8106.29 MB/s Benchmark____GWs_Int_2kx01x1-16 4596728 767.2 ns/op 8077.85 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2585514 1370 ns/op 9005.82 MB/s Benchmark____GWs_Int_4kx01x1-16 2548719 1409 ns/op 8756.79 MB/s Benchmark____GWs_Int_4kx01x1-16 2611808 1366 ns/op 9033.03 MB/s Benchmark____GWs_Int_4kx01x1-16 2644977 1372 ns/op 8993.94 MB/s Benchmark____GWs_Int_4kx01x1-16 2652009 1384 ns/op 8916.73 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6516172 557.1 ns/op 5609.43 MB/s Benchmark____GWs_Int_1kx10x1-16 6221206 563.3 ns/op 5547.20 MB/s Benchmark____GWs_Int_1kx10x1-16 6398992 554.7 ns/op 5633.94 MB/s Benchmark____GWs_Int_1kx10x1-16 6508424 559.0 ns/op 5590.49 MB/s Benchmark____GWs_Int_1kx10x1-16 5700096 565.9 ns/op 5522.33 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4153158 846.1 ns/op 7324.47 MB/s Benchmark____GWs_Int_2kx10x1-16 4141960 848.5 ns/op 7303.74 MB/s Benchmark____GWs_Int_2kx10x1-16 4120036 851.3 ns/op 7279.86 MB/s Benchmark____GWs_Int_2kx10x1-16 4068189 841.9 ns/op 7361.00 MB/s Benchmark____GWs_Int_2kx10x1-16 4143410 853.4 ns/op 7261.52 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2141528 1528 ns/op 8075.91 MB/s Benchmark____GWs_Int_4kx10x1-16 2311540 1574 ns/op 7839.61 MB/s Benchmark____GWs_Int_4kx10x1-16 2427034 1526 ns/op 8087.50 MB/s Benchmark____GWs_Int_4kx10x1-16 2262129 1546 ns/op 7982.69 MB/s Benchmark____GWs_Int_4kx10x1-16 2314686 1519 ns/op 8126.57 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 7973086 426.8 ns/op 238.98 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8295447 434.6 ns/op 234.69 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8354780 433.3 ns/op 235.41 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8248654 432.4 ns/op 235.90 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8236441 432.9 ns/op 235.61 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 710770 5071 ns/op 34.91 MB/s Benchmark__GWs_Reqs_1SubEach-16 744657 5324 ns/op 33.25 MB/s Benchmark__GWs_Reqs_1SubEach-16 728626 5251 ns/op 33.71 MB/s Benchmark__GWs_Reqs_1SubEach-16 765367 5357 ns/op 33.04 MB/s Benchmark__GWs_Reqs_1SubEach-16 747156 5299 ns/op 33.40 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2156.994s