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 49501220 72.04 ns/op 152.70 MB/s Benchmark______Pub0b_Payload-16 47644884 72.28 ns/op 152.19 MB/s Benchmark______Pub0b_Payload-16 41974225 72.12 ns/op 152.52 MB/s Benchmark______Pub0b_Payload-16 46965529 72.18 ns/op 152.39 MB/s Benchmark______Pub0b_Payload-16 47356048 72.14 ns/op 152.48 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46935681 72.69 ns/op 261.38 MB/s Benchmark______Pub8b_Payload-16 46984131 76.76 ns/op 247.52 MB/s Benchmark______Pub8b_Payload-16 46996870 72.89 ns/op 260.68 MB/s Benchmark______Pub8b_Payload-16 49371542 74.78 ns/op 254.09 MB/s Benchmark______Pub8b_Payload-16 46765276 74.18 ns/op 256.12 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44061358 77.63 ns/op 566.78 MB/s Benchmark_____Pub32b_Payload-16 44266959 76.55 ns/op 574.81 MB/s Benchmark_____Pub32b_Payload-16 44347365 82.36 ns/op 534.25 MB/s Benchmark_____Pub32b_Payload-16 44470876 77.52 ns/op 567.62 MB/s Benchmark_____Pub32b_Payload-16 47025362 76.78 ns/op 573.03 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39911928 86.63 ns/op 1627.70 MB/s Benchmark____Pub128B_Payload-16 39243006 85.98 ns/op 1639.96 MB/s Benchmark____Pub128B_Payload-16 41862553 87.37 ns/op 1613.82 MB/s Benchmark____Pub128B_Payload-16 34806128 87.18 ns/op 1617.37 MB/s Benchmark____Pub128B_Payload-16 41712222 87.61 ns/op 1609.35 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 35509147 96.15 ns/op 2797.62 MB/s Benchmark____Pub256B_Payload-16 36027154 95.23 ns/op 2824.67 MB/s Benchmark____Pub256B_Payload-16 36114397 95.53 ns/op 2815.84 MB/s Benchmark____Pub256B_Payload-16 38114083 94.42 ns/op 2848.95 MB/s Benchmark____Pub256B_Payload-16 35869041 95.66 ns/op 2811.92 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 24836871 138.8 ns/op 7479.26 MB/s Benchmark______Pub1K_Payload-16 23955318 143.8 ns/op 7218.12 MB/s Benchmark______Pub1K_Payload-16 23947141 137.2 ns/op 7566.13 MB/s Benchmark______Pub1K_Payload-16 24512480 138.4 ns/op 7501.66 MB/s Benchmark______Pub1K_Payload-16 23826783 139.5 ns/op 7438.82 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5702007 617.1 ns/op 6660.27 MB/s Benchmark______Pub4K_Payload-16 5458462 626.6 ns/op 6559.52 MB/s Benchmark______Pub4K_Payload-16 5752537 631.4 ns/op 6509.38 MB/s Benchmark______Pub4K_Payload-16 5645710 613.5 ns/op 6699.42 MB/s Benchmark______Pub4K_Payload-16 5567769 626.2 ns/op 6563.28 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2751576 1285 ns/op 6384.79 MB/s Benchmark______Pub8K_Payload-16 2626284 1279 ns/op 6415.33 MB/s Benchmark______Pub8K_Payload-16 2734416 1282 ns/op 6401.02 MB/s Benchmark______Pub8K_Payload-16 2684904 1285 ns/op 6386.61 MB/s Benchmark______Pub8K_Payload-16 2782914 1274 ns/op 6442.96 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 649538 5561 ns/op 5895.12 MB/s Benchmark_____Pub32K_Payload-16 650260 5398 ns/op 6073.25 MB/s Benchmark_____Pub32K_Payload-16 649219 5438 ns/op 6028.84 MB/s Benchmark_____Pub32K_Payload-16 563331 6245 ns/op 5249.74 MB/s Benchmark_____Pub32K_Payload-16 648450 5589 ns/op 5866.14 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32695512 93.29 ns/op 117.92 MB/s Benchmark__AuthPub0b_Payload-16 35978394 92.31 ns/op 119.17 MB/s Benchmark__AuthPub0b_Payload-16 36878961 92.83 ns/op 118.50 MB/s Benchmark__AuthPub0b_Payload-16 34013894 92.96 ns/op 118.33 MB/s Benchmark__AuthPub0b_Payload-16 38836966 93.10 ns/op 118.15 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15485822 229.1 ns/op Benchmark_____________PubSub-16 15712452 227.7 ns/op Benchmark_____________PubSub-16 15526612 227.4 ns/op Benchmark_____________PubSub-16 15694897 227.6 ns/op Benchmark_____________PubSub-16 15506041 227.5 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15708067 224.9 ns/op Benchmark_____PubSubTwoConns-16 15793807 226.7 ns/op Benchmark_____PubSubTwoConns-16 15759321 226.7 ns/op Benchmark_____PubSubTwoConns-16 15782041 226.2 ns/op Benchmark_____PubSubTwoConns-16 15641826 226.1 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:54714->127.0.0.1:37859: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:38522->127.0.0.1:35893: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:59176->127.0.0.1:41799: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:34534->127.0.0.1:45379: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:56838->127.0.0.1:38627: 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 14375186 245.5 ns/op Benchmark_____PubTwoQueueSub-16 14368776 245.6 ns/op Benchmark_____PubTwoQueueSub-16 14438916 246.3 ns/op Benchmark_____PubTwoQueueSub-16 14426096 245.6 ns/op Benchmark_____PubTwoQueueSub-16 14407015 246.4 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14427099 246.3 ns/op Benchmark____PubFourQueueSub-16 14397694 246.6 ns/op Benchmark____PubFourQueueSub-16 14279353 246.7 ns/op Benchmark____PubFourQueueSub-16 14381475 246.3 ns/op Benchmark____PubFourQueueSub-16 14409709 246.5 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14423150 246.0 ns/op Benchmark___PubEightQueueSub-16 14152105 245.9 ns/op Benchmark___PubEightQueueSub-16 14374628 245.8 ns/op Benchmark___PubEightQueueSub-16 14434381 244.7 ns/op Benchmark___PubEightQueueSub-16 14395742 245.8 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23203 157314 ns/op Benchmark_PubSub512kTwoConns-16 23102 155604 ns/op Benchmark_PubSub512kTwoConns-16 23011 155696 ns/op Benchmark_PubSub512kTwoConns-16 22884 156103 ns/op Benchmark_PubSub512kTwoConns-16 23182 157180 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15237332 230.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15086533 228.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 14920737 230.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15233584 230.5 ns/op Benchmark__DenyMsgNoWCPubSub-16 15075280 230.4 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15201762 230.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 15100825 230.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15010214 230.2 ns/op Benchmark_DenyMsgYesWCPubSub-16 15230562 231.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 14792138 232.9 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 10927974 312.9 ns/op Benchmark____RoutedPubSub_0b-16 11315910 308.7 ns/op Benchmark____RoutedPubSub_0b-16 11167496 312.9 ns/op Benchmark____RoutedPubSub_0b-16 11417608 313.4 ns/op Benchmark____RoutedPubSub_0b-16 11294306 319.3 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6447859 543.6 ns/op Benchmark____RoutedPubSub_1K-16 6686386 546.4 ns/op Benchmark____RoutedPubSub_1K-16 6551876 540.5 ns/op Benchmark____RoutedPubSub_1K-16 6811705 545.3 ns/op Benchmark____RoutedPubSub_1K-16 6663270 541.8 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 86425 44531 ns/op Benchmark__RoutedPubSub_100K-16 85636 42050 ns/op Benchmark__RoutedPubSub_100K-16 85086 42054 ns/op Benchmark__RoutedPubSub_100K-16 85380 42150 ns/op Benchmark__RoutedPubSub_100K-16 84631 42131 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9513524 322.1 ns/op Benchmark____Routed2QueueSub-16 9433405 325.9 ns/op Benchmark____Routed2QueueSub-16 9550008 316.5 ns/op Benchmark____Routed2QueueSub-16 9527227 323.0 ns/op Benchmark____Routed2QueueSub-16 9695914 316.0 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9401949 327.4 ns/op Benchmark____Routed4QueueSub-16 9534466 323.9 ns/op Benchmark____Routed4QueueSub-16 10956646 316.9 ns/op Benchmark____Routed4QueueSub-16 11116681 332.7 ns/op Benchmark____Routed4QueueSub-16 9492661 325.9 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9243885 338.2 ns/op Benchmark____Routed8QueueSub-16 9134619 335.7 ns/op Benchmark____Routed8QueueSub-16 9323601 325.6 ns/op Benchmark____Routed8QueueSub-16 9118071 335.1 ns/op Benchmark____Routed8QueueSub-16 9114956 330.0 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8825475 344.0 ns/op Benchmark___Routed16QueueSub-16 8888887 357.5 ns/op Benchmark___Routed16QueueSub-16 10423064 352.3 ns/op Benchmark___Routed16QueueSub-16 8663632 347.3 ns/op Benchmark___Routed16QueueSub-16 8780494 355.6 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6422358 557.1 ns/op Benchmark____________RouteCompressOff-16 6406036 559.5 ns/op Benchmark____________RouteCompressOff-16 6516721 555.8 ns/op Benchmark____________RouteCompressOff-16 6384934 548.6 ns/op Benchmark____________RouteCompressOff-16 6372285 559.6 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6307729 553.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6420837 557.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6352878 547.7 ns/op Benchmark_RouteCompressS2Uncompressed-16 6372686 548.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6359532 547.9 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6331351 559.0 ns/op Benchmark_________RouteCompressS2Fast-16 6468342 550.8 ns/op Benchmark_________RouteCompressS2Fast-16 6310700 549.9 ns/op Benchmark_________RouteCompressS2Fast-16 6526036 553.5 ns/op Benchmark_________RouteCompressS2Fast-16 6414105 548.2 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6425694 551.8 ns/op Benchmark_______RouteCompressS2Better-16 6438596 551.8 ns/op Benchmark_______RouteCompressS2Better-16 6414097 548.1 ns/op Benchmark_______RouteCompressS2Better-16 6383115 535.9 ns/op Benchmark_______RouteCompressS2Better-16 6530192 557.0 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6362257 550.5 ns/op Benchmark_________RouteCompressS2Best-16 6548467 550.5 ns/op Benchmark_________RouteCompressS2Best-16 6326659 550.2 ns/op Benchmark_________RouteCompressS2Best-16 6209792 559.0 ns/op Benchmark_________RouteCompressS2Best-16 6344162 550.3 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4672819 767.5 ns/op 324.44 MB/s Benchmark______FanOut_8x1x10-16 4672183 767.1 ns/op 324.60 MB/s Benchmark______FanOut_8x1x10-16 4646526 772.9 ns/op 322.14 MB/s Benchmark______FanOut_8x1x10-16 4631058 768.8 ns/op 323.86 MB/s Benchmark______FanOut_8x1x10-16 4608364 770.7 ns/op 323.07 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 526334 6097 ns/op 380.37 MB/s Benchmark_____FanOut_8x1x100-16 539583 6145 ns/op 377.39 MB/s Benchmark_____FanOut_8x1x100-16 555550 6242 ns/op 371.52 MB/s Benchmark_____FanOut_8x1x100-16 564408 6091 ns/op 380.76 MB/s Benchmark_____FanOut_8x1x100-16 549884 6115 ns/op 379.23 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 47666 76567 ns/op 300.64 MB/s Benchmark____FanOut_8x10x100-16 47332 75160 ns/op 306.26 MB/s Benchmark____FanOut_8x10x100-16 47739 75678 ns/op 304.17 MB/s Benchmark____FanOut_8x10x100-16 47472 75271 ns/op 305.82 MB/s Benchmark____FanOut_8x10x100-16 47799 75446 ns/op 305.11 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5898 609763 ns/op 393.63 MB/s Benchmark___FanOut_8x10x1000-16 5672 605842 ns/op 396.17 MB/s Benchmark___FanOut_8x10x1000-16 5860 607881 ns/op 394.85 MB/s Benchmark___FanOut_8x10x1000-16 5808 608059 ns/op 394.73 MB/s Benchmark___FanOut_8x10x1000-16 5724 605973 ns/op 396.09 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4918 718208 ns/op 320.27 MB/s Benchmark___FanOut_8x100x100-16 4930 736048 ns/op 312.51 MB/s Benchmark___FanOut_8x100x100-16 4912 719250 ns/op 319.80 MB/s Benchmark___FanOut_8x100x100-16 4894 719159 ns/op 319.84 MB/s Benchmark___FanOut_8x100x100-16 4933 719849 ns/op 319.54 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 538 6315129 ns/op 380.04 MB/s Benchmark__FanOut_8x100x1000-16 556 6364641 ns/op 377.09 MB/s Benchmark__FanOut_8x100x1000-16 567 6294134 ns/op 381.31 MB/s Benchmark__FanOut_8x100x1000-16 559 6335882 ns/op 378.80 MB/s Benchmark__FanOut_8x100x1000-16 554 6254067 ns/op 383.75 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 516 6849839 ns/op 364.97 MB/s Benchmark__FanOut_8x10x10000-16 518 6865909 ns/op 364.12 MB/s Benchmark__FanOut_8x10x10000-16 518 6854787 ns/op 364.71 MB/s Benchmark__FanOut_8x10x10000-16 523 6801279 ns/op 367.58 MB/s Benchmark__FanOut_8x10x10000-16 511 6863050 ns/op 364.27 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 932 3806345 ns/op 302.13 MB/s Benchmark___FanOut_8x500x100-16 938 3822664 ns/op 300.84 MB/s Benchmark___FanOut_8x500x100-16 927 3818081 ns/op 301.20 MB/s Benchmark___FanOut_8x500x100-16 934 3808230 ns/op 301.98 MB/s Benchmark___FanOut_8x500x100-16 921 3825417 ns/op 300.63 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 359752 9540 ns/op 1534.63 MB/s Benchmark___FanOut_128x1x100-16 362220 9523 ns/op 1537.51 MB/s Benchmark___FanOut_128x1x100-16 358208 9547 ns/op 1533.49 MB/s Benchmark___FanOut_128x1x100-16 366429 9664 ns/op 1514.96 MB/s Benchmark___FanOut_128x1x100-16 361111 9552 ns/op 1532.71 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32359 111006 ns/op 1307.51 MB/s Benchmark__FanOut_128x10x100-16 32518 110942 ns/op 1308.26 MB/s Benchmark__FanOut_128x10x100-16 32253 111232 ns/op 1304.85 MB/s Benchmark__FanOut_128x10x100-16 32492 111484 ns/op 1301.90 MB/s Benchmark__FanOut_128x10x100-16 32043 111501 ns/op 1301.70 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3732 891113 ns/op 1638.56 MB/s Benchmark_FanOut_128x10x1000-16 3984 890143 ns/op 1640.34 MB/s Benchmark_FanOut_128x10x1000-16 3952 889834 ns/op 1640.91 MB/s Benchmark_FanOut_128x10x1000-16 4011 885915 ns/op 1648.17 MB/s Benchmark_FanOut_128x10x1000-16 3913 883134 ns/op 1653.36 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3488 1019140 ns/op 1422.91 MB/s Benchmark_FanOut_128x100x100-16 3482 1023592 ns/op 1416.72 MB/s Benchmark_FanOut_128x100x100-16 3520 1023710 ns/op 1416.56 MB/s Benchmark_FanOut_128x100x100-16 3505 1024743 ns/op 1415.13 MB/s Benchmark_FanOut_128x100x100-16 3382 1031960 ns/op 1405.23 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 386 9502522 ns/op 1536.45 MB/s BenchmarkFanOut_128x100x1000-16 369 9383487 ns/op 1555.94 MB/s BenchmarkFanOut_128x100x1000-16 379 9434800 ns/op 1547.48 MB/s BenchmarkFanOut_128x100x1000-16 378 9524194 ns/op 1532.95 MB/s BenchmarkFanOut_128x100x1000-16 380 9535890 ns/op 1531.07 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 366 9801540 ns/op 1499.78 MB/s BenchmarkFanOut_128x10x10000-16 366 9720344 ns/op 1512.31 MB/s BenchmarkFanOut_128x10x10000-16 368 9911645 ns/op 1483.12 MB/s BenchmarkFanOut_128x10x10000-16 369 9829048 ns/op 1495.58 MB/s BenchmarkFanOut_128x10x10000-16 367 9841968 ns/op 1493.62 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 669 5335378 ns/op 1358.88 MB/s BenchmarkFanOut__128x500x100-16 658 5282431 ns/op 1372.50 MB/s BenchmarkFanOut__128x500x100-16 643 5303801 ns/op 1366.97 MB/s BenchmarkFanOut__128x500x100-16 664 5296459 ns/op 1368.87 MB/s BenchmarkFanOut__128x500x100-16 663 5358576 ns/op 1353.00 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1928 1858241 ns/op 2847.06 MB/s Benchmark_FanOut_512x100x100-16 1952 1859325 ns/op 2845.40 MB/s Benchmark_FanOut_512x100x100-16 1888 1853081 ns/op 2854.99 MB/s Benchmark_FanOut_512x100x100-16 1948 1837760 ns/op 2878.79 MB/s Benchmark_FanOut_512x100x100-16 1922 1870578 ns/op 2828.28 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 212 16870621 ns/op 3141.59 MB/s Benchmark__FanOut_512x100x1k-16 214 16942442 ns/op 3128.27 MB/s Benchmark__FanOut_512x100x1k-16 212 16829189 ns/op 3149.32 MB/s Benchmark__FanOut_512x100x1k-16 216 16889526 ns/op 3138.07 MB/s Benchmark__FanOut_512x100x1k-16 213 16810503 ns/op 3152.82 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3163 1142617 ns/op 9129.07 MB/s Benchmark____FanOut_1kx10x1k-16 3096 1156776 ns/op 9017.34 MB/s Benchmark____FanOut_1kx10x1k-16 2941 1162160 ns/op 8975.56 MB/s Benchmark____FanOut_1kx10x1k-16 3212 1148347 ns/op 9083.52 MB/s Benchmark____FanOut_1kx10x1k-16 3090 1147439 ns/op 9090.71 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2796 1277743 ns/op 8155.81 MB/s Benchmark__FanOut_1kx100x100-16 2739 1269613 ns/op 8208.04 MB/s Benchmark__FanOut_1kx100x100-16 2724 1275518 ns/op 8170.04 MB/s Benchmark__FanOut_1kx100x100-16 2778 1268840 ns/op 8213.04 MB/s Benchmark__FanOut_1kx100x100-16 2689 1273463 ns/op 8183.23 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4450927 775.3 ns/op 321.18 MB/s Benchmark_____RFanOut_8x1x10-16 4410295 781.8 ns/op 318.50 MB/s Benchmark_____RFanOut_8x1x10-16 4539548 776.9 ns/op 320.52 MB/s Benchmark_____RFanOut_8x1x10-16 4395358 787.7 ns/op 316.09 MB/s Benchmark_____RFanOut_8x1x10-16 4441021 780.9 ns/op 318.88 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 517210 6193 ns/op 374.45 MB/s Benchmark____RFanOut_8x1x100-16 540476 6326 ns/op 366.58 MB/s Benchmark____RFanOut_8x1x100-16 521620 6209 ns/op 373.50 MB/s Benchmark____RFanOut_8x1x100-16 538111 6484 ns/op 357.63 MB/s Benchmark____RFanOut_8x1x100-16 526387 6196 ns/op 374.28 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47035 75335 ns/op 305.56 MB/s Benchmark___RFanOut_8x10x100-16 47394 75588 ns/op 304.53 MB/s Benchmark___RFanOut_8x10x100-16 47598 77759 ns/op 296.03 MB/s Benchmark___RFanOut_8x10x100-16 47814 76316 ns/op 301.63 MB/s Benchmark___RFanOut_8x10x100-16 47612 76380 ns/op 301.37 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5604 625419 ns/op 383.77 MB/s Benchmark__RFanOut_8x10x1000-16 5772 613991 ns/op 390.92 MB/s Benchmark__RFanOut_8x10x1000-16 5775 617924 ns/op 388.43 MB/s Benchmark__RFanOut_8x10x1000-16 5440 613401 ns/op 391.29 MB/s Benchmark__RFanOut_8x10x1000-16 5660 613173 ns/op 391.44 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4989 730127 ns/op 315.04 MB/s Benchmark__RFanOut_8x100x100-16 4928 715840 ns/op 321.33 MB/s Benchmark__RFanOut_8x100x100-16 4900 722119 ns/op 318.53 MB/s Benchmark__RFanOut_8x100x100-16 4915 713367 ns/op 322.44 MB/s Benchmark__RFanOut_8x100x100-16 4918 714333 ns/op 322.01 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 573 6307782 ns/op 380.49 MB/s Benchmark_RFanOut_8x100x1000-16 558 6342971 ns/op 378.37 MB/s Benchmark_RFanOut_8x100x1000-16 565 6342375 ns/op 378.41 MB/s Benchmark_RFanOut_8x100x1000-16 543 6390042 ns/op 375.59 MB/s Benchmark_RFanOut_8x100x1000-16 566 6389639 ns/op 375.61 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 519 6901022 ns/op 362.27 MB/s Benchmark_RFanOut_8x10x10000-16 514 7095124 ns/op 352.36 MB/s Benchmark_RFanOut_8x10x10000-16 511 6794440 ns/op 367.95 MB/s Benchmark_RFanOut_8x10x10000-16 530 6764560 ns/op 369.58 MB/s Benchmark_RFanOut_8x10x10000-16 505 6807266 ns/op 367.26 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3030 1165812 ns/op 8947.45 MB/s Benchmark_RFanOut_1kx10x1000-16 2995 1152733 ns/op 9048.96 MB/s Benchmark_RFanOut_1kx10x1000-16 2996 1160051 ns/op 8991.88 MB/s Benchmark_RFanOut_1kx10x1000-16 3141 1153888 ns/op 9039.91 MB/s Benchmark_RFanOut_1kx10x1000-16 2946 1175711 ns/op 8872.11 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7000831 505.4 ns/op 4111.87 MB/s Benchmark_____FanIn_1kx100x1-16 6987151 504.1 ns/op 4122.33 MB/s Benchmark_____FanIn_1kx100x1-16 6944169 506.3 ns/op 4104.65 MB/s Benchmark_____FanIn_1kx100x1-16 6983988 506.9 ns/op 4099.45 MB/s Benchmark_____FanIn_1kx100x1-16 6992826 508.2 ns/op 4088.79 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2631792 1363 ns/op 6034.13 MB/s Benchmark_____FanIn_4kx100x1-16 2616364 1369 ns/op 6003.70 MB/s Benchmark_____FanIn_4kx100x1-16 2623246 1347 ns/op 6102.80 MB/s Benchmark_____FanIn_4kx100x1-16 2631356 1370 ns/op 5999.53 MB/s Benchmark_____FanIn_4kx100x1-16 2663254 1356 ns/op 6063.01 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1691050 2103 ns/op 7803.64 MB/s Benchmark_____FanIn_8kx100x1-16 1643130 2124 ns/op 7726.94 MB/s Benchmark_____FanIn_8kx100x1-16 1710439 2111 ns/op 7776.02 MB/s Benchmark_____FanIn_8kx100x1-16 1714471 2114 ns/op 7764.21 MB/s Benchmark_____FanIn_8kx100x1-16 1670882 2110 ns/op 7777.34 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 866520 4127 ns/op 7947.56 MB/s Benchmark____FanIn_16kx100x1-16 869289 4102 ns/op 7995.68 MB/s Benchmark____FanIn_16kx100x1-16 864736 4222 ns/op 7768.30 MB/s Benchmark____FanIn_16kx100x1-16 870183 4116 ns/op 7968.57 MB/s Benchmark____FanIn_16kx100x1-16 871963 4149 ns/op 7905.03 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 90004269 vs 11321003100 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58228->127.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: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:57844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57406->127.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: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:57870->127.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:57778->127.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: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:58052->127.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:58190->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57970->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58166->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58042->127.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: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:57556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58222->127.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:57998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57972->127.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: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:57586->127.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: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: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: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:58202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57754->127.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:57992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57654->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:57748->127.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: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:57890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57462->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58242->127.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:58152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58058->127.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:58068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57734->127.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:58094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58004->127.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:58252->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57674->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 166962 20099 ns/op 6522.92 MB/s Benchmark____FanIn_64kx100x1-16 171404 20042 ns/op 6541.44 MB/s Benchmark____FanIn_64kx100x1-16 163785 20014 ns/op 6550.56 MB/s Benchmark____FanIn_64kx100x1-16 170434 20062 ns/op 6534.98 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 298491930 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35664->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:35918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35648->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: 659382700 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37820->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37632->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:37556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37836->127.0.0.1:5222: write: broken pipe bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1202357480 vs 8193125000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40122->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:40184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40160->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:40672->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: 534060660 vs 11693228000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55942->127.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:55752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:55424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:55878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55664->127.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:55486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55372->127.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:55706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55404->127.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:55928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:55552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55828->127.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:55962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55436->127.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:56038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:55470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55396->127.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:55440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55640->127.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:55780->127.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:55350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55804->127.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:55516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55388->127.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:56204->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:56206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55704->127.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:55920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55736->127.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:55692->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: 702380220 vs 11457266000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58768->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59110->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58528->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58558->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58838->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59152->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58314->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58758->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5512170 647.9 ns/op 438.31 MB/s Benchmark___BumpPubCount_1x3-16 5514694 648.6 ns/op 437.90 MB/s Benchmark___BumpPubCount_1x3-16 5539879 647.9 ns/op 438.35 MB/s Benchmark___BumpPubCount_1x3-16 5554749 647.3 ns/op 438.77 MB/s Benchmark___BumpPubCount_1x3-16 5506749 646.2 ns/op 439.49 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5275119 672.0 ns/op 422.63 MB/s Benchmark___BumpPubCount_2x3-16 5249814 676.9 ns/op 419.53 MB/s Benchmark___BumpPubCount_2x3-16 5245785 681.4 ns/op 416.81 MB/s Benchmark___BumpPubCount_2x3-16 5276840 677.4 ns/op 419.27 MB/s Benchmark___BumpPubCount_2x3-16 5174956 679.9 ns/op 417.69 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5542866 646.9 ns/op 439.01 MB/s Benchmark___BumpPubCount_5x3-16 5366071 649.1 ns/op 437.50 MB/s Benchmark___BumpPubCount_5x3-16 5224123 652.2 ns/op 435.48 MB/s Benchmark___BumpPubCount_5x3-16 5171446 648.6 ns/op 437.89 MB/s Benchmark___BumpPubCount_5x3-16 5519560 646.9 ns/op 439.03 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5522475 648.7 ns/op 437.79 MB/s Benchmark__BumpPubCount_10x3-16 5517259 647.4 ns/op 438.66 MB/s Benchmark__BumpPubCount_10x3-16 5521650 649.4 ns/op 437.34 MB/s Benchmark__BumpPubCount_10x3-16 5547808 650.9 ns/op 436.32 MB/s Benchmark__BumpPubCount_10x3-16 5531175 648.1 ns/op 438.21 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 11960096 282.1 ns/op 3686.88 MB/s Benchmark____GWs_Opt_1kx01x0-16 12171338 276.0 ns/op 3767.54 MB/s Benchmark____GWs_Opt_1kx01x0-16 12909488 271.4 ns/op 3832.18 MB/s Benchmark____GWs_Opt_1kx01x0-16 12790322 267.5 ns/op 3888.45 MB/s Benchmark____GWs_Opt_1kx01x0-16 12484604 287.5 ns/op 3618.00 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10237770 338.6 ns/op 6095.89 MB/s Benchmark____GWs_Opt_2kx01x0-16 10279972 343.8 ns/op 6003.34 MB/s Benchmark____GWs_Opt_2kx01x0-16 10237086 357.9 ns/op 5767.03 MB/s Benchmark____GWs_Opt_2kx01x0-16 10910028 322.8 ns/op 6393.84 MB/s Benchmark____GWs_Opt_2kx01x0-16 10390740 360.4 ns/op 5727.73 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5681160 637.6 ns/op 6448.99 MB/s Benchmark____GWs_Opt_4kx01x0-16 5663557 607.8 ns/op 6765.10 MB/s Benchmark____GWs_Opt_4kx01x0-16 5515506 622.0 ns/op 6610.54 MB/s Benchmark____GWs_Opt_4kx01x0-16 5766850 625.8 ns/op 6571.27 MB/s Benchmark____GWs_Opt_4kx01x0-16 5671492 657.1 ns/op 6257.89 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 27462225 111.4 ns/op 9337.95 MB/s Benchmark____GWs_Opt_1kx10x0-16 27934053 112.1 ns/op 9276.02 MB/s Benchmark____GWs_Opt_1kx10x0-16 32157194 107.4 ns/op 9687.88 MB/s Benchmark____GWs_Opt_1kx10x0-16 32955616 109.2 ns/op 9521.90 MB/s Benchmark____GWs_Opt_1kx10x0-16 31780620 113.6 ns/op 9158.01 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 23017423 169.1 ns/op 12202.93 MB/s Benchmark____GWs_Opt_2kx10x0-16 25365787 148.4 ns/op 13909.60 MB/s Benchmark____GWs_Opt_2kx10x0-16 22430455 146.5 ns/op 14085.71 MB/s Benchmark____GWs_Opt_2kx10x0-16 23381884 155.6 ns/op 13261.56 MB/s Benchmark____GWs_Opt_2kx10x0-16 22487430 157.6 ns/op 13096.89 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 11676177 293.3 ns/op 14020.00 MB/s bench_test.go:55: Failed read: read tcp 127.0.0.1:34254->127.0.0.1:44753: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 13113937 288.0 ns/op 14276.97 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:58552->127.0.0.1:33197: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:39244->127.0.0.1:44439: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 12625710 291.0 ns/op 14129.00 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6519147 555.3 ns/op 5627.14 MB/s Benchmark____GWs_Opt_1kx01x1-16 6476814 558.0 ns/op 5600.65 MB/s Benchmark____GWs_Opt_1kx01x1-16 6390723 556.8 ns/op 5612.26 MB/s Benchmark____GWs_Opt_1kx01x1-16 6495338 549.3 ns/op 5688.97 MB/s Benchmark____GWs_Opt_1kx01x1-16 6591088 546.0 ns/op 5723.79 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4614459 758.2 ns/op 8173.42 MB/s Benchmark____GWs_Opt_2kx01x1-16 4547443 763.6 ns/op 8115.62 MB/s Benchmark____GWs_Opt_2kx01x1-16 4778972 759.4 ns/op 8160.61 MB/s Benchmark____GWs_Opt_2kx01x1-16 4598990 771.1 ns/op 8036.56 MB/s Benchmark____GWs_Opt_2kx01x1-16 4247293 770.1 ns/op 8047.40 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2600096 1400 ns/op 8816.99 MB/s Benchmark____GWs_Opt_4kx01x1-16 2321994 1389 ns/op 8886.79 MB/s Benchmark____GWs_Opt_4kx01x1-16 2584712 1374 ns/op 8983.13 MB/s Benchmark____GWs_Opt_4kx01x1-16 2630580 1516 ns/op 8142.13 MB/s Benchmark____GWs_Opt_4kx01x1-16 2604808 3138 ns/op 3933.38 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6077064 558.2 ns/op 5598.39 MB/s Benchmark____GWs_Opt_1kx10x1-16 6611540 556.4 ns/op 5616.28 MB/s Benchmark____GWs_Opt_1kx10x1-16 6619921 551.2 ns/op 5669.68 MB/s Benchmark____GWs_Opt_1kx10x1-16 6400932 559.4 ns/op 5585.91 MB/s Benchmark____GWs_Opt_1kx10x1-16 6294309 574.7 ns/op 5437.77 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 3883351 853.4 ns/op 7261.53 MB/s Benchmark____GWs_Opt_2kx10x1-16 4255718 836.5 ns/op 7408.02 MB/s Benchmark____GWs_Opt_2kx10x1-16 3932734 841.4 ns/op 7365.05 MB/s Benchmark____GWs_Opt_2kx10x1-16 4296938 853.1 ns/op 7264.37 MB/s Benchmark____GWs_Opt_2kx10x1-16 4260726 838.4 ns/op 7391.28 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2277468 1524 ns/op 8100.33 MB/s Benchmark____GWs_Opt_4kx10x1-16 2258828 1504 ns/op 8205.36 MB/s Benchmark____GWs_Opt_4kx10x1-16 2193403 1581 ns/op 7805.33 MB/s Benchmark____GWs_Opt_4kx10x1-16 2248672 1535 ns/op 8038.90 MB/s Benchmark____GWs_Opt_4kx10x1-16 2324868 1531 ns/op 8058.20 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12606370 292.9 ns/op 3550.48 MB/s Benchmark____GWs_Int_1kx01x0-16 11379998 290.1 ns/op 3585.56 MB/s Benchmark____GWs_Int_1kx01x0-16 12893430 291.0 ns/op 3574.30 MB/s Benchmark____GWs_Int_1kx01x0-16 12264141 291.1 ns/op 3573.24 MB/s Benchmark____GWs_Int_1kx01x0-16 12157888 287.3 ns/op 3620.12 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10283966 353.1 ns/op 5845.81 MB/s Benchmark____GWs_Int_2kx01x0-16 10226282 351.0 ns/op 5880.70 MB/s Benchmark____GWs_Int_2kx01x0-16 9859666 356.6 ns/op 5788.78 MB/s Benchmark____GWs_Int_2kx01x0-16 10595716 330.9 ns/op 6237.44 MB/s Benchmark____GWs_Int_2kx01x0-16 9701138 358.6 ns/op 5756.25 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5918106 646.2 ns/op 6363.17 MB/s Benchmark____GWs_Int_4kx01x0-16 5675400 698.4 ns/op 5887.40 MB/s Benchmark____GWs_Int_4kx01x0-16 5600317 634.9 ns/op 6476.99 MB/s Benchmark____GWs_Int_4kx01x0-16 5852116 643.6 ns/op 6389.44 MB/s Benchmark____GWs_Int_4kx01x0-16 5722801 638.7 ns/op 6437.89 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31741228 122.5 ns/op 8488.09 MB/s Benchmark____GWs_Int_1kx10x0-16 31550838 117.1 ns/op 8880.74 MB/s Benchmark____GWs_Int_1kx10x0-16 32477001 113.9 ns/op 9128.75 MB/s Benchmark____GWs_Int_1kx10x0-16 33214219 107.6 ns/op 9667.78 MB/s Benchmark____GWs_Int_1kx10x0-16 32816695 119.3 ns/op 8720.66 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 24646873 139.6 ns/op 14789.94 MB/s Benchmark____GWs_Int_2kx10x0-16 23997782 144.6 ns/op 14275.57 MB/s Benchmark____GWs_Int_2kx10x0-16 25665529 142.5 ns/op 14484.22 MB/s Benchmark____GWs_Int_2kx10x0-16 25392410 145.5 ns/op 14180.72 MB/s Benchmark____GWs_Int_2kx10x0-16 25431939 149.3 ns/op 13827.98 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13036959 333.6 ns/op 12325.10 MB/s Benchmark____GWs_Int_4kx10x0-16 13199793 319.0 ns/op 12890.20 MB/s Benchmark____GWs_Int_4kx10x0-16 13217395 343.0 ns/op 11990.02 MB/s Benchmark____GWs_Int_4kx10x0-16 12445688 319.2 ns/op 12882.72 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:43044->127.0.0.1:36693: i/o timeout bench_test.go:167: Did not receive all bytes: 198 vs 220 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:60666->127.0.0.1:38355: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6503623 561.0 ns/op 5570.71 MB/s Benchmark____GWs_Int_1kx01x1-16 6271519 568.0 ns/op 5501.77 MB/s Benchmark____GWs_Int_1kx01x1-16 6600230 682.1 ns/op 4581.77 MB/s Benchmark____GWs_Int_1kx01x1-16 6337594 558.0 ns/op 5600.71 MB/s Benchmark____GWs_Int_1kx01x1-16 6235893 561.9 ns/op 5561.61 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4731642 767.1 ns/op 8077.97 MB/s Benchmark____GWs_Int_2kx01x1-16 4195786 772.5 ns/op 8022.06 MB/s Benchmark____GWs_Int_2kx01x1-16 4518373 780.6 ns/op 7938.29 MB/s Benchmark____GWs_Int_2kx01x1-16 4737292 781.0 ns/op 7934.22 MB/s Benchmark____GWs_Int_2kx01x1-16 4038788 775.2 ns/op 7994.03 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2613561 1592 ns/op 7750.84 MB/s Benchmark____GWs_Int_4kx01x1-16 2497328 1369 ns/op 9016.56 MB/s Benchmark____GWs_Int_4kx01x1-16 2599081 1397 ns/op 8833.40 MB/s Benchmark____GWs_Int_4kx01x1-16 2284219 1390 ns/op 8881.16 MB/s Benchmark____GWs_Int_4kx01x1-16 2657127 1374 ns/op 8980.21 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6115743 562.2 ns/op 5558.18 MB/s Benchmark____GWs_Int_1kx10x1-16 6248457 563.7 ns/op 5543.58 MB/s Benchmark____GWs_Int_1kx10x1-16 6323092 564.6 ns/op 5535.08 MB/s Benchmark____GWs_Int_1kx10x1-16 6092836 567.5 ns/op 5506.74 MB/s Benchmark____GWs_Int_1kx10x1-16 6152871 565.0 ns/op 5531.18 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4164174 840.5 ns/op 7373.38 MB/s Benchmark____GWs_Int_2kx10x1-16 3979400 840.3 ns/op 7375.14 MB/s Benchmark____GWs_Int_2kx10x1-16 3983636 854.3 ns/op 7254.00 MB/s Benchmark____GWs_Int_2kx10x1-16 4259414 843.3 ns/op 7348.41 MB/s Benchmark____GWs_Int_2kx10x1-16 4671118 846.7 ns/op 7319.23 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2274820 1799 ns/op 6861.44 MB/s Benchmark____GWs_Int_4kx10x1-16 2261187 1563 ns/op 7895.72 MB/s Benchmark____GWs_Int_4kx10x1-16 2379282 1528 ns/op 8079.09 MB/s Benchmark____GWs_Int_4kx10x1-16 2202646 1508 ns/op 8182.20 MB/s Benchmark____GWs_Int_4kx10x1-16 2190825 2807 ns/op 4395.89 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 7992594 439.6 ns/op 232.02 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8186983 436.2 ns/op 233.81 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8030121 438.0 ns/op 232.89 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7871523 440.3 ns/op 231.67 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8267796 437.6 ns/op 233.11 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 711150 5119 ns/op 34.58 MB/s Benchmark__GWs_Reqs_1SubEach-16 754038 5291 ns/op 33.45 MB/s Benchmark__GWs_Reqs_1SubEach-16 744368 5386 ns/op 32.86 MB/s Benchmark__GWs_Reqs_1SubEach-16 730671 5368 ns/op 32.97 MB/s Benchmark__GWs_Reqs_1SubEach-16 735230 5272 ns/op 33.57 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2142.064s