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 54804116 64.82 ns/op 169.70 MB/s Benchmark______Pub0b_Payload-16 52203434 65.01 ns/op 169.21 MB/s Benchmark______Pub0b_Payload-16 52676272 64.62 ns/op 170.24 MB/s Benchmark______Pub0b_Payload-16 52695794 64.72 ns/op 169.97 MB/s Benchmark______Pub0b_Payload-16 52161006 64.36 ns/op 170.92 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 52218964 66.18 ns/op 287.10 MB/s Benchmark______Pub8b_Payload-16 52197536 65.11 ns/op 291.82 MB/s Benchmark______Pub8b_Payload-16 47719639 65.15 ns/op 291.63 MB/s Benchmark______Pub8b_Payload-16 51832002 64.93 ns/op 292.63 MB/s Benchmark______Pub8b_Payload-16 51949845 65.28 ns/op 291.06 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 47174608 69.29 ns/op 635.04 MB/s Benchmark_____Pub32b_Payload-16 48770884 69.52 ns/op 632.95 MB/s Benchmark_____Pub32b_Payload-16 48545546 69.40 ns/op 634.01 MB/s Benchmark_____Pub32b_Payload-16 51544618 69.90 ns/op 629.48 MB/s Benchmark_____Pub32b_Payload-16 48443263 70.02 ns/op 628.35 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 42297339 79.87 ns/op 1765.31 MB/s Benchmark____Pub128B_Payload-16 45141560 80.59 ns/op 1749.66 MB/s Benchmark____Pub128B_Payload-16 45220302 85.32 ns/op 1652.64 MB/s Benchmark____Pub128B_Payload-16 42251989 79.38 ns/op 1776.34 MB/s Benchmark____Pub128B_Payload-16 45220244 79.94 ns/op 1763.87 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 38625967 88.08 ns/op 3054.05 MB/s Benchmark____Pub256B_Payload-16 34276275 88.61 ns/op 3035.75 MB/s Benchmark____Pub256B_Payload-16 40743232 90.27 ns/op 2979.85 MB/s Benchmark____Pub256B_Payload-16 39023814 89.07 ns/op 3020.21 MB/s Benchmark____Pub256B_Payload-16 39572691 86.89 ns/op 3095.87 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 23751534 145.7 ns/op 7124.26 MB/s Benchmark______Pub1K_Payload-16 23760238 135.4 ns/op 7668.70 MB/s Benchmark______Pub1K_Payload-16 24579738 131.1 ns/op 7920.45 MB/s Benchmark______Pub1K_Payload-16 24390759 139.9 ns/op 7417.48 MB/s Benchmark______Pub1K_Payload-16 23505646 129.7 ns/op 8004.66 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5600740 630.2 ns/op 6521.53 MB/s Benchmark______Pub4K_Payload-16 5360366 628.8 ns/op 6536.69 MB/s Benchmark______Pub4K_Payload-16 5622447 622.0 ns/op 6607.62 MB/s Benchmark______Pub4K_Payload-16 5554755 627.4 ns/op 6551.03 MB/s Benchmark______Pub4K_Payload-16 5303092 621.8 ns/op 6609.70 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2737578 1272 ns/op 6452.57 MB/s Benchmark______Pub8K_Payload-16 2814626 1271 ns/op 6454.02 MB/s Benchmark______Pub8K_Payload-16 2823982 1276 ns/op 6431.83 MB/s Benchmark______Pub8K_Payload-16 2773615 1272 ns/op 6449.84 MB/s Benchmark______Pub8K_Payload-16 2719980 1362 ns/op 6025.55 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 569235 5449 ns/op 6016.81 MB/s Benchmark_____Pub32K_Payload-16 652516 6875 ns/op 4768.57 MB/s Benchmark_____Pub32K_Payload-16 672044 5490 ns/op 5971.83 MB/s Benchmark_____Pub32K_Payload-16 671378 5373 ns/op 6101.78 MB/s Benchmark_____Pub32K_Payload-16 507184 11178 ns/op 2932.83 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 40893721 88.63 ns/op 124.12 MB/s Benchmark__AuthPub0b_Payload-16 38687122 88.28 ns/op 124.60 MB/s Benchmark__AuthPub0b_Payload-16 38748984 88.10 ns/op 124.86 MB/s Benchmark__AuthPub0b_Payload-16 38427597 88.39 ns/op 124.45 MB/s Benchmark__AuthPub0b_Payload-16 34427979 88.08 ns/op 124.89 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 16917624 210.7 ns/op Benchmark_____________PubSub-16 16619274 211.6 ns/op Benchmark_____________PubSub-16 16930365 211.3 ns/op Benchmark_____________PubSub-16 16768191 211.3 ns/op Benchmark_____________PubSub-16 16898059 211.7 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 16768713 210.3 ns/op Benchmark_____PubSubTwoConns-16 16805241 210.5 ns/op Benchmark_____PubSubTwoConns-16 16760595 210.4 ns/op Benchmark_____PubSubTwoConns-16 16858222 210.2 ns/op Benchmark_____PubSubTwoConns-16 16741197 210.0 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:44340->127.0.0.1:42189: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:51374->127.0.0.1:40095: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:50436->127.0.0.1:37815: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42502->127.0.0.1:44013: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:59202->127.0.0.1:43863: 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 15326450 229.5 ns/op Benchmark_____PubTwoQueueSub-16 15387187 229.7 ns/op Benchmark_____PubTwoQueueSub-16 15443264 229.5 ns/op Benchmark_____PubTwoQueueSub-16 15374979 229.6 ns/op Benchmark_____PubTwoQueueSub-16 15525262 229.9 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 15437766 230.2 ns/op Benchmark____PubFourQueueSub-16 15715263 230.4 ns/op Benchmark____PubFourQueueSub-16 15475642 229.2 ns/op Benchmark____PubFourQueueSub-16 15524398 230.6 ns/op Benchmark____PubFourQueueSub-16 15288848 229.8 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 15295250 229.9 ns/op Benchmark___PubEightQueueSub-16 15433194 228.4 ns/op Benchmark___PubEightQueueSub-16 15584103 230.1 ns/op Benchmark___PubEightQueueSub-16 15168196 230.5 ns/op Benchmark___PubEightQueueSub-16 15344703 228.5 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23168 155578 ns/op Benchmark_PubSub512kTwoConns-16 23095 155129 ns/op Benchmark_PubSub512kTwoConns-16 22984 158681 ns/op Benchmark_PubSub512kTwoConns-16 22676 157591 ns/op Benchmark_PubSub512kTwoConns-16 22855 157772 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 16036567 214.2 ns/op Benchmark__DenyMsgNoWCPubSub-16 16338523 213.3 ns/op Benchmark__DenyMsgNoWCPubSub-16 16163612 213.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 16441104 214.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 16096124 214.2 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 16223797 214.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 16443957 214.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 16219278 214.9 ns/op Benchmark_DenyMsgYesWCPubSub-16 16237771 214.1 ns/op Benchmark_DenyMsgYesWCPubSub-16 16281213 214.0 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11705605 299.5 ns/op Benchmark____RoutedPubSub_0b-16 11746827 298.9 ns/op Benchmark____RoutedPubSub_0b-16 11721186 295.9 ns/op Benchmark____RoutedPubSub_0b-16 11920878 297.4 ns/op Benchmark____RoutedPubSub_0b-16 11906350 296.3 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6981204 517.0 ns/op Benchmark____RoutedPubSub_1K-16 6921368 518.7 ns/op Benchmark____RoutedPubSub_1K-16 6899932 506.2 ns/op Benchmark____RoutedPubSub_1K-16 6995967 524.0 ns/op Benchmark____RoutedPubSub_1K-16 6646828 524.0 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 84494 43966 ns/op Benchmark__RoutedPubSub_100K-16 81138 42560 ns/op Benchmark__RoutedPubSub_100K-16 83157 43172 ns/op Benchmark__RoutedPubSub_100K-16 84468 42474 ns/op Benchmark__RoutedPubSub_100K-16 84572 43430 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 11946078 300.6 ns/op Benchmark____Routed2QueueSub-16 10035843 303.3 ns/op Benchmark____Routed2QueueSub-16 9812263 309.2 ns/op Benchmark____Routed2QueueSub-16 12048117 296.9 ns/op Benchmark____Routed2QueueSub-16 9945001 305.2 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 11656215 304.9 ns/op Benchmark____Routed4QueueSub-16 11842077 301.8 ns/op Benchmark____Routed4QueueSub-16 9820647 309.1 ns/op Benchmark____Routed4QueueSub-16 11523853 306.5 ns/op Benchmark____Routed4QueueSub-16 9763340 310.4 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9537706 315.8 ns/op Benchmark____Routed8QueueSub-16 11555197 310.5 ns/op Benchmark____Routed8QueueSub-16 9585070 315.2 ns/op Benchmark____Routed8QueueSub-16 11328375 313.4 ns/op Benchmark____Routed8QueueSub-16 9477199 321.6 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 9039871 335.0 ns/op Benchmark___Routed16QueueSub-16 8930385 337.3 ns/op Benchmark___Routed16QueueSub-16 8928145 339.4 ns/op Benchmark___Routed16QueueSub-16 9246408 339.1 ns/op Benchmark___Routed16QueueSub-16 9164462 338.7 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6736543 526.7 ns/op Benchmark____________RouteCompressOff-16 6686674 532.5 ns/op Benchmark____________RouteCompressOff-16 6761208 529.3 ns/op Benchmark____________RouteCompressOff-16 6705592 523.9 ns/op Benchmark____________RouteCompressOff-16 6812138 532.5 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6726734 461.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6756018 527.6 ns/op Benchmark_RouteCompressS2Uncompressed-16 6676113 489.3 ns/op Benchmark_RouteCompressS2Uncompressed-16 6705453 529.1 ns/op Benchmark_RouteCompressS2Uncompressed-16 6615338 529.3 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6667946 527.9 ns/op Benchmark_________RouteCompressS2Fast-16 6723716 526.5 ns/op Benchmark_________RouteCompressS2Fast-16 6564990 529.8 ns/op Benchmark_________RouteCompressS2Fast-16 6570165 527.3 ns/op Benchmark_________RouteCompressS2Fast-16 6632917 530.9 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6833199 453.7 ns/op Benchmark_______RouteCompressS2Better-16 6599708 536.5 ns/op Benchmark_______RouteCompressS2Better-16 6441380 537.5 ns/op Benchmark_______RouteCompressS2Better-16 6526460 531.4 ns/op Benchmark_______RouteCompressS2Better-16 6530144 531.6 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6547077 533.6 ns/op Benchmark_________RouteCompressS2Best-16 6717475 525.7 ns/op Benchmark_________RouteCompressS2Best-16 6559210 572.7 ns/op Benchmark_________RouteCompressS2Best-16 7944256 538.3 ns/op Benchmark_________RouteCompressS2Best-16 6507987 526.8 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 5124980 695.0 ns/op 358.27 MB/s Benchmark______FanOut_8x1x10-16 5166841 695.4 ns/op 358.05 MB/s Benchmark______FanOut_8x1x10-16 5142217 699.3 ns/op 356.06 MB/s Benchmark______FanOut_8x1x10-16 5135803 694.9 ns/op 358.34 MB/s Benchmark______FanOut_8x1x10-16 5145145 694.4 ns/op 358.59 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 591852 5397 ns/op 429.69 MB/s Benchmark_____FanOut_8x1x100-16 629505 5348 ns/op 433.65 MB/s Benchmark_____FanOut_8x1x100-16 647466 5400 ns/op 429.46 MB/s Benchmark_____FanOut_8x1x100-16 615054 5330 ns/op 435.11 MB/s Benchmark_____FanOut_8x1x100-16 609300 5409 ns/op 428.72 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 52832 68007 ns/op 338.48 MB/s Benchmark____FanOut_8x10x100-16 52533 68050 ns/op 338.27 MB/s Benchmark____FanOut_8x10x100-16 52888 67965 ns/op 338.69 MB/s Benchmark____FanOut_8x10x100-16 52456 68050 ns/op 338.27 MB/s Benchmark____FanOut_8x10x100-16 52638 68170 ns/op 337.67 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 6750 539767 ns/op 444.67 MB/s Benchmark___FanOut_8x10x1000-16 6471 539169 ns/op 445.16 MB/s Benchmark___FanOut_8x10x1000-16 6481 534944 ns/op 448.68 MB/s Benchmark___FanOut_8x10x1000-16 6812 535253 ns/op 448.42 MB/s Benchmark___FanOut_8x10x1000-16 6385 536636 ns/op 447.27 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 5520 639097 ns/op 359.91 MB/s Benchmark___FanOut_8x100x100-16 5469 636271 ns/op 361.51 MB/s Benchmark___FanOut_8x100x100-16 5504 637529 ns/op 360.80 MB/s Benchmark___FanOut_8x100x100-16 5522 638459 ns/op 360.27 MB/s Benchmark___FanOut_8x100x100-16 5599 639162 ns/op 359.88 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 643 5592887 ns/op 429.12 MB/s Benchmark__FanOut_8x100x1000-16 642 5582759 ns/op 429.90 MB/s Benchmark__FanOut_8x100x1000-16 636 5535157 ns/op 433.60 MB/s Benchmark__FanOut_8x100x1000-16 639 5468198 ns/op 438.90 MB/s Benchmark__FanOut_8x100x1000-16 650 5567692 ns/op 431.06 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 612 5943501 ns/op 420.63 MB/s Benchmark__FanOut_8x10x10000-16 616 5901970 ns/op 423.59 MB/s Benchmark__FanOut_8x10x10000-16 594 5890085 ns/op 424.45 MB/s Benchmark__FanOut_8x10x10000-16 597 5929232 ns/op 421.64 MB/s Benchmark__FanOut_8x10x10000-16 579 5981134 ns/op 417.98 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 1042 3398299 ns/op 338.41 MB/s Benchmark___FanOut_8x500x100-16 1045 3417099 ns/op 336.55 MB/s Benchmark___FanOut_8x500x100-16 1042 3404041 ns/op 337.84 MB/s Benchmark___FanOut_8x500x100-16 1042 3421324 ns/op 336.13 MB/s Benchmark___FanOut_8x500x100-16 1047 3426035 ns/op 335.67 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 387220 8894 ns/op 1646.13 MB/s Benchmark___FanOut_128x1x100-16 385456 8879 ns/op 1648.94 MB/s Benchmark___FanOut_128x1x100-16 387856 8887 ns/op 1647.52 MB/s Benchmark___FanOut_128x1x100-16 385449 8919 ns/op 1641.55 MB/s Benchmark___FanOut_128x1x100-16 385172 8896 ns/op 1645.77 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 34659 103623 ns/op 1400.67 MB/s Benchmark__FanOut_128x10x100-16 34680 103334 ns/op 1404.58 MB/s Benchmark__FanOut_128x10x100-16 34560 103482 ns/op 1402.57 MB/s Benchmark__FanOut_128x10x100-16 34650 103585 ns/op 1401.17 MB/s Benchmark__FanOut_128x10x100-16 34429 103613 ns/op 1400.80 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 4182 804201 ns/op 1815.64 MB/s Benchmark_FanOut_128x10x1000-16 4328 802136 ns/op 1820.32 MB/s Benchmark_FanOut_128x10x1000-16 4398 805307 ns/op 1813.15 MB/s Benchmark_FanOut_128x10x1000-16 4472 809879 ns/op 1802.91 MB/s Benchmark_FanOut_128x10x1000-16 4352 805926 ns/op 1811.76 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3718 948753 ns/op 1528.47 MB/s Benchmark_FanOut_128x100x100-16 3734 950558 ns/op 1525.57 MB/s Benchmark_FanOut_128x100x100-16 3694 948182 ns/op 1529.39 MB/s Benchmark_FanOut_128x100x100-16 3696 948259 ns/op 1529.27 MB/s Benchmark_FanOut_128x100x100-16 3721 949102 ns/op 1527.91 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 421 8532445 ns/op 1711.13 MB/s BenchmarkFanOut_128x100x1000-16 404 8549157 ns/op 1707.79 MB/s BenchmarkFanOut_128x100x1000-16 421 8595472 ns/op 1698.59 MB/s BenchmarkFanOut_128x100x1000-16 417 8643001 ns/op 1689.24 MB/s BenchmarkFanOut_128x100x1000-16 416 8541536 ns/op 1709.31 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 406 8832879 ns/op 1664.25 MB/s BenchmarkFanOut_128x10x10000-16 403 8900958 ns/op 1651.52 MB/s BenchmarkFanOut_128x10x10000-16 404 8887942 ns/op 1653.94 MB/s BenchmarkFanOut_128x10x10000-16 408 8895064 ns/op 1652.62 MB/s BenchmarkFanOut_128x10x10000-16 406 8890195 ns/op 1653.52 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 714 5005792 ns/op 1448.35 MB/s BenchmarkFanOut__128x500x100-16 703 4997579 ns/op 1450.73 MB/s BenchmarkFanOut__128x500x100-16 709 4988120 ns/op 1453.48 MB/s BenchmarkFanOut__128x500x100-16 718 4998773 ns/op 1450.38 MB/s BenchmarkFanOut__128x500x100-16 709 5005784 ns/op 1448.35 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 2019 1772008 ns/op 2985.61 MB/s Benchmark_FanOut_512x100x100-16 1998 1775686 ns/op 2979.43 MB/s Benchmark_FanOut_512x100x100-16 1988 1790527 ns/op 2954.73 MB/s Benchmark_FanOut_512x100x100-16 1999 1773025 ns/op 2983.90 MB/s Benchmark_FanOut_512x100x100-16 1998 1787187 ns/op 2960.25 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 226 16066258 ns/op 3298.87 MB/s Benchmark__FanOut_512x100x1k-16 223 16139611 ns/op 3283.88 MB/s Benchmark__FanOut_512x100x1k-16 220 16281310 ns/op 3255.30 MB/s Benchmark__FanOut_512x100x1k-16 220 16150491 ns/op 3281.67 MB/s Benchmark__FanOut_512x100x1k-16 223 16136181 ns/op 3284.58 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3244 1095658 ns/op 9520.34 MB/s Benchmark____FanOut_1kx10x1k-16 3232 1140425 ns/op 9146.63 MB/s Benchmark____FanOut_1kx10x1k-16 3315 1119630 ns/op 9316.51 MB/s Benchmark____FanOut_1kx10x1k-16 3193 1088957 ns/op 9578.92 MB/s Benchmark____FanOut_1kx10x1k-16 3352 1101413 ns/op 9470.60 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2925 1196868 ns/op 8706.93 MB/s Benchmark__FanOut_1kx100x100-16 2845 1193849 ns/op 8728.94 MB/s Benchmark__FanOut_1kx100x100-16 2916 1200308 ns/op 8681.97 MB/s Benchmark__FanOut_1kx100x100-16 2947 1191385 ns/op 8746.99 MB/s Benchmark__FanOut_1kx100x100-16 2841 1200874 ns/op 8677.88 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 5030769 709.2 ns/op 351.11 MB/s Benchmark_____RFanOut_8x1x10-16 4866033 709.3 ns/op 351.07 MB/s Benchmark_____RFanOut_8x1x10-16 4940236 697.2 ns/op 357.13 MB/s Benchmark_____RFanOut_8x1x10-16 4704529 703.6 ns/op 353.90 MB/s Benchmark_____RFanOut_8x1x10-16 4970694 701.7 ns/op 354.83 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 613518 5302 ns/op 437.38 MB/s Benchmark____RFanOut_8x1x100-16 630022 5327 ns/op 435.34 MB/s Benchmark____RFanOut_8x1x100-16 645638 5269 ns/op 440.09 MB/s Benchmark____RFanOut_8x1x100-16 557732 5453 ns/op 425.25 MB/s Benchmark____RFanOut_8x1x100-16 597259 5315 ns/op 436.33 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 53002 68034 ns/op 338.35 MB/s Benchmark___RFanOut_8x10x100-16 53148 67872 ns/op 339.15 MB/s Benchmark___RFanOut_8x10x100-16 52812 68208 ns/op 337.48 MB/s Benchmark___RFanOut_8x10x100-16 52689 68100 ns/op 338.02 MB/s Benchmark___RFanOut_8x10x100-16 52876 67970 ns/op 338.66 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 6656 542334 ns/op 442.57 MB/s Benchmark__RFanOut_8x10x1000-16 6513 534877 ns/op 448.74 MB/s Benchmark__RFanOut_8x10x1000-16 6800 537444 ns/op 446.59 MB/s Benchmark__RFanOut_8x10x1000-16 6633 540328 ns/op 444.21 MB/s Benchmark__RFanOut_8x10x1000-16 6087 536902 ns/op 447.04 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 5606 635136 ns/op 362.16 MB/s Benchmark__RFanOut_8x100x100-16 5469 636696 ns/op 361.27 MB/s Benchmark__RFanOut_8x100x100-16 5504 636892 ns/op 361.16 MB/s Benchmark__RFanOut_8x100x100-16 5490 636563 ns/op 361.35 MB/s Benchmark__RFanOut_8x100x100-16 5602 637004 ns/op 361.09 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 644 5715117 ns/op 419.94 MB/s Benchmark_RFanOut_8x100x1000-16 633 5619923 ns/op 427.06 MB/s Benchmark_RFanOut_8x100x1000-16 631 5651900 ns/op 424.64 MB/s Benchmark_RFanOut_8x100x1000-16 630 5567204 ns/op 431.10 MB/s Benchmark_RFanOut_8x100x1000-16 628 5635193 ns/op 425.90 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 612 5950391 ns/op 420.14 MB/s Benchmark_RFanOut_8x10x10000-16 597 5956004 ns/op 419.75 MB/s Benchmark_RFanOut_8x10x10000-16 595 5961233 ns/op 419.38 MB/s Benchmark_RFanOut_8x10x10000-16 584 5969777 ns/op 418.78 MB/s Benchmark_RFanOut_8x10x10000-16 613 6003024 ns/op 416.46 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3087 1107360 ns/op 9419.73 MB/s Benchmark_RFanOut_1kx10x1000-16 3093 1140483 ns/op 9146.16 MB/s Benchmark_RFanOut_1kx10x1000-16 3150 1097098 ns/op 9507.85 MB/s Benchmark_RFanOut_1kx10x1000-16 3256 1101944 ns/op 9466.03 MB/s Benchmark_RFanOut_1kx10x1000-16 3123 1137914 ns/op 9166.81 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 7213446 487.5 ns/op 4262.73 MB/s Benchmark_____FanIn_1kx100x1-16 7220262 488.6 ns/op 4252.65 MB/s Benchmark_____FanIn_1kx100x1-16 7246105 491.1 ns/op 4231.05 MB/s Benchmark_____FanIn_1kx100x1-16 7135159 488.3 ns/op 4255.15 MB/s Benchmark_____FanIn_1kx100x1-16 7233511 486.9 ns/op 4267.82 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2662047 1333 ns/op 6166.24 MB/s Benchmark_____FanIn_4kx100x1-16 2634021 1329 ns/op 6185.02 MB/s Benchmark_____FanIn_4kx100x1-16 2685816 1327 ns/op 6196.88 MB/s Benchmark_____FanIn_4kx100x1-16 2621353 1346 ns/op 6110.72 MB/s Benchmark_____FanIn_4kx100x1-16 2647998 1363 ns/op 6031.50 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1709109 2145 ns/op 7652.44 MB/s Benchmark_____FanIn_8kx100x1-16 1725072 2110 ns/op 7778.01 MB/s Benchmark_____FanIn_8kx100x1-16 1708380 2099 ns/op 7819.97 MB/s Benchmark_____FanIn_8kx100x1-16 1724013 2439 ns/op 6730.00 MB/s Benchmark_____FanIn_8kx100x1-16 1709224 2083 ns/op 7881.00 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 888469 4142 ns/op 7919.04 MB/s Benchmark____FanIn_16kx100x1-16 879174 4114 ns/op 7972.74 MB/s Benchmark____FanIn_16kx100x1-16 870130 4179 ns/op 7849.23 MB/s Benchmark____FanIn_16kx100x1-16 869415 4074 ns/op 8051.99 MB/s Benchmark____FanIn_16kx100x1-16 867018 4094 ns/op 8012.53 MB/s Benchmark____FanIn_64kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 3334877769 vs 10993238100 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46512->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46210->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46796->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46438->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46588->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46928->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46412->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46996->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46772->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46898->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46664->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46596->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46430->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46240->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46224->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46724->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46904->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46598->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46846->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46558->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46498->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46370->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46308->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46398->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46602->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:46606->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 166790 19600 ns/op 6688.82 MB/s Benchmark____FanIn_64kx100x1-16 162741 19892 ns/op 6590.67 MB/s Benchmark____FanIn_64kx100x1-16 166698 20033 ns/op 6544.29 MB/s Benchmark____FanIn_64kx100x1-16 171675 19809 ns/op 6618.51 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 633820150 vs 11680119000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60426->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60016->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59738->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60012->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60248->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60474->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60460->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60556->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60394->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60544->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59762->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59918->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60530->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60098->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60066->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60500->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60470->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59696->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60448->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60490->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: 1117804430 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33522->127.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:33406->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: 332837510 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35294->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35466->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35884->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35586->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:35752->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35684->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35524->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:35328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35442->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35852->127.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:35120->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35058->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35084->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35414->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35202->127.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:35624->127.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:35720->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35716->127.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: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: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:35660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35020->127.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:35238->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35140->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35190->127.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:35766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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: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:35790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35038->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:35678->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:35390->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: 285645110 vs 1310900000 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:37056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37514->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36816->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36912->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36822->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36830->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37334->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37148->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36896->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36952->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37568->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37264->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37508->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37578->127.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:37224->127.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:37030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36950->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37188->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37172->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37548->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37106->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37292->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37486->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37190->127.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: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:37634->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37186->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37382->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37626->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36924->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37118->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37144->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:36832->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37198->127.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: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:37146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:37206->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: 135547060 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38880->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38630->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39044->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39048->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39074->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38892->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39420->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39440->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39008->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38868->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38894->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39396->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39354->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39182->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39300->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38838->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38862->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39450->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38650->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38606->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39406->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38760->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39208->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39282->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39024->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:39456->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38866->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39314->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39380->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39468->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38920->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39110->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38770->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:39068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:38728->127.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 Benchmark___BumpPubCount_1x3-16 5996216 596.6 ns/op 476.00 MB/s Benchmark___BumpPubCount_1x3-16 6057402 597.6 ns/op 475.25 MB/s Benchmark___BumpPubCount_1x3-16 6011428 597.2 ns/op 475.56 MB/s Benchmark___BumpPubCount_1x3-16 6051037 593.1 ns/op 478.83 MB/s Benchmark___BumpPubCount_1x3-16 5999061 597.3 ns/op 475.45 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5609188 629.0 ns/op 451.49 MB/s Benchmark___BumpPubCount_2x3-16 5647486 630.0 ns/op 450.79 MB/s Benchmark___BumpPubCount_2x3-16 5645041 634.5 ns/op 447.61 MB/s Benchmark___BumpPubCount_2x3-16 5616798 632.2 ns/op 449.24 MB/s Benchmark___BumpPubCount_2x3-16 5640868 632.5 ns/op 449.03 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5705874 614.0 ns/op 462.53 MB/s Benchmark___BumpPubCount_5x3-16 5790609 622.4 ns/op 456.29 MB/s Benchmark___BumpPubCount_5x3-16 5862747 614.8 ns/op 461.92 MB/s Benchmark___BumpPubCount_5x3-16 5863088 611.7 ns/op 464.29 MB/s Benchmark___BumpPubCount_5x3-16 5200354 612.1 ns/op 463.94 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5892178 609.2 ns/op 466.22 MB/s Benchmark__BumpPubCount_10x3-16 5915949 608.3 ns/op 466.86 MB/s Benchmark__BumpPubCount_10x3-16 5907666 609.3 ns/op 466.08 MB/s Benchmark__BumpPubCount_10x3-16 5889639 608.8 ns/op 466.45 MB/s Benchmark__BumpPubCount_10x3-16 5829679 608.5 ns/op 466.74 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12750468 268.7 ns/op 3870.52 MB/s Benchmark____GWs_Opt_1kx01x0-16 13139986 274.5 ns/op 3789.15 MB/s Benchmark____GWs_Opt_1kx01x0-16 11147803 276.8 ns/op 3757.68 MB/s Benchmark____GWs_Opt_1kx01x0-16 12740628 278.0 ns/op 3740.35 MB/s Benchmark____GWs_Opt_1kx01x0-16 11650104 274.3 ns/op 3791.40 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10357036 340.8 ns/op 6055.64 MB/s Benchmark____GWs_Opt_2kx01x0-16 10498852 344.7 ns/op 5988.03 MB/s Benchmark____GWs_Opt_2kx01x0-16 9946032 356.8 ns/op 5784.47 MB/s Benchmark____GWs_Opt_2kx01x0-16 10972657 337.8 ns/op 6109.78 MB/s Benchmark____GWs_Opt_2kx01x0-16 10597798 341.1 ns/op 6050.52 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 6014382 620.7 ns/op 6625.23 MB/s Benchmark____GWs_Opt_4kx01x0-16 5893209 617.3 ns/op 6661.75 MB/s Benchmark____GWs_Opt_4kx01x0-16 5817028 690.3 ns/op 5956.59 MB/s Benchmark____GWs_Opt_4kx01x0-16 5905053 640.3 ns/op 6422.41 MB/s Benchmark____GWs_Opt_4kx01x0-16 5941609 600.7 ns/op 6845.40 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 30310639 110.3 ns/op 9431.69 MB/s Benchmark____GWs_Opt_1kx10x0-16 30663136 106.0 ns/op 9814.78 MB/s Benchmark____GWs_Opt_1kx10x0-16 31653049 110.3 ns/op 9430.24 MB/s Benchmark____GWs_Opt_1kx10x0-16 30262918 110.4 ns/op 9421.19 MB/s Benchmark____GWs_Opt_1kx10x0-16 32282853 108.6 ns/op 9572.14 MB/s Benchmark____GWs_Opt_2kx10x0 Benchmark____GWs_Opt_2kx10x0-16 22759634 177.2 ns/op 11646.24 MB/s Benchmark____GWs_Opt_2kx10x0-16 23988766 418.2 ns/op 4935.71 MB/s Benchmark____GWs_Opt_2kx10x0-16 25987545 153.8 ns/op 13416.09 MB/s Benchmark____GWs_Opt_2kx10x0-16 23248621 144.6 ns/op 14277.26 MB/s Benchmark____GWs_Opt_2kx10x0-16 21743564 155.6 ns/op 13265.72 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 12751754 293.4 ns/op 14014.51 MB/s Benchmark____GWs_Opt_4kx10x0-16 10996633 371.2 ns/op 11076.85 MB/s Benchmark____GWs_Opt_4kx10x0-16 13193535 387.6 ns/op 10609.93 MB/s Benchmark____GWs_Opt_4kx10x0-16 10798886 299.8 ns/op 13715.84 MB/s Benchmark____GWs_Opt_4kx10x0-16 12722126 297.0 ns/op 13845.15 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6752073 525.8 ns/op 5943.80 MB/s Benchmark____GWs_Opt_1kx01x1-16 6705147 542.2 ns/op 5763.11 MB/s Benchmark____GWs_Opt_1kx01x1-16 6656532 531.4 ns/op 5880.23 MB/s Benchmark____GWs_Opt_1kx01x1-16 6451959 539.0 ns/op 5797.93 MB/s Benchmark____GWs_Opt_1kx01x1-16 6688399 541.1 ns/op 5775.44 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4685583 739.8 ns/op 8376.44 MB/s Benchmark____GWs_Opt_2kx01x1-16 4763245 784.5 ns/op 7899.70 MB/s Benchmark____GWs_Opt_2kx01x1-16 4828906 738.7 ns/op 8388.70 MB/s Benchmark____GWs_Opt_2kx01x1-16 4766744 739.8 ns/op 8376.07 MB/s Benchmark____GWs_Opt_2kx01x1-16 4754155 746.5 ns/op 8300.93 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2595291 1481 ns/op 8334.91 MB/s Benchmark____GWs_Opt_4kx01x1-16 2667944 1362 ns/op 9063.81 MB/s Benchmark____GWs_Opt_4kx01x1-16 2656078 1337 ns/op 9228.82 MB/s Benchmark____GWs_Opt_4kx01x1-16 2692106 1342 ns/op 9199.10 MB/s Benchmark____GWs_Opt_4kx01x1-16 2649510 2338 ns/op 5277.73 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6812528 557.4 ns/op 5606.66 MB/s Benchmark____GWs_Opt_1kx10x1-16 6695083 538.0 ns/op 5808.86 MB/s Benchmark____GWs_Opt_1kx10x1-16 6664669 540.2 ns/op 5784.83 MB/s Benchmark____GWs_Opt_1kx10x1-16 6273861 526.6 ns/op 5933.94 MB/s Benchmark____GWs_Opt_1kx10x1-16 6322236 537.5 ns/op 5813.70 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4239048 829.2 ns/op 7473.04 MB/s Benchmark____GWs_Opt_2kx10x1-16 4362145 769.8 ns/op 8050.16 MB/s Benchmark____GWs_Opt_2kx10x1-16 4247937 854.2 ns/op 7254.73 MB/s Benchmark____GWs_Opt_2kx10x1-16 4184223 834.8 ns/op 7423.15 MB/s Benchmark____GWs_Opt_2kx10x1-16 4069294 822.3 ns/op 7536.24 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2565860 1519 ns/op 8123.46 MB/s Benchmark____GWs_Opt_4kx10x1-16 2328034 1533 ns/op 8051.71 MB/s Benchmark____GWs_Opt_4kx10x1-16 2278894 1547 ns/op 7977.48 MB/s Benchmark____GWs_Opt_4kx10x1-16 2429175 1514 ns/op 8152.52 MB/s Benchmark____GWs_Opt_4kx10x1-16 2421744 1486 ns/op 8306.74 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 11983552 285.0 ns/op 3649.02 MB/s Benchmark____GWs_Int_1kx01x0-16 11109457 285.8 ns/op 3639.24 MB/s Benchmark____GWs_Int_1kx01x0-16 11580166 291.6 ns/op 3566.94 MB/s Benchmark____GWs_Int_1kx01x0-16 12849560 280.7 ns/op 3704.42 MB/s Benchmark____GWs_Int_1kx01x0-16 11779537 288.2 ns/op 3608.12 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10527828 352.2 ns/op 5860.12 MB/s Benchmark____GWs_Int_2kx01x0-16 9474907 362.7 ns/op 5689.94 MB/s Benchmark____GWs_Int_2kx01x0-16 10870722 348.9 ns/op 5916.06 MB/s Benchmark____GWs_Int_2kx01x0-16 9571123 354.2 ns/op 5827.33 MB/s Benchmark____GWs_Int_2kx01x0-16 10491330 352.3 ns/op 5858.84 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5827436 632.2 ns/op 6504.24 MB/s Benchmark____GWs_Int_4kx01x0-16 5740324 628.0 ns/op 6547.86 MB/s Benchmark____GWs_Int_4kx01x0-16 5705641 618.3 ns/op 6650.93 MB/s Benchmark____GWs_Int_4kx01x0-16 5783301 630.9 ns/op 6517.83 MB/s Benchmark____GWs_Int_4kx01x0-16 5707714 634.4 ns/op 6481.79 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 32328454 110.6 ns/op 9406.44 MB/s Benchmark____GWs_Int_1kx10x0-16 31794195 112.0 ns/op 9283.73 MB/s Benchmark____GWs_Int_1kx10x0-16 32593488 110.0 ns/op 9455.04 MB/s Benchmark____GWs_Int_1kx10x0-16 31768089 117.2 ns/op 8872.17 MB/s Benchmark____GWs_Int_1kx10x0-16 32026472 108.6 ns/op 9576.57 MB/s Benchmark____GWs_Int_2kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:59126->127.0.0.1:46577: 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:53134->127.0.0.1:34553: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x0-16 Benchmark____GWs_Int_2kx10x0-16 25554202 149.2 ns/op 13829.36 MB/s Benchmark____GWs_Int_2kx10x0-16 25813084 146.7 ns/op 14069.23 MB/s Benchmark____GWs_Int_2kx10x0-16 25411747 141.1 ns/op 14627.89 MB/s Benchmark____GWs_Int_2kx10x0-16 22730258 151.8 ns/op 13600.67 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 13112311 282.3 ns/op 14564.81 MB/s Benchmark____GWs_Int_4kx10x0-16 12164500 298.9 ns/op 13758.28 MB/s Benchmark____GWs_Int_4kx10x0-16 12311535 316.4 ns/op 12996.83 MB/s Benchmark____GWs_Int_4kx10x0-16 12922225 277.3 ns/op 14826.33 MB/s Benchmark____GWs_Int_4kx10x0-16 11814429 323.7 ns/op 12702.13 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6680136 543.2 ns/op 5752.50 MB/s Benchmark____GWs_Int_1kx01x1-16 6546910 544.8 ns/op 5736.39 MB/s Benchmark____GWs_Int_1kx01x1-16 6440107 538.9 ns/op 5799.00 MB/s Benchmark____GWs_Int_1kx01x1-16 6780165 542.5 ns/op 5760.76 MB/s Benchmark____GWs_Int_1kx01x1-16 6765229 539.7 ns/op 5790.73 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4721559 758.4 ns/op 8171.64 MB/s Benchmark____GWs_Int_2kx01x1-16 4896709 740.0 ns/op 8374.59 MB/s Benchmark____GWs_Int_2kx01x1-16 4814199 739.7 ns/op 8378.16 MB/s Benchmark____GWs_Int_2kx01x1-16 4753947 741.1 ns/op 8362.25 MB/s Benchmark____GWs_Int_2kx01x1-16 4333226 748.4 ns/op 8280.30 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2733026 1348 ns/op 9157.30 MB/s Benchmark____GWs_Int_4kx01x1-16 2268720 1495 ns/op 8254.40 MB/s Benchmark____GWs_Int_4kx01x1-16 2324526 1342 ns/op 9198.20 MB/s Benchmark____GWs_Int_4kx01x1-16 2636329 1355 ns/op 9104.85 MB/s Benchmark____GWs_Int_4kx01x1-16 2330175 1344 ns/op 9184.61 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6839625 526.1 ns/op 5940.01 MB/s Benchmark____GWs_Int_1kx10x1-16 6410934 570.0 ns/op 5482.49 MB/s Benchmark____GWs_Int_1kx10x1-16 6662452 536.9 ns/op 5820.63 MB/s Benchmark____GWs_Int_1kx10x1-16 6833419 543.0 ns/op 5755.40 MB/s Benchmark____GWs_Int_1kx10x1-16 6708664 545.6 ns/op 5727.95 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4278157 864.6 ns/op 7167.56 MB/s Benchmark____GWs_Int_2kx10x1-16 4156168 823.8 ns/op 7522.68 MB/s Benchmark____GWs_Int_2kx10x1-16 4113792 845.2 ns/op 7332.22 MB/s Benchmark____GWs_Int_2kx10x1-16 4531791 852.4 ns/op 7269.67 MB/s Benchmark____GWs_Int_2kx10x1-16 4112664 813.8 ns/op 7614.51 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2342558 1495 ns/op 8256.94 MB/s Benchmark____GWs_Int_4kx10x1-16 2172562 1561 ns/op 7905.66 MB/s Benchmark____GWs_Int_4kx10x1-16 2359017 1716 ns/op 7190.24 MB/s Benchmark____GWs_Int_4kx10x1-16 2522476 1495 ns/op 8256.82 MB/s Benchmark____GWs_Int_4kx10x1-16 2379843 1524 ns/op 8097.59 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8730804 423.0 ns/op 241.13 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8785773 425.2 ns/op 239.91 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8640102 422.0 ns/op 241.73 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8950340 424.1 ns/op 240.54 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8664091 428.4 ns/op 238.08 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 768154 4873 ns/op 36.32 MB/s Benchmark__GWs_Reqs_1SubEach-16 845038 4914 ns/op 36.02 MB/s Benchmark__GWs_Reqs_1SubEach-16 796879 4868 ns/op 36.36 MB/s Benchmark__GWs_Reqs_1SubEach-16 782701 4977 ns/op 35.56 MB/s Benchmark__GWs_Reqs_1SubEach-16 779958 4941 ns/op 35.82 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2131.665s