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 49928869 78.24 ns/op 140.60 MB/s Benchmark______Pub0b_Payload-16 47360244 71.81 ns/op 153.18 MB/s Benchmark______Pub0b_Payload-16 47311328 78.49 ns/op 140.14 MB/s Benchmark______Pub0b_Payload-16 44164129 71.95 ns/op 152.87 MB/s Benchmark______Pub0b_Payload-16 43780689 71.81 ns/op 153.19 MB/s Benchmark______Pub8b_Payload Benchmark______Pub8b_Payload-16 46878165 72.59 ns/op 261.73 MB/s Benchmark______Pub8b_Payload-16 43559600 72.56 ns/op 261.87 MB/s Benchmark______Pub8b_Payload-16 43501627 72.56 ns/op 261.84 MB/s Benchmark______Pub8b_Payload-16 46769074 72.44 ns/op 262.29 MB/s Benchmark______Pub8b_Payload-16 46774645 72.79 ns/op 261.04 MB/s Benchmark_____Pub32b_Payload Benchmark_____Pub32b_Payload-16 44069026 76.38 ns/op 576.07 MB/s Benchmark_____Pub32b_Payload-16 43114191 76.47 ns/op 575.40 MB/s Benchmark_____Pub32b_Payload-16 43781826 77.07 ns/op 570.89 MB/s Benchmark_____Pub32b_Payload-16 44640238 76.53 ns/op 574.94 MB/s Benchmark_____Pub32b_Payload-16 44373843 78.13 ns/op 563.15 MB/s Benchmark____Pub128B_Payload Benchmark____Pub128B_Payload-16 41418028 85.77 ns/op 1644.01 MB/s Benchmark____Pub128B_Payload-16 35123784 86.10 ns/op 1637.67 MB/s Benchmark____Pub128B_Payload-16 42293228 87.14 ns/op 1618.16 MB/s Benchmark____Pub128B_Payload-16 42079912 87.41 ns/op 1613.13 MB/s Benchmark____Pub128B_Payload-16 39833427 85.53 ns/op 1648.59 MB/s Benchmark____Pub256B_Payload Benchmark____Pub256B_Payload-16 36289158 95.00 ns/op 2831.67 MB/s Benchmark____Pub256B_Payload-16 36240951 94.95 ns/op 2833.16 MB/s Benchmark____Pub256B_Payload-16 38559340 99.72 ns/op 2697.43 MB/s Benchmark____Pub256B_Payload-16 32838664 91.90 ns/op 2927.03 MB/s Benchmark____Pub256B_Payload-16 36007664 95.47 ns/op 2817.75 MB/s Benchmark______Pub1K_Payload Benchmark______Pub1K_Payload-16 22738596 138.8 ns/op 7478.73 MB/s Benchmark______Pub1K_Payload-16 24227931 147.7 ns/op 7028.27 MB/s Benchmark______Pub1K_Payload-16 24277701 138.8 ns/op 7478.14 MB/s Benchmark______Pub1K_Payload-16 26483667 138.6 ns/op 7489.32 MB/s Benchmark______Pub1K_Payload-16 22748538 137.9 ns/op 7526.95 MB/s Benchmark______Pub4K_Payload Benchmark______Pub4K_Payload-16 5582139 619.1 ns/op 6638.47 MB/s Benchmark______Pub4K_Payload-16 5651800 624.4 ns/op 6582.44 MB/s Benchmark______Pub4K_Payload-16 5787154 622.5 ns/op 6602.80 MB/s Benchmark______Pub4K_Payload-16 5262094 626.0 ns/op 6565.75 MB/s Benchmark______Pub4K_Payload-16 5743465 622.1 ns/op 6607.02 MB/s Benchmark______Pub8K_Payload Benchmark______Pub8K_Payload-16 2822283 1266 ns/op 6481.50 MB/s Benchmark______Pub8K_Payload-16 2710618 1285 ns/op 6385.82 MB/s Benchmark______Pub8K_Payload-16 2725945 1273 ns/op 6448.50 MB/s Benchmark______Pub8K_Payload-16 2737802 1273 ns/op 6444.99 MB/s Benchmark______Pub8K_Payload-16 2724681 1281 ns/op 6406.93 MB/s Benchmark_____Pub32K_Payload Benchmark_____Pub32K_Payload-16 671524 5331 ns/op 6149.92 MB/s Benchmark_____Pub32K_Payload-16 659306 5280 ns/op 6208.71 MB/s Benchmark_____Pub32K_Payload-16 650368 5477 ns/op 5985.05 MB/s Benchmark_____Pub32K_Payload-16 661956 5505 ns/op 5955.07 MB/s Benchmark_____Pub32K_Payload-16 579157 5589 ns/op 5865.74 MB/s Benchmark__AuthPub0b_Payload Benchmark__AuthPub0b_Payload-16 32837167 92.89 ns/op 118.42 MB/s Benchmark__AuthPub0b_Payload-16 38954377 93.79 ns/op 117.28 MB/s Benchmark__AuthPub0b_Payload-16 37005806 91.83 ns/op 119.79 MB/s Benchmark__AuthPub0b_Payload-16 37086756 91.84 ns/op 119.77 MB/s Benchmark__AuthPub0b_Payload-16 36305839 92.43 ns/op 119.00 MB/s Benchmark_____________PubSub Benchmark_____________PubSub-16 15581409 227.9 ns/op Benchmark_____________PubSub-16 15743870 230.0 ns/op Benchmark_____________PubSub-16 15624369 227.1 ns/op Benchmark_____________PubSub-16 15513795 227.1 ns/op Benchmark_____________PubSub-16 15502398 228.2 ns/op Benchmark_____PubSubTwoConns Benchmark_____PubSubTwoConns-16 15512178 226.2 ns/op Benchmark_____PubSubTwoConns-16 15818642 225.4 ns/op Benchmark_____PubSubTwoConns-16 15670231 225.8 ns/op Benchmark_____PubSubTwoConns-16 15687841 228.6 ns/op Benchmark_____PubSubTwoConns-16 15546736 225.1 ns/op Benchmark__PubServiceImports bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:32868->127.0.0.1:38697: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:42858->127.0.0.1:34219: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:55094->127.0.0.1:33135: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:56570->127.0.0.1:37399: write: connection reset by peer --- FAIL: Benchmark__PubServiceImports-16 bench_test.go:351: Received error on FLUSH write: write tcp 127.0.0.1:45172->127.0.0.1:42115: 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 14423136 246.6 ns/op Benchmark_____PubTwoQueueSub-16 14058390 246.1 ns/op Benchmark_____PubTwoQueueSub-16 14377880 245.9 ns/op Benchmark_____PubTwoQueueSub-16 14480206 245.9 ns/op Benchmark_____PubTwoQueueSub-16 14402490 247.0 ns/op Benchmark____PubFourQueueSub Benchmark____PubFourQueueSub-16 14467158 246.4 ns/op Benchmark____PubFourQueueSub-16 14422065 246.8 ns/op Benchmark____PubFourQueueSub-16 14298573 246.5 ns/op Benchmark____PubFourQueueSub-16 14248371 246.5 ns/op Benchmark____PubFourQueueSub-16 14291624 249.1 ns/op Benchmark___PubEightQueueSub Benchmark___PubEightQueueSub-16 14430436 247.4 ns/op Benchmark___PubEightQueueSub-16 14196942 246.5 ns/op Benchmark___PubEightQueueSub-16 14376853 244.6 ns/op Benchmark___PubEightQueueSub-16 14500518 246.4 ns/op Benchmark___PubEightQueueSub-16 14515650 246.7 ns/op Benchmark_PubSub512kTwoConns Benchmark_PubSub512kTwoConns-16 23078 155744 ns/op Benchmark_PubSub512kTwoConns-16 21631 156595 ns/op Benchmark_PubSub512kTwoConns-16 23103 156094 ns/op Benchmark_PubSub512kTwoConns-16 23070 157112 ns/op Benchmark_PubSub512kTwoConns-16 22473 157185 ns/op Benchmark__DenyMsgNoWCPubSub Benchmark__DenyMsgNoWCPubSub-16 15234618 229.4 ns/op Benchmark__DenyMsgNoWCPubSub-16 15246104 230.1 ns/op Benchmark__DenyMsgNoWCPubSub-16 15124771 229.9 ns/op Benchmark__DenyMsgNoWCPubSub-16 15142652 231.0 ns/op Benchmark__DenyMsgNoWCPubSub-16 15026788 229.9 ns/op Benchmark_DenyMsgYesWCPubSub Benchmark_DenyMsgYesWCPubSub-16 15225618 229.8 ns/op Benchmark_DenyMsgYesWCPubSub-16 15177936 231.0 ns/op Benchmark_DenyMsgYesWCPubSub-16 15166412 231.4 ns/op Benchmark_DenyMsgYesWCPubSub-16 14984557 229.6 ns/op Benchmark_DenyMsgYesWCPubSub-16 15056842 230.3 ns/op Benchmark____RoutedPubSub_0b Benchmark____RoutedPubSub_0b-16 11415116 316.6 ns/op Benchmark____RoutedPubSub_0b-16 11087944 315.4 ns/op Benchmark____RoutedPubSub_0b-16 11300470 316.2 ns/op Benchmark____RoutedPubSub_0b-16 11500736 320.2 ns/op Benchmark____RoutedPubSub_0b-16 11049507 320.6 ns/op Benchmark____RoutedPubSub_1K Benchmark____RoutedPubSub_1K-16 6692290 539.6 ns/op Benchmark____RoutedPubSub_1K-16 6481122 610.2 ns/op Benchmark____RoutedPubSub_1K-16 6614361 535.9 ns/op Benchmark____RoutedPubSub_1K-16 6679551 536.7 ns/op Benchmark____RoutedPubSub_1K-16 6602360 604.0 ns/op Benchmark__RoutedPubSub_100K Benchmark__RoutedPubSub_100K-16 85779 42282 ns/op Benchmark__RoutedPubSub_100K-16 84416 41650 ns/op Benchmark__RoutedPubSub_100K-16 85191 40872 ns/op Benchmark__RoutedPubSub_100K-16 82384 41359 ns/op Benchmark__RoutedPubSub_100K-16 85956 41619 ns/op Benchmark____Routed2QueueSub Benchmark____Routed2QueueSub-16 9502357 321.1 ns/op Benchmark____Routed2QueueSub-16 9731316 322.3 ns/op Benchmark____Routed2QueueSub-16 9556508 330.8 ns/op Benchmark____Routed2QueueSub-16 9766312 331.0 ns/op Benchmark____Routed2QueueSub-16 9586315 334.7 ns/op Benchmark____Routed4QueueSub Benchmark____Routed4QueueSub-16 9199518 332.3 ns/op Benchmark____Routed4QueueSub-16 9564388 321.6 ns/op Benchmark____Routed4QueueSub-16 9530017 320.7 ns/op Benchmark____Routed4QueueSub-16 9717097 322.2 ns/op Benchmark____Routed4QueueSub-16 9594075 332.1 ns/op Benchmark____Routed8QueueSub Benchmark____Routed8QueueSub-16 9336543 329.6 ns/op Benchmark____Routed8QueueSub-16 9169776 328.7 ns/op Benchmark____Routed8QueueSub-16 9097970 332.2 ns/op Benchmark____Routed8QueueSub-16 9264542 335.5 ns/op Benchmark____Routed8QueueSub-16 10886170 328.9 ns/op Benchmark___Routed16QueueSub Benchmark___Routed16QueueSub-16 8966192 338.3 ns/op Benchmark___Routed16QueueSub-16 8981616 348.1 ns/op Benchmark___Routed16QueueSub-16 8803374 350.6 ns/op Benchmark___Routed16QueueSub-16 8907578 345.8 ns/op Benchmark___Routed16QueueSub-16 10206676 348.2 ns/op Benchmark____________RouteCompressOff Benchmark____________RouteCompressOff-16 6357115 556.6 ns/op Benchmark____________RouteCompressOff-16 6429133 554.9 ns/op Benchmark____________RouteCompressOff-16 6546724 554.5 ns/op Benchmark____________RouteCompressOff-16 6397135 553.0 ns/op Benchmark____________RouteCompressOff-16 6310047 554.7 ns/op Benchmark_RouteCompressS2Uncompressed Benchmark_RouteCompressS2Uncompressed-16 6290497 554.2 ns/op Benchmark_RouteCompressS2Uncompressed-16 6331864 558.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6300260 547.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6363993 556.5 ns/op Benchmark_RouteCompressS2Uncompressed-16 6326898 555.0 ns/op Benchmark_________RouteCompressS2Fast Benchmark_________RouteCompressS2Fast-16 6395076 557.3 ns/op Benchmark_________RouteCompressS2Fast-16 6382900 556.9 ns/op Benchmark_________RouteCompressS2Fast-16 6241449 551.6 ns/op Benchmark_________RouteCompressS2Fast-16 6496941 557.2 ns/op Benchmark_________RouteCompressS2Fast-16 6340486 560.6 ns/op Benchmark_______RouteCompressS2Better Benchmark_______RouteCompressS2Better-16 6211968 553.7 ns/op Benchmark_______RouteCompressS2Better-16 6352903 554.3 ns/op Benchmark_______RouteCompressS2Better-16 6423285 559.8 ns/op Benchmark_______RouteCompressS2Better-16 6561494 551.9 ns/op Benchmark_______RouteCompressS2Better-16 6357465 553.6 ns/op Benchmark_________RouteCompressS2Best Benchmark_________RouteCompressS2Best-16 6275106 554.9 ns/op Benchmark_________RouteCompressS2Best-16 6413480 553.1 ns/op Benchmark_________RouteCompressS2Best-16 6359721 556.9 ns/op Benchmark_________RouteCompressS2Best-16 6392796 549.6 ns/op Benchmark_________RouteCompressS2Best-16 6482292 553.2 ns/op Benchmark______FanOut_8x1x10 Benchmark______FanOut_8x1x10-16 4614276 779.6 ns/op 319.38 MB/s Benchmark______FanOut_8x1x10-16 4604313 774.5 ns/op 321.48 MB/s Benchmark______FanOut_8x1x10-16 4606309 772.5 ns/op 322.34 MB/s Benchmark______FanOut_8x1x10-16 4589652 779.7 ns/op 319.35 MB/s Benchmark______FanOut_8x1x10-16 4616349 774.1 ns/op 321.65 MB/s Benchmark_____FanOut_8x1x100 Benchmark_____FanOut_8x1x100-16 528868 6225 ns/op 372.55 MB/s Benchmark_____FanOut_8x1x100-16 533462 6237 ns/op 371.81 MB/s Benchmark_____FanOut_8x1x100-16 538736 6182 ns/op 375.15 MB/s Benchmark_____FanOut_8x1x100-16 533737 6191 ns/op 374.58 MB/s Benchmark_____FanOut_8x1x100-16 550825 6166 ns/op 376.08 MB/s Benchmark____FanOut_8x10x100 Benchmark____FanOut_8x10x100-16 46486 77241 ns/op 298.01 MB/s Benchmark____FanOut_8x10x100-16 46246 77440 ns/op 297.25 MB/s Benchmark____FanOut_8x10x100-16 46410 77800 ns/op 295.87 MB/s Benchmark____FanOut_8x10x100-16 46281 77194 ns/op 298.20 MB/s Benchmark____FanOut_8x10x100-16 46684 77446 ns/op 297.23 MB/s Benchmark___FanOut_8x10x1000 Benchmark___FanOut_8x10x1000-16 5667 631363 ns/op 380.16 MB/s Benchmark___FanOut_8x10x1000-16 5571 625857 ns/op 383.50 MB/s Benchmark___FanOut_8x10x1000-16 5569 620276 ns/op 386.96 MB/s Benchmark___FanOut_8x10x1000-16 5792 625361 ns/op 383.81 MB/s Benchmark___FanOut_8x10x1000-16 5713 624514 ns/op 384.33 MB/s Benchmark___FanOut_8x100x100 Benchmark___FanOut_8x100x100-16 4879 728863 ns/op 315.59 MB/s Benchmark___FanOut_8x100x100-16 4794 734634 ns/op 313.11 MB/s Benchmark___FanOut_8x100x100-16 4848 734490 ns/op 313.17 MB/s Benchmark___FanOut_8x100x100-16 4766 733512 ns/op 313.59 MB/s Benchmark___FanOut_8x100x100-16 4846 732154 ns/op 314.17 MB/s Benchmark__FanOut_8x100x1000 Benchmark__FanOut_8x100x1000-16 541 6481325 ns/op 370.30 MB/s Benchmark__FanOut_8x100x1000-16 546 6445137 ns/op 372.38 MB/s Benchmark__FanOut_8x100x1000-16 538 6438575 ns/op 372.76 MB/s Benchmark__FanOut_8x100x1000-16 525 6624015 ns/op 362.32 MB/s Benchmark__FanOut_8x100x1000-16 544 6613597 ns/op 362.89 MB/s Benchmark__FanOut_8x10x10000 Benchmark__FanOut_8x10x10000-16 520 6916036 ns/op 361.48 MB/s Benchmark__FanOut_8x10x10000-16 510 7023451 ns/op 355.95 MB/s Benchmark__FanOut_8x10x10000-16 514 6936559 ns/op 360.41 MB/s Benchmark__FanOut_8x10x10000-16 516 7054620 ns/op 354.38 MB/s Benchmark__FanOut_8x10x10000-16 522 6973447 ns/op 358.51 MB/s Benchmark___FanOut_8x500x100 Benchmark___FanOut_8x500x100-16 922 3870490 ns/op 297.12 MB/s Benchmark___FanOut_8x500x100-16 912 3889073 ns/op 295.71 MB/s Benchmark___FanOut_8x500x100-16 930 3902749 ns/op 294.67 MB/s Benchmark___FanOut_8x500x100-16 910 3922029 ns/op 293.22 MB/s Benchmark___FanOut_8x500x100-16 918 3860263 ns/op 297.91 MB/s Benchmark___FanOut_128x1x100 Benchmark___FanOut_128x1x100-16 349435 9569 ns/op 1530.06 MB/s Benchmark___FanOut_128x1x100-16 357232 9649 ns/op 1517.36 MB/s Benchmark___FanOut_128x1x100-16 355922 9705 ns/op 1508.59 MB/s Benchmark___FanOut_128x1x100-16 358384 9600 ns/op 1525.05 MB/s Benchmark___FanOut_128x1x100-16 369199 9641 ns/op 1518.57 MB/s Benchmark__FanOut_128x10x100 Benchmark__FanOut_128x10x100-16 31714 113194 ns/op 1282.23 MB/s Benchmark__FanOut_128x10x100-16 31791 113016 ns/op 1284.26 MB/s Benchmark__FanOut_128x10x100-16 31851 114096 ns/op 1272.09 MB/s Benchmark__FanOut_128x10x100-16 31556 113353 ns/op 1280.43 MB/s Benchmark__FanOut_128x10x100-16 31640 112916 ns/op 1285.39 MB/s Benchmark_FanOut_128x10x1000 Benchmark_FanOut_128x10x1000-16 3776 898618 ns/op 1624.87 MB/s Benchmark_FanOut_128x10x1000-16 3928 898480 ns/op 1625.12 MB/s Benchmark_FanOut_128x10x1000-16 3848 907650 ns/op 1608.70 MB/s Benchmark_FanOut_128x10x1000-16 3832 898710 ns/op 1624.71 MB/s Benchmark_FanOut_128x10x1000-16 3938 900367 ns/op 1621.72 MB/s Benchmark_FanOut_128x100x100 Benchmark_FanOut_128x100x100-16 3406 1031501 ns/op 1405.86 MB/s Benchmark_FanOut_128x100x100-16 3336 1032835 ns/op 1404.04 MB/s Benchmark_FanOut_128x100x100-16 3382 1028615 ns/op 1409.80 MB/s Benchmark_FanOut_128x100x100-16 3381 1029449 ns/op 1408.66 MB/s Benchmark_FanOut_128x100x100-16 3412 1030633 ns/op 1407.04 MB/s BenchmarkFanOut_128x100x1000 BenchmarkFanOut_128x100x1000-16 363 9487918 ns/op 1538.81 MB/s BenchmarkFanOut_128x100x1000-16 373 9562653 ns/op 1526.79 MB/s BenchmarkFanOut_128x100x1000-16 368 9534801 ns/op 1531.25 MB/s BenchmarkFanOut_128x100x1000-16 369 9568554 ns/op 1525.85 MB/s BenchmarkFanOut_128x100x1000-16 375 9600555 ns/op 1520.76 MB/s BenchmarkFanOut_128x10x10000 BenchmarkFanOut_128x10x10000-16 366 9888937 ns/op 1486.52 MB/s BenchmarkFanOut_128x10x10000-16 363 9905761 ns/op 1484.00 MB/s BenchmarkFanOut_128x10x10000-16 364 9857857 ns/op 1491.21 MB/s BenchmarkFanOut_128x10x10000-16 364 9841831 ns/op 1493.64 MB/s BenchmarkFanOut_128x10x10000-16 367 9888326 ns/op 1486.62 MB/s BenchmarkFanOut__128x500x100 BenchmarkFanOut__128x500x100-16 656 5434145 ns/op 1334.18 MB/s BenchmarkFanOut__128x500x100-16 655 5400669 ns/op 1342.45 MB/s BenchmarkFanOut__128x500x100-16 657 5452336 ns/op 1329.73 MB/s BenchmarkFanOut__128x500x100-16 657 5411627 ns/op 1339.73 MB/s BenchmarkFanOut__128x500x100-16 660 5417281 ns/op 1338.34 MB/s Benchmark_FanOut_512x100x100 Benchmark_FanOut_512x100x100-16 1916 1878546 ns/op 2816.29 MB/s Benchmark_FanOut_512x100x100-16 1857 1857130 ns/op 2848.76 MB/s Benchmark_FanOut_512x100x100-16 1916 1855600 ns/op 2851.11 MB/s Benchmark_FanOut_512x100x100-16 1887 1852857 ns/op 2855.33 MB/s Benchmark_FanOut_512x100x100-16 1916 1855646 ns/op 2851.04 MB/s Benchmark__FanOut_512x100x1k Benchmark__FanOut_512x100x1k-16 213 16915245 ns/op 3133.30 MB/s Benchmark__FanOut_512x100x1k-16 210 17086706 ns/op 3101.86 MB/s Benchmark__FanOut_512x100x1k-16 208 17040869 ns/op 3110.20 MB/s Benchmark__FanOut_512x100x1k-16 212 17032173 ns/op 3111.79 MB/s Benchmark__FanOut_512x100x1k-16 212 17130813 ns/op 3093.87 MB/s Benchmark____FanOut_1kx10x1k Benchmark____FanOut_1kx10x1k-16 3176 1168648 ns/op 8925.73 MB/s Benchmark____FanOut_1kx10x1k-16 2661 1172501 ns/op 8896.40 MB/s Benchmark____FanOut_1kx10x1k-16 2846 1149026 ns/op 9078.16 MB/s Benchmark____FanOut_1kx10x1k-16 3204 1142559 ns/op 9129.54 MB/s Benchmark____FanOut_1kx10x1k-16 3068 1152161 ns/op 9053.46 MB/s Benchmark__FanOut_1kx100x100 Benchmark__FanOut_1kx100x100-16 2774 1267595 ns/op 8221.11 MB/s Benchmark__FanOut_1kx100x100-16 2712 1270918 ns/op 8199.62 MB/s Benchmark__FanOut_1kx100x100-16 2744 1272847 ns/op 8187.19 MB/s Benchmark__FanOut_1kx100x100-16 2742 1273006 ns/op 8186.16 MB/s Benchmark__FanOut_1kx100x100-16 2707 1278601 ns/op 8150.34 MB/s Benchmark_____RFanOut_8x1x10 Benchmark_____RFanOut_8x1x10-16 4470012 792.4 ns/op 314.22 MB/s Benchmark_____RFanOut_8x1x10-16 4420420 794.2 ns/op 313.52 MB/s Benchmark_____RFanOut_8x1x10-16 4416762 788.6 ns/op 315.75 MB/s Benchmark_____RFanOut_8x1x10-16 4520342 818.9 ns/op 304.06 MB/s Benchmark_____RFanOut_8x1x10-16 4386349 787.6 ns/op 316.16 MB/s Benchmark____RFanOut_8x1x100 Benchmark____RFanOut_8x1x100-16 525685 6237 ns/op 371.82 MB/s Benchmark____RFanOut_8x1x100-16 557782 6310 ns/op 367.54 MB/s Benchmark____RFanOut_8x1x100-16 515864 6274 ns/op 369.61 MB/s Benchmark____RFanOut_8x1x100-16 552244 6275 ns/op 369.58 MB/s Benchmark____RFanOut_8x1x100-16 530568 6255 ns/op 370.72 MB/s Benchmark___RFanOut_8x10x100 Benchmark___RFanOut_8x10x100-16 46740 76432 ns/op 301.17 MB/s Benchmark___RFanOut_8x10x100-16 46384 76532 ns/op 300.78 MB/s Benchmark___RFanOut_8x10x100-16 46011 77776 ns/op 295.97 MB/s Benchmark___RFanOut_8x10x100-16 46816 76819 ns/op 299.65 MB/s Benchmark___RFanOut_8x10x100-16 46336 76888 ns/op 299.38 MB/s Benchmark__RFanOut_8x10x1000 Benchmark__RFanOut_8x10x1000-16 5629 632707 ns/op 379.35 MB/s Benchmark__RFanOut_8x10x1000-16 5618 637062 ns/op 376.76 MB/s Benchmark__RFanOut_8x10x1000-16 5380 643312 ns/op 373.10 MB/s Benchmark__RFanOut_8x10x1000-16 5619 628224 ns/op 382.06 MB/s Benchmark__RFanOut_8x10x1000-16 5732 626656 ns/op 383.02 MB/s Benchmark__RFanOut_8x100x100 Benchmark__RFanOut_8x100x100-16 4773 729327 ns/op 315.39 MB/s Benchmark__RFanOut_8x100x100-16 4870 727515 ns/op 316.17 MB/s Benchmark__RFanOut_8x100x100-16 4818 730428 ns/op 314.91 MB/s Benchmark__RFanOut_8x100x100-16 4788 731070 ns/op 314.63 MB/s Benchmark__RFanOut_8x100x100-16 4852 738808 ns/op 311.34 MB/s Benchmark_RFanOut_8x100x1000 Benchmark_RFanOut_8x100x1000-16 536 6919656 ns/op 346.84 MB/s Benchmark_RFanOut_8x100x1000-16 549 6485568 ns/op 370.06 MB/s Benchmark_RFanOut_8x100x1000-16 542 6525230 ns/op 367.81 MB/s Benchmark_RFanOut_8x100x1000-16 541 6649195 ns/op 360.95 MB/s Benchmark_RFanOut_8x100x1000-16 530 6638454 ns/op 361.53 MB/s Benchmark_RFanOut_8x10x10000 Benchmark_RFanOut_8x10x10000-16 500 6951619 ns/op 359.63 MB/s Benchmark_RFanOut_8x10x10000-16 516 7017520 ns/op 356.25 MB/s Benchmark_RFanOut_8x10x10000-16 506 6994041 ns/op 357.45 MB/s Benchmark_RFanOut_8x10x10000-16 498 7089067 ns/op 352.66 MB/s Benchmark_RFanOut_8x10x10000-16 504 6926167 ns/op 360.95 MB/s Benchmark_RFanOut_1kx10x1000 Benchmark_RFanOut_1kx10x1000-16 3172 1171185 ns/op 8906.39 MB/s Benchmark_RFanOut_1kx10x1000-16 2824 1166371 ns/op 8943.16 MB/s Benchmark_RFanOut_1kx10x1000-16 2934 1146756 ns/op 9096.13 MB/s Benchmark_RFanOut_1kx10x1000-16 3054 1190795 ns/op 8759.72 MB/s Benchmark_RFanOut_1kx10x1000-16 2880 1156208 ns/op 9021.77 MB/s Benchmark_____FanIn_1kx100x1 Benchmark_____FanIn_1kx100x1-16 6982119 504.7 ns/op 4117.50 MB/s Benchmark_____FanIn_1kx100x1-16 6816140 507.7 ns/op 4092.63 MB/s Benchmark_____FanIn_1kx100x1-16 6927798 507.2 ns/op 4096.70 MB/s Benchmark_____FanIn_1kx100x1-16 6952726 505.6 ns/op 4109.90 MB/s Benchmark_____FanIn_1kx100x1-16 6878811 505.5 ns/op 4110.74 MB/s Benchmark_____FanIn_4kx100x1 Benchmark_____FanIn_4kx100x1-16 2607440 1378 ns/op 5965.51 MB/s Benchmark_____FanIn_4kx100x1-16 2619002 1374 ns/op 5985.12 MB/s Benchmark_____FanIn_4kx100x1-16 2608686 1360 ns/op 6044.75 MB/s Benchmark_____FanIn_4kx100x1-16 2568500 1361 ns/op 6039.88 MB/s Benchmark_____FanIn_4kx100x1-16 2556099 1350 ns/op 6089.20 MB/s Benchmark_____FanIn_8kx100x1 Benchmark_____FanIn_8kx100x1-16 1688986 2156 ns/op 7612.58 MB/s Benchmark_____FanIn_8kx100x1-16 1720033 2110 ns/op 7780.68 MB/s Benchmark_____FanIn_8kx100x1-16 1700703 2108 ns/op 7786.56 MB/s Benchmark_____FanIn_8kx100x1-16 1715772 2130 ns/op 7707.49 MB/s Benchmark_____FanIn_8kx100x1-16 1726251 2119 ns/op 7747.11 MB/s Benchmark____FanIn_16kx100x1 Benchmark____FanIn_16kx100x1-16 880563 4130 ns/op 7940.96 MB/s Benchmark____FanIn_16kx100x1-16 861837 4132 ns/op 7937.32 MB/s Benchmark____FanIn_16kx100x1-16 863781 4196 ns/op 7817.19 MB/s Benchmark____FanIn_16kx100x1-16 867124 4147 ns/op 7909.25 MB/s Benchmark____FanIn_16kx100x1-16 863830 4199 ns/op 7811.78 MB/s Benchmark____FanIn_64kx100x1 Benchmark____FanIn_64kx100x1-16 171740 19892 ns/op 6590.75 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 284893338 vs 655530000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:53982->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54622->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54094->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54078->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54700->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54028->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark____FanIn_64kx100x1-16 Benchmark____FanIn_64kx100x1-16 165204 19789 ns/op 6625.10 MB/s Benchmark____FanIn_64kx100x1-16 173008 19951 ns/op 6571.39 MB/s Benchmark____FanIn_64kx100x1-16 170172 19967 ns/op 6565.93 MB/s Benchmark___FanIn_128kx100x1 bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 382127350 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55108->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55390->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54660->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54902->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54756->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55418->127.0.0.1:5222: write: broken pipe bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54876->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55274->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54746->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55328->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55458->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55256->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54794->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55036->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55268->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54788->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54934->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55204->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54806->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54732->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55348->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54970->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54656->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55510->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55336->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55280->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55168->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55446->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55538->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55416->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55480->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54910->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54986->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55080->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55180->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55006->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55488->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54666->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55472->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:55546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:54706->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: 367445270 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56698->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56520->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56540->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56552->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56936->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57332->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56570->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57156->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57234->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56672->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56662->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57026->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56584->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57218->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56914->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57112->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56668->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56608->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56870->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56490->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57272->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57088->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57362->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56840->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56860->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56686->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56802->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57220->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57142->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57030->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57176->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56768->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56978->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57154->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56754->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57386->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56632->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56926->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57046->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57162->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56998->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57278->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57344->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57290->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56850->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56812->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56972->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57270->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57246->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56504->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57358->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:57304->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57372->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57198->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57192->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56566->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56826->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57316->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56646->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57200->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:56526->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:57078->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: 338736560 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58814->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58614->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58988->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58944->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58966->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58522->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58610->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58324->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58444->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58562->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58690->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58390->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58748->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58436->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59040->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58658->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59076->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58930->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59130->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58358->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58628->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58546->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58790->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58890->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58404->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58424->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58900->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58994->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58734->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58886->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58992->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58456->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58594->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58872->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58864->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59068->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58534->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58612->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58350->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58718->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58476->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58408->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58848->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58502->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58422->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58976->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58804->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59166->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58750->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59086->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58506->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58374->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58318->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58818->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58736->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58722->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59014->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58302->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59004->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58488->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59102->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59028->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58410->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59062->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58908->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58682->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58726->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59056->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58774->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:59136->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:58854->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: 615991910 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60146->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60792->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60242->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60150->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60400->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60062->127.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: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:60798->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60776->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:60516->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60764->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60878->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60828->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60288->127.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:60216->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60206->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60174->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60574->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60250->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60254->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60428->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60306->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60228->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60638->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60464->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60402->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60582->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60132->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60716->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60888->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60652->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60298->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60730->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60340->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60494->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60190->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60432->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60842->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:60852->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:60742->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60608->127.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:60096->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60710->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60844->127.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:60322->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60260->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60778->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1: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:60126->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:60684->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: 269521040 vs 1310900000 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33874->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34090->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33550->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34376->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34024->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34338->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33670->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34052->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33916->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33858->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34072->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33946->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34042->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33620->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33692->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33648->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33580->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33810->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34010->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33852->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33644->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33600->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34122->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33728->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34284->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34378->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34262->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33694->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34360->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34032->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33956->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33636->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34164->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33578->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33542->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33740->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34202->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34158->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34212->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34128->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33604->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33980->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34230->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34312->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34226->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34020->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34392->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33702->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33616->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34170->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33984->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33712->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33654->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33560->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33844->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34116->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33564->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34364->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34346->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33968->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34000->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33834->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34082->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34050->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34276->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33744->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33758->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34152->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34236->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34002->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33592->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34092->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34326->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34194->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33800->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34296->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34232->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33532->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34342->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33528->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34138->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34384->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34104->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33786->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33782->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33906->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34178->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33890->127.0.0.1:5222: write: connection reset by peer --- FAIL: Benchmark___FanIn_128kx100x1-16 Benchmark___BumpPubCount_1x3 bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33766->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34252->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33824->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33706->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34064->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33932->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33942->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34124->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33676->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33680->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:33572->127.0.0.1:5222: write: connection reset by peer bench_test.go:1096: Received error on PUB write: write tcp 127.0.0.1:34380->127.0.0.1:5222: write: connection reset by peer Benchmark___BumpPubCount_1x3-16 5530250 646.3 ns/op 439.41 MB/s Benchmark___BumpPubCount_1x3-16 5504932 655.4 ns/op 433.34 MB/s Benchmark___BumpPubCount_1x3-16 5537463 647.6 ns/op 438.55 MB/s Benchmark___BumpPubCount_1x3-16 5574572 648.7 ns/op 437.83 MB/s Benchmark___BumpPubCount_1x3-16 5480599 648.4 ns/op 438.01 MB/s Benchmark___BumpPubCount_2x3 Benchmark___BumpPubCount_2x3-16 5295129 685.5 ns/op 414.28 MB/s Benchmark___BumpPubCount_2x3-16 5260945 674.0 ns/op 421.35 MB/s Benchmark___BumpPubCount_2x3-16 5265519 680.3 ns/op 417.46 MB/s Benchmark___BumpPubCount_2x3-16 5223542 683.3 ns/op 415.61 MB/s Benchmark___BumpPubCount_2x3-16 5245464 673.9 ns/op 421.46 MB/s Benchmark___BumpPubCount_5x3 Benchmark___BumpPubCount_5x3-16 5385445 649.8 ns/op 437.04 MB/s Benchmark___BumpPubCount_5x3-16 5487000 647.3 ns/op 438.75 MB/s Benchmark___BumpPubCount_5x3-16 5403861 651.7 ns/op 435.77 MB/s Benchmark___BumpPubCount_5x3-16 5521598 649.2 ns/op 437.44 MB/s Benchmark___BumpPubCount_5x3-16 5155209 646.6 ns/op 439.25 MB/s Benchmark__BumpPubCount_10x3 Benchmark__BumpPubCount_10x3-16 5098437 648.1 ns/op 438.18 MB/s Benchmark__BumpPubCount_10x3-16 5513788 648.0 ns/op 438.28 MB/s Benchmark__BumpPubCount_10x3-16 5527962 650.3 ns/op 436.73 MB/s Benchmark__BumpPubCount_10x3-16 5542590 645.8 ns/op 439.74 MB/s Benchmark__BumpPubCount_10x3-16 5554200 644.9 ns/op 440.37 MB/s Benchmark____GWs_Opt_1kx01x0 Benchmark____GWs_Opt_1kx01x0-16 12263817 271.1 ns/op 3836.22 MB/s Benchmark____GWs_Opt_1kx01x0-16 12501288 278.4 ns/op 3734.99 MB/s Benchmark____GWs_Opt_1kx01x0-16 13486894 283.5 ns/op 3668.89 MB/s Benchmark____GWs_Opt_1kx01x0-16 12930152 264.3 ns/op 3934.41 MB/s Benchmark____GWs_Opt_1kx01x0-16 12495482 272.6 ns/op 3814.45 MB/s Benchmark____GWs_Opt_2kx01x0 Benchmark____GWs_Opt_2kx01x0-16 10247143 343.1 ns/op 6015.69 MB/s Benchmark____GWs_Opt_2kx01x0-16 9939097 339.6 ns/op 6078.40 MB/s Benchmark____GWs_Opt_2kx01x0-16 9873882 346.6 ns/op 5954.35 MB/s Benchmark____GWs_Opt_2kx01x0-16 10111066 343.1 ns/op 6015.45 MB/s Benchmark____GWs_Opt_2kx01x0-16 10483582 342.1 ns/op 6033.76 MB/s Benchmark____GWs_Opt_4kx01x0 Benchmark____GWs_Opt_4kx01x0-16 5513703 633.1 ns/op 6494.74 MB/s Benchmark____GWs_Opt_4kx01x0-16 5822956 616.7 ns/op 6667.70 MB/s Benchmark____GWs_Opt_4kx01x0-16 5829301 599.7 ns/op 6856.52 MB/s Benchmark____GWs_Opt_4kx01x0-16 5912517 628.7 ns/op 6540.51 MB/s Benchmark____GWs_Opt_4kx01x0-16 5842718 631.8 ns/op 6508.15 MB/s Benchmark____GWs_Opt_1kx10x0 Benchmark____GWs_Opt_1kx10x0-16 31691388 113.6 ns/op 9158.36 MB/s Benchmark____GWs_Opt_1kx10x0-16 31055354 110.4 ns/op 9417.71 MB/s Benchmark____GWs_Opt_1kx10x0-16 30939201 112.0 ns/op 9289.05 MB/s Benchmark____GWs_Opt_1kx10x0-16 30772281 116.7 ns/op 8913.68 MB/s Benchmark____GWs_Opt_1kx10x0-16 27514393 112.4 ns/op 9256.21 MB/s Benchmark____GWs_Opt_2kx10x0 bench_test.go:158: Error on read: read tcp 127.0.0.1:52934->127.0.0.1:34311: 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:35668->127.0.0.1:38647: use of closed network connection --- FAIL: Benchmark____GWs_Opt_2kx10x0-16 Benchmark____GWs_Opt_2kx10x0-16 25361358 161.2 ns/op 12802.63 MB/s Benchmark____GWs_Opt_2kx10x0-16 18906052 172.3 ns/op 11978.97 MB/s Benchmark____GWs_Opt_2kx10x0-16 25427902 150.2 ns/op 13744.46 MB/s Benchmark____GWs_Opt_2kx10x0-16 24097053 155.3 ns/op 13287.21 MB/s Benchmark____GWs_Opt_4kx10x0 Benchmark____GWs_Opt_4kx10x0-16 13179381 280.4 ns/op 14663.11 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:57466->127.0.0.1:36685: 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:46756->127.0.0.1:35943: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 12032497 295.9 ns/op 13894.49 MB/s bench_test.go:158: Error on read: read tcp 127.0.0.1:49642->127.0.0.1:43845: 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:33746->127.0.0.1:40303: use of closed network connection --- FAIL: Benchmark____GWs_Opt_4kx10x0-16 Benchmark____GWs_Opt_4kx10x0-16 12824070 311.8 ns/op 13188.23 MB/s Benchmark____GWs_Opt_1kx01x1 Benchmark____GWs_Opt_1kx01x1-16 6498438 585.4 ns/op 5338.42 MB/s Benchmark____GWs_Opt_1kx01x1-16 6367525 554.8 ns/op 5633.15 MB/s Benchmark____GWs_Opt_1kx01x1-16 6336188 550.5 ns/op 5676.23 MB/s Benchmark____GWs_Opt_1kx01x1-16 6456524 549.2 ns/op 5690.30 MB/s Benchmark____GWs_Opt_1kx01x1-16 6582892 551.2 ns/op 5669.11 MB/s Benchmark____GWs_Opt_2kx01x1 Benchmark____GWs_Opt_2kx01x1-16 4593753 765.9 ns/op 8091.23 MB/s Benchmark____GWs_Opt_2kx01x1-16 4748701 771.7 ns/op 8030.20 MB/s Benchmark____GWs_Opt_2kx01x1-16 4780023 758.8 ns/op 8166.92 MB/s Benchmark____GWs_Opt_2kx01x1-16 4726034 762.9 ns/op 8122.92 MB/s Benchmark____GWs_Opt_2kx01x1-16 4699936 840.5 ns/op 7373.39 MB/s Benchmark____GWs_Opt_4kx01x1 Benchmark____GWs_Opt_4kx01x1-16 2213935 1642 ns/op 7516.07 MB/s Benchmark____GWs_Opt_4kx01x1-16 2614012 1358 ns/op 9090.25 MB/s Benchmark____GWs_Opt_4kx01x1-16 2614740 1375 ns/op 8974.21 MB/s Benchmark____GWs_Opt_4kx01x1-16 2610621 1383 ns/op 8921.01 MB/s Benchmark____GWs_Opt_4kx01x1-16 2369761 1414 ns/op 8726.56 MB/s Benchmark____GWs_Opt_1kx10x1 Benchmark____GWs_Opt_1kx10x1-16 6297566 557.1 ns/op 5609.17 MB/s Benchmark____GWs_Opt_1kx10x1-16 6463159 560.6 ns/op 5574.37 MB/s Benchmark____GWs_Opt_1kx10x1-16 6178262 557.6 ns/op 5604.39 MB/s Benchmark____GWs_Opt_1kx10x1-16 5903234 559.3 ns/op 5587.17 MB/s Benchmark____GWs_Opt_1kx10x1-16 6316396 559.6 ns/op 5584.27 MB/s Benchmark____GWs_Opt_2kx10x1 Benchmark____GWs_Opt_2kx10x1-16 4095285 877.2 ns/op 7064.44 MB/s Benchmark____GWs_Opt_2kx10x1-16 4341988 844.2 ns/op 7340.40 MB/s Benchmark____GWs_Opt_2kx10x1-16 4192057 848.2 ns/op 7305.73 MB/s Benchmark____GWs_Opt_2kx10x1-16 4235865 835.8 ns/op 7414.64 MB/s Benchmark____GWs_Opt_2kx10x1-16 4006904 852.9 ns/op 7265.42 MB/s Benchmark____GWs_Opt_4kx10x1 Benchmark____GWs_Opt_4kx10x1-16 2292327 1517 ns/op 8135.20 MB/s Benchmark____GWs_Opt_4kx10x1-16 2336617 1535 ns/op 8041.44 MB/s Benchmark____GWs_Opt_4kx10x1-16 2394174 1526 ns/op 8085.65 MB/s Benchmark____GWs_Opt_4kx10x1-16 2343620 1523 ns/op 8105.35 MB/s Benchmark____GWs_Opt_4kx10x1-16 2256243 1558 ns/op 7921.85 MB/s Benchmark____GWs_Int_1kx01x0 Benchmark____GWs_Int_1kx01x0-16 12515031 288.5 ns/op 3604.64 MB/s Benchmark____GWs_Int_1kx01x0-16 12707162 294.7 ns/op 3528.99 MB/s Benchmark____GWs_Int_1kx01x0-16 12628867 284.8 ns/op 3651.25 MB/s Benchmark____GWs_Int_1kx01x0-16 12548373 283.7 ns/op 3665.92 MB/s Benchmark____GWs_Int_1kx01x0-16 12413361 283.6 ns/op 3667.52 MB/s Benchmark____GWs_Int_2kx01x0 Benchmark____GWs_Int_2kx01x0-16 10460818 356.0 ns/op 5798.18 MB/s Benchmark____GWs_Int_2kx01x0-16 9672913 353.4 ns/op 5839.82 MB/s Benchmark____GWs_Int_2kx01x0-16 10373818 346.5 ns/op 5956.71 MB/s Benchmark____GWs_Int_2kx01x0-16 10009717 364.0 ns/op 5669.98 MB/s Benchmark____GWs_Int_2kx01x0-16 9178112 351.7 ns/op 5868.29 MB/s Benchmark____GWs_Int_4kx01x0 Benchmark____GWs_Int_4kx01x0-16 5614801 621.0 ns/op 6621.10 MB/s Benchmark____GWs_Int_4kx01x0-16 5802026 629.8 ns/op 6529.50 MB/s Benchmark____GWs_Int_4kx01x0-16 5815386 607.6 ns/op 6767.31 MB/s Benchmark____GWs_Int_4kx01x0-16 5984798 620.4 ns/op 6628.35 MB/s Benchmark____GWs_Int_4kx01x0-16 6005245 630.2 ns/op 6524.63 MB/s Benchmark____GWs_Int_1kx10x0 Benchmark____GWs_Int_1kx10x0-16 31725210 127.8 ns/op 8139.20 MB/s Benchmark____GWs_Int_1kx10x0-16 31520728 109.7 ns/op 9480.53 MB/s Benchmark____GWs_Int_1kx10x0-16 28847521 108.6 ns/op 9572.66 MB/s Benchmark____GWs_Int_1kx10x0-16 32896597 110.1 ns/op 9448.36 MB/s Benchmark____GWs_Int_1kx10x0-16 32109982 108.8 ns/op 9554.78 MB/s Benchmark____GWs_Int_2kx10x0 Benchmark____GWs_Int_2kx10x0-16 25252486 141.7 ns/op 14567.73 MB/s Benchmark____GWs_Int_2kx10x0-16 23984043 208.8 ns/op 9882.85 MB/s Benchmark____GWs_Int_2kx10x0-16 23314472 166.8 ns/op 12373.51 MB/s Benchmark____GWs_Int_2kx10x0-16 25850450 157.4 ns/op 13114.57 MB/s Benchmark____GWs_Int_2kx10x0-16 25520666 160.9 ns/op 12828.81 MB/s Benchmark____GWs_Int_4kx10x0 Benchmark____GWs_Int_4kx10x0-16 9946112 315.6 ns/op 13027.90 MB/s Benchmark____GWs_Int_4kx10x0-16 12084913 348.5 ns/op 11798.90 MB/s Benchmark____GWs_Int_4kx10x0-16 10104146 406.0 ns/op 10127.21 MB/s Benchmark____GWs_Int_4kx10x0-16 7817724 427.0 ns/op 9630.91 MB/s Benchmark____GWs_Int_4kx10x0-16 13235302 326.6 ns/op 12589.48 MB/s Benchmark____GWs_Int_1kx01x1 Benchmark____GWs_Int_1kx01x1-16 6297969 548.3 ns/op 5699.30 MB/s Benchmark____GWs_Int_1kx01x1-16 6433640 559.6 ns/op 5584.22 MB/s Benchmark____GWs_Int_1kx01x1-16 6539701 558.1 ns/op 5599.50 MB/s Benchmark____GWs_Int_1kx01x1-16 6385855 548.4 ns/op 5698.20 MB/s Benchmark____GWs_Int_1kx01x1-16 6452983 560.2 ns/op 5578.52 MB/s Benchmark____GWs_Int_2kx01x1 Benchmark____GWs_Int_2kx01x1-16 4699447 773.8 ns/op 8008.26 MB/s Benchmark____GWs_Int_2kx01x1-16 4676155 760.7 ns/op 8146.20 MB/s Benchmark____GWs_Int_2kx01x1-16 4737750 768.4 ns/op 8064.82 MB/s Benchmark____GWs_Int_2kx01x1-16 4709384 771.3 ns/op 8034.53 MB/s Benchmark____GWs_Int_2kx01x1-16 4676131 783.6 ns/op 7908.87 MB/s Benchmark____GWs_Int_4kx01x1 Benchmark____GWs_Int_4kx01x1-16 2615826 1679 ns/op 7350.66 MB/s Benchmark____GWs_Int_4kx01x1-16 2643831 1377 ns/op 8962.20 MB/s Benchmark____GWs_Int_4kx01x1-16 2648499 1485 ns/op 8309.51 MB/s Benchmark____GWs_Int_4kx01x1-16 2631820 1369 ns/op 9014.68 MB/s Benchmark____GWs_Int_4kx01x1-16 2343039 1370 ns/op 9006.94 MB/s Benchmark____GWs_Int_1kx10x1 Benchmark____GWs_Int_1kx10x1-16 6043198 558.3 ns/op 5597.01 MB/s Benchmark____GWs_Int_1kx10x1-16 5978715 563.1 ns/op 5549.61 MB/s Benchmark____GWs_Int_1kx10x1-16 6211441 561.5 ns/op 5565.77 MB/s Benchmark____GWs_Int_1kx10x1-16 6184578 559.0 ns/op 5590.17 MB/s Benchmark____GWs_Int_1kx10x1-16 6625833 591.6 ns/op 5282.55 MB/s Benchmark____GWs_Int_2kx10x1 Benchmark____GWs_Int_2kx10x1-16 4184840 850.1 ns/op 7290.07 MB/s bench_test.go:158: Error on read: EOF bench_test.go:167: Did not receive all bytes: 5184829468 vs 8436800460 bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:57026->127.0.0.1:45707: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:57024->127.0.0.1:45707: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:57022->127.0.0.1:45707: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:57008->127.0.0.1:45707: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:56996->127.0.0.1:45707: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:56986->127.0.0.1:45707: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:56970->127.0.0.1:45707: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:56956->127.0.0.1:45707: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:56952->127.0.0.1:45707: use of closed network connection bench_test.go:1255: Received error on PUB write: write tcp 127.0.0.1:56940->127.0.0.1:45707: use of closed network connection --- FAIL: Benchmark____GWs_Int_2kx10x1-16 Benchmark____GWs_Int_2kx10x1-16 3882386 843.3 ns/op 7348.56 MB/s Benchmark____GWs_Int_2kx10x1-16 4173369 837.5 ns/op 7399.71 MB/s Benchmark____GWs_Int_2kx10x1-16 4020985 843.7 ns/op 7345.17 MB/s Benchmark____GWs_Int_4kx10x1 Benchmark____GWs_Int_4kx10x1-16 2401941 1632 ns/op 7562.95 MB/s Benchmark____GWs_Int_4kx10x1-16 2279296 1650 ns/op 7477.46 MB/s Benchmark____GWs_Int_4kx10x1-16 2425876 1500 ns/op 8229.46 MB/s Benchmark____GWs_Int_4kx10x1-16 2352320 1515 ns/op 8147.02 MB/s Benchmark____GWs_Int_4kx10x1-16 2272545 1865 ns/op 6617.54 MB/s Benchmark__GWs_Reqs_1_SubAll Benchmark__GWs_Reqs_1_SubAll-16 8530354 441.0 ns/op 231.31 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8576758 427.1 ns/op 238.81 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8272407 432.7 ns/op 235.75 MB/s Benchmark__GWs_Reqs_1_SubAll-16 8310843 433.2 ns/op 235.47 MB/s Benchmark__GWs_Reqs_1_SubAll-16 7891390 433.2 ns/op 235.45 MB/s Benchmark__GWs_Reqs_1SubEach Benchmark__GWs_Reqs_1SubEach-16 630186 5046 ns/op 35.08 MB/s Benchmark__GWs_Reqs_1SubEach-16 776286 5336 ns/op 33.17 MB/s Benchmark__GWs_Reqs_1SubEach-16 717121 5230 ns/op 33.85 MB/s Benchmark__GWs_Reqs_1SubEach-16 741409 5248 ns/op 33.73 MB/s Benchmark__GWs_Reqs_1SubEach-16 726207 5231 ns/op 33.84 MB/s FAIL exit status 1 FAIL github.com/nats-io/nats-server/v2/test 2188.513s