dorjesinpo
dorjesinpo
Retire `ConfigureQueueStream` SDK sends `ConfigureStream` unconditionally. This must be in accord with broker's MessageProperties V2 and configureStream configurations.
Broker can initiate and negotiate connection before `startListening`. In this case, cannot close the channel before newly created cluster `startDispatched` (the latter relies on read callback).
1. Increase Event (batch) size. Keep PUT soft limit 2. Use bsls::BlockGrowth::BSLS_CONSTANT (instead of geometric) for pools 3. Avoid mwcu::MemOutStream while validating in Cluster 4. StorageManager::processReceiptEvent in IO thread (minus...
Messages that have fixed destination (such as PUSH/ACK/Relay PUT/Relay CONFIRM) do not have to go on Cluster thread - it is a bottleneck. Instead, messages can go directly to mqbnet::Channel...
Replacing VirtualStorage collections of GUIDs, one for each app, with one collection per queue. The new collection allocates consecutive memory (vector) if needed to keep apps states for each GUID....
First step in optimizing shutdown logic. The goal of which is to avoid iterating subStreams (preparing for Reliable Broadcast). The `ClusterQueueHelper::d_counterOfUnconfirmed` is all we will need for shutdown in the...
The race: 1. Domain is being reconfigured with one less app 2. Domain saves the new config as `d_config` _before_ proceeding with updating Apps (in Cluster thread) 3. PUT arrives...
Consider 10 consumers with 10 as maxUnconfirmed threshold; combined 100. The delivery to individual consumer starts when number of unconfirmed messages is less or equal to 8 (80% of 10);...
Cannot use `bmqp::SchemaLearner` in both FSM and event threads. Instead, call the leaner in FSM and cache the result (schema) in the generated event.
1) removing queue creation/deletion cbs 2) a step towards converging CSL/legacy