Commit Graph

9 Commits

Author SHA1 Message Date
Evgeny Poberezkin
7a25174866 fix journal mode, tests pass 2024-12-16 22:25:21 +00:00
Evgeny Poberezkin
14aed2dda7 refactor 2024-12-15 16:38:09 +00:00
Evgeny Poberezkin
a319a377a1 types for store 2024-12-15 11:19:36 +00:00
Evgeny Poberezkin
dfa77a1efa remove recipientId from QueueRec, statePath from queue object 2024-12-13 18:29:23 +00:00
Evgeny Poberezkin
1bdf8bc3e3 parameterize journal store for queue storage 2024-12-12 09:06:10 +00:00
Evgeny
d3275cef48 smp server: combine messages and queue storage to optimise performance, prevent race condition when deleting queue and to avoid "orphan" messages. (#1395)
* smp server: combine queue and message store into one class (WIP)

* keep deleted queue tombstones to prevent race conditions and errors when restoring

* move store log from server to store implementations

* STMQueueStore type class

* fix store closed when messages expired, handle store writing errors

* types

* version

* fix recovery from missing write journal, tests

* version
2024-11-07 08:09:11 +00:00
Evgeny
870a60fc5d smp server: reduce memory usage when starting, all servers: prevent losing state on termination while compacting state (#1385)
* smp server: reduce memory usage when starting

* servers: prevent losing state when compacting is incomplete (terminated abnormally)

* fix test

* fix/refactor

* message

* remove .bak

* simpler
2024-10-25 15:39:59 +01:00
Evgeny
f871f20172 smp server: fix notification delivery (#1350)
* .401

* stats for undelivered notifications

* logs, stats

* control port show ntf client IDs

* check that Ntf client is still current and that queue is not full, drop notifications otherwise

* prevent losing notifications when client is not current or queue full

* add log when no notifications, remove some logs

* reduce STM transaction

* revert version change
2024-10-07 09:01:28 +01:00
Evgeny
80d3518d55 tests: store log (#1348)
* 6.1.0.4

* tests: store log

* random

* more tests
2024-10-06 21:21:08 +01:00