Improve packet distribution across threads (#1342)

In Progress

Activities

wojciech.kapcia@tigase.net opened 2 years ago

from https://github.com/tigase/tigase-server/issues/177

Components distribute the load to the different threads and queues according to the hash code calculation of a packet. 
Session manager respectively checks not null values of `packet.getPacketFrom`, `packet.getPacketTo` and `packet.getStanzaTo().getBareJID()`.

For the initial connection establishment process, starting from the `STREAM_OPENED` to the `TLS_HANDSHAKE_COMPLETE` commands, the same thread processes all connection attempts. The reason for that is `hashCodeForPacket` calculated according to the same value `sess-man@HOSTNAME`.

Example `tigase.stats.sess_man_Processed_packets_thread_IN` results in our test env after some period of time.
<img width="1786" alt="image" src="https://user-images.githubusercontent.com/1856241/204809059-1ea6f8ea-a4d2-4a96-8d72-9ba81bebc489.png">

To resolve this bottleneck, shouldn't we use connection id for better thread distribution?

An example from my local machine. `AbstractMessageReceiver.addPacket` and `addPacketNB` logs while opening a stream.
QueueIdx is calculated by `sess-man@localhost`.  (I have 10 CPU core in my machine). 
Every connection request will end up in queues 6 and 46. 
Instead, queueIdx could be calculated according to `c2s@localhost/127.0.0.1_5222_127.0.0.1_53424`. 
This would speed up connection establishment process.
Better thread utilization
Less risk for queue overflow.

1. `QueueIdx: 6 NAME: message-router TYPE: set ELEM_NAME: iq COMMAND: STREAM_OPENED PACKET_FROM: null PACKET_TO: null STANZA_FROM: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_TO: sess-man@localhost`
2. ` QueueIdx: 46 NAME: sess-man TYPE: set ELEM_NAME: iq COMMAND: STREAM_OPENED PACKET_FROM: null PACKET_TO: null STANZA_FROM: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_TO: sess-man@localhost`
3. `QueueIdx: 16 NAME: message-router TYPE: result ELEM_NAME: iq COMMAND: null PACKET_FROM: sess-man@localhost PACKET_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_FROM: sess-man@localhost STANZA_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 `
4. `QueueIdx: 16 NAME: c2s TYPE: result ELEM_NAME: iq COMMAND: null PACKET_FROM: sess-man@localhost PACKET_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_FROM: sess-man@localhost STANZA_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424`
5. `QueueIdx: 6 NAME: message-router TYPE: get ELEM_NAME: iq COMMAND: GETFEATURES PACKET_FROM: null PACKET_TO: null STANZA_FROM: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_TO: sess-man@localhost`
6. `QueueIdx: 46 NAME: sess-man TYPE: get ELEM_NAME: iq COMMAND: GETFEATURES PACKET_FROM: null PACKET_TO: null STANZA_FROM: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_TO: sess-man@localhost`
7. `QueueIdx: 16 NAME: message-router TYPE: result ELEM_NAME: iq COMMAND: GETFEATURES PACKET_FROM: sess-man@localhost PACKET_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_FROM: sess-man@localhost STANZA_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424`
8. `QueueIdx: 16 NAME: c2s TYPE: result ELEM_NAME: iq COMMAND: GETFEATURES PACKET_FROM: sess-man@localhost PACKET_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_FROM: sess-man@localhost STANZA_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424`
9. `QueueIdx: 16 NAME: message-router TYPE: null ELEM_NAME: starttls PACKET_FROM: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 PACKET_TO: sess-man@localhost STANZA_FROM: null STANZA_TO: null`
10. `QueueIdx: 96 NAME: sess-man TYPE: null ELEM_NAME: starttls PACKET_FROM: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 PACKET_TO: sess-man@localhost STANZA_FROM: null STANZA_TO: null`
11. `QueueIdx: 39 NAME: message-router TYPE: set ELEM_NAME: iq COMMAND: STARTTLS PACKET_FROM: sess-man@localhost PACKET_TO: null STANZA_FROM: sess-man@localhost STANZA_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424`
12. `QueueIdx: 16 NAME: c2s TYPE: set ELEM_NAME: iq COMMAND: STARTTLS PACKET_FROM: sess-man@localhost PACKET_TO: null STANZA_FROM: sess-man@localhost STANZA_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424`
13. `QueueIdx: 6 NAME: message-router TYPE: set ELEM_NAME: iq COMMAND: TLS_HANDSHAKE_COMPLETE PACKET_FROM: null PACKET_TO: null STANZA_FROM: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_TO: sess-man@localhost`
14. `QueueIdx: 46 NAME: sess-man TYPE: set ELEM_NAME: iq COMMAND: TLS_HANDSHAKE_COMPLETE PACKET_FROM: null PACKET_TO: null STANZA_FROM: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_TO: sess-man@localhost`
15. `QueueIdx: 6 NAME: message-router TYPE: get ELEM_NAME: iq COMMAND: GETFEATURES PACKET_FROM: null PACKET_TO: null STANZA_FROM: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_TO: sess-man@localhost`
16. `QueueIdx: 46 NAME: sess-man TYPE: get ELEM_NAME: iq COMMAND: GETFEATURES PACKET_FROM: null PACKET_TO: null STANZA_FROM: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_TO: sess-man@localhost`
17. `QueueIdx: 16 NAME: c2s TYPE: result ELEM_NAME: iq COMMAND: GETFEATURES PACKET_FROM: sess-man@localhost PACKET_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_FROM: sess-man@localhost STANZA_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424`
18.` QueueIdx: 16 NAME: message-router TYPE: result ELEM_NAME: iq COMMAND: GETFEATURES PACKET_FROM: sess-man@localhost PACKET_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424 STANZA_FROM: sess-man@localhost STANZA_TO: c2s@localhost/127.0.0.1_5222_127.0.0.1_53424`



Tigase version: 8.1.0
JVM flavour and version : openjdk 11.0.7 2020-04-14
Operating system/distribution/version : Ubuntu 18.04.1 LTS
INTEL(R) XEON(R) PLATINUM 8259CL CPU @ 2.50GHZ
GNU/Linux - 1 CPU - 2 virtual CPU - 4.06G RAM

https://github.com/tigase/tigase-server/pull/179

wojciech.kapcia@tigase.net commented 2 years ago

Current distribution on tigase.im:

ext/Processed packets thread IN=[0, 0, 0, 0, 0, 0, 0, 0]
ext/Processed packets thread OUT=[0, 0, 0, 0, 0, 0, 0, 0]
ext/Processed packets thread (outliers) IN=mean: 0.00, deviation: 0.00
ext/Processed packets thread (outliers) OUT=mean: 0.00, deviation: 0.00
amp/Processed packets thread IN=[0, 0, 0, 0, 5202, 0, 0, 0]
amp/Processed packets thread OUT=[0, 0, 0, 0, 0, 0, 0, 0]
amp/Processed packets thread (outliers) IN=mean: 650.00, deviation: 1720.40, outliers: [in_4-amp:5202:x8.00]
amp/Processed packets thread (outliers) OUT=mean: 0.00, deviation: 0.00
upload/Processed packets thread IN=[2657]
upload/Processed packets thread OUT=[2657]
upload/Processed packets thread (outliers) IN=mean: 2657.00, deviation: 0.00
upload/Processed packets thread (outliers) OUT=mean: 2657.00, deviation: 0.00
c2s/Processed packets thread IN=[64047, 70567, 64155, 60027, 64437, 65596, 61595, 137487]
c2s/Processed packets thread OUT=[45331, 48973, 41990, 39260, 43342, 43986, 89923, 44610]
c2s/Processed packets thread (outliers) IN=mean: 73488.00, deviation: 24360.54, outliers: [in_7-c2s:137487:x1.87]
c2s/Processed packets thread (outliers) OUT=mean: 49676.00, deviation: 15430.98, outliers: [out_6-c2s:89923:x1.81]
ws2s/Processed packets thread IN=[136, 32, 54, 156, 88, 23, 134, 287]
ws2s/Processed packets thread OUT=[114, 17, 36, 86, 65, 13, 179, 134]
ws2s/Processed packets thread (outliers) IN=mean: 113.00, deviation: 80.52, outliers: [in_7-ws2s:287:x2.54]
ws2s/Processed packets thread (outliers) OUT=mean: 80.00, deviation: 55.37
monitor/Processed packets thread IN=[0]
monitor/Processed packets thread OUT=[0]
monitor/Processed packets thread (outliers) IN=mean: 0.00, deviation: 0.00
monitor/Processed packets thread (outliers) OUT=mean: 0.00, deviation: 0.00
bosh/Processed packets thread IN=[0, 0, 0, 0, 0, 0, 0, 0]
bosh/Processed packets thread OUT=[0, 0, 0, 0, 0, 0, 0, 0]
bosh/Processed packets thread (outliers) IN=mean: 0.00, deviation: 0.00
bosh/Processed packets thread (outliers) OUT=mean: 0.00, deviation: 0.00
push/Processed packets thread IN=[2316, 5353, 5022, 9101, 7178, 6290, 4920, 4863]
push/Processed packets thread OUT=[44847]
push/Processed packets thread (outliers) IN=mean: 5630.00, deviation: 1850.71
push/Processed packets thread (outliers) OUT=mean: 44847.00, deviation: 0.00
cl-comp/Processed packets thread IN=[16051, 25801, 14433, 71764, 14347, 14778, 44070, 14248, 11896, 23412, 10930, 11737, 13939, 16772, 26066, 12234]
cl-comp/Processed packets thread OUT=[29236, 22509, 24044, 47346, 69727, 25129, 31141, 27249, 28664, 31957, 21389, 35478, 22124, 24551, 52732, 22422]
cl-comp/Processed packets thread (outliers) IN=mean: 21404.00, deviation: 15354.09, outliers: [in_3-cl-comp:71764:x3.35]
cl-comp/Processed packets thread (outliers) OUT=mean: 32231.00, deviation: 12990.16, outliers: [out_4-cl-comp:69727:x2.16]
socks5/Processed packets thread IN=[194]
socks5/Processed packets thread OUT=[194]
socks5/Processed packets thread (outliers) IN=mean: 194.00, deviation: 0.00
socks5/Processed packets thread (outliers) OUT=mean: 194.00, deviation: 0.00
ext-disco/Processed packets thread IN=[18]
ext-disco/Processed packets thread OUT=[18]
ext-disco/Processed packets thread (outliers) IN=mean: 18.00, deviation: 0.00
ext-disco/Processed packets thread (outliers) OUT=mean: 18.00, deviation: 0.00
meet/Processed packets thread IN=[2600]
meet/Processed packets thread OUT=[2600]
meet/Processed packets thread (outliers) IN=mean: 2600.00, deviation: 0.00
meet/Processed packets thread (outliers) OUT=mean: 2600.00, deviation: 0.00
eventbus/Processed packets thread IN=[22298, 0]
eventbus/Processed packets thread OUT=[11887, 11910]
eventbus/Processed packets thread (outliers) IN=mean: 11149.00, deviation: 11149.00
eventbus/Processed packets thread (outliers) OUT=mean: 11898.00, deviation: 11.51
s2s/Processed packets thread IN=[27756, 35559, 52410, 20567, 23449, 25701, 46565, 18182]
s2s/Processed packets thread OUT=[0, 108603, 3219, 62719, 8991, 41507, 5966, 41515]
s2s/Processed packets thread (outliers) IN=mean: 31273.00, deviation: 11670.54
s2s/Processed packets thread (outliers) OUT=mean: 34065.00, deviation: 35387.16, outliers: [out_1-s2s:108603:x3.19]
http/Processed packets thread IN=[92]
http/Processed packets thread OUT=[92]
http/Processed packets thread (outliers) IN=mean: 92.00, deviation: 0.00
http/Processed packets thread (outliers) OUT=mean: 92.00, deviation: 0.00
muc/Processed packets thread IN=[515, 13279, 1495, 2676, 1185, 359, 347, 2495]
muc/Processed packets thread OUT=[2870, 2936, 3078, 2482, 1610, 2622, 1164, 7432]
muc/Processed packets thread (outliers) IN=mean: 2793.00, deviation: 4053.17, outliers: [in_1-muc:13279:x4.75]
muc/Processed packets thread (outliers) OUT=mean: 3024.00, deviation: 1781.12, outliers: [out_7-muc:7432:x2.46]
sess-man/Processed packets thread IN=[37486, 31567, 30881, 24934, 29975, 292843, 46029, 119688, 31456, 36362, 27984, 32583, 28900, 30030, 36817, 33048]
sess-man/Processed packets thread OUT=[41422, 53514, 47539, 55480, 54023, 106506, 140142, 117023, 49999, 42278, 47921, 41894, 66444, 44799, 57099, 48536]
sess-man/Processed packets thread (outliers) IN=mean: 54411.00, deviation: 65214.96, outliers: [in_5-sess-man:292843:x5.38]
sess-man/Processed packets thread (outliers) OUT=mean: 63413.00, deviation: 29100.70, outliers: [out_6-sess-man:140142:x2.21]
message-archive/Processed packets thread IN=[850, 1405, 1116, 1259, 4088, 1036, 1123, 2213]
message-archive/Processed packets thread OUT=[6807, 6501, 33959, 1727, 2261, 6404, 207, 1331]
message-archive/Processed packets thread (outliers) IN=mean: 1636.00, deviation: 1003.25, outliers: [in_4-message-archive:4088:x2.50]
message-archive/Processed packets thread (outliers) OUT=mean: 7399.00, deviation: 10336.20, outliers: [out_2-message-archive:33959:x4.59]
mix/Processed packets thread IN=[310, 545, 534, 366, 623, 1169, 104, 338]
mix/Processed packets thread OUT=[857, 147, 2370, 147, 826, 613, 972, 0]
mix/Processed packets thread (outliers) IN=mean: 498.00, deviation: 296.43, outliers: [in_5-mix:1169:x2.35]
mix/Processed packets thread (outliers) OUT=mean: 741.00, deviation: 707.00, outliers: [out_2-mix:2370:x3.20]
message-router/Processed packets thread IN=[175185, 175633, 157117, 153618, 182951, 537733, 232391, 348122]
message-router/Processed packets thread OUT=[23161]
message-router/Processed packets thread (outliers) IN=mean: 245343.00, deviation: 125546.25, outliers: [in_5-message-router:537733:x2.19]
message-router/Processed packets thread (outliers) OUT=mean: 23161.00, deviation: 0.00
pubsub/Processed packets thread IN=[9131, 13805, 11135, 14295, 11269, 9587, 7656, 11750]
pubsub/Processed packets thread OUT=[6038, 5879, 6042, 6042, 5988, 6055, 6004, 6056]
pubsub/Processed packets thread (outliers) IN=mean: 11078.00, deviation: 2121.35
pubsub/Processed packets thread (outliers) OUT=mean: 6013.00, deviation: 55.43, outliers: [out_1-pubsub:5879:x0.98]

tigase.org:

amp/Processed packets thread IN=[0, 14, 0, 0, 0, 0, 0, 0]
amp/Processed packets thread OUT=[0, 0, 0, 0, 0, 0, 0, 0]
amp/Processed packets thread (outliers) IN=mean: 1.00, deviation: 4.69, outliers: [in_1-amp:14:x14.00]
amp/Processed packets thread (outliers) OUT=mean: 0.00, deviation: 0.00
upload/Processed packets thread IN=[50]
upload/Processed packets thread OUT=[50]
upload/Processed packets thread (outliers) IN=mean: 50.00, deviation: 0.00
upload/Processed packets thread (outliers) OUT=mean: 50.00, deviation: 0.00
bosh/Processed packets thread IN=[0, 0, 0, 0, 0, 0, 0, 0]
bosh/Processed packets thread OUT=[0, 0, 0, 0, 0, 0, 0, 0]
bosh/Processed packets thread (outliers) IN=mean: 0.00, deviation: 0.00
bosh/Processed packets thread (outliers) OUT=mean: 0.00, deviation: 0.00
cl-comp/Processed packets thread IN=[2237, 10226, 189, 8436, 7094, 11754, 3958, 3222, 5104, 135, 6174, 3951, 6726, 2127, 3104, 1794]
cl-comp/Processed packets thread OUT=[655, 1467, 629, 725, 837, 894, 5215, 498, 1597, 427, 2342, 2783, 573, 316, 419, 494]
cl-comp/Processed packets thread (outliers) IN=mean: 4764.00, deviation: 3302.67, outliers: [in_5-cl-comp:11754:x2.47]
cl-comp/Processed packets thread (outliers) OUT=mean: 1241.00, deviation: 1239.42, outliers: [out_6-cl-comp:5215:x4.20]
ext-disco/Processed packets thread IN=[27]
ext-disco/Processed packets thread OUT=[27]
ext-disco/Processed packets thread (outliers) IN=mean: 27.00, deviation: 0.00
ext-disco/Processed packets thread (outliers) OUT=mean: 27.00, deviation: 0.00
sess-man/Processed packets thread IN=[1014, 1316, 367, 116, 1007, 289, 174, 248, 105362, 420, 16472, 520, 193, 1018, 5170, 223]
sess-man/Processed packets thread OUT=[4042, 1892, 715, 175, 3348, 1538, 1060, 2392, 34246, 5096, 6250, 1444, 827, 4101, 4439, 594]
sess-man/Processed packets thread (outliers) IN=mean: 8369.00, deviation: 25352.70, outliers: [in_8-sess-man:105362:x12.59]
sess-man/Processed packets thread (outliers) OUT=mean: 4509.00, deviation: 7877.62, outliers: [out_8-sess-man:34246:x7.60]
mix/Processed packets thread IN=[0, 53, 179, 1687, 2068, 194, 0, 2]
mix/Processed packets thread OUT=[99, 527, 784, 1852, 3253, 211, 5, 1]
mix/Processed packets thread (outliers) IN=mean: 522.00, deviation: 791.19
mix/Processed packets thread (outliers) OUT=mean: 841.00, deviation: 1077.83, outliers: [out_4-mix:3253:x3.87]
pubsub/Processed packets thread IN=[334, 324, 645, 805, 465, 420, 316, 314]
pubsub/Processed packets thread OUT=[408, 392, 389, 417, 379, 407, 389, 377]
pubsub/Processed packets thread (outliers) IN=mean: 452.00, deviation: 169.89, outliers: [in_3-pubsub:805:x1.78]
pubsub/Processed packets thread (outliers) OUT=mean: 394.00, deviation: 13.52
ext/Processed packets thread IN=[0, 0, 0, 0, 0, 0, 0, 0]
ext/Processed packets thread OUT=[0, 0, 0, 0, 0, 0, 0, 0]
ext/Processed packets thread (outliers) IN=mean: 0.00, deviation: 0.00
ext/Processed packets thread (outliers) OUT=mean: 0.00, deviation: 0.00
c2s/Processed packets thread IN=[4406, 1111, 3745, 1570, 3266, 4371, 4825, 438]
c2s/Processed packets thread OUT=[987, 256, 902, 524, 1023, 982, 1860, 100]
c2s/Processed packets thread (outliers) IN=mean: 2966.00, deviation: 1580.39
c2s/Processed packets thread (outliers) OUT=mean: 829.00, deviation: 513.21, outliers: [out_6-c2s:1860:x2.24]
ws2s/Processed packets thread IN=[0, 0, 0, 0, 0, 0, 0, 0]
ws2s/Processed packets thread OUT=[0, 0, 0, 0, 0, 0, 0, 0]
ws2s/Processed packets thread (outliers) IN=mean: 0.00, deviation: 0.00
ws2s/Processed packets thread (outliers) OUT=mean: 0.00, deviation: 0.00
monitor/Processed packets thread IN=[27]
monitor/Processed packets thread OUT=[27]
monitor/Processed packets thread (outliers) IN=mean: 27.00, deviation: 0.00
monitor/Processed packets thread (outliers) OUT=mean: 27.00, deviation: 0.00
push/Processed packets thread IN=[0, 9, 34, 0, 0, 0, 6, 29]
push/Processed packets thread OUT=[78]
push/Processed packets thread (outliers) IN=mean: 9.00, deviation: 13.03
push/Processed packets thread (outliers) OUT=mean: 78.00, deviation: 0.00
socks5/Processed packets thread IN=[0]
socks5/Processed packets thread OUT=[0]
socks5/Processed packets thread (outliers) IN=mean: 0.00, deviation: 0.00
socks5/Processed packets thread (outliers) OUT=mean: 0.00, deviation: 0.00
tags/Processed packets thread IN=[49]
tags/Processed packets thread OUT=[49]
tags/Processed packets thread (outliers) IN=mean: 49.00, deviation: 0.00
tags/Processed packets thread (outliers) OUT=mean: 49.00, deviation: 0.00
meet/Processed packets thread IN=[49]
meet/Processed packets thread OUT=[49]
meet/Processed packets thread (outliers) IN=mean: 49.00, deviation: 0.00
meet/Processed packets thread (outliers) OUT=mean: 49.00, deviation: 0.00
s2s/Processed packets thread IN=[34396, 72217, 37900, 20067, 9285, 51713, 24313, 44471]
s2s/Processed packets thread OUT=[254, 11, 79001, 0, 0, 937, 0, 104697]
s2s/Processed packets thread (outliers) IN=mean: 36795.00, deviation: 18491.85
s2s/Processed packets thread (outliers) OUT=mean: 23112.00, deviation: 40202.71, outliers: [out_7-s2s:104697:x4.53]
eventbus/Processed packets thread IN=[0, 4626]
eventbus/Processed packets thread OUT=[5, 4610]
eventbus/Processed packets thread (outliers) IN=mean: 2313.00, deviation: 2313.00
eventbus/Processed packets thread (outliers) OUT=mean: 2307.00, deviation: 2302.50
http/Processed packets thread IN=[375]
http/Processed packets thread OUT=[375]
http/Processed packets thread (outliers) IN=mean: 375.00, deviation: 0.00
http/Processed packets thread (outliers) OUT=mean: 375.00, deviation: 0.00
c2s8/Processed packets thread IN=[0, 0, 0, 0, 0, 0, 0, 0]
c2s8/Processed packets thread OUT=[0, 0, 0, 0, 0, 0, 0, 0]
c2s8/Processed packets thread (outliers) IN=mean: 0.00, deviation: 0.00
c2s8/Processed packets thread (outliers) OUT=mean: 0.00, deviation: 0.00
muc/Processed packets thread IN=[2695, 3440, 18222, 13728, 8829, 8736, 9282, 13806]
muc/Processed packets thread OUT=[17781, 11729, 55572, 17480, 33839, 20554, 35125, 67834]
muc/Processed packets thread (outliers) IN=mean: 9842.00, deviation: 4945.54
muc/Processed packets thread (outliers) OUT=mean: 32489.00, deviation: 18727.93
message-archive/Processed packets thread IN=[0, 1523, 167, 1, 0, 1, 8, 3]
message-archive/Processed packets thread OUT=[0, 132, 319, 184, 1678, 2, 0, 0]
message-archive/Processed packets thread (outliers) IN=mean: 212.00, deviation: 498.12, outliers: [in_1-message-archive:1523:x7.18]
message-archive/Processed packets thread (outliers) OUT=mean: 289.00, deviation: 536.05, outliers: [out_4-message-archive:1678:x5.81]
c2s4/Processed packets thread IN=[0, 0, 0, 0, 0, 0, 0, 0]
c2s4/Processed packets thread OUT=[0, 0, 0, 0, 0, 0, 0, 0]
c2s4/Processed packets thread (outliers) IN=mean: 0.00, deviation: 0.00
c2s4/Processed packets thread (outliers) OUT=mean: 0.00, deviation: 0.00
message-router/Processed packets thread IN=[310540, 51339, 47338, 9447, 24532, 58140, 24842, 23821]
message-router/Processed packets thread OUT=[748]
message-router/Processed packets thread (outliers) IN=mean: 68749.00, deviation: 92705.99, outliers: [in_0-message-router:310540:x4.52]
message-router/Processed packets thread (outliers) OUT=mean: 748.00, deviation: 0.00

tts-ng against MySQL:

ext/Processed packets thread IN[S] = [0, 0, 13, 0, 0, 0, 0, 0]
ext/Processed packets thread OUT[S] = [13, 0, 0, 0, 0, 0, 0, 0]
ext/Processed packets thread (outliers) IN[S] = mean: 1.00, deviation: 4.34, outliers: [in_2-ext:13:x13.00]
ext/Processed packets thread (outliers) OUT[S] = mean: 1.00, deviation: 4.34, outliers: [out_0-ext:13:x13.00]
upload/Processed packets thread IN[S] = [36]
upload/Processed packets thread OUT[S] = [36]
upload/Processed packets thread (outliers) IN[S] = mean: 36.00, deviation: 0.00
upload/Processed packets thread (outliers) OUT[S] = mean: 36.00, deviation: 0.00
c2s/Processed packets thread IN[S] = [2127, 3789, 3471, 3570, 3040, 2715, 2474, 3439]
c2s/Processed packets thread OUT[S] = [871, 1159, 3409, 1002, 1022, 987, 913, 1063]
c2s/Processed packets thread (outliers) IN[S] = mean: 3078.00, deviation: 551.68
c2s/Processed packets thread (outliers) OUT[S] = mean: 1303.00, deviation: 800.13, outliers: [out_2-c2s:3409:x2.62]
amp/Processed packets thread IN[S] = [0, 0, 396, 3, 0, 0, 0, 1]
amp/Processed packets thread OUT[S] = [0, 0, 0, 1, 0, 0, 0, 1]
amp/Processed packets thread (outliers) IN[S] = mean: 50.00, deviation: 130.78, outliers: [in_2-amp:396:x7.92]
amp/Processed packets thread (outliers) OUT[S] = mean: 0.00, deviation: 0.50
monitor/Processed packets thread IN[S] = [34]
monitor/Processed packets thread OUT[S] = [34]
monitor/Processed packets thread (outliers) IN[S] = mean: 34.00, deviation: 0.00
monitor/Processed packets thread (outliers) OUT[S] = mean: 34.00, deviation: 0.00
ws2s/Processed packets thread IN[S] = [35, 0, 16, 17, 17, 13, 0, 27]
ws2s/Processed packets thread OUT[S] = [20, 0, 34, 11, 10, 12, 0, 19]
ws2s/Processed packets thread (outliers) IN[S] = mean: 15.00, deviation: 11.22
ws2s/Processed packets thread (outliers) OUT[S] = mean: 13.00, deviation: 10.48, outliers: [out_2-ws2s:34:x2.62]
bosh/Processed packets thread IN[S] = [0, 0, 13, 0, 0, 18, 25, 14]
bosh/Processed packets thread OUT[S] = [0, 0, 19, 0, 0, 13, 19, 11]
bosh/Processed packets thread (outliers) IN[S] = mean: 8.00, deviation: 9.39
bosh/Processed packets thread (outliers) OUT[S] = mean: 7.00, deviation: 8.19
wg/Processed packets thread IN[S] = [0, 0, 5, 0, 37, 0, 0, 4]
wg/Processed packets thread OUT[S] = [6, 3, 15, 7, 6, 6, 2, 2]
wg/Processed packets thread (outliers) IN[S] = mean: 5.00, deviation: 11.99, outliers: [in_4-wg:37:x7.40]
wg/Processed packets thread (outliers) OUT[S] = mean: 5.00, deviation: 4.02, outliers: [out_2-wg:15:x3.00]
ext-disco/Processed packets thread IN[S] = [34]
ext-disco/Processed packets thread OUT[S] = [34]
ext-disco/Processed packets thread (outliers) IN[S] = mean: 34.00, deviation: 0.00
ext-disco/Processed packets thread (outliers) OUT[S] = mean: 34.00, deviation: 0.00
eventbus/Processed packets thread IN[S] = [31, 0]
eventbus/Processed packets thread OUT[S] = [18, 13]
eventbus/Processed packets thread (outliers) IN[S] = mean: 15.00, deviation: 15.51
eventbus/Processed packets thread (outliers) OUT[S] = mean: 15.00, deviation: 2.55
s2s/Processed packets thread IN[S] = [0, 0, 0, 0, 0, 0, 0, 0]
s2s/Processed packets thread OUT[S] = [0, 0, 0, 0, 0, 0, 0, 0]
s2s/Processed packets thread (outliers) IN[S] = mean: 0.00, deviation: 0.00
s2s/Processed packets thread (outliers) OUT[S] = mean: 0.00, deviation: 0.00
http/Processed packets thread IN[S] = [1141]
http/Processed packets thread OUT[S] = [1114]
http/Processed packets thread (outliers) IN[S] = mean: 1141.00, deviation: 0.00
http/Processed packets thread (outliers) OUT[S] = mean: 1114.00, deviation: 0.00
muc/Processed packets thread IN[S] = [62, 12, 24, 5, 20, 42, 40, 30]
muc/Processed packets thread OUT[S] = [109, 16, 46, 9, 93, 92, 126, 65]
muc/Processed packets thread (outliers) IN[S] = mean: 29.00, deviation: 17.14
muc/Processed packets thread (outliers) OUT[S] = mean: 69.00, deviation: 40.17
sess-man/Processed packets thread IN[S] = [711, 1066, 629, 3304, 577, 625, 515, 755, 479, 767, 1087, 805, 774, 706, 712, 624]
sess-man/Processed packets thread OUT[S] = [8586, 1601, 3473, 2051, 1237, 1391, 1264, 2129, 837, 2088, 1745, 1558, 1826, 1337, 2633, 1658]
sess-man/Processed packets thread (outliers) IN[S] = mean: 883.00, deviation: 645.40, outliers: [in_3-sess-man:3304:x3.74]
sess-man/Processed packets thread (outliers) OUT[S] = mean: 2213.00, deviation: 1751.75, outliers: [out_0-sess-man:8586:x3.88]
message-archive/Processed packets thread IN[S] = [41, 56, 48, 49, 76, 19, 2, 72]
message-archive/Processed packets thread OUT[S] = [0, 0, 8, 46, 22, 11, 123, 50]
message-archive/Processed packets thread (outliers) IN[S] = mean: 45.00, deviation: 23.39
message-archive/Processed packets thread (outliers) OUT[S] = mean: 32.00, deviation: 38.67, outliers: [out_6-message-archive:123:x3.84]
mix/Processed packets thread IN[S] = [38, 4, 4, 8, 6, 4, 1, 1]
mix/Processed packets thread OUT[S] = [19, 44, 13, 0, 3, 6, 0, 3]
mix/Processed packets thread (outliers) IN[S] = mean: 8.00, deviation: 11.46, outliers: [in_0-mix:38:x4.75]
mix/Processed packets thread (outliers) OUT[S] = mean: 11.00, deviation: 13.93, outliers: [out_1-mix:44:x4.00]
ext-man/Processed packets thread IN[S] = [40]
ext-man/Processed packets thread OUT[S] = [40]
ext-man/Processed packets thread (outliers) IN[S] = mean: 40.00, deviation: 0.00
ext-man/Processed packets thread (outliers) OUT[S] = mean: 40.00, deviation: 0.00
message-router/Processed packets thread IN[S] = [10595, 5304, 5997, 7912, 4613, 4220, 5278, 6825]
message-router/Processed packets thread OUT[S] = [1073]
message-router/Processed packets thread (outliers) IN[S] = mean: 6343.00, deviation: 1955.99, outliers: [in_0-message-router:10595:x1.67]
message-router/Processed packets thread (outliers) OUT[S] = mean: 1073.00, deviation: 0.00
pubsub/Processed packets thread IN[S] = [184, 145, 170, 157, 186, 134, 169, 192]
pubsub/Processed packets thread OUT[S] = [89, 84, 94, 93, 80, 94, 79, 88]
pubsub/Processed packets thread (outliers) IN[S] = mean: 167.00, deviation: 19.24
pubsub/Processed packets thread (outliers) OUT[S] = mean: 87.00, deviation: 5.71
audit-log/Processed packets thread IN[S] = [6939]
audit-log/Processed packets thread OUT[S] = [0]
audit-log/Processed packets thread (outliers) IN[S] = mean: 6939.00, deviation: 0.00
audit-log/Processed packets thread (outliers) OUT[S] = mean: 0.00, deviation: 0.00

wojciech.kapcia@tigase.net commented 2 years ago

2500 connections, plain connect/disconnect

before change:

c2s/Processed packets thread IN=[783, 804, 749, 737, 758, 779, 814, 791, 852, 864, 911, 840, 875, 909, 959, 965, 933, 931, 932, 923, 901, 887, 902, 963, 922, 868, 667, 808, 835, 779, 810, 821, 854, 795, 768, 794, 797, 794, 757, 783]
c2s/Processed packets thread OUT=[521, 531, 495, 496, 503, 520, 539, 522, 567, 580, 602, 558, 586, 603, 637, 639, 620, 621, 621, 612, 603, 585, 603, 639, 10579, 577, 425, 540, 557, 522, 538, 546, 567, 530, 513, 530, 532, 531, 504, 520]
c2s/Processed packets thread (outliers) IN=mean: 840,00, deviation: 71,20, outliers: [in_26-c2s:667:x0,79]
c2s/Processed packets thread (outliers) OUT=mean: 807,00, deviation: 1565,35, outliers: [out_24-c2s:10579:x13,11]
sess-man/Processed packets thread IN=[278, 315, 297, 298, 314, 340, 359, 324, 315, 290, 287, 252, 270, 270, 270, 252, 252, 288, 315, 324, 306, 279, 288, 306, 315, 298, 270, 234, 234, 243, 278, 313, 342, 305, 298, 314, 333, 342, 306, 287, 243, 216, 198, 198, 189, 180, 180, 198, 252, 10257, 315, 306, 2154, 333, 367, 387, 368, 333, 306, 288, 297, 306, 315, 333, 297, 279, 2000, 306, 323, 279, 260, 233, 225, 225, 215, 216, 199, 189, 198, 233]
sess-man/Processed packets thread OUT=[326, 372, 349, 340, 367, 395, 421, 382, 367, 335, 340, 297, 318, 2787, 314, 297, 296, 336, 371, 381, 353, 330, 336, 359, 370, 351, 321, 274, 274, 282, 326, 364, 401, 355, 346, 362, 384, 395, 358, 335, 283, 255, 235, 232, 223, 210, 213, 235, 296, 337, 370, 357, 2841, 391, 432, 455, 430, 388, 354, 338, 347, 362, 365, 391, 348, 325, 210, 354, 375, 323, 304, 274, 264, 263, 251, 255, 7683, 222, 231, 274]
sess-man/Processed packets thread (outliers) IN=mean: 449,00, deviation: 1139,54, outliers: [in_49-sess-man:10257:x22,84]
sess-man/Processed packets thread (outliers) OUT=mean: 482,00, deviation: 900,08, outliers: [out_13-sess-man:2787:x5,78, out_52-sess-man:2841:x5,89, out_76-sess-man:7683:x15,94]
message-router/Processed packets thread IN=[1130, 1158, 1079, 1068, 1093, 1125, 1173, 1139, 1230, 11219, 1312, 1212, 1266, 3781, 1383, 1391, 1346, 1345, 1346, 1331, 1303, 1277, 1304, 1389, 1330, 1253, 956, 1168, 1206, 1127, 1168, 1184, 1232, 1148, 1110, 1147, 16027, 1148, 1093, 1129]
message-router/Processed packets thread OUT=[2470]
message-router/Processed packets thread (outliers) IN=mean: 1895,00, deviation: 2774,61, outliers: [in_9-message-router:11219:x5,92, in_36-message-router:16027:x8,46]
message-router/Processed packets thread (outliers) OUT=mean: 2470,00, deviation: 0,00

with proposed change

c2s/Processed packets thread IN=[862, 905, 943, 916, 912, 922, 941, 920, 930, 929, 968, 920, 879, 873, 834, 878, 789, 795, 776, 822, 779, 768, 755, 769, 824, 785, 774, 822, 846, 838, 820, 791, 816, 873, 848, 864, 833, 888, 838, 847]
c2s/Processed packets thread OUT=[820, 858, 896, 870, 870, 871, 897, 871, 885, 884, 923, 871, 846, 833, 794, 832, 754, 754, 741, 780, 741, 728, 715, 728, 780, 741, 740, 780, 807, 794, 780, 755, 781, 832, 806, 819, 793, 845, 794, 806]
c2s/Processed packets thread (outliers) IN=mean: 852,00, deviation: 57,48, outliers: [in_10-c2s:968:x1,14]
c2s/Processed packets thread (outliers) OUT=mean: 810,00, deviation: 54,82, outliers: [out_10-c2s:923:x1,14]
sess-man/Processed packets thread IN=[403, 442, 441, 428, 441, 455, 468, 429, 391, 351, 351, 338, 338, 338, 338, 364, 364, 429, 481, 533, 520, 507, 481, 494, 494, 429, 391, 338, 299, 286, 286, 287, 299, 312, 338, 377, 403, 455, 442, 416, 417, 416, 455, 442, 429, 416, 429, 442, 494, 533, 572, 533, 2107, 495, 456, 468, 390, 325, 260, 247, 221, 221, 234, 234, 286, 312, 2463, 442, 508, 508, 494, 468, 482, 520, 468, 442, 390, 390, 352, 390]
sess-man/Processed packets thread OUT=[520, 549, 554, 547, 561, 562, 567, 527, 480, 441, 447, 443, 436, 432, 423, 445, 449, 504, 544, 577, 564, 546, 523, 543, 551, 499, 474, 428, 410, 421, 424, 427, 435, 438, 459, 485, 504, 533, 506, 470, 465, 455, 490, 478, 472, 460, 477, 509, 559, 601, 632, 608, 581, 578, 547, 562, 495, 438, 380, 381, 371, 375, 380, 376, 412, 427, 460, 517, 547, 533, 515, 480, 493, 526, 493, 484, 442, 462, 457, 500]
sess-man/Processed packets thread (outliers) IN=mean: 451,00, deviation: 306,34, outliers: [in_52-sess-man:2107:x4,67, in_66-sess-man:2463:x5,46]
sess-man/Processed packets thread (outliers) OUT=mean: 488,00, deviation: 60,39, outliers: [out_50-sess-man:632:x1,30]
message-router/Processed packets thread IN=[1927, 1981, 2064, 2021, 2029, 2017, 2064, 2034, 2049, 2051, 2130, 2056, 1994, 1973, 1892, 1967, 1828, 1826, 1793, 1866, 1808, 1779, 1746, 1777, 1871, 1794, 1800, 1847, 1883, 1870, 1837, 1776, 1821, 1908, 1874, 1906, 1856, 1960, 1881, 1899]
message-router/Processed packets thread OUT=[2481]
message-router/Processed packets thread (outliers) IN=mean: 1911,00, deviation: 100,42, outliers: [in_10-message-router:2130:x1,11]
message-router/Processed packets thread (outliers) OUT=mean: 2481,00, deviation: 0,00

2500 connections, 10 messages send:

before changes:

c2s/Processed packets thread IN=[1207, 1209, 1234, 1151, 1156, 1153, 1126, 1228, 1107, 1142, 1178, 1283, 1259, 1188, 1288, 1270, 1326, 1241, 1319, 1295, 1325, 1304, 1283, 1332, 1405, 1437, 983, 1310, 1247, 1375, 1281, 1267, 1259, 1404, 1337, 1304, 1280, 1267, 1270, 1166]
c2s/Processed packets thread OUT=[1601, 1607, 1628, 1529, 1530, 1506, 1479, 1603, 1462, 1492, 1546, 1661, 1597, 1533, 1649, 1634, 1699, 1603, 1695, 1663, 1694, 1665, 1633, 1682, 11733, 1815, 1197, 1675, 1594, 1752, 1633, 1636, 1616, 1812, 1743, 1704, 1667, 1667, 1662, 1548]
c2s/Processed packets thread (outliers) IN=mean: 1254,00, deviation: 88,55, outliers: [in_25-c2s:1437:x1,15, in_26-c2s:983:x0,78]
c2s/Processed packets thread (outliers) OUT=mean: 1871,00, deviation: 1582,66, outliers: [out_24-c2s:11733:x6,27]
sess-man/Processed packets thread IN=[1039, 1115, 1103, 952, 958, 973, 998, 1006, 885, 812, 690, 721, 699, 808, 837, 788, 835, 914, 1101, 1182, 1273, 1323, 1245, 1255, 1282, 1406, 1208, 1104, 926, 930, 904, 893, 861, 972, 874, 879, 876, 965, 1021, 919, 891, 825, 869, 924, 922, 888, 846, 960, 941, 11022, 1204, 1304, 2507, 1076, 1158, 1192, 1217, 1033, 990, 818, 775, 697, 732, 760, 811, 757, 1537, 928, 1009, 1179, 1087, 1114, 1115, 1185, 1214, 1191, 1109, 1049, 980, 990]
sess-man/Processed packets thread OUT=[708, 749, 757, 641, 662, 689, 701, 706, 626, 597, 502, 534, 520, 3073, 631, 591, 630, 691, 814, 861, 933, 967, 907, 917, 924, 1015, 867, 790, 674, 678, 654, 643, 620, 693, 613, 628, 617, 669, 725, 640, 630, 592, 620, 665, 655, 18363, 613, 693, 665, 752, 838, 921, 3394, 763, 820, 842, 860, 711, 712, 585, 560, 509, 543, 571, 613, 578, 330, 694, 740, 865, 808, 809, 819, 852, 865, 841, 8231, 744, 686, 695]
sess-man/Processed packets thread (outliers) IN=mean: 1141,00, deviation: 1137,95, outliers: [in_49-sess-man:11022:x9,66]
sess-man/Processed packets thread (outliers) OUT=mean: 1086,00, deviation: 2153,06, outliers: [out_45-sess-man:18363:x16,91, out_76-sess-man:8231:x7,58]
message-archive/Processed packets thread IN=[0, 0, 0, 0, 0, 17634, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0]
message-archive/Processed packets thread OUT=[0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0]
message-archive/Processed packets thread (outliers) IN=mean: 440,00, deviation: 2753,11, outliers: [in_5-message-archive:17634:x40,08]
message-archive/Processed packets thread (outliers) OUT=mean: 0,00, deviation: 0,00
message-router/Processed packets thread IN=[3355, 3358, 3446, 3268, 3287, 3292, 3245, 3453, 3200, 13267, 3334, 3564, 3461, 5832, 3544, 3499, 3638, 3429, 3701, 3539, 3642, 3578, 3537, 3603, 3731, 3851, 2846, 3609, 3442, 3740, 3557, 3542, 3509, 3797, 3655, 3634, 18347, 3527, 3504, 3336]
message-router/Processed packets thread OUT=[2471]
message-router/Processed packets thread (outliers) IN=mean: 4167,00, deviation: 2760,29, outliers: [in_9-message-router:13267:x3,18, in_36-message-router:18347:x4,40]
message-router/Processed packets thread (outliers) OUT=mean: 2471,00, deviation: 0,00

after changes:

c2s/Processed packets thread IN=[1178, 1171, 1245, 1191, 1173, 1218, 1222, 1320, 1336, 1296, 1358, 1524, 1475, 1545, 1598, 1620, 1771, 1728, 1591, 1655, 1634, 1555, 1544, 1518, 1447, 1369, 919, 1177, 1264, 1300, 1238, 1278, 1192, 1180, 1149, 1220, 1278, 1223, 1281, 1204]
c2s/Processed packets thread OUT=[1746, 1755, 1778, 1771, 1743, 1819, 1809, 1886, 1935, 1821, 1991, 2131, 2101, 2158, 2224, 2305, 2382, 2305, 2221, 2216, 2223, 2200, 2181, 2171, 2127, 2010, 1549, 1813, 1800, 1908, 1880, 1895, 1864, 1789, 1856, 1835, 1905, 1809, 1894, 1820]
c2s/Processed packets thread (outliers) IN=mean: 1354,00, deviation: 190,79, outliers: [in_16-c2s:1771:x1,31, in_26-c2s:919:x0,68]
c2s/Processed packets thread (outliers) OUT=mean: 1965,00, deviation: 198,37, outliers: [out_16-c2s:2382:x1,21, out_26-c2s:1549:x0,79]
sess-man/Processed packets thread IN=[1067, 1097, 1174, 1203, 1162, 1256, 1236, 1263, 1253, 1153, 1231, 1263, 1231, 1192, 1197, 1217, 1196, 1180, 1138, 1138, 1107, 1092, 1066, 1115, 1091, 1094, 1122, 1068, 1090, 1185, 1211, 1232, 1224, 1171, 1245, 1160, 1221, 1112, 1145, 1056, 984, 967, 927, 897, 912, 884, 885, 945, 990, 1003, 1094, 1195, 2510, 1265, 1318, 1367, 1473, 1438, 1390, 1391, 1418, 1401, 1392, 1358, 1344, 1230, 2002, 1067, 1040, 1044, 964, 940, 912, 897, 874, 931, 934, 958, 1040, 1061]
sess-man/Processed packets thread OUT=[1191, 1206, 1262, 1287, 1275, 1292, 1214, 1205, 1144, 1086, 1129, 1176, 1143, 1081, 1060, 1072, 1098, 1086, 1036, 1015, 990, 961, 965, 1025, 1028, 1038, 1074, 1063, 1125, 1234, 1257, 1273, 1224, 1206, 1231, 1178, 1171, 1030, 1017, 921, 850, 839, 841, 832, 844, 832, 868, 967, 1026, 1059, 1104, 1159, 1164, 1193, 1252, 1285, 1326, 1304, 1279, 1309, 1352, 1350, 1310, 1268, 1238, 1205, 989, 1042, 957, 906, 813, 763, 753, 768, 781, 841, 878, 962, 1095, 1173]
sess-man/Processed packets thread (outliers) IN=mean: 1166,00, deviation: 232,30, outliers: [in_52-sess-man:2510:x2,15, in_66-sess-man:2002:x1,72]
sess-man/Processed packets thread (outliers) OUT=mean: 1085,00, deviation: 162,69, outliers: [out_72-sess-man:753:x0,69]
message-archive/Processed packets thread IN=[0, 0, 0, 0, 0, 15360, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0]
message-archive/Processed packets thread OUT=[0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0]
message-archive/Processed packets thread (outliers) IN=mean: 384,00, deviation: 2398,08, outliers: [in_5-message-archive:15360:x40,00]
message-archive/Processed packets thread (outliers) OUT=mean: 0,00, deviation: 0,00
message-router/Processed packets thread IN=[3907, 3920, 4005, 4016, 3988, 4067, 4012, 4184, 4229, 4090, 4350, 4598, 4539, 4557, 4662, 4788, 4936, 4825, 4664, 4668, 4696, 4640, 4582, 4592, 4518, 4381, 3737, 4040, 4002, 4170, 4068, 4045, 3952, 3875, 3984, 3972, 4072, 3918, 4128, 4036]
message-router/Processed packets thread OUT=[2465]
message-router/Processed packets thread (outliers) IN=mean: 4260,00, deviation: 321,68, outliers: [in_16-message-router:4936:x1,16]
message-router/Processed packets thread (outliers) OUT=mean: 2465,00, deviation: 0,00

wojciech.kapcia@tigase.net commented 2 years ago

merged

wojciech.kapcia@tigase.net commented 2 years ago

After merging TTS tests started to fail with missing packets, which would indicated concurrency issues. For how I reverted the change.

wojciech.kapcia@tigase.net batch edited 4 months ago

Name	Previous Value	Current Value
Iterations	empty	tigase-server-8.4.0

wojciech.kapcia@tigase.net added "Related" #1486 4 months ago

wojciech.kapcia@tigase.net batch edited 3 months ago

Name	Previous Value	Current Value
Iterations	tigase-server-8.4.0	tigase-server-8.5.0
Version	tigase-server-8.4.0	tigase-server-8.5.0

Type	New Feature
Priority	Normal
Assignee	wojciech.kapcia@tigase.net
Version	tigase-server-8.5.0

Iterations

tigase-server-8.5.0 Open

#1486 Open

Only 1 thread processes all connection requests and queue overflows

Issue Votes (0)

Watchers (2)

Reference

tigase/_server/server-core#1342