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 43231804 73.57 ns/op 149.52 MB/s Benchmark______Pub0b_Payload-16 47122719 73.04 ns/op 150.60 MB/s Benchmark______Pub0b_Payload-16 46699066 73.34 ns/op 149.99 MB/s Benchmark______Pub0b_Payload-16 43387230 73.62 ns/op 149.41 MB/s Benchmark______Pub0b_Payload-16 42708421 72.78 ns/op 151.13 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46216923 74.14 ns/op 256.27 MB/s Benchmark______Pub8b_Payload-16 46359138 74.23 ns/op 255.98 MB/s Benchmark______Pub8b_Payload-16 46146373 76.17 ns/op 249.46 MB/s Benchmark______Pub8b_Payload-16 46080753 73.40 ns/op 258.86 MB/s Benchmark______Pub8b_Payload-16 48440798 74.04 ns/op 256.63 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 43162056 78.59 ns/op 559.89 MB/s Benchmark_____Pub32b_Payload-16 43035788 80.03 ns/op 549.80 MB/s Benchmark_____Pub32b_Payload-16 43084694 82.05 ns/op 536.24 MB/s Benchmark_____Pub32b_Payload-16 42766946 78.95 ns/op 557.28 MB/s Benchmark_____Pub32b_Payload-16 45422745 77.76 ns/op 565.85 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 38489677 88.90 ns/op 1586.02 MB/s Benchmark____Pub128B_Payload-16 33861554 97.09 ns/op 1452.21 MB/s Benchmark____Pub128B_Payload-16 40461770 90.53 ns/op 1557.45 MB/s Benchmark____Pub128B_Payload-16 38192062 88.78 ns/op 1588.16 MB/s Benchmark____Pub128B_Payload-16 38238337 89.92 ns/op 1568.05 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35705644 97.47 ns/op 2759.89 MB/s Benchmark____Pub256B_Payload-16 35294019 96.28 ns/op 2793.98 MB/s Benchmark____Pub256B_Payload-16 35689410 96.32 ns/op 2792.73 MB/s Benchmark____Pub256B_Payload-16 33496453 99.80 ns/op 2695.39 MB/s Benchmark____Pub256B_Payload-16 31769912 98.92 ns/op 2719.48 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 25284859 141.1 ns/op 7356.34 MB/s Benchmark______Pub1K_Payload-16 24240662 144.5 ns/op 7182.67 MB/s Benchmark______Pub1K_Payload-16 21484576 149.2 ns/op 6959.17 MB/s Benchmark______Pub1K_Payload-16 21888770 153.2 ns/op 6776.86 MB/s Benchmark______Pub1K_Payload-16 22219982 184.3 ns/op 5630.93 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5244051 612.3 ns/op 6711.97 MB/s Benchmark______Pub4K_Payload-16 5678774 611.1 ns/op 6725.58 MB/s Benchmark______Pub4K_Payload-16 5806304 611.3 ns/op 6723.61 MB/s Benchmark______Pub4K_Payload-16 5233002 620.9 ns/op 6619.50 MB/s Benchmark______Pub4K_Payload-16 5420467 629.7 ns/op 6526.60 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2735492 1277 ns/op 6424.73 MB/s Benchmark______Pub8K_Payload-16 2700393 1279 ns/op 6414.16 MB/s Benchmark______Pub8K_Payload-16 2820451 1293 ns/op 6348.73 MB/s Benchmark______Pub8K_Payload-16 2776717 1268 ns/op 6469.20 MB/s Benchmark______Pub8K_Payload-16 2750763 1274 ns/op 6442.58 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 553729 5561 ns/op 5894.70 MB/s Benchmark_____Pub32K_Payload-16 657302 5562 ns/op 5893.60 MB/s Benchmark_____Pub32K_Payload-16 646011 5432 ns/op 6034.84 MB/s Benchmark_____Pub32K_Payload-16 533200 7645 ns/op 4288.41 MB/s Benchmark_____Pub32K_Payload-16 552111 5549 ns/op 5908.23 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32247895 94.01 ns/op 117.01 MB/s Benchmark__AuthPub0b_Payload-16 36683862 93.88 ns/op 117.17 MB/s Benchmark__AuthPub0b_Payload-16 36263942 93.27 ns/op 117.94 MB/s Benchmark__AuthPub0b_Payload-16 35547736 93.50 ns/op 117.64 MB/s Benchmark__AuthPub0b_Payload-16 36283142 95.03 ns/op 115.75 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15857223 227.2 ns/op Benchmark_____________PubSub-16 15715996 226.9 ns/op Benchmark_____________PubSub-16 15612867 226.6 ns/op Benchmark_____________PubSub-16 15268942 227.3 ns/op Benchmark_____________PubSub-16 15475960 226.7 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15413210 226.3 ns/op Benchmark_____PubSubTwoConns-16 15601917 226.6 ns/op Benchmark_____PubSubTwoConns-16 15648500 226.1 ns/op Benchmark_____PubSubTwoConns-16 15778292 226.2 ns/op Benchmark_____PubSubTwoConns-16 15732712 225.9 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:52542->127.0.0.1:32957: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50082->127.0.0.1:45381: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:36876->127.0.0.1:42157: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42124->127.0.0.1:40969: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:56996->127.0.0.1:40655: 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 14299213 246.8 ns/op Benchmark_____PubTwoQueueSub-16 14497256 246.5 ns/op Benchmark_____PubTwoQueueSub-16 14321029 246.8 ns/op Benchmark_____PubTwoQueueSub-16 14422410 246.7 ns/op Benchmark_____PubTwoQueueSub-16 14332338 246.4 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14463817 247.1 ns/op Benchmark____PubFourQueueSub-16 14581123 247.1 ns/op Benchmark____PubFourQueueSub-16 14292144 246.3 ns/op Benchmark____PubFourQueueSub-16 14414275 246.0 ns/op Benchmark____PubFourQueueSub-16 14549403 245.4 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14373120 246.3 ns/op Benchmark___PubEightQueueSub-16 14338598 246.3 ns/op Benchmark___PubEightQueueSub-16 14489649 246.8 ns/op Benchmark___PubEightQueueSub-16 14388369 246.8 ns/op Benchmark___PubEightQueueSub-16 14344701 246.6 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23184 155459 ns/op Benchmark_PubSub512kTwoConns-16 23161 155993 ns/op Benchmark_PubSub512kTwoConns-16 23132 155898 ns/op Benchmark_PubSub512kTwoConns-16 23136 156322 ns/op Benchmark_PubSub512kTwoConns-16 23070 156055 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15276640 230.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15001797 228.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15262052 230.7 ns/op Benchmark__DenyMsgNoWCPubSub-16 15217082 228.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15183722 228.3 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15183250 228.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 14776350 229.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 15048705 229.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15260246 229.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15234084 229.6 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11315553 317.4 ns/op Benchmark____RoutedPubSub_0b-16 11127771 315.3 ns/op Benchmark____RoutedPubSub_0b-16 11094896 317.7 ns/op Benchmark____RoutedPubSub_0b-16 11145277 314.4 ns/op Benchmark____RoutedPubSub_0b-16 11413491 311.7 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6569361 931.3 ns/op Benchmark____RoutedPubSub_1K-16 6450248 536.5 ns/op Benchmark____RoutedPubSub_1K-16 6632032 522.5 ns/op Benchmark____RoutedPubSub_1K-16 6457977 544.7 ns/op Benchmark____RoutedPubSub_1K-16 6524083 537.4 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84692 42541 ns/op Benchmark__RoutedPubSub_100K-16 86674 43171 ns/op Benchmark__RoutedPubSub_100K-16 79386 46857 ns/op Benchmark__RoutedPubSub_100K-16 78264 44855 ns/op Benchmark__RoutedPubSub_100K-16 81646 42576 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9456145 322.4 ns/op Benchmark____Routed2QueueSub-16 9670678 317.9 ns/op Benchmark____Routed2QueueSub-16 11148566 319.5 ns/op Benchmark____Routed2QueueSub-16 9568832 330.0 ns/op Benchmark____Routed2QueueSub-16 9614010 317.9 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9309416 325.2 ns/op Benchmark____Routed4QueueSub-16 9328897 324.7 ns/op Benchmark____Routed4QueueSub-16 9489385 323.9 ns/op Benchmark____Routed4QueueSub-16 9305026 326.6 ns/op Benchmark____Routed4QueueSub-16 9102295 333.1 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9074002 333.5 ns/op Benchmark____Routed8QueueSub-16 9173958 341.9 ns/op Benchmark____Routed8QueueSub-16 8933203 336.7 ns/op Benchmark____Routed8QueueSub-16 8995328 334.3 ns/op Benchmark____Routed8QueueSub-16 9098350 340.1 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8836494 352.3 ns/op Benchmark___Routed16QueueSub-16 8938988 351.5 ns/op Benchmark___Routed16QueueSub-16 8688168 352.1 ns/op Benchmark___Routed16QueueSub-16 8801293 345.2 ns/op Benchmark___Routed16QueueSub-16 8655406 354.0 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6533625 545.6 ns/op Benchmark____________RouteCompressOff-16 6456706 555.0 ns/op Benchmark____________RouteCompressOff-16 6342636 552.1 ns/op Benchmark____________RouteCompressOff-16 6426795 554.6 ns/op Benchmark____________RouteCompressOff-16 6589428 526.3 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6525460 562.4 ns/op Benchmark_RouteCompressS2Uncompressed-16 6298611 555.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6462046 554.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6433022 528.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6452882 551.2 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6380792 548.8 ns/op Benchmark_________RouteCompressS2Fast-16 6398491 545.6 ns/op Benchmark_________RouteCompressS2Fast-16 6454795 545.2 ns/op Benchmark_________RouteCompressS2Fast-16 6364321 503.5 ns/op Benchmark_________RouteCompressS2Fast-16 6385185 544.6 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6433478 470.4 ns/op Benchmark_______RouteCompressS2Better-16 6456399 471.7 ns/op Benchmark_______RouteCompressS2Better-16 6288001 559.3 ns/op Benchmark_______RouteCompressS2Better-16 6377838 526.9 ns/op Benchmark_______RouteCompressS2Better-16 6312211 516.9 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6352695 511.2 ns/op Benchmark_________RouteCompressS2Best-16 6443464 552.5 ns/op Benchmark_________RouteCompressS2Best-16 6420072 561.2 ns/op Benchmark_________RouteCompressS2Best-16 6276328 551.7 ns/op Benchmark_________RouteCompressS2Best-16 6615964 549.8 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4651200 769.3 ns/op 323.68 MB/s Benchmark______FanOut_8x1x10-16 4640516 767.6 ns/op 324.37 MB/s Benchmark______FanOut_8x1x10-16 4656034 770.2 ns/op 323.28 MB/s Benchmark______FanOut_8x1x10-16 4612170 773.1 ns/op 322.07 MB/s Benchmark______FanOut_8x1x10-16 4638832 769.5 ns/op 323.59 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 578580 6218 ns/op 372.98 MB/s Benchmark_____FanOut_8x1x100-16 505233 6271 ns/op 369.80 MB/s Benchmark_____FanOut_8x1x100-16 524618 6366 ns/op 364.25 MB/s Benchmark_____FanOut_8x1x100-16 549178 6193 ns/op 374.44 MB/s Benchmark_____FanOut_8x1x100-16 536157 6155 ns/op 376.76 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 48146 74809 ns/op 307.71 MB/s Benchmark____FanOut_8x10x100-16 47978 74730 ns/op 308.03 MB/s Benchmark____FanOut_8x10x100-16 47498 74917 ns/op 307.26 MB/s Benchmark____FanOut_8x10x100-16 47875 75229 ns/op 305.98 MB/s Benchmark____FanOut_8x10x100-16 47944 74795 ns/op 307.76 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5798 603697 ns/op 397.58 MB/s Benchmark___FanOut_8x10x1000-16 5774 601824 ns/op 398.82 MB/s Benchmark___FanOut_8x10x1000-16 5990 604302 ns/op 397.18 MB/s Benchmark___FanOut_8x10x1000-16 5618 601302 ns/op 399.17 MB/s Benchmark___FanOut_8x10x1000-16 5942 621670 ns/op 386.09 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4909 709802 ns/op 324.06 MB/s Benchmark___FanOut_8x100x100-16 5023 707938 ns/op 324.91 MB/s Benchmark___FanOut_8x100x100-16 4981 709257 ns/op 324.31 MB/s Benchmark___FanOut_8x100x100-16 4990 709716 ns/op 324.10 MB/s Benchmark___FanOut_8x100x100-16 5000 707100 ns/op 325.30 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 579 6128497 ns/op 391.62 MB/s Benchmark__FanOut_8x100x1000-16 565 6169869 ns/op 388.99 MB/s Benchmark__FanOut_8x100x1000-16 559 6239370 ns/op 384.66 MB/s Benchmark__FanOut_8x100x1000-16 567 6181326 ns/op 388.27 MB/s Benchmark__FanOut_8x100x1000-16 558 6161952 ns/op 389.49 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 536 6737626 ns/op 371.05 MB/s Benchmark__FanOut_8x10x10000-16 537 6743676 ns/op 370.72 MB/s Benchmark__FanOut_8x10x10000-16 541 6653885 ns/op 375.72 MB/s Benchmark__FanOut_8x10x10000-16 534 6835995 ns/op 365.71 MB/s Benchmark__FanOut_8x10x10000-16 526 6759849 ns/op 369.83 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 938 3783478 ns/op 303.96 MB/s Benchmark___FanOut_8x500x100-16 946 3756765 ns/op 306.12 MB/s Benchmark___FanOut_8x500x100-16 945 3757272 ns/op 306.08 MB/s Benchmark___FanOut_8x500x100-16 934 3765670 ns/op 305.40 MB/s Benchmark___FanOut_8x500x100-16 932 3775751 ns/op 304.58 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 355879 9592 ns/op 1526.45 MB/s Benchmark___FanOut_128x1x100-16 365652 9631 ns/op 1520.20 MB/s Benchmark___FanOut_128x1x100-16 361789 9636 ns/op 1519.37 MB/s Benchmark___FanOut_128x1x100-16 363715 9611 ns/op 1523.44 MB/s Benchmark___FanOut_128x1x100-16 357267 9564 ns/op 1530.78 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32269 111080 ns/op 1306.64 MB/s Benchmark__FanOut_128x10x100-16 32245 111551 ns/op 1301.11 MB/s Benchmark__FanOut_128x10x100-16 32419 112241 ns/op 1293.12 MB/s Benchmark__FanOut_128x10x100-16 32210 111783 ns/op 1298.42 MB/s Benchmark__FanOut_128x10x100-16 32346 110925 ns/op 1308.46 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4051 873921 ns/op 1670.79 MB/s Benchmark_FanOut_128x10x1000-16 4077 880131 ns/op 1659.00 MB/s Benchmark_FanOut_128x10x1000-16 3990 883338 ns/op 1652.98 MB/s Benchmark_FanOut_128x10x1000-16 4154 881002 ns/op 1657.36 MB/s Benchmark_FanOut_128x10x1000-16 4082 881684 ns/op 1656.08 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3541 1036113 ns/op 1399.60 MB/s Benchmark_FanOut_128x100x100-16 3514 1012158 ns/op 1432.72 MB/s Benchmark_FanOut_128x100x100-16 3478 1015053 ns/op 1428.64 MB/s Benchmark_FanOut_128x100x100-16 3526 1018843 ns/op 1423.32 MB/s Benchmark_FanOut_128x100x100-16 3496 1016679 ns/op 1426.35 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 385 9407761 ns/op 1551.93 MB/s BenchmarkFanOut_128x100x1000-16 374 9368278 ns/op 1558.47 MB/s BenchmarkFanOut_128x100x1000-16 379 9383900 ns/op 1555.87 MB/s BenchmarkFanOut_128x100x1000-16 381 9417577 ns/op 1550.31 MB/s BenchmarkFanOut_128x100x1000-16 381 9460108 ns/op 1543.34 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 368 9699206 ns/op 1515.60 MB/s BenchmarkFanOut_128x10x10000-16 376 9723815 ns/op 1511.77 MB/s BenchmarkFanOut_128x10x10000-16 372 9653059 ns/op 1522.85 MB/s BenchmarkFanOut_128x10x10000-16 373 9670374 ns/op 1520.12 MB/s BenchmarkFanOut_128x10x10000-16 370 9736136 ns/op 1509.85 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 672 5282239 ns/op 1372.55 MB/s BenchmarkFanOut__128x500x100-16 670 5289876 ns/op 1370.57 MB/s BenchmarkFanOut__128x500x100-16 675 5310835 ns/op 1365.16 MB/s BenchmarkFanOut__128x500x100-16 663 5251505 ns/op 1380.58 MB/s BenchmarkFanOut__128x500x100-16 676 5286790 ns/op 1371.37 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1929 1838176 ns/op 2878.14 MB/s Benchmark_FanOut_512x100x100-16 1904 1857973 ns/op 2847.47 MB/s Benchmark_FanOut_512x100x100-16 1888 1846371 ns/op 2865.36 MB/s Benchmark_FanOut_512x100x100-16 1911 1843763 ns/op 2869.42 MB/s Benchmark_FanOut_512x100x100-16 1940 1856339 ns/op 2849.98 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 216 17059213 ns/op 3106.86 MB/s Benchmark__FanOut_512x100x1k-16 214 16705027 ns/op 3172.73 MB/s Benchmark__FanOut_512x100x1k-16 213 16902136 ns/op 3135.73 MB/s Benchmark__FanOut_512x100x1k-16 217 16784099 ns/op 3157.78 MB/s Benchmark__FanOut_512x100x1k-16 213 16831550 ns/op 3148.88 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3190 1160122 ns/op 8991.33 MB/s Benchmark____FanOut_1kx10x1k-16 3291 1140710 ns/op 9144.34 MB/s Benchmark____FanOut_1kx10x1k-16 3054 1153354 ns/op 9044.09 MB/s Benchmark____FanOut_1kx10x1k-16 3099 1152764 ns/op 9048.72 MB/s Benchmark____FanOut_1kx10x1k-16 2953 1150320 ns/op 9067.94 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2738 1250507 ns/op 8333.45 MB/s Benchmark__FanOut_1kx100x100-16 2763 1264046 ns/op 8244.19 MB/s Benchmark__FanOut_1kx100x100-16 2754 1252080 ns/op 8322.98 MB/s Benchmark__FanOut_1kx100x100-16 2776 1268576 ns/op 8214.75 MB/s Benchmark__FanOut_1kx100x100-16 2745 1267071 ns/op 8224.51 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4273040 819.0 ns/op 304.04 MB/s Benchmark_____RFanOut_8x1x10-16 4280946 831.4 ns/op 299.48 MB/s Benchmark_____RFanOut_8x1x10-16 4243020 816.0 ns/op 305.14 MB/s Benchmark_____RFanOut_8x1x10-16 4276350 827.0 ns/op 301.10 MB/s Benchmark_____RFanOut_8x1x10-16 4206078 814.1 ns/op 305.85 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 504842 6661 ns/op 348.15 MB/s Benchmark____RFanOut_8x1x100-16 485019 6620 ns/op 350.29 MB/s Benchmark____RFanOut_8x1x100-16 494847 6658 ns/op 348.28 MB/s Benchmark____RFanOut_8x1x100-16 465619 6655 ns/op 348.44 MB/s Benchmark____RFanOut_8x1x100-16 490083 6666 ns/op 347.87 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 43797 80313 ns/op 286.62 MB/s Benchmark___RFanOut_8x10x100-16 44419 82283 ns/op 279.75 MB/s Benchmark___RFanOut_8x10x100-16 43501 80872 ns/op 284.64 MB/s Benchmark___RFanOut_8x10x100-16 44300 81836 ns/op 281.28 MB/s Benchmark___RFanOut_8x10x100-16 44536 82192 ns/op 280.06 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5301 669218 ns/op 358.66 MB/s Benchmark__RFanOut_8x10x1000-16 5132 673848 ns/op 356.19 MB/s Benchmark__RFanOut_8x10x1000-16 5277 669976 ns/op 358.25 MB/s Benchmark__RFanOut_8x10x1000-16 5305 674450 ns/op 355.87 MB/s Benchmark__RFanOut_8x10x1000-16 5136 668851 ns/op 358.85 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4624 765508 ns/op 300.48 MB/s Benchmark__RFanOut_8x100x100-16 4609 773180 ns/op 297.50 MB/s Benchmark__RFanOut_8x100x100-16 4633 767939 ns/op 299.53 MB/s Benchmark__RFanOut_8x100x100-16 4644 767980 ns/op 299.51 MB/s Benchmark__RFanOut_8x100x100-16 4582 766218 ns/op 300.20 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 505 6922243 ns/op 346.71 MB/s Benchmark_RFanOut_8x100x1000-16 514 6913187 ns/op 347.17 MB/s Benchmark_RFanOut_8x100x1000-16 488 6932062 ns/op 346.22 MB/s Benchmark_RFanOut_8x100x1000-16 505 6869991 ns/op 349.35 MB/s Benchmark_RFanOut_8x100x1000-16 505 6933216 ns/op 346.16 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 468 7345300 ns/op 340.36 MB/s Benchmark_RFanOut_8x10x10000-16 477 7636530 ns/op 327.38 MB/s Benchmark_RFanOut_8x10x10000-16 482 7349441 ns/op 340.16 MB/s Benchmark_RFanOut_8x10x10000-16 470 7537723 ns/op 331.67 MB/s Benchmark_RFanOut_8x10x10000-16 481 7450369 ns/op 335.56 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 2869 1181026 ns/op 8832.19 MB/s Benchmark_RFanOut_1kx10x1000-16 3051 1176808 ns/op 8863.84 MB/s Benchmark_RFanOut_1kx10x1000-16 2977 1185443 ns/op 8799.27 MB/s Benchmark_RFanOut_1kx10x1000-16 2953 1176276 ns/op 8867.85 MB/s Benchmark_RFanOut_1kx10x1000-16 2930 1179246 ns/op 8845.52 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6980424 505.5 ns/op 4110.69 MB/s Benchmark_____FanIn_1kx100x1-16 6944480 509.1 ns/op 4081.95 MB/s Benchmark_____FanIn_1kx100x1-16 6881499 506.3 ns/op 4104.27 MB/s Benchmark_____FanIn_1kx100x1-16 6953702 505.7 ns/op 4109.21 MB/s Benchmark_____FanIn_1kx100x1-16 7033657 507.5 ns/op 4094.72 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2669830 1366 ns/op 6018.09 MB/s Benchmark_____FanIn_4kx100x1-16 2650206 1373 ns/op 5988.76 MB/s Benchmark_____FanIn_4kx100x1-16 2608890 1366 ns/op 6019.84 MB/s Benchmark_____FanIn_4kx100x1-16 2576608 1365 ns/op 6025.61 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 148369184 vs 10723684800 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57322->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark_____FanIn_4kx100x1-16 Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1675150 2111 ns/op 7774.02 MB/s Benchmark_____FanIn_8kx100x1-16 1672821 2104 ns/op 7801.41 MB/s Benchmark_____FanIn_8kx100x1-16 1663236 2120 ns/op 7742.34 MB/s Benchmark_____FanIn_8kx100x1-16 1686657 2140 ns/op 7671.25 MB/s Benchmark_____FanIn_8kx100x1-16 1701070 2121 ns/op 7740.60 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 860604 4192 ns/op 7824.35 MB/s Benchmark____FanIn_16kx100x1-16 871654 4902 ns/op 6691.02 MB/s Benchmark____FanIn_16kx100x1-16 855574 4221 ns/op 7771.51 MB/s Benchmark____FanIn_16kx100x1-16 858686 4103 ns/op 7994.96 MB/s Benchmark____FanIn_16kx100x1-16 878610 4160 ns/op 7884.55 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 164250 19835 ns/op 6609.59 MB/s Benchmark____FanIn_64kx100x1-16 167998 19884 ns/op 6593.46 MB/s Benchmark____FanIn_64kx100x1-16 169339 19969 ns/op 6565.31 MB/s Benchmark____FanIn_64kx100x1-16 176244 19730 ns/op 6644.84 MB/s Benchmark____FanIn_64kx100x1-16 165974 19925 ns/op 6579.79 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 381078630 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60388->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60800->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:60380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32874->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: 343586890 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34026->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34770->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: 108542520 vs 1310900000 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:53946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53332->127.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:53478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54200->127.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:53410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53728->127.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:53640->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53990->127.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:54230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53364->127.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 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53628->127.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:54098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53882->127.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:54092->127.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:53902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53928->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: 349748120 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55554->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55526->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:55504->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: 770809200 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57330->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57770->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57788->127.0.0.1:5222: write: broken pipe Benchmark___BumpPubCount_1x3-16 5522392 646.5 ns/op 439.26 MB/s Benchmark___BumpPubCount_1x3-16 5577498 639.9 ns/op 443.82 MB/s Benchmark___BumpPubCount_1x3-16 5565655 647.0 ns/op 438.92 MB/s Benchmark___BumpPubCount_1x3-16 5521890 640.6 ns/op 443.35 MB/s Benchmark___BumpPubCount_1x3-16 5626580 643.4 ns/op 441.38 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5164785 671.9 ns/op 422.66 MB/s Benchmark___BumpPubCount_2x3-16 5281453 674.8 ns/op 420.87 MB/s Benchmark___BumpPubCount_2x3-16 5255743 676.3 ns/op 419.93 MB/s Benchmark___BumpPubCount_2x3-16 5305839 673.3 ns/op 421.77 MB/s Benchmark___BumpPubCount_2x3-16 5271409 677.0 ns/op 419.49 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5508147 652.8 ns/op 435.03 MB/s Benchmark___BumpPubCount_5x3-16 5529303 645.1 ns/op 440.22 MB/s Benchmark___BumpPubCount_5x3-16 5536191 647.2 ns/op 438.84 MB/s Benchmark___BumpPubCount_5x3-16 5533948 651.3 ns/op 436.03 MB/s Benchmark___BumpPubCount_5x3-16 5349891 644.0 ns/op 440.98 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5547117 650.4 ns/op 436.63 MB/s Benchmark__BumpPubCount_10x3-16 5512040 645.5 ns/op 439.98 MB/s Benchmark__BumpPubCount_10x3-16 5525484 649.4 ns/op 437.34 MB/s Benchmark__BumpPubCount_10x3-16 5528125 646.1 ns/op 439.56 MB/s Benchmark__BumpPubCount_10x3-16 5519695 646.8 ns/op 439.10 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11837617 282.0 ns/op 3687.43 MB/s Benchmark____GWs_Opt_1kx01x0-16 12749307 276.4 ns/op 3762.08 MB/s Benchmark____GWs_Opt_1kx01x0-16 12946700 273.8 ns/op 3798.79 MB/s Benchmark____GWs_Opt_1kx01x0-16 12639790 286.5 ns/op 3629.42 MB/s Benchmark____GWs_Opt_1kx01x0-16 12801571 278.0 ns/op 3740.91 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10001476 322.3 ns/op 6403.42 MB/s Benchmark____GWs_Opt_2kx01x0-16 10417198 332.3 ns/op 6211.28 MB/s Benchmark____GWs_Opt_2kx01x0-16 10528810 352.5 ns/op 5856.08 MB/s Benchmark____GWs_Opt_2kx01x0-16 10106947 338.6 ns/op 6095.57 MB/s Benchmark____GWs_Opt_2kx01x0-16 10131320 340.8 ns/op 6057.02 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5741133 622.4 ns/op 6607.03 MB/s Benchmark____GWs_Opt_4kx01x0-16 5906550 607.8 ns/op 6765.93 MB/s Benchmark____GWs_Opt_4kx01x0-16 5863615 608.0 ns/op 6762.88 MB/s Benchmark____GWs_Opt_4kx01x0-16 5630310 615.1 ns/op 6684.68 MB/s Benchmark____GWs_Opt_4kx01x0-16 5880807 617.0 ns/op 6664.95 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 28104826 110.6 ns/op 9407.38 MB/s Benchmark____GWs_Opt_1kx10x0-16 31566985 115.9 ns/op 8974.84 MB/s Benchmark____GWs_Opt_1kx10x0-16 31085749 110.3 ns/op 9428.01 MB/s Benchmark____GWs_Opt_1kx10x0-16 31287123 114.1 ns/op 9118.51 MB/s Benchmark____GWs_Opt_1kx10x0-16 30431097 109.6 ns/op 9486.62 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24715083 141.9 ns/op 14546.43 MB/s Benchmark____GWs_Opt_2kx10x0-16 24558514 155.7 ns/op 13259.24 MB/s Benchmark____GWs_Opt_2kx10x0-16 25293896 156.6 ns/op 13177.08 MB/s Benchmark____GWs_Opt_2kx10x0-16 20848838 157.6 ns/op 13096.32 MB/s Benchmark____GWs_Opt_2kx10x0-16 25575578 165.7 ns/op 12457.18 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12108842 318.6 ns/op 12907.52 MB/s Benchmark____GWs_Opt_4kx10x0-16 1000000 4853 ns/op 847.31 MB/s Benchmark____GWs_Opt_4kx10x0-16 12256616 328.5 ns/op 12516.14 MB/s Benchmark____GWs_Opt_4kx10x0-16 12937171 288.4 ns/op 14260.36 MB/s Benchmark____GWs_Opt_4kx10x0-16 13105722 332.5 ns/op 12366.34 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6609943 549.4 ns/op 5687.70 MB/s Benchmark____GWs_Opt_1kx01x1-16 6571983 547.6 ns/op 5706.65 MB/s Benchmark____GWs_Opt_1kx01x1-16 6455740 547.1 ns/op 5711.75 MB/s Benchmark____GWs_Opt_1kx01x1-16 6447513 542.9 ns/op 5756.64 MB/s Benchmark____GWs_Opt_1kx01x1-16 6532497 540.5 ns/op 5781.90 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4772547 757.2 ns/op 8184.60 MB/s Benchmark____GWs_Opt_2kx01x1-16 4486149 772.1 ns/op 8025.87 MB/s Benchmark____GWs_Opt_2kx01x1-16 4703953 767.3 ns/op 8076.08 MB/s Benchmark____GWs_Opt_2kx01x1-16 4108399 742.6 ns/op 8344.45 MB/s Benchmark____GWs_Opt_2kx01x1-16 4779282 748.5 ns/op 8279.49 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2565991 1365 ns/op 9040.90 MB/s Benchmark____GWs_Opt_4kx01x1-16 2658562 1361 ns/op 9065.09 MB/s Benchmark____GWs_Opt_4kx01x1-16 2489206 1350 ns/op 9143.79 MB/s Benchmark____GWs_Opt_4kx01x1-16 2638764 1366 ns/op 9033.55 MB/s Benchmark____GWs_Opt_4kx01x1-16 2630280 1376 ns/op 8968.49 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6315444 542.7 ns/op 5757.94 MB/s Benchmark____GWs_Opt_1kx10x1-16 6434148 559.5 ns/op 5585.10 MB/s Benchmark____GWs_Opt_1kx10x1-16 6405554 557.1 ns/op 5609.53 MB/s Benchmark____GWs_Opt_1kx10x1-16 6404912 554.9 ns/op 5631.62 MB/s Benchmark____GWs_Opt_1kx10x1-16 6153153 560.0 ns/op 5579.95 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4289745 830.1 ns/op 7465.79 MB/s Benchmark____GWs_Opt_2kx10x1-16 4323152 855.9 ns/op 7240.31 MB/s Benchmark____GWs_Opt_2kx10x1-16 4002775 839.2 ns/op 7384.68 MB/s Benchmark____GWs_Opt_2kx10x1-16 4123129 833.8 ns/op 7432.18 MB/s Benchmark____GWs_Opt_2kx10x1-16 4372221 844.8 ns/op 7335.18 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2574537 1535 ns/op 8040.69 MB/s Benchmark____GWs_Opt_4kx10x1-16 2358895 1580 ns/op 7808.83 MB/s Benchmark____GWs_Opt_4kx10x1-16 2269952 1547 ns/op 7979.75 MB/s Benchmark____GWs_Opt_4kx10x1-16 2165763 1512 ns/op 8163.08 MB/s Benchmark____GWs_Opt_4kx10x1-16 2249152 1509 ns/op 8180.67 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12399345 290.3 ns/op 3582.05 MB/s Benchmark____GWs_Int_1kx01x0-16 12276238 290.4 ns/op 3581.02 MB/s Benchmark____GWs_Int_1kx01x0-16 11759506 287.6 ns/op 3615.53 MB/s Benchmark____GWs_Int_1kx01x0-16 12500032 287.6 ns/op 3616.52 MB/s Benchmark____GWs_Int_1kx01x0-16 12371017 292.2 ns/op 3558.63 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 9934291 342.4 ns/op 6028.17 MB/s Benchmark____GWs_Int_2kx01x0-16 10478101 362.8 ns/op 5688.89 MB/s Benchmark____GWs_Int_2kx01x0-16 10577758 364.6 ns/op 5661.32 MB/s Benchmark____GWs_Int_2kx01x0-16 9682476 372.1 ns/op 5546.64 MB/s Benchmark____GWs_Int_2kx01x0-16 10202203 372.6 ns/op 5538.83 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5729916 650.9 ns/op 6317.36 MB/s Benchmark____GWs_Int_4kx01x0-16 5670859 644.8 ns/op 6377.65 MB/s Benchmark____GWs_Int_4kx01x0-16 5690779 640.7 ns/op 6417.91 MB/s Benchmark____GWs_Int_4kx01x0-16 5813858 630.9 ns/op 6517.63 MB/s Benchmark____GWs_Int_4kx01x0-16 5607346 636.7 ns/op 6458.65 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31102608 111.4 ns/op 9333.96 MB/s Benchmark____GWs_Int_1kx10x0-16 27475956 113.8 ns/op 9134.83 MB/s Benchmark____GWs_Int_1kx10x0-16 32228212 110.9 ns/op 9376.09 MB/s Benchmark____GWs_Int_1kx10x0-16 31338853 116.0 ns/op 8964.35 MB/s Benchmark____GWs_Int_1kx10x0-16 31151604 114.1 ns/op 9118.56 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 26072168 149.2 ns/op 13834.07 MB/s Benchmark____GWs_Int_2kx10x0-16 25264101 144.1 ns/op 14322.16 MB/s Benchmark____GWs_Int_2kx10x0-16 25674762 157.2 ns/op 13128.82 MB/s Benchmark____GWs_Int_2kx10x0-16 22444963 144.9 ns/op 14246.55 MB/s Benchmark____GWs_Int_2kx10x0-16 25917498 139.5 ns/op 14793.34 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13215742 336.8 ns/op 12209.40 MB/s Benchmark____GWs_Int_4kx10x0-16 12299486 278.7 ns/op 14752.81 MB/s Benchmark____GWs_Int_4kx10x0-16 12914799 302.2 ns/op 13607.76 MB/s Benchmark____GWs_Int_4kx10x0-16 11303619 335.9 ns/op 12240.92 MB/s Benchmark____GWs_Int_4kx10x0-16 12839757 278.4 ns/op 14768.24 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6440919 550.5 ns/op 5676.26 MB/s Benchmark____GWs_Int_1kx01x1-16 6194356 567.6 ns/op 5505.44 MB/s Benchmark____GWs_Int_1kx01x1-16 6361575 554.4 ns/op 5637.16 MB/s Benchmark____GWs_Int_1kx01x1-16 6171498 555.0 ns/op 5630.26 MB/s Benchmark____GWs_Int_1kx01x1-16 6437124 551.8 ns/op 5663.75 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4634692 754.9 ns/op 8209.49 MB/s Benchmark____GWs_Int_2kx01x1-16 4787828 766.0 ns/op 8089.92 MB/s Benchmark____GWs_Int_2kx01x1-16 4505431 755.7 ns/op 8200.01 MB/s Benchmark____GWs_Int_2kx01x1-16 4692764 770.3 ns/op 8044.78 MB/s Benchmark____GWs_Int_2kx01x1-16 4644225 773.4 ns/op 8012.68 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2538045 1366 ns/op 9033.60 MB/s Benchmark____GWs_Int_4kx01x1-16 2626784 1381 ns/op 8935.67 MB/s Benchmark____GWs_Int_4kx01x1-16 2628826 1368 ns/op 9024.32 MB/s Benchmark____GWs_Int_4kx01x1-16 2568980 1358 ns/op 9090.48 MB/s Benchmark____GWs_Int_4kx01x1-16 2639218 1530 ns/op 8068.36 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6251791 555.7 ns/op 5623.99 MB/s Benchmark____GWs_Int_1kx10x1-16 6174841 555.9 ns/op 5621.06 MB/s Benchmark____GWs_Int_1kx10x1-16 6599779 558.6 ns/op 5593.99 MB/s Benchmark____GWs_Int_1kx10x1-16 6634947 561.0 ns/op 5570.85 MB/s Benchmark____GWs_Int_1kx10x1-16 6053184 555.8 ns/op 5622.81 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 3907117 829.4 ns/op 7471.74 MB/s Benchmark____GWs_Int_2kx10x1-16 4614549 829.0 ns/op 7475.25 MB/s Benchmark____GWs_Int_2kx10x1-16 4191460 849.0 ns/op 7299.02 MB/s Benchmark____GWs_Int_2kx10x1-16 4166686 850.9 ns/op 7282.89 MB/s Benchmark____GWs_Int_2kx10x1-16 4223742 838.8 ns/op 7387.55 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2357941 1517 ns/op 8133.13 MB/s Benchmark____GWs_Int_4kx10x1-16 2335276 1491 ns/op 8276.69 MB/s Benchmark____GWs_Int_4kx10x1-16 2151732 1504 ns/op 8203.13 MB/s Benchmark____GWs_Int_4kx10x1-16 2470765 1566 ns/op 7878.52 MB/s Benchmark____GWs_Int_4kx10x1-16 2154838 1502 ns/op 8218.45 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8033638 435.8 ns/op 234.07 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8660042 443.1 ns/op 230.19 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8150824 439.1 ns/op 232.31 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8548177 435.6 ns/op 234.15 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7893465 434.6 ns/op 234.71 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 622891 5058 ns/op 34.99 MB/s Benchmark__GWs_Reqs_1SubEach-16 762800 5189 ns/op 34.11 MB/s Benchmark__GWs_Reqs_1SubEach-16 799410 5364 ns/op 33.00 MB/s Benchmark__GWs_Reqs_1SubEach-16 775083 5284 ns/op 33.50 MB/s Benchmark__GWs_Reqs_1SubEach-16 738926 5258 ns/op 33.66 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2056.743s