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 49806555 72.14 ns/op 152.49 MB/s Benchmark______Pub0b_Payload-16 49672713 72.27 ns/op 152.20 MB/s Benchmark______Pub0b_Payload-16 47376913 72.52 ns/op 151.68 MB/s Benchmark______Pub0b_Payload-16 46970553 74.13 ns/op 148.39 MB/s Benchmark______Pub0b_Payload-16 45610106 72.74 ns/op 151.22 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46479789 73.26 ns/op 259.35 MB/s Benchmark______Pub8b_Payload-16 46634703 74.80 ns/op 254.00 MB/s Benchmark______Pub8b_Payload-16 46832870 72.75 ns/op 261.18 MB/s Benchmark______Pub8b_Payload-16 45284139 74.78 ns/op 254.06 MB/s Benchmark______Pub8b_Payload-16 46346956 72.77 ns/op 261.10 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44241549 77.18 ns/op 570.11 MB/s Benchmark_____Pub32b_Payload-16 46750213 78.27 ns/op 562.18 MB/s Benchmark_____Pub32b_Payload-16 44043796 77.12 ns/op 570.57 MB/s Benchmark_____Pub32b_Payload-16 43947458 77.11 ns/op 570.65 MB/s Benchmark_____Pub32b_Payload-16 44199786 77.17 ns/op 570.17 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38045112 86.79 ns/op 1624.60 MB/s Benchmark____Pub128B_Payload-16 41165512 87.54 ns/op 1610.60 MB/s Benchmark____Pub128B_Payload-16 38137982 86.54 ns/op 1629.22 MB/s Benchmark____Pub128B_Payload-16 34110129 92.55 ns/op 1523.55 MB/s Benchmark____Pub128B_Payload-16 34576587 88.87 ns/op 1586.58 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 34090339 105.5 ns/op 2549.40 MB/s Benchmark____Pub256B_Payload-16 30331785 101.0 ns/op 2664.21 MB/s Benchmark____Pub256B_Payload-16 35090601 95.10 ns/op 2828.69 MB/s Benchmark____Pub256B_Payload-16 35074798 94.88 ns/op 2835.04 MB/s Benchmark____Pub256B_Payload-16 36307519 101.5 ns/op 2650.52 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 25233307 150.0 ns/op 6920.96 MB/s Benchmark______Pub1K_Payload-16 25617343 144.4 ns/op 7187.80 MB/s Benchmark______Pub1K_Payload-16 26722124 140.8 ns/op 7370.56 MB/s Benchmark______Pub1K_Payload-16 24435788 136.6 ns/op 7596.93 MB/s Benchmark______Pub1K_Payload-16 26498340 144.6 ns/op 7178.37 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5616096 625.2 ns/op 6573.91 MB/s Benchmark______Pub4K_Payload-16 5554174 616.1 ns/op 6670.83 MB/s Benchmark______Pub4K_Payload-16 5361933 631.7 ns/op 6505.99 MB/s Benchmark______Pub4K_Payload-16 5670704 623.4 ns/op 6592.74 MB/s Benchmark______Pub4K_Payload-16 5902936 632.3 ns/op 6499.59 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2784512 1268 ns/op 6470.58 MB/s Benchmark______Pub8K_Payload-16 2712823 1272 ns/op 6452.07 MB/s Benchmark______Pub8K_Payload-16 2700931 1273 ns/op 6448.35 MB/s Benchmark______Pub8K_Payload-16 2771473 1273 ns/op 6444.57 MB/s Benchmark______Pub8K_Payload-16 2674028 1284 ns/op 6389.25 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 560919 5384 ns/op 6089.09 MB/s Benchmark_____Pub32K_Payload-16 676461 5478 ns/op 5984.29 MB/s Benchmark_____Pub32K_Payload-16 655776 5709 ns/op 5742.82 MB/s Benchmark_____Pub32K_Payload-16 645987 5574 ns/op 5881.28 MB/s Benchmark_____Pub32K_Payload-16 665019 9269 ns/op 3536.90 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 31958865 96.58 ns/op 113.89 MB/s Benchmark__AuthPub0b_Payload-16 32068876 94.19 ns/op 116.78 MB/s Benchmark__AuthPub0b_Payload-16 36391332 93.90 ns/op 117.15 MB/s Benchmark__AuthPub0b_Payload-16 36482024 93.73 ns/op 117.36 MB/s Benchmark__AuthPub0b_Payload-16 36591201 94.41 ns/op 116.51 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15244296 229.6 ns/op Benchmark_____________PubSub-16 15422974 229.5 ns/op Benchmark_____________PubSub-16 15490196 229.0 ns/op Benchmark_____________PubSub-16 15566286 230.1 ns/op Benchmark_____________PubSub-16 15474834 229.7 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15662270 227.9 ns/op Benchmark_____PubSubTwoConns-16 15450537 227.8 ns/op Benchmark_____PubSubTwoConns-16 15476422 228.3 ns/op Benchmark_____PubSubTwoConns-16 15577660 227.9 ns/op Benchmark_____PubSubTwoConns-16 15559494 229.0 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50934->127.0.0.1:41679: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:53226->127.0.0.1:44879: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:45940->127.0.0.1:45757: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57444->127.0.0.1:40573: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57176->127.0.0.1:39257: 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 14254795 250.7 ns/op Benchmark_____PubTwoQueueSub-16 14326089 249.4 ns/op Benchmark_____PubTwoQueueSub-16 14262657 249.7 ns/op Benchmark_____PubTwoQueueSub-16 14075480 250.2 ns/op Benchmark_____PubTwoQueueSub-16 14178608 250.2 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14221410 250.7 ns/op Benchmark____PubFourQueueSub-16 14181819 250.5 ns/op Benchmark____PubFourQueueSub-16 14149951 250.6 ns/op Benchmark____PubFourQueueSub-16 14141166 251.1 ns/op Benchmark____PubFourQueueSub-16 14149674 250.7 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14025534 251.1 ns/op Benchmark___PubEightQueueSub-16 14035672 250.2 ns/op Benchmark___PubEightQueueSub-16 14170952 251.0 ns/op Benchmark___PubEightQueueSub-16 14187070 251.7 ns/op Benchmark___PubEightQueueSub-16 14158214 250.8 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23168 156706 ns/op Benchmark_PubSub512kTwoConns-16 22551 157253 ns/op Benchmark_PubSub512kTwoConns-16 21504 154957 ns/op Benchmark_PubSub512kTwoConns-16 23397 156141 ns/op Benchmark_PubSub512kTwoConns-16 23091 154864 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15106486 229.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15063441 231.8 ns/op Benchmark__DenyMsgNoWCPubSub-16 15132615 231.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 14894866 232.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 14996437 232.3 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15249841 232.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 14607540 230.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15283116 231.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15036016 232.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15016774 232.0 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11346502 313.0 ns/op Benchmark____RoutedPubSub_0b-16 11560545 310.7 ns/op Benchmark____RoutedPubSub_0b-16 11197633 310.8 ns/op Benchmark____RoutedPubSub_0b-16 11433284 308.6 ns/op Benchmark____RoutedPubSub_0b-16 11324018 309.7 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6643760 527.3 ns/op Benchmark____RoutedPubSub_1K-16 6800898 528.6 ns/op Benchmark____RoutedPubSub_1K-16 6935130 531.8 ns/op Benchmark____RoutedPubSub_1K-16 6739004 550.3 ns/op Benchmark____RoutedPubSub_1K-16 6799764 531.0 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84397 42823 ns/op Benchmark__RoutedPubSub_100K-16 84487 44060 ns/op Benchmark__RoutedPubSub_100K-16 83001 42994 ns/op Benchmark__RoutedPubSub_100K-16 83557 42900 ns/op Benchmark__RoutedPubSub_100K-16 83575 41615 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9760311 319.4 ns/op Benchmark____Routed2QueueSub-16 10090262 313.9 ns/op Benchmark____Routed2QueueSub-16 11287666 317.8 ns/op Benchmark____Routed2QueueSub-16 9703533 312.2 ns/op Benchmark____Routed2QueueSub-16 9657687 325.1 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9343980 326.7 ns/op Benchmark____Routed4QueueSub-16 11304034 321.1 ns/op Benchmark____Routed4QueueSub-16 9448497 319.2 ns/op Benchmark____Routed4QueueSub-16 9479968 323.8 ns/op Benchmark____Routed4QueueSub-16 11424708 318.4 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9184402 334.2 ns/op Benchmark____Routed8QueueSub-16 9392850 327.9 ns/op Benchmark____Routed8QueueSub-16 9375944 334.0 ns/op Benchmark____Routed8QueueSub-16 9214732 329.3 ns/op Benchmark____Routed8QueueSub-16 9092670 330.6 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8876197 345.8 ns/op Benchmark___Routed16QueueSub-16 8941540 353.8 ns/op Benchmark___Routed16QueueSub-16 8662099 349.6 ns/op Benchmark___Routed16QueueSub-16 8788106 354.5 ns/op Benchmark___Routed16QueueSub-16 8881890 349.9 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6343354 549.1 ns/op Benchmark____________RouteCompressOff-16 6347673 549.8 ns/op Benchmark____________RouteCompressOff-16 6404685 552.7 ns/op Benchmark____________RouteCompressOff-16 6446682 550.2 ns/op Benchmark____________RouteCompressOff-16 6353506 551.5 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6575614 545.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6547665 552.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6536245 543.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6475312 555.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6391364 555.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6577116 539.4 ns/op Benchmark_________RouteCompressS2Fast-16 6378865 552.5 ns/op Benchmark_________RouteCompressS2Fast-16 6408100 545.4 ns/op Benchmark_________RouteCompressS2Fast-16 6300056 548.2 ns/op Benchmark_________RouteCompressS2Fast-16 6435627 550.2 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6349029 547.8 ns/op Benchmark_______RouteCompressS2Better-16 6564932 546.5 ns/op Benchmark_______RouteCompressS2Better-16 6435537 545.2 ns/op Benchmark_______RouteCompressS2Better-16 6537576 544.6 ns/op Benchmark_______RouteCompressS2Better-16 6344647 523.1 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6459769 544.0 ns/op Benchmark_________RouteCompressS2Best-16 6392971 544.0 ns/op Benchmark_________RouteCompressS2Best-16 6363264 540.7 ns/op Benchmark_________RouteCompressS2Best-16 6520344 545.2 ns/op Benchmark_________RouteCompressS2Best-16 6561286 541.5 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4651396 770.1 ns/op 323.34 MB/s Benchmark______FanOut_8x1x10-16 4693231 775.0 ns/op 321.30 MB/s Benchmark______FanOut_8x1x10-16 4623309 767.8 ns/op 324.29 MB/s Benchmark______FanOut_8x1x10-16 4635835 769.0 ns/op 323.80 MB/s Benchmark______FanOut_8x1x10-16 4592227 772.6 ns/op 322.28 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 539329 6088 ns/op 380.88 MB/s Benchmark_____FanOut_8x1x100-16 549093 6056 ns/op 382.91 MB/s Benchmark_____FanOut_8x1x100-16 557871 6054 ns/op 383.07 MB/s Benchmark_____FanOut_8x1x100-16 562196 6244 ns/op 371.38 MB/s Benchmark_____FanOut_8x1x100-16 535023 6221 ns/op 372.79 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48238 74606 ns/op 308.54 MB/s Benchmark____FanOut_8x10x100-16 46689 74637 ns/op 308.41 MB/s Benchmark____FanOut_8x10x100-16 48039 74640 ns/op 308.40 MB/s Benchmark____FanOut_8x10x100-16 47968 74441 ns/op 309.23 MB/s Benchmark____FanOut_8x10x100-16 47672 75963 ns/op 303.03 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5947 594594 ns/op 403.67 MB/s Benchmark___FanOut_8x10x1000-16 5960 593471 ns/op 404.43 MB/s Benchmark___FanOut_8x10x1000-16 5946 594423 ns/op 403.79 MB/s Benchmark___FanOut_8x10x1000-16 6130 594600 ns/op 403.66 MB/s Benchmark___FanOut_8x10x1000-16 5740 594810 ns/op 403.52 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5016 704199 ns/op 326.64 MB/s Benchmark___FanOut_8x100x100-16 5030 703508 ns/op 326.96 MB/s Benchmark___FanOut_8x100x100-16 5020 704265 ns/op 326.61 MB/s Benchmark___FanOut_8x100x100-16 5011 704587 ns/op 326.46 MB/s Benchmark___FanOut_8x100x100-16 5042 707496 ns/op 325.12 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 591 6163686 ns/op 389.38 MB/s Benchmark__FanOut_8x100x1000-16 585 6282631 ns/op 382.01 MB/s Benchmark__FanOut_8x100x1000-16 584 6151702 ns/op 390.14 MB/s Benchmark__FanOut_8x100x1000-16 589 6078247 ns/op 394.85 MB/s Benchmark__FanOut_8x100x1000-16 568 6257993 ns/op 383.51 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 530 6654249 ns/op 375.70 MB/s Benchmark__FanOut_8x10x10000-16 532 6900241 ns/op 362.31 MB/s Benchmark__FanOut_8x10x10000-16 542 6671034 ns/op 374.76 MB/s Benchmark__FanOut_8x10x10000-16 517 6732791 ns/op 371.32 MB/s Benchmark__FanOut_8x10x10000-16 531 6792259 ns/op 368.07 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 944 3753083 ns/op 306.42 MB/s Benchmark___FanOut_8x500x100-16 943 3762361 ns/op 305.66 MB/s Benchmark___FanOut_8x500x100-16 951 3746508 ns/op 306.96 MB/s Benchmark___FanOut_8x500x100-16 956 3731082 ns/op 308.23 MB/s Benchmark___FanOut_8x500x100-16 954 3735763 ns/op 307.84 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 363595 9456 ns/op 1548.37 MB/s Benchmark___FanOut_128x1x100-16 368746 9444 ns/op 1550.33 MB/s Benchmark___FanOut_128x1x100-16 370785 9384 ns/op 1560.14 MB/s Benchmark___FanOut_128x1x100-16 359888 9536 ns/op 1535.33 MB/s Benchmark___FanOut_128x1x100-16 365114 9376 ns/op 1561.62 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32636 109468 ns/op 1325.88 MB/s Benchmark__FanOut_128x10x100-16 32930 109518 ns/op 1325.27 MB/s Benchmark__FanOut_128x10x100-16 32601 109733 ns/op 1322.68 MB/s Benchmark__FanOut_128x10x100-16 32578 109649 ns/op 1323.69 MB/s Benchmark__FanOut_128x10x100-16 32973 109221 ns/op 1328.87 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4062 869246 ns/op 1679.78 MB/s Benchmark_FanOut_128x10x1000-16 3919 873129 ns/op 1672.31 MB/s Benchmark_FanOut_128x10x1000-16 4069 857632 ns/op 1702.53 MB/s Benchmark_FanOut_128x10x1000-16 4035 874877 ns/op 1668.97 MB/s Benchmark_FanOut_128x10x1000-16 4024 870091 ns/op 1678.15 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3511 1007847 ns/op 1438.85 MB/s Benchmark_FanOut_128x100x100-16 3541 1004762 ns/op 1443.27 MB/s Benchmark_FanOut_128x100x100-16 3482 1007971 ns/op 1438.67 MB/s Benchmark_FanOut_128x100x100-16 3508 1005755 ns/op 1441.84 MB/s Benchmark_FanOut_128x100x100-16 3459 1017719 ns/op 1424.89 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 394 9204163 ns/op 1586.25 MB/s BenchmarkFanOut_128x100x1000-16 387 9254967 ns/op 1577.55 MB/s BenchmarkFanOut_128x100x1000-16 393 9220054 ns/op 1583.52 MB/s BenchmarkFanOut_128x100x1000-16 387 9308689 ns/op 1568.44 MB/s BenchmarkFanOut_128x100x1000-16 380 9310254 ns/op 1568.18 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 370 9642372 ns/op 1524.54 MB/s BenchmarkFanOut_128x10x10000-16 376 9639695 ns/op 1524.96 MB/s BenchmarkFanOut_128x10x10000-16 373 9693727 ns/op 1516.46 MB/s BenchmarkFanOut_128x10x10000-16 373 9576460 ns/op 1535.03 MB/s BenchmarkFanOut_128x10x10000-16 376 9608429 ns/op 1529.92 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 673 5215295 ns/op 1390.17 MB/s BenchmarkFanOut__128x500x100-16 673 5280708 ns/op 1372.95 MB/s BenchmarkFanOut__128x500x100-16 666 5273185 ns/op 1374.91 MB/s BenchmarkFanOut__128x500x100-16 678 5278438 ns/op 1373.54 MB/s BenchmarkFanOut__128x500x100-16 681 5232366 ns/op 1385.63 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1952 1837261 ns/op 2879.57 MB/s Benchmark_FanOut_512x100x100-16 1947 1845714 ns/op 2866.38 MB/s Benchmark_FanOut_512x100x100-16 1909 1826334 ns/op 2896.80 MB/s Benchmark_FanOut_512x100x100-16 1912 1837691 ns/op 2878.90 MB/s Benchmark_FanOut_512x100x100-16 1947 1833559 ns/op 2885.39 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 218 16680496 ns/op 3177.40 MB/s Benchmark__FanOut_512x100x1k-16 214 16560269 ns/op 3200.46 MB/s Benchmark__FanOut_512x100x1k-16 216 16746789 ns/op 3164.82 MB/s Benchmark__FanOut_512x100x1k-16 217 16505050 ns/op 3211.17 MB/s Benchmark__FanOut_512x100x1k-16 217 16675774 ns/op 3178.29 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3242 1149423 ns/op 9075.02 MB/s Benchmark____FanOut_1kx10x1k-16 3081 1181772 ns/op 8826.61 MB/s Benchmark____FanOut_1kx10x1k-16 2844 1125623 ns/op 9266.90 MB/s Benchmark____FanOut_1kx10x1k-16 2949 1152709 ns/op 9049.15 MB/s Benchmark____FanOut_1kx10x1k-16 3086 1146090 ns/op 9101.41 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2794 1257951 ns/op 8284.14 MB/s Benchmark__FanOut_1kx100x100-16 2808 1257106 ns/op 8289.71 MB/s Benchmark__FanOut_1kx100x100-16 2858 1253029 ns/op 8316.68 MB/s Benchmark__FanOut_1kx100x100-16 2796 1257043 ns/op 8290.12 MB/s Benchmark__FanOut_1kx100x100-16 2743 1259777 ns/op 8272.13 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4574371 794.8 ns/op 313.31 MB/s Benchmark_____RFanOut_8x1x10-16 4479558 773.6 ns/op 321.86 MB/s Benchmark_____RFanOut_8x1x10-16 4329297 786.2 ns/op 316.70 MB/s Benchmark_____RFanOut_8x1x10-16 4459189 789.2 ns/op 315.51 MB/s Benchmark_____RFanOut_8x1x10-16 4392080 787.6 ns/op 316.17 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 537399 6307 ns/op 367.70 MB/s Benchmark____RFanOut_8x1x100-16 483868 7146 ns/op 324.52 MB/s Benchmark____RFanOut_8x1x100-16 558676 6114 ns/op 379.29 MB/s Benchmark____RFanOut_8x1x100-16 549136 6109 ns/op 379.61 MB/s Benchmark____RFanOut_8x1x100-16 505480 6057 ns/op 382.83 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 48214 76128 ns/op 302.37 MB/s Benchmark___RFanOut_8x10x100-16 47395 74615 ns/op 308.50 MB/s Benchmark___RFanOut_8x10x100-16 47877 75229 ns/op 305.98 MB/s Benchmark___RFanOut_8x10x100-16 48150 74742 ns/op 307.98 MB/s Benchmark___RFanOut_8x10x100-16 47875 75393 ns/op 305.32 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5772 598363 ns/op 401.13 MB/s Benchmark__RFanOut_8x10x1000-16 5792 601477 ns/op 399.05 MB/s Benchmark__RFanOut_8x10x1000-16 6032 601042 ns/op 399.34 MB/s Benchmark__RFanOut_8x10x1000-16 5896 596412 ns/op 402.44 MB/s Benchmark__RFanOut_8x10x1000-16 5773 600858 ns/op 399.46 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4924 707759 ns/op 325.00 MB/s Benchmark__RFanOut_8x100x100-16 5000 708570 ns/op 324.62 MB/s Benchmark__RFanOut_8x100x100-16 5011 708965 ns/op 324.44 MB/s Benchmark__RFanOut_8x100x100-16 4995 707755 ns/op 325.00 MB/s Benchmark__RFanOut_8x100x100-16 4956 707641 ns/op 325.05 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 577 6169619 ns/op 389.01 MB/s Benchmark_RFanOut_8x100x1000-16 561 6258557 ns/op 383.48 MB/s Benchmark_RFanOut_8x100x1000-16 565 6132174 ns/op 391.38 MB/s Benchmark_RFanOut_8x100x1000-16 582 6178072 ns/op 388.47 MB/s Benchmark_RFanOut_8x100x1000-16 579 6133744 ns/op 391.28 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 541 6718336 ns/op 372.12 MB/s Benchmark_RFanOut_8x10x10000-16 522 6776535 ns/op 368.92 MB/s Benchmark_RFanOut_8x10x10000-16 534 6876430 ns/op 363.56 MB/s Benchmark_RFanOut_8x10x10000-16 537 6712324 ns/op 372.45 MB/s Benchmark_RFanOut_8x10x10000-16 534 6847885 ns/op 365.08 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2835 1154037 ns/op 9038.74 MB/s Benchmark_RFanOut_1kx10x1000-16 3206 1163649 ns/op 8964.08 MB/s Benchmark_RFanOut_1kx10x1000-16 3268 1161133 ns/op 8983.50 MB/s Benchmark_RFanOut_1kx10x1000-16 3199 1169566 ns/op 8918.72 MB/s Benchmark_RFanOut_1kx10x1000-16 3012 1159242 ns/op 8998.15 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6931652 503.6 ns/op 4126.35 MB/s Benchmark_____FanIn_1kx100x1-16 6982617 503.5 ns/op 4127.24 MB/s Benchmark_____FanIn_1kx100x1-16 6945054 504.7 ns/op 4117.22 MB/s Benchmark_____FanIn_1kx100x1-16 6972132 502.6 ns/op 4134.31 MB/s Benchmark_____FanIn_1kx100x1-16 6982347 506.0 ns/op 4106.61 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2627754 1358 ns/op 6054.21 MB/s Benchmark_____FanIn_4kx100x1-16 2618445 1358 ns/op 6056.48 MB/s Benchmark_____FanIn_4kx100x1-16 2582514 1361 ns/op 6039.21 MB/s Benchmark_____FanIn_4kx100x1-16 2640412 1358 ns/op 6053.06 MB/s Benchmark_____FanIn_4kx100x1-16 2602591 1360 ns/op 6043.54 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1701165 2115 ns/op 7759.33 MB/s Benchmark_____FanIn_8kx100x1-16 1731241 2115 ns/op 7760.69 MB/s Benchmark_____FanIn_8kx100x1-16 1712511 2112 ns/op 7771.73 MB/s Benchmark_____FanIn_8kx100x1-16 1700479 2117 ns/op 7752.87 MB/s Benchmark_____FanIn_8kx100x1-16 1711580 2121 ns/op 7737.80 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 854307 4192 ns/op 7825.28 MB/s Benchmark____FanIn_16kx100x1-16 868662 4166 ns/op 7873.28 MB/s Benchmark____FanIn_16kx100x1-16 854944 4150 ns/op 7904.09 MB/s Benchmark____FanIn_16kx100x1-16 859371 4159 ns/op 7887.20 MB/s Benchmark____FanIn_16kx100x1-16 866138 4194 ns/op 7820.38 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 4130166765 vs 10894908600 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47744->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47204->127.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:47172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47810->127.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:47166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47840->127.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: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:47186->127.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:47190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47874->127.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:47070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47852->127.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:47142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47118->127.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:47148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47284->127.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:47772->127.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:47640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47408->127.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:47056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47614->127.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:47918->127.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:47862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47160->127.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:47616->127.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:47728->127.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: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:47650->127.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:47698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47828->127.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:47116->127.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:47236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47966->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47778->127.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:47596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47832->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 168912 19952 ns/op 6570.82 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7200210414 vs 11157120600 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53356->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 160216 19727 ns/op 6645.93 MB/s Benchmark____FanIn_64kx100x1-16 155436 19905 ns/op 6586.42 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 122175880 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42870->127.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: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:42518->127.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:42706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42418->127.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:42702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42894->127.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:42688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42384->127.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:42552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42810->127.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:43208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42888->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42806->127.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:42720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43140->127.0.0.1:5222: write: connection reset by peer 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:43070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42458->127.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:42644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42748->127.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:42584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43062->127.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:43100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42988->127.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:43152->127.0.0.1:5222: write: broken pipe 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:42866->127.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:43160->127.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:42862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42362->127.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:43010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:43022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:42882->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:42406->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: 480313760 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44626->127.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:44254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44406->127.0.0.1:5222: write: connection reset by peer 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: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:44532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44292->127.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:44758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44244->127.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: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:44474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44810->127.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:44458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44558->127.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:44590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44158->127.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:44304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44478->127.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:44306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44512->127.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:44242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:44922->127.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 --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1321125020 vs 10867361000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47392->127.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:47512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47346->127.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:47000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47434->127.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: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: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:46688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47324->127.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:47050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46812->127.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:46822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46752->127.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 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46900->127.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:47338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46834->127.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:47016->127.0.0.1:5222: write: connection reset by peer 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:46910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47522->127.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:47416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47156->127.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:47108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47092->127.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:46674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47162->127.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:47192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46954->127.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:47374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47110->127.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:47166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46818->127.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:46844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46722->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: 519247490 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48734->127.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:48478->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:49310->127.0.0.1:5222: write: broken pipe bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1170764790 vs 11653901000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51316->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51954->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51714->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:52038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:51594->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5500447 646.4 ns/op 439.36 MB/s Benchmark___BumpPubCount_1x3-16 5478543 644.4 ns/op 440.72 MB/s Benchmark___BumpPubCount_1x3-16 5582186 646.4 ns/op 439.35 MB/s Benchmark___BumpPubCount_1x3-16 5502260 648.0 ns/op 438.27 MB/s Benchmark___BumpPubCount_1x3-16 5519179 646.3 ns/op 439.40 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5288262 680.0 ns/op 417.63 MB/s Benchmark___BumpPubCount_2x3-16 5312749 675.4 ns/op 420.48 MB/s Benchmark___BumpPubCount_2x3-16 5297656 674.6 ns/op 420.99 MB/s Benchmark___BumpPubCount_2x3-16 5311692 677.9 ns/op 418.95 MB/s Benchmark___BumpPubCount_2x3-16 5287286 676.0 ns/op 420.14 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5567073 644.2 ns/op 440.87 MB/s Benchmark___BumpPubCount_5x3-16 5587707 641.5 ns/op 442.72 MB/s Benchmark___BumpPubCount_5x3-16 5327342 640.2 ns/op 443.59 MB/s Benchmark___BumpPubCount_5x3-16 5560392 643.7 ns/op 441.21 MB/s Benchmark___BumpPubCount_5x3-16 5590590 643.5 ns/op 441.34 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5589867 640.2 ns/op 443.60 MB/s Benchmark__BumpPubCount_10x3-16 5608274 642.8 ns/op 441.84 MB/s Benchmark__BumpPubCount_10x3-16 5543149 644.3 ns/op 440.80 MB/s Benchmark__BumpPubCount_10x3-16 5627319 640.3 ns/op 443.56 MB/s Benchmark__BumpPubCount_10x3-16 5613727 642.8 ns/op 441.85 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12314090 278.4 ns/op 3735.12 MB/s Benchmark____GWs_Opt_1kx01x0-16 12606907 273.7 ns/op 3799.88 MB/s Benchmark____GWs_Opt_1kx01x0-16 12195070 277.7 ns/op 3745.51 MB/s Benchmark____GWs_Opt_1kx01x0-16 12357504 275.6 ns/op 3773.92 MB/s Benchmark____GWs_Opt_1kx01x0-16 12519438 268.7 ns/op 3870.36 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9648061 335.8 ns/op 6147.35 MB/s Benchmark____GWs_Opt_2kx01x0-16 9293332 343.3 ns/op 6012.38 MB/s Benchmark____GWs_Opt_2kx01x0-16 10656114 321.4 ns/op 6422.15 MB/s Benchmark____GWs_Opt_2kx01x0-16 10370088 340.1 ns/op 6068.50 MB/s Benchmark____GWs_Opt_2kx01x0-16 10405879 336.9 ns/op 6125.97 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5916370 611.0 ns/op 6729.55 MB/s Benchmark____GWs_Opt_4kx01x0-16 5966325 598.8 ns/op 6866.66 MB/s Benchmark____GWs_Opt_4kx01x0-16 5224813 619.7 ns/op 6635.19 MB/s Benchmark____GWs_Opt_4kx01x0-16 5748990 635.8 ns/op 6467.35 MB/s Benchmark____GWs_Opt_4kx01x0-16 5683099 634.4 ns/op 6481.47 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 27018427 120.7 ns/op 8618.77 MB/s Benchmark____GWs_Opt_1kx10x0-16 29333533 115.4 ns/op 9015.61 MB/s Benchmark____GWs_Opt_1kx10x0-16 33210940 113.1 ns/op 9197.61 MB/s Benchmark____GWs_Opt_1kx10x0-16 31947391 111.0 ns/op 9365.29 MB/s Benchmark____GWs_Opt_1kx10x0-16 30750777 111.0 ns/op 9370.04 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23675748 145.0 ns/op 14231.01 MB/s Benchmark____GWs_Opt_2kx10x0-16 24403978 167.5 ns/op 12321.35 MB/s Benchmark____GWs_Opt_2kx10x0-16 25697102 151.0 ns/op 13667.30 MB/s Benchmark____GWs_Opt_2kx10x0-16 24361326 168.1 ns/op 12278.82 MB/s Benchmark____GWs_Opt_2kx10x0-16 24469364 162.4 ns/op 12709.85 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 13144401 293.8 ns/op 13996.33 MB/s Benchmark____GWs_Opt_4kx10x0-16 11581904 288.2 ns/op 14266.20 MB/s Benchmark____GWs_Opt_4kx10x0-16 12938742 294.2 ns/op 13975.77 MB/s Benchmark____GWs_Opt_4kx10x0-16 12674466 293.5 ns/op 14010.12 MB/s Benchmark____GWs_Opt_4kx10x0-16 11278887 306.1 ns/op 13434.64 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6648159 540.4 ns/op 5783.01 MB/s Benchmark____GWs_Opt_1kx01x1-16 6588379 542.9 ns/op 5755.94 MB/s Benchmark____GWs_Opt_1kx01x1-16 6708669 546.5 ns/op 5717.93 MB/s Benchmark____GWs_Opt_1kx01x1-16 6810468 539.8 ns/op 5788.89 MB/s Benchmark____GWs_Opt_1kx01x1-16 6623967 546.7 ns/op 5716.60 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4580546 744.8 ns/op 8320.01 MB/s Benchmark____GWs_Opt_2kx01x1-16 4584350 740.9 ns/op 8364.58 MB/s Benchmark____GWs_Opt_2kx01x1-16 4646426 745.4 ns/op 8313.65 MB/s Benchmark____GWs_Opt_2kx01x1-16 4610726 759.6 ns/op 8158.45 MB/s Benchmark____GWs_Opt_2kx01x1-16 4854372 754.4 ns/op 8214.48 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2635094 1363 ns/op 9056.60 MB/s Benchmark____GWs_Opt_4kx01x1-16 2380483 1358 ns/op 9088.96 MB/s Benchmark____GWs_Opt_4kx01x1-16 2600546 1366 ns/op 9036.42 MB/s Benchmark____GWs_Opt_4kx01x1-16 1000000 3570 ns/op 3456.52 MB/s Benchmark____GWs_Opt_4kx01x1-16 2630072 1383 ns/op 8922.33 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6530973 552.4 ns/op 5656.82 MB/s Benchmark____GWs_Opt_1kx10x1-16 6261817 559.0 ns/op 5590.68 MB/s Benchmark____GWs_Opt_1kx10x1-16 6533865 551.7 ns/op 5663.87 MB/s Benchmark____GWs_Opt_1kx10x1-16 6475266 1047 ns/op 2985.76 MB/s Benchmark____GWs_Opt_1kx10x1-16 6625602 543.3 ns/op 5752.22 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4113799 858.2 ns/op 7220.58 MB/s Benchmark____GWs_Opt_2kx10x1-16 4803316 846.0 ns/op 7325.26 MB/s Benchmark____GWs_Opt_2kx10x1-16 4171750 846.8 ns/op 7318.45 MB/s Benchmark____GWs_Opt_2kx10x1-16 3974350 818.5 ns/op 7570.85 MB/s Benchmark____GWs_Opt_2kx10x1-16 4605166 843.2 ns/op 7349.74 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2325754 1441 ns/op 8565.09 MB/s Benchmark____GWs_Opt_4kx10x1-16 2314323 1506 ns/op 8194.18 MB/s Benchmark____GWs_Opt_4kx10x1-16 2274918 1514 ns/op 8149.10 MB/s Benchmark____GWs_Opt_4kx10x1-16 2318356 1509 ns/op 8180.44 MB/s Benchmark____GWs_Opt_4kx10x1-16 2428336 1520 ns/op 8117.15 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 11961727 284.5 ns/op 3655.75 MB/s Benchmark____GWs_Int_1kx01x0-16 12189753 310.6 ns/op 3348.09 MB/s Benchmark____GWs_Int_1kx01x0-16 12580113 291.2 ns/op 3571.23 MB/s Benchmark____GWs_Int_1kx01x0-16 12290054 280.3 ns/op 3709.84 MB/s Benchmark____GWs_Int_1kx01x0-16 12544657 289.3 ns/op 3595.38 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9912032 353.5 ns/op 5838.35 MB/s Benchmark____GWs_Int_2kx01x0-16 10320105 359.1 ns/op 5747.28 MB/s Benchmark____GWs_Int_2kx01x0-16 10196145 352.1 ns/op 5862.18 MB/s Benchmark____GWs_Int_2kx01x0-16 9479112 354.9 ns/op 5815.33 MB/s Benchmark____GWs_Int_2kx01x0-16 10154802 356.9 ns/op 5783.33 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5862014 620.5 ns/op 6626.67 MB/s Benchmark____GWs_Int_4kx01x0-16 5949608 629.9 ns/op 6527.55 MB/s Benchmark____GWs_Int_4kx01x0-16 5737134 694.2 ns/op 5923.48 MB/s Benchmark____GWs_Int_4kx01x0-16 5709214 634.6 ns/op 6479.64 MB/s Benchmark____GWs_Int_4kx01x0-16 5924198 645.8 ns/op 6367.14 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 28238812 115.4 ns/op 9009.33 MB/s Benchmark____GWs_Int_1kx10x0-16 31141465 113.2 ns/op 9190.74 MB/s Benchmark____GWs_Int_1kx10x0-16 32939214 111.9 ns/op 9296.56 MB/s Benchmark____GWs_Int_1kx10x0-16 29156956 110.7 ns/op 9398.15 MB/s Benchmark____GWs_Int_1kx10x0-16 31970668 117.5 ns/op 8851.56 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25697391 146.9 ns/op 14049.37 MB/s Benchmark____GWs_Int_2kx10x0-16 25947889 141.1 ns/op 14628.43 MB/s Benchmark____GWs_Int_2kx10x0-16 25330099 175.2 ns/op 11781.08 MB/s Benchmark____GWs_Int_2kx10x0-16 25271857 141.5 ns/op 14591.23 MB/s Benchmark____GWs_Int_2kx10x0-16 26043830 158.3 ns/op 13038.41 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13232353 320.5 ns/op 12828.34 MB/s Benchmark____GWs_Int_4kx10x0-16 10801574 306.3 ns/op 13422.58 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:50612->127.0.0.1:39873: 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:39338->127.0.0.1:45735: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 13406288 293.2 ns/op 14025.82 MB/s Benchmark____GWs_Int_4kx10x0-16 13064802 309.6 ns/op 13282.94 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6448599 550.2 ns/op 5680.14 MB/s Benchmark____GWs_Int_1kx01x1-16 6526400 555.3 ns/op 5627.96 MB/s Benchmark____GWs_Int_1kx01x1-16 6444147 550.3 ns/op 5678.53 MB/s Benchmark____GWs_Int_1kx01x1-16 6669740 551.5 ns/op 5666.64 MB/s Benchmark____GWs_Int_1kx01x1-16 6598902 554.3 ns/op 5637.72 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4751826 758.0 ns/op 8175.09 MB/s Benchmark____GWs_Int_2kx01x1-16 4805068 772.3 ns/op 8024.54 MB/s Benchmark____GWs_Int_2kx01x1-16 4753941 755.1 ns/op 8206.62 MB/s Benchmark____GWs_Int_2kx01x1-16 4853028 764.9 ns/op 8101.31 MB/s Benchmark____GWs_Int_2kx01x1-16 4555255 759.7 ns/op 8157.06 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2556720 1378 ns/op 8958.30 MB/s Benchmark____GWs_Int_4kx01x1-16 2567548 1592 ns/op 7751.27 MB/s Benchmark____GWs_Int_4kx01x1-16 2293258 1363 ns/op 9056.15 MB/s Benchmark____GWs_Int_4kx01x1-16 2542546 1639 ns/op 7527.39 MB/s Benchmark____GWs_Int_4kx01x1-16 2264733 1819 ns/op 6783.51 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6562010 552.2 ns/op 5658.71 MB/s Benchmark____GWs_Int_1kx10x1-16 6509792 543.0 ns/op 5755.51 MB/s Benchmark____GWs_Int_1kx10x1-16 6598724 553.8 ns/op 5643.16 MB/s Benchmark____GWs_Int_1kx10x1-16 6487374 557.4 ns/op 5605.88 MB/s Benchmark____GWs_Int_1kx10x1-16 6526910 626.7 ns/op 4986.28 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4139982 862.0 ns/op 7188.83 MB/s Benchmark____GWs_Int_2kx10x1-16 4094610 841.9 ns/op 7361.03 MB/s Benchmark____GWs_Int_2kx10x1-16 4296716 833.5 ns/op 7434.91 MB/s Benchmark____GWs_Int_2kx10x1-16 4374129 849.6 ns/op 7294.19 MB/s Benchmark____GWs_Int_2kx10x1-16 4729322 840.0 ns/op 7377.29 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2356010 1664 ns/op 7417.95 MB/s Benchmark____GWs_Int_4kx10x1-16 2477994 1503 ns/op 8210.19 MB/s Benchmark____GWs_Int_4kx10x1-16 2336164 1502 ns/op 8218.27 MB/s Benchmark____GWs_Int_4kx10x1-16 2402022 1649 ns/op 7484.13 MB/s Benchmark____GWs_Int_4kx10x1-16 2334367 1575 ns/op 7834.47 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8162112 434.1 ns/op 234.98 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8381680 432.5 ns/op 235.85 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8071706 429.0 ns/op 237.74 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8345428 426.5 ns/op 239.15 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8437334 430.8 ns/op 236.75 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 624106 5091 ns/op 34.76 MB/s Benchmark__GWs_Reqs_1SubEach-16 795544 5266 ns/op 33.61 MB/s Benchmark__GWs_Reqs_1SubEach-16 733674 5221 ns/op 33.90 MB/s Benchmark__GWs_Reqs_1SubEach-16 710172 5315 ns/op 33.30 MB/s Benchmark__GWs_Reqs_1SubEach-16 753584 5278 ns/op 33.54 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2116.355s