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 53466403 67.22 ns/op 163.65 MB/s Benchmark______Pub0b_Payload-16 53633145 67.18 ns/op 163.75 MB/s Benchmark______Pub0b_Payload-16 50630491 67.14 ns/op 163.85 MB/s Benchmark______Pub0b_Payload-16 50534640 67.26 ns/op 163.55 MB/s Benchmark______Pub0b_Payload-16 50435510 67.18 ns/op 163.75 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 49883942 67.76 ns/op 280.42 MB/s Benchmark______Pub8b_Payload-16 49917862 68.15 ns/op 278.78 MB/s Benchmark______Pub8b_Payload-16 49634481 68.34 ns/op 278.03 MB/s Benchmark______Pub8b_Payload-16 49796451 68.10 ns/op 279.00 MB/s Benchmark______Pub8b_Payload-16 48698881 68.05 ns/op 279.22 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 49864065 72.26 ns/op 608.94 MB/s Benchmark_____Pub32b_Payload-16 46493739 72.17 ns/op 609.67 MB/s Benchmark_____Pub32b_Payload-16 46938016 72.04 ns/op 610.74 MB/s Benchmark_____Pub32b_Payload-16 47092254 72.53 ns/op 606.62 MB/s Benchmark_____Pub32b_Payload-16 46857950 72.65 ns/op 605.65 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 44391820 82.30 ns/op 1713.24 MB/s Benchmark____Pub128B_Payload-16 41040978 83.76 ns/op 1683.32 MB/s Benchmark____Pub128B_Payload-16 41866146 82.05 ns/op 1718.55 MB/s Benchmark____Pub128B_Payload-16 44168167 81.61 ns/op 1727.67 MB/s Benchmark____Pub128B_Payload-16 42069907 81.06 ns/op 1739.53 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 39956659 91.82 ns/op 2929.55 MB/s Benchmark____Pub256B_Payload-16 34053027 89.98 ns/op 2989.47 MB/s Benchmark____Pub256B_Payload-16 34659543 88.55 ns/op 3037.74 MB/s Benchmark____Pub256B_Payload-16 33644532 90.54 ns/op 2971.00 MB/s Benchmark____Pub256B_Payload-16 38619182 88.79 ns/op 3029.46 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 25932603 132.1 ns/op 7854.99 MB/s Benchmark______Pub1K_Payload-16 24473202 135.4 ns/op 7666.38 MB/s Benchmark______Pub1K_Payload-16 23963784 143.1 ns/op 7252.82 MB/s Benchmark______Pub1K_Payload-16 24309559 130.9 ns/op 7929.21 MB/s Benchmark______Pub1K_Payload-16 27809756 136.5 ns/op 7602.30 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5675175 626.8 ns/op 6556.71 MB/s Benchmark______Pub4K_Payload-16 5491768 623.6 ns/op 6590.82 MB/s Benchmark______Pub4K_Payload-16 5066458 643.0 ns/op 6392.33 MB/s Benchmark______Pub4K_Payload-16 5160003 635.8 ns/op 6464.55 MB/s Benchmark______Pub4K_Payload-16 5077328 617.3 ns/op 6658.09 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2813016 1283 ns/op 6395.56 MB/s Benchmark______Pub8K_Payload-16 2669514 1304 ns/op 6294.57 MB/s Benchmark______Pub8K_Payload-16 2790721 1288 ns/op 6368.70 MB/s Benchmark______Pub8K_Payload-16 2793020 1283 ns/op 6397.45 MB/s Benchmark______Pub8K_Payload-16 2810958 1285 ns/op 6385.83 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 561898 5430 ns/op 6037.59 MB/s Benchmark_____Pub32K_Payload-16 665782 5483 ns/op 5978.50 MB/s Benchmark_____Pub32K_Payload-16 669600 5393 ns/op 6079.06 MB/s Benchmark_____Pub32K_Payload-16 570124 5329 ns/op 6151.39 MB/s Benchmark_____Pub32K_Payload-16 663507 5422 ns/op 6046.65 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 34449379 87.33 ns/op 125.96 MB/s Benchmark__AuthPub0b_Payload-16 38669356 86.97 ns/op 126.49 MB/s Benchmark__AuthPub0b_Payload-16 39032661 86.85 ns/op 126.65 MB/s Benchmark__AuthPub0b_Payload-16 39269628 86.96 ns/op 126.50 MB/s Benchmark__AuthPub0b_Payload-16 34681617 86.94 ns/op 126.52 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 17181942 208.1 ns/op Benchmark_____________PubSub-16 17123085 208.0 ns/op Benchmark_____________PubSub-16 16948125 207.2 ns/op Benchmark_____________PubSub-16 17218641 207.8 ns/op Benchmark_____________PubSub-16 16927760 207.2 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 17005504 206.0 ns/op Benchmark_____PubSubTwoConns-16 16932213 207.0 ns/op Benchmark_____PubSubTwoConns-16 16930467 207.0 ns/op Benchmark_____PubSubTwoConns-16 17051704 206.5 ns/op Benchmark_____PubSubTwoConns-16 17212672 206.1 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:49516->127.0.0.1:35001: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:60906->127.0.0.1:41833: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:52850->127.0.0.1:34221: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:46964->127.0.0.1:42697: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:40746->127.0.0.1:40579: 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 15362430 227.8 ns/op Benchmark_____PubTwoQueueSub-16 15508723 228.4 ns/op Benchmark_____PubTwoQueueSub-16 15485708 228.0 ns/op Benchmark_____PubTwoQueueSub-16 15638170 228.0 ns/op Benchmark_____PubTwoQueueSub-16 15346651 228.2 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15556420 228.9 ns/op Benchmark____PubFourQueueSub-16 15711061 226.9 ns/op Benchmark____PubFourQueueSub-16 15687039 225.5 ns/op Benchmark____PubFourQueueSub-16 15355998 228.6 ns/op Benchmark____PubFourQueueSub-16 15538723 228.3 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15472156 228.2 ns/op Benchmark___PubEightQueueSub-16 15539199 226.3 ns/op Benchmark___PubEightQueueSub-16 15804445 226.7 ns/op Benchmark___PubEightQueueSub-16 15559682 227.3 ns/op Benchmark___PubEightQueueSub-16 15437245 228.2 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23119 157534 ns/op Benchmark_PubSub512kTwoConns-16 22292 170067 ns/op Benchmark_PubSub512kTwoConns-16 22492 159234 ns/op Benchmark_PubSub512kTwoConns-16 22360 159593 ns/op Benchmark_PubSub512kTwoConns-16 22390 159386 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 16524262 211.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 16611045 210.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 16458670 211.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 16674669 210.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 16904208 211.4 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16218447 209.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 16404867 211.5 ns/op Benchmark_DenyMsgYesWCPubSub-16 16490870 211.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 16473841 211.3 ns/op Benchmark_DenyMsgYesWCPubSub-16 16434303 212.0 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 12033268 294.0 ns/op Benchmark____RoutedPubSub_0b-16 11833090 293.0 ns/op Benchmark____RoutedPubSub_0b-16 12009463 299.9 ns/op Benchmark____RoutedPubSub_0b-16 11792689 296.4 ns/op Benchmark____RoutedPubSub_0b-16 11749110 293.4 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6845719 695.7 ns/op Benchmark____RoutedPubSub_1K-16 7135207 497.9 ns/op Benchmark____RoutedPubSub_1K-16 6885116 510.2 ns/op Benchmark____RoutedPubSub_1K-16 7072664 506.4 ns/op Benchmark____RoutedPubSub_1K-16 6950726 516.3 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 80073 40599 ns/op Benchmark__RoutedPubSub_100K-16 83515 43150 ns/op Benchmark__RoutedPubSub_100K-16 86746 43384 ns/op Benchmark__RoutedPubSub_100K-16 79746 46625 ns/op Benchmark__RoutedPubSub_100K-16 77191 45124 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11945760 305.4 ns/op Benchmark____Routed2QueueSub-16 9978860 306.7 ns/op Benchmark____Routed2QueueSub-16 12116892 295.7 ns/op Benchmark____Routed2QueueSub-16 10241118 297.3 ns/op Benchmark____Routed2QueueSub-16 10061176 314.4 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 10195106 307.6 ns/op Benchmark____Routed4QueueSub-16 12054375 305.4 ns/op Benchmark____Routed4QueueSub-16 11947851 300.0 ns/op Benchmark____Routed4QueueSub-16 9924813 306.8 ns/op Benchmark____Routed4QueueSub-16 9953488 309.0 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9657656 319.2 ns/op Benchmark____Routed8QueueSub-16 9922878 310.4 ns/op Benchmark____Routed8QueueSub-16 9759410 307.9 ns/op Benchmark____Routed8QueueSub-16 9954535 303.0 ns/op Benchmark____Routed8QueueSub-16 11610105 310.7 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 9233011 332.4 ns/op Benchmark___Routed16QueueSub-16 11041473 327.9 ns/op Benchmark___Routed16QueueSub-16 10854445 330.4 ns/op Benchmark___Routed16QueueSub-16 11011495 331.1 ns/op Benchmark___Routed16QueueSub-16 10858831 330.9 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6658788 525.1 ns/op Benchmark____________RouteCompressOff-16 6800478 520.7 ns/op Benchmark____________RouteCompressOff-16 6805485 524.4 ns/op Benchmark____________RouteCompressOff-16 6807517 520.4 ns/op Benchmark____________RouteCompressOff-16 6669612 520.0 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6757579 524.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6770679 531.0 ns/op Benchmark_RouteCompressS2Uncompressed-16 6722210 522.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6743223 524.8 ns/op Benchmark_RouteCompressS2Uncompressed-16 6721090 473.4 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6765231 502.2 ns/op Benchmark_________RouteCompressS2Fast-16 6707595 527.8 ns/op Benchmark_________RouteCompressS2Fast-16 6755601 524.2 ns/op Benchmark_________RouteCompressS2Fast-16 6842764 528.3 ns/op Benchmark_________RouteCompressS2Fast-16 6565861 521.8 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6849900 530.3 ns/op Benchmark_______RouteCompressS2Better-16 6858394 528.4 ns/op Benchmark_______RouteCompressS2Better-16 6579169 527.2 ns/op Benchmark_______RouteCompressS2Better-16 6808262 447.9 ns/op Benchmark_______RouteCompressS2Better-16 6713688 525.5 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6784063 490.0 ns/op Benchmark_________RouteCompressS2Best-16 6932803 525.3 ns/op Benchmark_________RouteCompressS2Best-16 6874399 526.1 ns/op Benchmark_________RouteCompressS2Best-16 6775539 528.3 ns/op Benchmark_________RouteCompressS2Best-16 6600841 524.9 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5206106 682.2 ns/op 365.01 MB/s Benchmark______FanOut_8x1x10-16 5299382 682.0 ns/op 365.13 MB/s Benchmark______FanOut_8x1x10-16 5240569 680.7 ns/op 365.80 MB/s Benchmark______FanOut_8x1x10-16 5077104 683.2 ns/op 364.46 MB/s Benchmark______FanOut_8x1x10-16 5247307 698.3 ns/op 356.57 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 635094 5266 ns/op 440.39 MB/s Benchmark_____FanOut_8x1x100-16 610292 5302 ns/op 437.40 MB/s Benchmark_____FanOut_8x1x100-16 646911 5349 ns/op 433.51 MB/s Benchmark_____FanOut_8x1x100-16 612918 5334 ns/op 434.73 MB/s Benchmark_____FanOut_8x1x100-16 635755 5360 ns/op 432.66 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 52981 67685 ns/op 340.09 MB/s Benchmark____FanOut_8x10x100-16 52918 67820 ns/op 339.41 MB/s Benchmark____FanOut_8x10x100-16 52905 67927 ns/op 338.88 MB/s Benchmark____FanOut_8x10x100-16 52933 67760 ns/op 339.71 MB/s Benchmark____FanOut_8x10x100-16 51932 67964 ns/op 338.70 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6694 538184 ns/op 445.98 MB/s Benchmark___FanOut_8x10x1000-16 6326 532491 ns/op 450.75 MB/s Benchmark___FanOut_8x10x1000-16 6818 530232 ns/op 452.67 MB/s Benchmark___FanOut_8x10x1000-16 6754 535719 ns/op 448.03 MB/s Benchmark___FanOut_8x10x1000-16 6642 527435 ns/op 455.07 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5542 634357 ns/op 362.60 MB/s Benchmark___FanOut_8x100x100-16 5600 633612 ns/op 363.03 MB/s Benchmark___FanOut_8x100x100-16 5497 628988 ns/op 365.70 MB/s Benchmark___FanOut_8x100x100-16 5515 639653 ns/op 359.60 MB/s Benchmark___FanOut_8x100x100-16 5547 636645 ns/op 361.30 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 644 5557366 ns/op 431.86 MB/s Benchmark__FanOut_8x100x1000-16 640 5494320 ns/op 436.82 MB/s Benchmark__FanOut_8x100x1000-16 637 5522123 ns/op 434.62 MB/s Benchmark__FanOut_8x100x1000-16 644 5617003 ns/op 427.28 MB/s Benchmark__FanOut_8x100x1000-16 631 5553552 ns/op 432.16 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 608 5946637 ns/op 420.41 MB/s Benchmark__FanOut_8x10x10000-16 604 5895363 ns/op 424.07 MB/s Benchmark__FanOut_8x10x10000-16 597 5846443 ns/op 427.61 MB/s Benchmark__FanOut_8x10x10000-16 616 5818448 ns/op 429.67 MB/s Benchmark__FanOut_8x10x10000-16 614 5912615 ns/op 422.83 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1050 3405691 ns/op 337.68 MB/s Benchmark___FanOut_8x500x100-16 1048 3407371 ns/op 337.51 MB/s Benchmark___FanOut_8x500x100-16 1046 3422334 ns/op 336.03 MB/s Benchmark___FanOut_8x500x100-16 1053 3403845 ns/op 337.86 MB/s Benchmark___FanOut_8x500x100-16 1047 3384065 ns/op 339.83 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 393895 8863 ns/op 1651.86 MB/s Benchmark___FanOut_128x1x100-16 375564 8891 ns/op 1646.76 MB/s Benchmark___FanOut_128x1x100-16 369175 8893 ns/op 1646.31 MB/s Benchmark___FanOut_128x1x100-16 383314 8919 ns/op 1641.63 MB/s Benchmark___FanOut_128x1x100-16 388651 8901 ns/op 1644.96 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 34809 103380 ns/op 1403.95 MB/s Benchmark__FanOut_128x10x100-16 34888 103324 ns/op 1404.71 MB/s Benchmark__FanOut_128x10x100-16 34770 103333 ns/op 1404.60 MB/s Benchmark__FanOut_128x10x100-16 34665 103291 ns/op 1405.17 MB/s Benchmark__FanOut_128x10x100-16 34784 103031 ns/op 1408.71 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4243 802944 ns/op 1818.49 MB/s Benchmark_FanOut_128x10x1000-16 4474 804888 ns/op 1814.09 MB/s Benchmark_FanOut_128x10x1000-16 4551 807469 ns/op 1808.29 MB/s Benchmark_FanOut_128x10x1000-16 4383 800055 ns/op 1825.05 MB/s Benchmark_FanOut_128x10x1000-16 4426 799138 ns/op 1827.14 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3745 951058 ns/op 1524.77 MB/s Benchmark_FanOut_128x100x100-16 3775 947542 ns/op 1530.42 MB/s Benchmark_FanOut_128x100x100-16 3757 946722 ns/op 1531.75 MB/s Benchmark_FanOut_128x100x100-16 3769 944154 ns/op 1535.92 MB/s Benchmark_FanOut_128x100x100-16 3661 946018 ns/op 1532.89 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 422 8440322 ns/op 1729.81 MB/s BenchmarkFanOut_128x100x1000-16 424 8485530 ns/op 1720.59 MB/s BenchmarkFanOut_128x100x1000-16 429 8428385 ns/op 1732.26 MB/s BenchmarkFanOut_128x100x1000-16 430 8457031 ns/op 1726.39 MB/s BenchmarkFanOut_128x100x1000-16 422 8344760 ns/op 1749.62 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 408 8825275 ns/op 1665.69 MB/s BenchmarkFanOut_128x10x10000-16 408 8864150 ns/op 1658.38 MB/s BenchmarkFanOut_128x10x10000-16 406 8806916 ns/op 1669.16 MB/s BenchmarkFanOut_128x10x10000-16 406 8809866 ns/op 1668.60 MB/s BenchmarkFanOut_128x10x10000-16 410 8809148 ns/op 1668.74 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 724 4980631 ns/op 1455.67 MB/s BenchmarkFanOut__128x500x100-16 704 4960009 ns/op 1461.72 MB/s BenchmarkFanOut__128x500x100-16 706 4959403 ns/op 1461.90 MB/s BenchmarkFanOut__128x500x100-16 711 4988589 ns/op 1453.35 MB/s BenchmarkFanOut__128x500x100-16 712 4973122 ns/op 1457.87 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 2006 1759936 ns/op 3006.09 MB/s Benchmark_FanOut_512x100x100-16 1983 1778359 ns/op 2974.95 MB/s Benchmark_FanOut_512x100x100-16 1978 1771438 ns/op 2986.57 MB/s Benchmark_FanOut_512x100x100-16 1977 1779004 ns/op 2973.87 MB/s Benchmark_FanOut_512x100x100-16 1977 1766392 ns/op 2995.10 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 222 16052360 ns/op 3301.73 MB/s Benchmark__FanOut_512x100x1k-16 224 15981902 ns/op 3316.28 MB/s Benchmark__FanOut_512x100x1k-16 224 16081858 ns/op 3295.67 MB/s Benchmark__FanOut_512x100x1k-16 223 16042017 ns/op 3303.86 MB/s Benchmark__FanOut_512x100x1k-16 222 16111794 ns/op 3289.55 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 2839 1072554 ns/op 9725.42 MB/s Benchmark____FanOut_1kx10x1k-16 3116 1103332 ns/op 9454.13 MB/s Benchmark____FanOut_1kx10x1k-16 2956 1111490 ns/op 9384.73 MB/s Benchmark____FanOut_1kx10x1k-16 3346 1116477 ns/op 9342.82 MB/s Benchmark____FanOut_1kx10x1k-16 3097 1093083 ns/op 9542.77 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2907 1190890 ns/op 8750.63 MB/s Benchmark__FanOut_1kx100x100-16 2947 1194061 ns/op 8727.39 MB/s Benchmark__FanOut_1kx100x100-16 2918 1194792 ns/op 8722.05 MB/s Benchmark__FanOut_1kx100x100-16 2986 1192376 ns/op 8739.72 MB/s Benchmark__FanOut_1kx100x100-16 2941 1192538 ns/op 8738.54 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4851504 694.1 ns/op 358.71 MB/s Benchmark_____RFanOut_8x1x10-16 4965602 683.1 ns/op 364.54 MB/s Benchmark_____RFanOut_8x1x10-16 4967688 699.7 ns/op 355.87 MB/s Benchmark_____RFanOut_8x1x10-16 5037168 696.3 ns/op 357.61 MB/s Benchmark_____RFanOut_8x1x10-16 5107231 696.2 ns/op 357.65 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 600093 5339 ns/op 434.39 MB/s Benchmark____RFanOut_8x1x100-16 657656 5275 ns/op 439.61 MB/s Benchmark____RFanOut_8x1x100-16 622320 5257 ns/op 441.14 MB/s Benchmark____RFanOut_8x1x100-16 609626 5371 ns/op 431.75 MB/s Benchmark____RFanOut_8x1x100-16 609788 5340 ns/op 434.24 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 53071 68247 ns/op 337.29 MB/s Benchmark___RFanOut_8x10x100-16 51818 68194 ns/op 337.55 MB/s Benchmark___RFanOut_8x10x100-16 52412 68204 ns/op 337.50 MB/s Benchmark___RFanOut_8x10x100-16 52873 67928 ns/op 338.87 MB/s Benchmark___RFanOut_8x10x100-16 53030 68336 ns/op 336.85 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6517 549682 ns/op 436.65 MB/s Benchmark__RFanOut_8x10x1000-16 6464 541949 ns/op 442.88 MB/s Benchmark__RFanOut_8x10x1000-16 6535 540881 ns/op 443.76 MB/s Benchmark__RFanOut_8x10x1000-16 6616 540751 ns/op 443.86 MB/s Benchmark__RFanOut_8x10x1000-16 6548 543148 ns/op 441.90 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5526 635862 ns/op 361.74 MB/s Benchmark__RFanOut_8x100x100-16 5502 636315 ns/op 361.49 MB/s Benchmark__RFanOut_8x100x100-16 5518 637681 ns/op 360.71 MB/s Benchmark__RFanOut_8x100x100-16 5546 639926 ns/op 359.45 MB/s Benchmark__RFanOut_8x100x100-16 5547 636909 ns/op 361.15 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 631 5581453 ns/op 430.00 MB/s Benchmark_RFanOut_8x100x1000-16 628 5586421 ns/op 429.62 MB/s Benchmark_RFanOut_8x100x1000-16 646 5535726 ns/op 433.55 MB/s Benchmark_RFanOut_8x100x1000-16 631 5773963 ns/op 415.66 MB/s Benchmark_RFanOut_8x100x1000-16 637 5565454 ns/op 431.24 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 609 6133873 ns/op 407.58 MB/s Benchmark_RFanOut_8x10x10000-16 604 6013558 ns/op 415.73 MB/s Benchmark_RFanOut_8x10x10000-16 618 5923009 ns/op 422.09 MB/s Benchmark_RFanOut_8x10x10000-16 600 5924308 ns/op 421.99 MB/s Benchmark_RFanOut_8x10x10000-16 616 5836747 ns/op 428.32 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3264 1107054 ns/op 9422.34 MB/s Benchmark_RFanOut_1kx10x1000-16 3139 1115234 ns/op 9353.23 MB/s Benchmark_RFanOut_1kx10x1000-16 2983 1122949 ns/op 9288.97 MB/s Benchmark_RFanOut_1kx10x1000-16 3273 1122311 ns/op 9294.25 MB/s Benchmark_RFanOut_1kx10x1000-16 3228 1112128 ns/op 9379.35 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7323494 485.2 ns/op 4282.56 MB/s Benchmark_____FanIn_1kx100x1-16 7085828 486.5 ns/op 4271.49 MB/s Benchmark_____FanIn_1kx100x1-16 7182046 486.8 ns/op 4268.30 MB/s Benchmark_____FanIn_1kx100x1-16 7217946 485.4 ns/op 4281.03 MB/s Benchmark_____FanIn_1kx100x1-16 7269762 486.7 ns/op 4269.54 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2644488 1341 ns/op 6130.91 MB/s Benchmark_____FanIn_4kx100x1-16 2679217 1345 ns/op 6114.80 MB/s Benchmark_____FanIn_4kx100x1-16 2630868 1332 ns/op 6173.88 MB/s Benchmark_____FanIn_4kx100x1-16 2600835 1357 ns/op 6059.99 MB/s Benchmark_____FanIn_4kx100x1-16 2590447 1343 ns/op 6123.76 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1711532 2073 ns/op 7918.96 MB/s Benchmark_____FanIn_8kx100x1-16 1724470 2082 ns/op 7882.83 MB/s Benchmark_____FanIn_8kx100x1-16 1736070 2077 ns/op 7901.50 MB/s Benchmark_____FanIn_8kx100x1-16 1737657 2072 ns/op 7920.73 MB/s Benchmark_____FanIn_8kx100x1-16 1738052 2083 ns/op 7880.55 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 873873 4107 ns/op 7986.73 MB/s Benchmark____FanIn_16kx100x1-16 876776 4158 ns/op 7888.06 MB/s Benchmark____FanIn_16kx100x1-16 872608 4165 ns/op 7874.30 MB/s Benchmark____FanIn_16kx100x1-16 865507 4088 ns/op 8023.48 MB/s Benchmark____FanIn_16kx100x1-16 881011 4103 ns/op 7994.56 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 178512 19910 ns/op 6584.70 MB/s Benchmark____FanIn_64kx100x1-16 180698 20037 ns/op 6543.11 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 7451016192 vs 11353779600 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47948->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47704->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47866->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:47414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47708->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:48060->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:47542->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: 9120454443 vs 11058791100 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50320->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50222->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50018->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50160->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50452->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50536->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:50726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:49972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50100->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:50826->127.0.0.1:5222: write: connection reset by peer Benchmark____FanIn_64kx100x1-16 165357 19766 ns/op 6632.93 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 1152936550 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58622->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: 227047880 vs 11457266000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33630->127.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:33152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32978->127.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:32934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33400->127.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:33550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33484->127.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:33748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33596->127.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:33214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33578->127.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:33696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33720->127.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:33770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33466->127.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:33502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33352->127.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:32896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33618->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32860->127.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:33758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33262->127.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 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33290->127.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: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:33602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33686->127.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:33136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33642->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33784->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:32856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33366->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33520->127.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:33220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33110->127.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:33672->127.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: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:33598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33310->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33458->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:33288->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: 277124260 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35244->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35196->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35288->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34962->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35214->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35496->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35352->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35470->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35332->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34856->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35482->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34688->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34954->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35492->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35184->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34938->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35418->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34862->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: 392745640 vs 11221304000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37484->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37780->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37714->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37518->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37590->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37854->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38034->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37960->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37478->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38054->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37808->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37356->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37576->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37964->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37624->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37882->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38078->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: 758617830 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39368->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39434->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39736->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 Benchmark___BumpPubCount_1x3-16 5992284 597.8 ns/op 475.06 MB/s Benchmark___BumpPubCount_1x3-16 5973357 601.0 ns/op 472.57 MB/s Benchmark___BumpPubCount_1x3-16 6037518 591.0 ns/op 480.56 MB/s Benchmark___BumpPubCount_1x3-16 6054582 593.8 ns/op 478.24 MB/s Benchmark___BumpPubCount_1x3-16 5968750 594.9 ns/op 477.42 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5633180 634.2 ns/op 447.82 MB/s Benchmark___BumpPubCount_2x3-16 5666542 628.4 ns/op 451.98 MB/s Benchmark___BumpPubCount_2x3-16 5653238 628.3 ns/op 452.02 MB/s Benchmark___BumpPubCount_2x3-16 5638332 629.6 ns/op 451.08 MB/s Benchmark___BumpPubCount_2x3-16 5663167 628.5 ns/op 451.90 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5876209 611.4 ns/op 464.53 MB/s Benchmark___BumpPubCount_5x3-16 5859908 612.7 ns/op 463.54 MB/s Benchmark___BumpPubCount_5x3-16 5861928 609.7 ns/op 465.78 MB/s Benchmark___BumpPubCount_5x3-16 5411096 611.7 ns/op 464.26 MB/s Benchmark___BumpPubCount_5x3-16 5685589 609.5 ns/op 465.94 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5907764 606.5 ns/op 468.30 MB/s Benchmark__BumpPubCount_10x3-16 5910066 607.2 ns/op 467.74 MB/s Benchmark__BumpPubCount_10x3-16 5888750 606.8 ns/op 468.04 MB/s Benchmark__BumpPubCount_10x3-16 5906637 606.7 ns/op 468.10 MB/s Benchmark__BumpPubCount_10x3-16 5911726 606.8 ns/op 468.02 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12623539 271.2 ns/op 3834.69 MB/s Benchmark____GWs_Opt_1kx01x0-16 12142394 262.3 ns/op 3964.42 MB/s Benchmark____GWs_Opt_1kx01x0-16 13276848 272.2 ns/op 3820.95 MB/s Benchmark____GWs_Opt_1kx01x0-16 13342147 265.8 ns/op 3913.20 MB/s Benchmark____GWs_Opt_1kx01x0-16 13331665 269.2 ns/op 3863.25 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10831797 335.3 ns/op 6155.68 MB/s Benchmark____GWs_Opt_2kx01x0-16 10793635 350.5 ns/op 5889.36 MB/s Benchmark____GWs_Opt_2kx01x0-16 10316962 316.0 ns/op 6531.11 MB/s Benchmark____GWs_Opt_2kx01x0-16 11119261 331.8 ns/op 6220.26 MB/s Benchmark____GWs_Opt_2kx01x0-16 10024064 341.1 ns/op 6051.36 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5885706 613.1 ns/op 6707.41 MB/s Benchmark____GWs_Opt_4kx01x0-16 5698238 607.6 ns/op 6767.28 MB/s Benchmark____GWs_Opt_4kx01x0-16 5951919 587.5 ns/op 6999.16 MB/s Benchmark____GWs_Opt_4kx01x0-16 5868783 622.6 ns/op 6604.73 MB/s Benchmark____GWs_Opt_4kx01x0-16 5943610 601.4 ns/op 6837.90 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 29201487 110.5 ns/op 9408.47 MB/s Benchmark____GWs_Opt_1kx10x0-16 32528096 111.8 ns/op 9299.11 MB/s Benchmark____GWs_Opt_1kx10x0-16 31548652 112.6 ns/op 9234.10 MB/s Benchmark____GWs_Opt_1kx10x0-16 32628910 111.0 ns/op 9365.48 MB/s Benchmark____GWs_Opt_1kx10x0-16 32094688 118.1 ns/op 8809.50 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 26405635 148.8 ns/op 13872.15 MB/s Benchmark____GWs_Opt_2kx10x0-16 25490653 144.3 ns/op 14302.67 MB/s Benchmark____GWs_Opt_2kx10x0-16 24120344 146.7 ns/op 14067.72 MB/s Benchmark____GWs_Opt_2kx10x0-16 25694294 140.7 ns/op 14665.89 MB/s Benchmark____GWs_Opt_2kx10x0-16 21706894 147.0 ns/op 14038.39 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 10345717 322.5 ns/op 12750.89 MB/s Benchmark____GWs_Opt_4kx10x0-16 12944480 339.0 ns/op 12128.99 MB/s Benchmark____GWs_Opt_4kx10x0-16 12715274 291.2 ns/op 14119.59 MB/s Benchmark____GWs_Opt_4kx10x0-16 10837370 285.2 ns/op 14418.79 MB/s Benchmark____GWs_Opt_4kx10x0-16 11027594 343.6 ns/op 11968.19 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6819078 530.5 ns/op 5890.25 MB/s Benchmark____GWs_Opt_1kx01x1-16 6637486 534.3 ns/op 5848.41 MB/s Benchmark____GWs_Opt_1kx01x1-16 6900150 527.5 ns/op 5924.62 MB/s Benchmark____GWs_Opt_1kx01x1-16 7036390 533.6 ns/op 5856.98 MB/s Benchmark____GWs_Opt_1kx01x1-16 6754767 541.3 ns/op 5773.32 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4787247 752.5 ns/op 8235.45 MB/s Benchmark____GWs_Opt_2kx01x1-16 4839800 799.2 ns/op 7754.45 MB/s Benchmark____GWs_Opt_2kx01x1-16 4557286 754.8 ns/op 8210.33 MB/s Benchmark____GWs_Opt_2kx01x1-16 4798773 745.0 ns/op 8317.83 MB/s Benchmark____GWs_Opt_2kx01x1-16 4867204 732.5 ns/op 8459.61 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2647508 1350 ns/op 9143.34 MB/s Benchmark____GWs_Opt_4kx01x1-16 2676975 1357 ns/op 9094.43 MB/s Benchmark____GWs_Opt_4kx01x1-16 2680129 1541 ns/op 8006.65 MB/s Benchmark____GWs_Opt_4kx01x1-16 2650879 1326 ns/op 9308.59 MB/s Benchmark____GWs_Opt_4kx01x1-16 2650062 1389 ns/op 8882.69 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6499890 622.3 ns/op 5021.89 MB/s Benchmark____GWs_Opt_1kx10x1-16 6746068 605.0 ns/op 5165.54 MB/s Benchmark____GWs_Opt_1kx10x1-16 6364352 537.1 ns/op 5818.07 MB/s Benchmark____GWs_Opt_1kx10x1-16 6348866 522.5 ns/op 5981.40 MB/s Benchmark____GWs_Opt_1kx10x1-16 6847704 556.3 ns/op 5617.67 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4357222 827.3 ns/op 7490.64 MB/s Benchmark____GWs_Opt_2kx10x1-16 4409020 826.0 ns/op 7502.48 MB/s Benchmark____GWs_Opt_2kx10x1-16 4274852 829.9 ns/op 7467.57 MB/s Benchmark____GWs_Opt_2kx10x1-16 4210254 827.9 ns/op 7485.37 MB/s Benchmark____GWs_Opt_2kx10x1-16 4127386 825.5 ns/op 7506.57 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2426799 1512 ns/op 8161.22 MB/s Benchmark____GWs_Opt_4kx10x1-16 2370346 1499 ns/op 8232.22 MB/s Benchmark____GWs_Opt_4kx10x1-16 2470897 1498 ns/op 8236.18 MB/s Benchmark____GWs_Opt_4kx10x1-16 2422576 1468 ns/op 8408.93 MB/s Benchmark____GWs_Opt_4kx10x1-16 2461365 1438 ns/op 8584.96 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 11680078 277.6 ns/op 3746.79 MB/s Benchmark____GWs_Int_1kx01x0-16 12049603 277.6 ns/op 3746.94 MB/s Benchmark____GWs_Int_1kx01x0-16 12781422 277.1 ns/op 3752.78 MB/s Benchmark____GWs_Int_1kx01x0-16 12713480 276.2 ns/op 3766.02 MB/s Benchmark____GWs_Int_1kx01x0-16 12891766 275.1 ns/op 3780.13 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10328698 343.2 ns/op 6013.14 MB/s Benchmark____GWs_Int_2kx01x0-16 10606162 334.8 ns/op 6165.70 MB/s Benchmark____GWs_Int_2kx01x0-16 10695126 351.4 ns/op 5873.74 MB/s Benchmark____GWs_Int_2kx01x0-16 9146638 386.5 ns/op 5339.55 MB/s Benchmark____GWs_Int_2kx01x0-16 10575577 350.3 ns/op 5892.66 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5535914 623.1 ns/op 6599.46 MB/s Benchmark____GWs_Int_4kx01x0-16 6012523 611.8 ns/op 6720.74 MB/s Benchmark____GWs_Int_4kx01x0-16 5811458 650.4 ns/op 6322.40 MB/s Benchmark____GWs_Int_4kx01x0-16 5720697 622.9 ns/op 6600.88 MB/s Benchmark____GWs_Int_4kx01x0-16 5659666 623.9 ns/op 6591.06 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31902415 121.9 ns/op 8530.78 MB/s Benchmark____GWs_Int_1kx10x0-16 32618106 107.8 ns/op 9651.77 MB/s Benchmark____GWs_Int_1kx10x0-16 30983163 109.2 ns/op 9526.47 MB/s Benchmark____GWs_Int_1kx10x0-16 30901056 109.7 ns/op 9480.06 MB/s Benchmark____GWs_Int_1kx10x0-16 30660998 111.1 ns/op 9359.33 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 22553568 137.5 ns/op 15011.94 MB/s Benchmark____GWs_Int_2kx10x0-16 25757776 164.2 ns/op 12566.50 MB/s Benchmark____GWs_Int_2kx10x0-16 23577474 141.8 ns/op 14552.92 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:47580->127.0.0.1:40945: 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:33270->127.0.0.1:41663: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 bench_test.go:55: Failed read: read tcp 127.0.0.1:37404->127.0.0.1:39881: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_4kx10x0 bench_test.go:55: Failed read: read tcp 127.0.0.1:44822->127.0.0.1:44171: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 bench_test.go:158: Error on read: read tcp 127.0.0.1:59068->127.0.0.1:44553: 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:58782->127.0.0.1:42185: use of closed network connection --- FAIL: Benchmark____GWs_Int_4kx10x0-16 Benchmark____GWs_Int_4kx10x0-16 12753693 310.4 ns/op 13247.42 MB/s Benchmark____GWs_Int_4kx10x0-16 9318160 341.0 ns/op 12059.74 MB/s Benchmark____GWs_Int_4kx10x0-16 11211415 331.7 ns/op 12395.09 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6464438 546.7 ns/op 5716.54 MB/s Benchmark____GWs_Int_1kx01x1-16 6631850 538.7 ns/op 5801.02 MB/s Benchmark____GWs_Int_1kx01x1-16 6624853 533.8 ns/op 5853.97 MB/s Benchmark____GWs_Int_1kx01x1-16 6568471 537.1 ns/op 5818.12 MB/s Benchmark____GWs_Int_1kx01x1-16 6620638 536.2 ns/op 5828.24 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4701602 745.0 ns/op 8317.82 MB/s Benchmark____GWs_Int_2kx01x1-16 4688910 757.5 ns/op 8180.85 MB/s Benchmark____GWs_Int_2kx01x1-16 4873628 753.7 ns/op 8222.04 MB/s Benchmark____GWs_Int_2kx01x1-16 4753167 748.4 ns/op 8280.45 MB/s Benchmark____GWs_Int_2kx01x1-16 4866550 750.8 ns/op 8253.57 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2663466 1976 ns/op 6245.21 MB/s Benchmark____GWs_Int_4kx01x1-16 2619688 1723 ns/op 7163.75 MB/s Benchmark____GWs_Int_4kx01x1-16 2710935 1595 ns/op 7736.31 MB/s Benchmark____GWs_Int_4kx01x1-16 2624767 1340 ns/op 9210.10 MB/s Benchmark____GWs_Int_4kx01x1-16 2678582 2510 ns/op 4916.09 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6827890 541.5 ns/op 5770.56 MB/s Benchmark____GWs_Int_1kx10x1-16 6755078 559.7 ns/op 5583.81 MB/s Benchmark____GWs_Int_1kx10x1-16 6838668 532.7 ns/op 5866.09 MB/s Benchmark____GWs_Int_1kx10x1-16 6450837 543.0 ns/op 5755.57 MB/s Benchmark____GWs_Int_1kx10x1-16 6788946 528.5 ns/op 5913.00 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4283928 830.1 ns/op 7465.02 MB/s Benchmark____GWs_Int_2kx10x1-16 4232018 833.5 ns/op 7434.66 MB/s Benchmark____GWs_Int_2kx10x1-16 4234699 1355 ns/op 4572.88 MB/s Benchmark____GWs_Int_2kx10x1-16 4061877 859.9 ns/op 7206.49 MB/s Benchmark____GWs_Int_2kx10x1-16 4218392 820.0 ns/op 7557.43 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2492094 1489 ns/op 8287.54 MB/s Benchmark____GWs_Int_4kx10x1-16 2369108 1487 ns/op 8299.97 MB/s Benchmark____GWs_Int_4kx10x1-16 2360266 1656 ns/op 7453.29 MB/s Benchmark____GWs_Int_4kx10x1-16 2241535 1502 ns/op 8215.68 MB/s Benchmark____GWs_Int_4kx10x1-16 2460424 1493 ns/op 8267.36 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8595193 423.2 ns/op 241.04 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8869137 427.2 ns/op 238.77 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8665804 441.4 ns/op 231.06 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7995670 422.2 ns/op 241.60 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8385076 424.5 ns/op 240.30 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 777262 4708 ns/op 37.59 MB/s Benchmark__GWs_Reqs_1SubEach-16 797244 4970 ns/op 35.61 MB/s Benchmark__GWs_Reqs_1SubEach-16 785556 4903 ns/op 36.10 MB/s Benchmark__GWs_Reqs_1SubEach-16 828207 4997 ns/op 35.42 MB/s Benchmark__GWs_Reqs_1SubEach-16 845168 4898 ns/op 36.13 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2158.424s