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 49288749 72.09 ns/op 152.59 MB/s Benchmark______Pub0b_Payload-16 46980352 72.96 ns/op 150.78 MB/s Benchmark______Pub0b_Payload-16 47627046 73.15 ns/op 150.38 MB/s Benchmark______Pub0b_Payload-16 46685766 72.24 ns/op 152.28 MB/s Benchmark______Pub0b_Payload-16 49999366 72.08 ns/op 152.61 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46634341 72.74 ns/op 261.22 MB/s Benchmark______Pub8b_Payload-16 49584016 72.76 ns/op 261.12 MB/s Benchmark______Pub8b_Payload-16 46794874 75.98 ns/op 250.05 MB/s Benchmark______Pub8b_Payload-16 49303681 73.42 ns/op 258.79 MB/s Benchmark______Pub8b_Payload-16 46921938 73.33 ns/op 259.10 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 46963888 76.74 ns/op 573.40 MB/s Benchmark_____Pub32b_Payload-16 46653327 76.83 ns/op 572.72 MB/s Benchmark_____Pub32b_Payload-16 44703063 76.74 ns/op 573.35 MB/s Benchmark_____Pub32b_Payload-16 44411359 82.27 ns/op 534.80 MB/s Benchmark_____Pub32b_Payload-16 44755623 78.78 ns/op 558.54 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 39514957 85.89 ns/op 1641.72 MB/s Benchmark____Pub128B_Payload-16 39558865 87.04 ns/op 1620.00 MB/s Benchmark____Pub128B_Payload-16 41388442 86.38 ns/op 1632.25 MB/s Benchmark____Pub128B_Payload-16 39789175 85.76 ns/op 1644.15 MB/s Benchmark____Pub128B_Payload-16 39817095 87.53 ns/op 1610.82 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36587731 95.25 ns/op 2824.18 MB/s Benchmark____Pub256B_Payload-16 36700904 96.77 ns/op 2779.85 MB/s Benchmark____Pub256B_Payload-16 38374790 96.97 ns/op 2774.01 MB/s Benchmark____Pub256B_Payload-16 36447640 95.76 ns/op 2809.03 MB/s Benchmark____Pub256B_Payload-16 35244972 94.61 ns/op 2843.22 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23521560 142.7 ns/op 7274.02 MB/s Benchmark______Pub1K_Payload-16 22952786 141.3 ns/op 7347.67 MB/s Benchmark______Pub1K_Payload-16 23921844 142.7 ns/op 7274.59 MB/s Benchmark______Pub1K_Payload-16 23941652 136.9 ns/op 7582.12 MB/s Benchmark______Pub1K_Payload-16 23129991 140.5 ns/op 7386.71 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5412091 632.8 ns/op 6495.16 MB/s Benchmark______Pub4K_Payload-16 5597160 629.1 ns/op 6532.94 MB/s Benchmark______Pub4K_Payload-16 5639170 618.7 ns/op 6643.35 MB/s Benchmark______Pub4K_Payload-16 5716119 608.9 ns/op 6749.41 MB/s Benchmark______Pub4K_Payload-16 5576056 623.7 ns/op 6590.10 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2737750 1279 ns/op 6414.13 MB/s Benchmark______Pub8K_Payload-16 2744709 1278 ns/op 6422.31 MB/s Benchmark______Pub8K_Payload-16 2742397 1271 ns/op 6453.96 MB/s Benchmark______Pub8K_Payload-16 2678707 1278 ns/op 6419.50 MB/s Benchmark______Pub8K_Payload-16 2739248 1282 ns/op 6402.68 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 705328 5536 ns/op 5921.26 MB/s Benchmark_____Pub32K_Payload-16 660795 5388 ns/op 6084.74 MB/s Benchmark_____Pub32K_Payload-16 649647 5486 ns/op 5976.13 MB/s Benchmark_____Pub32K_Payload-16 654949 5474 ns/op 5989.20 MB/s Benchmark_____Pub32K_Payload-16 653652 5384 ns/op 6089.11 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32743982 92.82 ns/op 118.50 MB/s Benchmark__AuthPub0b_Payload-16 36852658 92.82 ns/op 118.51 MB/s Benchmark__AuthPub0b_Payload-16 36825549 93.33 ns/op 117.87 MB/s Benchmark__AuthPub0b_Payload-16 36769194 92.91 ns/op 118.39 MB/s Benchmark__AuthPub0b_Payload-16 36918984 92.67 ns/op 118.70 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15735054 226.0 ns/op Benchmark_____________PubSub-16 15444067 226.9 ns/op Benchmark_____________PubSub-16 15739695 226.4 ns/op Benchmark_____________PubSub-16 15700081 225.8 ns/op Benchmark_____________PubSub-16 15654322 226.7 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15827038 225.0 ns/op Benchmark_____PubSubTwoConns-16 15714661 224.6 ns/op Benchmark_____PubSubTwoConns-16 15721611 224.9 ns/op Benchmark_____PubSubTwoConns-16 15692210 224.3 ns/op Benchmark_____PubSubTwoConns-16 15747548 226.0 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:48450->127.0.0.1:40443: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:57172->127.0.0.1:38381: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49234->127.0.0.1:45209: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:35410->127.0.0.1:38289: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:38412->127.0.0.1:34711: 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 14698107 242.7 ns/op Benchmark_____PubTwoQueueSub-16 14244380 244.0 ns/op Benchmark_____PubTwoQueueSub-16 14642996 243.3 ns/op Benchmark_____PubTwoQueueSub-16 14669684 243.1 ns/op Benchmark_____PubTwoQueueSub-16 14532814 244.0 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14573318 243.2 ns/op Benchmark____PubFourQueueSub-16 14484295 243.0 ns/op Benchmark____PubFourQueueSub-16 14668119 243.8 ns/op Benchmark____PubFourQueueSub-16 14634982 243.7 ns/op Benchmark____PubFourQueueSub-16 14563720 243.6 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14631348 244.3 ns/op Benchmark___PubEightQueueSub-16 14416627 244.3 ns/op Benchmark___PubEightQueueSub-16 14596658 243.0 ns/op Benchmark___PubEightQueueSub-16 14331301 244.8 ns/op Benchmark___PubEightQueueSub-16 14461576 243.9 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23071 162926 ns/op Benchmark_PubSub512kTwoConns-16 23103 155844 ns/op Benchmark_PubSub512kTwoConns-16 23047 155238 ns/op Benchmark_PubSub512kTwoConns-16 23152 155592 ns/op Benchmark_PubSub512kTwoConns-16 21631 156117 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15227296 227.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15341594 228.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15452220 228.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15436044 228.6 ns/op Benchmark__DenyMsgNoWCPubSub-16 15260376 228.3 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15140043 227.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15460419 227.7 ns/op Benchmark_DenyMsgYesWCPubSub-16 15465930 228.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15254989 228.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 15256969 227.0 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11250595 309.9 ns/op Benchmark____RoutedPubSub_0b-16 11545797 310.0 ns/op Benchmark____RoutedPubSub_0b-16 11100306 315.2 ns/op Benchmark____RoutedPubSub_0b-16 11196452 312.6 ns/op Benchmark____RoutedPubSub_0b-16 11153678 320.4 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6703710 530.7 ns/op Benchmark____RoutedPubSub_1K-16 6663346 527.9 ns/op Benchmark____RoutedPubSub_1K-16 6522691 542.1 ns/op Benchmark____RoutedPubSub_1K-16 6569824 535.2 ns/op Benchmark____RoutedPubSub_1K-16 6506775 542.7 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85267 43464 ns/op Benchmark__RoutedPubSub_100K-16 84482 40879 ns/op Benchmark__RoutedPubSub_100K-16 86624 42096 ns/op Benchmark__RoutedPubSub_100K-16 84950 41988 ns/op Benchmark__RoutedPubSub_100K-16 85906 42079 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9734121 317.4 ns/op Benchmark____Routed2QueueSub-16 9886642 314.1 ns/op Benchmark____Routed2QueueSub-16 9982917 315.8 ns/op Benchmark____Routed2QueueSub-16 11496583 314.8 ns/op Benchmark____Routed2QueueSub-16 11687508 312.7 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9691130 324.6 ns/op Benchmark____Routed4QueueSub-16 9336771 321.5 ns/op Benchmark____Routed4QueueSub-16 9556464 320.4 ns/op Benchmark____Routed4QueueSub-16 9524558 321.1 ns/op Benchmark____Routed4QueueSub-16 9594597 321.5 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9171979 330.1 ns/op Benchmark____Routed8QueueSub-16 11124672 323.4 ns/op Benchmark____Routed8QueueSub-16 9288530 328.7 ns/op Benchmark____Routed8QueueSub-16 11128114 329.3 ns/op Benchmark____Routed8QueueSub-16 9297457 334.2 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8758287 345.0 ns/op Benchmark___Routed16QueueSub-16 8884308 345.9 ns/op Benchmark___Routed16QueueSub-16 8736687 353.2 ns/op Benchmark___Routed16QueueSub-16 10604343 347.9 ns/op Benchmark___Routed16QueueSub-16 8852599 343.2 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6459786 556.0 ns/op Benchmark____________RouteCompressOff-16 6399842 553.2 ns/op Benchmark____________RouteCompressOff-16 6476943 547.0 ns/op Benchmark____________RouteCompressOff-16 6454503 548.2 ns/op Benchmark____________RouteCompressOff-16 6413214 552.4 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6388329 549.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6435294 558.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6510986 551.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6501210 559.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6342675 552.0 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6470032 554.3 ns/op Benchmark_________RouteCompressS2Fast-16 6181664 553.8 ns/op Benchmark_________RouteCompressS2Fast-16 6406442 555.0 ns/op Benchmark_________RouteCompressS2Fast-16 6330554 546.4 ns/op Benchmark_________RouteCompressS2Fast-16 6319258 552.6 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6136286 546.5 ns/op Benchmark_______RouteCompressS2Better-16 6543181 550.8 ns/op Benchmark_______RouteCompressS2Better-16 6548751 552.8 ns/op Benchmark_______RouteCompressS2Better-16 6368233 549.4 ns/op Benchmark_______RouteCompressS2Better-16 6407151 557.8 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6301348 552.3 ns/op Benchmark_________RouteCompressS2Best-16 6350210 550.5 ns/op Benchmark_________RouteCompressS2Best-16 6324486 559.6 ns/op Benchmark_________RouteCompressS2Best-16 6530614 551.9 ns/op Benchmark_________RouteCompressS2Best-16 6371648 546.6 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4553776 775.7 ns/op 321.01 MB/s Benchmark______FanOut_8x1x10-16 4539370 773.8 ns/op 321.80 MB/s Benchmark______FanOut_8x1x10-16 4425986 772.8 ns/op 322.22 MB/s Benchmark______FanOut_8x1x10-16 4540474 772.4 ns/op 322.38 MB/s Benchmark______FanOut_8x1x10-16 4624275 774.5 ns/op 321.50 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 539740 6134 ns/op 378.06 MB/s Benchmark_____FanOut_8x1x100-16 546645 6165 ns/op 376.16 MB/s Benchmark_____FanOut_8x1x100-16 543332 6136 ns/op 377.92 MB/s Benchmark_____FanOut_8x1x100-16 536130 6126 ns/op 378.54 MB/s Benchmark_____FanOut_8x1x100-16 533200 6122 ns/op 378.79 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 46701 75366 ns/op 305.43 MB/s Benchmark____FanOut_8x10x100-16 47698 75124 ns/op 306.41 MB/s Benchmark____FanOut_8x10x100-16 47954 75177 ns/op 306.20 MB/s Benchmark____FanOut_8x10x100-16 47014 75213 ns/op 306.05 MB/s Benchmark____FanOut_8x10x100-16 46599 76374 ns/op 301.40 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5660 620044 ns/op 387.10 MB/s Benchmark___FanOut_8x10x1000-16 5888 604546 ns/op 397.02 MB/s Benchmark___FanOut_8x10x1000-16 5841 600750 ns/op 399.53 MB/s Benchmark___FanOut_8x10x1000-16 6013 598696 ns/op 400.90 MB/s Benchmark___FanOut_8x10x1000-16 5638 610526 ns/op 393.13 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5011 712353 ns/op 322.90 MB/s Benchmark___FanOut_8x100x100-16 4965 716057 ns/op 321.23 MB/s Benchmark___FanOut_8x100x100-16 4890 713927 ns/op 322.19 MB/s Benchmark___FanOut_8x100x100-16 4977 711811 ns/op 323.15 MB/s Benchmark___FanOut_8x100x100-16 4988 724713 ns/op 317.39 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 570 6186720 ns/op 387.93 MB/s Benchmark__FanOut_8x100x1000-16 565 6153201 ns/op 390.04 MB/s Benchmark__FanOut_8x100x1000-16 576 6358674 ns/op 377.44 MB/s Benchmark__FanOut_8x100x1000-16 572 6196064 ns/op 387.35 MB/s Benchmark__FanOut_8x100x1000-16 576 6239845 ns/op 384.63 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 537 6760844 ns/op 369.78 MB/s Benchmark__FanOut_8x10x10000-16 531 6828879 ns/op 366.10 MB/s Benchmark__FanOut_8x10x10000-16 517 6760810 ns/op 369.78 MB/s Benchmark__FanOut_8x10x10000-16 520 6757423 ns/op 369.97 MB/s Benchmark__FanOut_8x10x10000-16 524 6806771 ns/op 367.28 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 944 3783224 ns/op 303.98 MB/s Benchmark___FanOut_8x500x100-16 943 3816865 ns/op 301.30 MB/s Benchmark___FanOut_8x500x100-16 945 3775946 ns/op 304.56 MB/s Benchmark___FanOut_8x500x100-16 943 3789057 ns/op 303.51 MB/s Benchmark___FanOut_8x500x100-16 936 3792858 ns/op 303.21 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 360756 9590 ns/op 1526.73 MB/s Benchmark___FanOut_128x1x100-16 358882 9687 ns/op 1511.40 MB/s Benchmark___FanOut_128x1x100-16 362515 9670 ns/op 1514.10 MB/s Benchmark___FanOut_128x1x100-16 358654 9619 ns/op 1522.12 MB/s Benchmark___FanOut_128x1x100-16 361690 9571 ns/op 1529.65 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 32499 110427 ns/op 1314.37 MB/s Benchmark__FanOut_128x10x100-16 32547 112005 ns/op 1295.85 MB/s Benchmark__FanOut_128x10x100-16 32320 111140 ns/op 1305.93 MB/s Benchmark__FanOut_128x10x100-16 32200 111343 ns/op 1303.54 MB/s Benchmark__FanOut_128x10x100-16 32248 110902 ns/op 1308.73 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3841 885814 ns/op 1648.36 MB/s Benchmark_FanOut_128x10x1000-16 3709 884219 ns/op 1651.33 MB/s Benchmark_FanOut_128x10x1000-16 3910 883841 ns/op 1652.04 MB/s Benchmark_FanOut_128x10x1000-16 4070 878933 ns/op 1661.27 MB/s Benchmark_FanOut_128x10x1000-16 3957 881179 ns/op 1657.03 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3476 1016915 ns/op 1426.02 MB/s Benchmark_FanOut_128x100x100-16 3468 1017127 ns/op 1425.72 MB/s Benchmark_FanOut_128x100x100-16 3478 1018928 ns/op 1423.20 MB/s Benchmark_FanOut_128x100x100-16 3459 1018669 ns/op 1423.56 MB/s Benchmark_FanOut_128x100x100-16 3458 1030007 ns/op 1407.89 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 378 9382813 ns/op 1556.05 MB/s BenchmarkFanOut_128x100x1000-16 375 9572101 ns/op 1525.28 MB/s BenchmarkFanOut_128x100x1000-16 381 9506878 ns/op 1535.75 MB/s BenchmarkFanOut_128x100x1000-16 376 9403910 ns/op 1552.56 MB/s BenchmarkFanOut_128x100x1000-16 379 9381390 ns/op 1556.29 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 373 9729565 ns/op 1510.87 MB/s BenchmarkFanOut_128x10x10000-16 370 9709741 ns/op 1513.96 MB/s BenchmarkFanOut_128x10x10000-16 376 9675211 ns/op 1519.36 MB/s BenchmarkFanOut_128x10x10000-16 370 9654492 ns/op 1522.62 MB/s BenchmarkFanOut_128x10x10000-16 375 9691034 ns/op 1516.88 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 660 5267840 ns/op 1376.30 MB/s BenchmarkFanOut__128x500x100-16 673 5306195 ns/op 1366.35 MB/s BenchmarkFanOut__128x500x100-16 670 5302037 ns/op 1367.43 MB/s BenchmarkFanOut__128x500x100-16 670 5308650 ns/op 1365.72 MB/s BenchmarkFanOut__128x500x100-16 676 5321323 ns/op 1362.47 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1904 1855818 ns/op 2850.78 MB/s Benchmark_FanOut_512x100x100-16 1926 1862288 ns/op 2840.87 MB/s Benchmark_FanOut_512x100x100-16 1911 1849224 ns/op 2860.94 MB/s Benchmark_FanOut_512x100x100-16 1933 1850490 ns/op 2858.99 MB/s Benchmark_FanOut_512x100x100-16 1894 1850157 ns/op 2859.50 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 214 16865296 ns/op 3142.58 MB/s Benchmark__FanOut_512x100x1k-16 213 16843338 ns/op 3146.68 MB/s Benchmark__FanOut_512x100x1k-16 212 16766772 ns/op 3161.05 MB/s Benchmark__FanOut_512x100x1k-16 216 16697349 ns/op 3174.19 MB/s Benchmark__FanOut_512x100x1k-16 216 16685063 ns/op 3176.53 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2712 1140134 ns/op 9148.96 MB/s Benchmark____FanOut_1kx10x1k-16 3241 1158620 ns/op 9002.98 MB/s Benchmark____FanOut_1kx10x1k-16 3132 1159260 ns/op 8998.01 MB/s Benchmark____FanOut_1kx10x1k-16 2950 1147769 ns/op 9088.10 MB/s Benchmark____FanOut_1kx10x1k-16 2694 1139708 ns/op 9152.38 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2812 1278703 ns/op 8149.69 MB/s Benchmark__FanOut_1kx100x100-16 2781 1262489 ns/op 8254.36 MB/s Benchmark__FanOut_1kx100x100-16 2829 1274083 ns/op 8179.24 MB/s Benchmark__FanOut_1kx100x100-16 2761 1271173 ns/op 8197.97 MB/s Benchmark__FanOut_1kx100x100-16 2764 1263084 ns/op 8250.47 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4261702 806.0 ns/op 308.93 MB/s Benchmark_____RFanOut_8x1x10-16 4510604 779.4 ns/op 319.48 MB/s Benchmark_____RFanOut_8x1x10-16 4382436 804.2 ns/op 309.64 MB/s Benchmark_____RFanOut_8x1x10-16 4258686 797.1 ns/op 312.40 MB/s Benchmark_____RFanOut_8x1x10-16 4434648 796.0 ns/op 312.81 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 521271 6420 ns/op 361.24 MB/s Benchmark____RFanOut_8x1x100-16 530240 6409 ns/op 361.86 MB/s Benchmark____RFanOut_8x1x100-16 514407 6158 ns/op 376.58 MB/s Benchmark____RFanOut_8x1x100-16 560659 6379 ns/op 363.53 MB/s Benchmark____RFanOut_8x1x100-16 522043 6099 ns/op 380.20 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 47452 75373 ns/op 305.40 MB/s Benchmark___RFanOut_8x10x100-16 47220 75454 ns/op 305.07 MB/s Benchmark___RFanOut_8x10x100-16 47804 75186 ns/op 306.16 MB/s Benchmark___RFanOut_8x10x100-16 47509 75214 ns/op 306.05 MB/s Benchmark___RFanOut_8x10x100-16 47794 75359 ns/op 305.46 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5869 608254 ns/op 394.60 MB/s Benchmark__RFanOut_8x10x1000-16 5778 606851 ns/op 395.52 MB/s Benchmark__RFanOut_8x10x1000-16 5806 604215 ns/op 397.24 MB/s Benchmark__RFanOut_8x10x1000-16 5842 605639 ns/op 396.31 MB/s Benchmark__RFanOut_8x10x1000-16 5695 609166 ns/op 394.01 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4946 715107 ns/op 321.66 MB/s Benchmark__RFanOut_8x100x100-16 4921 712994 ns/op 322.61 MB/s Benchmark__RFanOut_8x100x100-16 4934 714242 ns/op 322.05 MB/s Benchmark__RFanOut_8x100x100-16 4938 736085 ns/op 312.49 MB/s Benchmark__RFanOut_8x100x100-16 4911 714902 ns/op 321.75 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 571 6281416 ns/op 382.08 MB/s Benchmark_RFanOut_8x100x1000-16 564 6267665 ns/op 382.92 MB/s Benchmark_RFanOut_8x100x1000-16 566 6463197 ns/op 371.34 MB/s Benchmark_RFanOut_8x100x1000-16 566 6273892 ns/op 382.54 MB/s Benchmark_RFanOut_8x100x1000-16 560 6276500 ns/op 382.38 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 529 6864963 ns/op 364.17 MB/s Benchmark_RFanOut_8x10x10000-16 517 6837564 ns/op 365.63 MB/s Benchmark_RFanOut_8x10x10000-16 523 6742813 ns/op 370.77 MB/s Benchmark_RFanOut_8x10x10000-16 528 6886725 ns/op 363.02 MB/s Benchmark_RFanOut_8x10x10000-16 526 6821960 ns/op 366.47 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3199 1158161 ns/op 9006.55 MB/s Benchmark_RFanOut_1kx10x1000-16 3129 1132268 ns/op 9212.51 MB/s Benchmark_RFanOut_1kx10x1000-16 2982 1154000 ns/op 9039.03 MB/s Benchmark_RFanOut_1kx10x1000-16 3050 1164703 ns/op 8955.96 MB/s Benchmark_RFanOut_1kx10x1000-16 2956 1152790 ns/op 9048.51 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6985429 504.7 ns/op 4117.36 MB/s Benchmark_____FanIn_1kx100x1-16 6892366 502.6 ns/op 4134.47 MB/s Benchmark_____FanIn_1kx100x1-16 6962380 505.3 ns/op 4112.03 MB/s Benchmark_____FanIn_1kx100x1-16 6944860 504.9 ns/op 4115.66 MB/s Benchmark_____FanIn_1kx100x1-16 6950085 504.4 ns/op 4119.54 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2673589 1367 ns/op 6013.59 MB/s Benchmark_____FanIn_4kx100x1-16 2586188 1367 ns/op 6013.69 MB/s Benchmark_____FanIn_4kx100x1-16 2666467 1363 ns/op 6033.97 MB/s Benchmark_____FanIn_4kx100x1-16 2587662 1358 ns/op 6056.24 MB/s Benchmark_____FanIn_4kx100x1-16 2648244 1380 ns/op 5957.44 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1677960 2107 ns/op 7790.06 MB/s Benchmark_____FanIn_8kx100x1-16 1677288 2121 ns/op 7740.19 MB/s Benchmark_____FanIn_8kx100x1-16 1710267 2123 ns/op 7731.62 MB/s Benchmark_____FanIn_8kx100x1-16 1702696 2122 ns/op 7735.36 MB/s Benchmark_____FanIn_8kx100x1-16 1715029 2114 ns/op 7764.20 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 861924 4121 ns/op 7959.50 MB/s Benchmark____FanIn_16kx100x1-16 872068 4127 ns/op 7947.28 MB/s Benchmark____FanIn_16kx100x1-16 868657 4180 ns/op 7846.99 MB/s Benchmark____FanIn_16kx100x1-16 869722 4186 ns/op 7834.99 MB/s Benchmark____FanIn_16kx100x1-16 866768 4125 ns/op 7950.75 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 8505370644 vs 10914574500 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58466->127.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: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:58112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58460->127.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: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:58432->127.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:58104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57756->127.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:58218->127.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:58186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58594->127.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:57898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58330->127.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:57962->127.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:58028->127.0.0.1:5222: write: connection reset by peer 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:57910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57924->127.0.0.1:5222: write: connection reset by peer 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:58080->127.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:58002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58126->127.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: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:58378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57904->127.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:58282->127.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:58140->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:57946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57758->127.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:57856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57834->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: 7039277799 vs 10678583700 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32922->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32964->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 166288 19854 ns/op 6603.49 MB/s Benchmark____FanIn_64kx100x1-16 164875 19852 ns/op 6603.93 MB/s Benchmark____FanIn_64kx100x1-16 167763 19781 ns/op 6627.76 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 122044790 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58114->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58918->127.0.0.1:5222: write: connection reset by peer 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:58834->127.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:58980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58232->127.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:58606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58574->127.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: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:58488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58518->127.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: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:58698->127.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:58550->127.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:58528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58636->127.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: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:58240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58868->127.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:58670->127.0.0.1:5222: write: connection reset by peer 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:58890->127.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:58342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58678->127.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: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:58534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58926->127.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:58272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58954->127.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:58694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:58768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58394->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58938->127.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 --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58386->127.0.0.1:5222: write: connection reset by peer 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:58886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58398->127.0.0.1:5222: write: connection reset by peer 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:58440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58594->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: 1621976570 vs 11483484000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32958->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33134->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32990->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32974->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33038->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33338->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1000741060 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35066->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35022->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34612->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: 435743160 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55070->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55926->127.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: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: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:55324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55674->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:55094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:55128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55410->127.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:55606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55266->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55258->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55188->127.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: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:55586->127.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:55078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55088->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1075200180 vs 11614574000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57940->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57990->127.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: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:58390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58286->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57824->127.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:58012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57966->127.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:58300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57828->127.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:58460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:57896->127.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:58166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58682->127.0.0.1:5222: write: broken pipe 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:57826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:57914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57836->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:58442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58100->127.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:58324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58010->127.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: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: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:58564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58536->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58454->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58204->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:58552->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5552113 650.1 ns/op 436.89 MB/s Benchmark___BumpPubCount_1x3-16 5453905 645.0 ns/op 440.34 MB/s Benchmark___BumpPubCount_1x3-16 5458986 649.2 ns/op 437.47 MB/s Benchmark___BumpPubCount_1x3-16 5514898 646.3 ns/op 439.41 MB/s Benchmark___BumpPubCount_1x3-16 5476952 651.4 ns/op 436.01 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5272798 680.8 ns/op 417.18 MB/s Benchmark___BumpPubCount_2x3-16 5141758 676.1 ns/op 420.05 MB/s Benchmark___BumpPubCount_2x3-16 5216506 674.3 ns/op 421.20 MB/s Benchmark___BumpPubCount_2x3-16 5327397 674.7 ns/op 420.94 MB/s Benchmark___BumpPubCount_2x3-16 5284845 679.0 ns/op 418.26 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5559324 642.1 ns/op 442.27 MB/s Benchmark___BumpPubCount_5x3-16 5415420 645.4 ns/op 440.05 MB/s Benchmark___BumpPubCount_5x3-16 5425872 643.9 ns/op 441.07 MB/s Benchmark___BumpPubCount_5x3-16 5545045 640.0 ns/op 443.75 MB/s Benchmark___BumpPubCount_5x3-16 5044940 641.5 ns/op 442.73 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5566878 640.9 ns/op 443.14 MB/s Benchmark__BumpPubCount_10x3-16 5540646 640.5 ns/op 443.43 MB/s Benchmark__BumpPubCount_10x3-16 5623483 639.5 ns/op 444.12 MB/s Benchmark__BumpPubCount_10x3-16 5576545 643.2 ns/op 441.56 MB/s Benchmark__BumpPubCount_10x3-16 5613282 641.2 ns/op 442.91 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12072158 275.9 ns/op 3769.14 MB/s Benchmark____GWs_Opt_1kx01x0-16 12144409 271.0 ns/op 3837.13 MB/s Benchmark____GWs_Opt_1kx01x0-16 12725881 277.9 ns/op 3742.05 MB/s Benchmark____GWs_Opt_1kx01x0-16 13216471 278.2 ns/op 3737.72 MB/s Benchmark____GWs_Opt_1kx01x0-16 13366621 271.4 ns/op 3832.31 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 9939570 325.8 ns/op 6336.14 MB/s Benchmark____GWs_Opt_2kx01x0-16 11018136 337.5 ns/op 6116.02 MB/s Benchmark____GWs_Opt_2kx01x0-16 10395142 335.6 ns/op 6149.30 MB/s Benchmark____GWs_Opt_2kx01x0-16 9495475 340.4 ns/op 6063.20 MB/s Benchmark____GWs_Opt_2kx01x0-16 10939773 372.3 ns/op 5543.94 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5908279 619.2 ns/op 6640.42 MB/s Benchmark____GWs_Opt_4kx01x0-16 5843156 597.9 ns/op 6877.34 MB/s Benchmark____GWs_Opt_4kx01x0-16 5931072 607.6 ns/op 6767.09 MB/s Benchmark____GWs_Opt_4kx01x0-16 5838626 605.3 ns/op 6793.19 MB/s Benchmark____GWs_Opt_4kx01x0-16 5767921 632.1 ns/op 6505.66 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30651884 116.5 ns/op 8927.43 MB/s Benchmark____GWs_Opt_1kx10x0-16 30652137 114.1 ns/op 9113.40 MB/s Benchmark____GWs_Opt_1kx10x0-16 32281693 111.9 ns/op 9290.41 MB/s Benchmark____GWs_Opt_1kx10x0-16 28036303 111.3 ns/op 9346.98 MB/s Benchmark____GWs_Opt_1kx10x0-16 28695808 107.4 ns/op 9684.71 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 24335478 142.6 ns/op 14477.03 MB/s Benchmark____GWs_Opt_2kx10x0-16 24769275 173.4 ns/op 11906.11 MB/s Benchmark____GWs_Opt_2kx10x0-16 25024708 146.6 ns/op 14082.24 MB/s Benchmark____GWs_Opt_2kx10x0-16 23913741 158.7 ns/op 13009.54 MB/s Benchmark____GWs_Opt_2kx10x0-16 23202894 154.5 ns/op 13355.35 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12830679 289.0 ns/op 14228.82 MB/s Benchmark____GWs_Opt_4kx10x0-16 11913943 372.4 ns/op 11040.98 MB/s Benchmark____GWs_Opt_4kx10x0-16 12861435 314.9 ns/op 13058.01 MB/s Benchmark____GWs_Opt_4kx10x0-16 10379118 344.6 ns/op 11934.35 MB/s Benchmark____GWs_Opt_4kx10x0-16 12093756 303.1 ns/op 13565.36 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6584838 556.6 ns/op 5614.59 MB/s Benchmark____GWs_Opt_1kx01x1-16 6398098 545.9 ns/op 5724.34 MB/s Benchmark____GWs_Opt_1kx01x1-16 6811554 544.4 ns/op 5740.77 MB/s Benchmark____GWs_Opt_1kx01x1-16 6476526 547.8 ns/op 5705.08 MB/s Benchmark____GWs_Opt_1kx01x1-16 6535596 538.3 ns/op 5805.85 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4847737 766.0 ns/op 8090.26 MB/s Benchmark____GWs_Opt_2kx01x1-16 4772601 759.3 ns/op 8161.63 MB/s Benchmark____GWs_Opt_2kx01x1-16 4738794 757.5 ns/op 8181.37 MB/s Benchmark____GWs_Opt_2kx01x1-16 4542991 800.4 ns/op 7741.96 MB/s Benchmark____GWs_Opt_2kx01x1-16 4441124 744.2 ns/op 8326.96 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2582377 1388 ns/op 8888.70 MB/s Benchmark____GWs_Opt_4kx01x1-16 2544666 1418 ns/op 8700.84 MB/s Benchmark____GWs_Opt_4kx01x1-16 2703675 1368 ns/op 9018.32 MB/s Benchmark____GWs_Opt_4kx01x1-16 2690700 1343 ns/op 9191.19 MB/s Benchmark____GWs_Opt_4kx01x1-16 2600158 1434 ns/op 8605.96 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6206811 556.6 ns/op 5614.28 MB/s Benchmark____GWs_Opt_1kx10x1-16 6601036 556.1 ns/op 5619.57 MB/s Benchmark____GWs_Opt_1kx10x1-16 6345630 550.6 ns/op 5676.02 MB/s Benchmark____GWs_Opt_1kx10x1-16 6264871 551.5 ns/op 5666.78 MB/s Benchmark____GWs_Opt_1kx10x1-16 6325192 539.1 ns/op 5796.26 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4079061 841.8 ns/op 7361.55 MB/s Benchmark____GWs_Opt_2kx10x1-16 4172276 845.0 ns/op 7333.69 MB/s Benchmark____GWs_Opt_2kx10x1-16 4192527 845.4 ns/op 7330.36 MB/s Benchmark____GWs_Opt_2kx10x1-16 4265970 824.5 ns/op 7516.35 MB/s Benchmark____GWs_Opt_2kx10x1-16 4287865 845.0 ns/op 7333.45 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2356437 1574 ns/op 7839.37 MB/s Benchmark____GWs_Opt_4kx10x1-16 2271024 1514 ns/op 8150.65 MB/s Benchmark____GWs_Opt_4kx10x1-16 2207619 1486 ns/op 8304.06 MB/s Benchmark____GWs_Opt_4kx10x1-16 2358928 1490 ns/op 8281.61 MB/s Benchmark____GWs_Opt_4kx10x1-16 2329402 1507 ns/op 8186.78 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12728655 287.6 ns/op 3615.52 MB/s Benchmark____GWs_Int_1kx01x0-16 12458835 289.9 ns/op 3587.82 MB/s Benchmark____GWs_Int_1kx01x0-16 11906708 278.3 ns/op 3736.88 MB/s Benchmark____GWs_Int_1kx01x0-16 12704184 287.4 ns/op 3618.61 MB/s Benchmark____GWs_Int_1kx01x0-16 12640639 291.6 ns/op 3566.96 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10199170 353.4 ns/op 5840.15 MB/s Benchmark____GWs_Int_2kx01x0-16 10438350 339.7 ns/op 6076.73 MB/s Benchmark____GWs_Int_2kx01x0-16 10099764 352.8 ns/op 5850.97 MB/s Benchmark____GWs_Int_2kx01x0-16 10267899 350.5 ns/op 5888.40 MB/s Benchmark____GWs_Int_2kx01x0-16 10393311 344.7 ns/op 5988.42 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5551048 632.5 ns/op 6501.29 MB/s Benchmark____GWs_Int_4kx01x0-16 5925220 630.8 ns/op 6518.42 MB/s Benchmark____GWs_Int_4kx01x0-16 5801103 631.7 ns/op 6509.33 MB/s Benchmark____GWs_Int_4kx01x0-16 5697450 635.4 ns/op 6471.05 MB/s Benchmark____GWs_Int_4kx01x0-16 5549902 638.4 ns/op 6441.44 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 30862312 108.4 ns/op 9595.58 MB/s Benchmark____GWs_Int_1kx10x0-16 30572407 109.7 ns/op 9480.41 MB/s Benchmark____GWs_Int_1kx10x0-16 31718862 126.6 ns/op 8214.71 MB/s Benchmark____GWs_Int_1kx10x0-16 31888636 112.0 ns/op 9285.74 MB/s Benchmark____GWs_Int_1kx10x0-16 32624386 116.0 ns/op 8966.26 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25658451 163.2 ns/op 12650.12 MB/s Benchmark____GWs_Int_2kx10x0-16 23675564 167.5 ns/op 12320.09 MB/s Benchmark____GWs_Int_2kx10x0-16 25751073 163.3 ns/op 12642.87 MB/s Benchmark____GWs_Int_2kx10x0-16 25880016 144.8 ns/op 14253.89 MB/s Benchmark____GWs_Int_2kx10x0-16 25747996 159.6 ns/op 12930.81 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 12028927 302.2 ns/op 13608.59 MB/s Benchmark____GWs_Int_4kx10x0-16 13358162 284.6 ns/op 14447.57 MB/s Benchmark____GWs_Int_4kx10x0-16 12796071 286.5 ns/op 14353.46 MB/s Benchmark____GWs_Int_4kx10x0-16 10608326 283.7 ns/op 14494.62 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:59214->127.0.0.1:35371: 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:33880->127.0.0.1:38931: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6732840 559.3 ns/op 5587.75 MB/s Benchmark____GWs_Int_1kx01x1-16 6279477 555.6 ns/op 5624.17 MB/s Benchmark____GWs_Int_1kx01x1-16 5655524 553.8 ns/op 5642.98 MB/s Benchmark____GWs_Int_1kx01x1-16 6408746 549.8 ns/op 5684.17 MB/s Benchmark____GWs_Int_1kx01x1-16 6613851 551.5 ns/op 5666.11 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4628150 752.2 ns/op 8238.67 MB/s Benchmark____GWs_Int_2kx01x1-16 4628562 755.3 ns/op 8204.33 MB/s Benchmark____GWs_Int_2kx01x1-16 4820413 765.4 ns/op 8096.02 MB/s Benchmark____GWs_Int_2kx01x1-16 4168639 934.7 ns/op 6629.91 MB/s Benchmark____GWs_Int_2kx01x1-16 4771966 763.9 ns/op 8112.62 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2621048 1354 ns/op 9113.51 MB/s Benchmark____GWs_Int_4kx01x1-16 2602485 1347 ns/op 9162.37 MB/s Benchmark____GWs_Int_4kx01x1-16 2439826 1355 ns/op 9110.62 MB/s Benchmark____GWs_Int_4kx01x1-16 2557432 1356 ns/op 9104.05 MB/s Benchmark____GWs_Int_4kx01x1-16 2636383 1535 ns/op 8037.69 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6378206 549.2 ns/op 5690.28 MB/s Benchmark____GWs_Int_1kx10x1-16 6684703 549.1 ns/op 5690.84 MB/s Benchmark____GWs_Int_1kx10x1-16 6604176 572.5 ns/op 5458.11 MB/s Benchmark____GWs_Int_1kx10x1-16 6529497 547.0 ns/op 5713.39 MB/s Benchmark____GWs_Int_1kx10x1-16 6428158 549.6 ns/op 5686.12 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4084440 834.3 ns/op 7428.15 MB/s Benchmark____GWs_Int_2kx10x1-16 4352365 831.4 ns/op 7453.27 MB/s Benchmark____GWs_Int_2kx10x1-16 4198640 845.9 ns/op 7325.81 MB/s Benchmark____GWs_Int_2kx10x1-16 4391820 897.1 ns/op 6907.98 MB/s Benchmark____GWs_Int_2kx10x1-16 4135587 829.8 ns/op 7468.13 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2167102 1536 ns/op 8035.08 MB/s Benchmark____GWs_Int_4kx10x1-16 2378400 1481 ns/op 8332.24 MB/s Benchmark____GWs_Int_4kx10x1-16 2305251 1492 ns/op 8269.18 MB/s Benchmark____GWs_Int_4kx10x1-16 2153814 1492 ns/op 8271.74 MB/s Benchmark____GWs_Int_4kx10x1-16 2283427 1437 ns/op 8590.50 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8221242 428.4 ns/op 238.08 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8625648 424.3 ns/op 240.41 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8396524 433.4 ns/op 235.37 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8216355 424.2 ns/op 240.45 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8404269 427.3 ns/op 238.70 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 649651 5025 ns/op 35.22 MB/s Benchmark__GWs_Reqs_1SubEach-16 771871 5127 ns/op 34.53 MB/s Benchmark__GWs_Reqs_1SubEach-16 715494 5268 ns/op 33.60 MB/s Benchmark__GWs_Reqs_1SubEach-16 786576 5289 ns/op 33.47 MB/s Benchmark__GWs_Reqs_1SubEach-16 696853 5196 ns/op 34.07 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2127.696s