Evgeny Poberezkin
b248f28efc
remove fromIntegral
2024-01-08 21:30:21 +00:00
Evgeny Poberezkin
72f33c6c2d
style
2024-01-08 21:25:39 +00:00
Evgeny Poberezkin
9016344ae5
remove unsafe
2024-01-08 21:15:57 +00:00
Evgeny Poberezkin
6abb6014e9
comment
2024-01-08 21:12:43 +00:00
Evgeny Poberezkin
2155e9ea54
builder
2024-01-08 21:11:04 +00:00
Evgeny Poberezkin
d2ea913feb
sized builder
2024-01-08 21:10:15 +00:00
Evgeny Poberezkin
0e0a5fe6c0
tests
2024-01-08 20:14:34 +00:00
Evgeny Poberezkin
94ce06e1e9
reduce delay
2024-01-08 19:25:15 +00:00
Evgeny Poberezkin
032191bd20
remove logs
2024-01-08 19:12:42 +00:00
Evgeny Poberezkin
3c0c890bcb
more delay, less worker delay
2024-01-08 19:06:14 +00:00
Evgeny Poberezkin
cc2c1e0dae
delays
2024-01-08 18:52:55 +00:00
Evgeny Poberezkin
58a188376b
debug2
2024-01-08 16:51:59 +00:00
Evgeny Poberezkin
34e8b9dbe7
debug test
2024-01-08 16:21:52 +00:00
Evgeny Poberezkin
e1518f06e2
use concat
2024-01-08 14:21:28 +00:00
Evgeny Poberezkin
6a753af499
do not materialize builder
2024-01-08 13:34:28 +00:00
Evgeny Poberezkin
2303f278fd
increase timeout in test
2024-01-08 13:13:25 +00:00
Evgeny Poberezkin
27d77e2d76
refactor
2024-01-08 10:02:24 +00:00
Evgeny Poberezkin
e9663b3371
refactor
2024-01-07 22:47:29 +00:00
Evgeny Poberezkin
85e9b74252
use Builder for batching commands
2024-01-07 22:19:06 +00:00
Evgeny Poberezkin
55808b0c82
5.5.0.4
v5.5.0-beta.4
2024-01-06 11:40:15 +00:00
Evgeny Poberezkin
fa794d7878
agent: send errors on subscription timeouts ( #937 )
...
* agent: debug server reconnections
* update lock only if it has the same name already
* report subscription timeouts
* clean up
2024-01-05 17:36:57 +00:00
Alexander Bondarenko
34056b9d7b
xftp-server: add control port ( #951 )
...
Co-authored-by: Evgeny Poberezkin <2769109+epoberezkin@users.noreply.github.com >
2024-01-05 17:36:19 +00:00
Alexander Bondarenko
87cec9ad16
control: try deleting from senders first ( #950 )
2024-01-05 17:07:29 +00:00
Evgeny Poberezkin
2488cf1e3a
agent: restart worker when it terminated ( #948 )
...
* agent: restart worker when it terminated
* comment
* remove writeTMVar
* remove writeTMVar 2
* remove writeTMVar 3
2024-01-05 14:22:26 +00:00
Alexander Bondarenko
b4495bb4f0
xftp-server: fix stats ( #944 )
...
* xftp-server: fix stats
* count file expirations
* rename
* simplify
* check files size
* store and fix fileSize check
* do
---------
Co-authored-by: Evgeny Poberezkin <2769109+epoberezkin@users.noreply.github.com >
2024-01-05 11:30:27 +00:00
Alexander Bondarenko
6d4834f306
core: publish sendMessagesB ( #949 )
2024-01-04 15:37:13 +00:00
Evgeny Poberezkin
37d30240fd
5.5.0.3
v5.5.0-beta.3
2024-01-03 20:36:54 +00:00
Alexander Bondarenko
8fd5e9f25a
servers: make writeStoreLogRecord atomic ( #946 )
...
* servers: make writeStoreLogRecord atomic
* comment
---------
Co-authored-by: Evgeny Poberezkin <2769109+epoberezkin@users.noreply.github.com >
2024-01-03 20:29:09 +00:00
Alexander Bondarenko
36298f2cea
smp-server: update stats ( #943 )
...
* smp-server: check queue balance in stats vs store
* smp-server: add msgExpired stats
* add msgExpired stats
* split expire/stats transactions
* count and pass msgExpired explicitly
* save/load qCount and use it for checking store
2024-01-02 21:24:17 +00:00
Evgeny Poberezkin
f954c2cd17
rfc: SMP proxies key scope and other considerations ( #927 )
...
* rfc: SMP proxies key scope and other considerations
* split line
2023-12-28 23:29:51 +00:00
Evgeny Poberezkin
d0588bd0ac
5.5.0.2
v5.5.0-beta.2
2023-12-27 20:35:56 +00:00
Alexander Bondarenko
7eb7bd5e81
xftp-server: add inactiveClientExpiration ( #936 )
...
* xftp-server: add inactiveClientExpiration
* fix test config
* add test
* add xftpPing
* switch to PCEUnexpectedResponse
* remove watchdog when server quits
* rename, loop
---------
Co-authored-by: Evgeny Poberezkin <2769109+epoberezkin@users.noreply.github.com >
2023-12-27 20:31:19 +00:00
Alexander Bondarenko
bb4de2e63c
ci: limit releases to GHC-9.6.3 ( #938 )
2023-12-27 15:55:42 +00:00
spaced4ndy
22e1932372
xftp, ntf: refactor, reuse workers abstractions ( #935 )
...
* xftp: refactor, reuse workers abstractions (wip, test fails)
* rename
* refactor (tests pass)
* refactor2
* linebreaks
* do
* reuse worker abstractions for notifications
---------
Co-authored-by: Evgeny Poberezkin <2769109+epoberezkin@users.noreply.github.com >
2023-12-27 13:02:08 +04:00
spaced4ndy
e43e4860b9
xftp: file workers cycle through pending files based on retries count (limit number of iterations per work item to prevent stuck delivery) ( #930 )
...
* xftp: test file reception - shouldn't get stuck if file is deleted on server
* comment
* expiration test
* approach
* wip
* sort by retries in other works, revert some diff
* revert diff
* modify tests
* refactor
* refactor
* remove prints
* apply to other workers
* remove import
* comment
* refactor
* revert queue size
* fix test
* rename
* comment, correct number of retries
---------
Co-authored-by: Evgeny Poberezkin <2769109+epoberezkin@users.noreply.github.com >
2023-12-26 22:20:25 +00:00
Alexander Bondarenko
efe7ce27e7
control: add delete command ( #933 )
...
* control: add delete command
* logDeleteQueue only when found
* use default StrEncoding for CPDelete arg
* move stats update from main transaction
* use size
* stabilize AUTH timing tests
* more iterations
---------
Co-authored-by: Evgeny Poberezkin <2769109+epoberezkin@users.noreply.github.com >
2023-12-26 20:20:12 +00:00
Evgeny Poberezkin
577e3cf14d
agent: add server msg IDs to agent logs, disable 2 tests ( #934 )
...
* agent: race when using agent via TCP
* remove logs
* enable tests
* comments
* use different databases for different clients
* enable all tests
2023-12-26 17:50:39 +00:00
Evgeny Poberezkin
7ddeca50e4
agent: mark work items failed ( #931 )
...
* agent: mark work items failed (WIP)
* add tests, created_at
* getWorkItem for snd and rcv files
* fix
* tests
* fix
* tests
* test
* tests
* rename
* fix,refactor
* add indexes
* update schema
* do not try to get more work when resuming an existing worker
---------
Co-authored-by: spaced4ndy <8711996+spaced4ndy@users.noreply.github.com >
2023-12-26 17:00:42 +04:00
Evgeny Poberezkin
1e15d56e92
5.5.0.1: fix migration
2023-12-23 16:06:11 +00:00
Evgeny Poberezkin
46056557f8
5.5.0.1: update .cabal
2023-12-23 14:12:20 +00:00
Evgeny Poberezkin
a57066a826
5.5.0.1
2023-12-23 13:42:22 +00:00
Evgeny Poberezkin
2489333c87
agent: use DB to queue async commands and messages ( #929 )
...
* agent: use DB to queue async commands and messages
* fix message delivery, async commands dont work
* fix async commands
* remove comment
* rename
* comment
* balance agent operation
* empty lines
* balance another agent operation
* diff
* worker
* qAddress
* fix incorrect queue ID in v1
* types for queues
* fix test
* update index
2023-12-23 12:59:53 +00:00
Evgeny Poberezkin
fa457d1c25
agent: avoid race condition between worker and supervisor when getting work ( #928 )
2023-12-22 11:12:36 +00:00
Evgeny Poberezkin
1c2604f6a3
agent: background mode for agent NSE ( #924 )
2023-12-22 08:59:07 +00:00
Evgeny Poberezkin
13a60d1d39
use ChaChaDRG as the source of randomness ( #920 )
...
* use ChaChaDRG as the source of randomness
* remove functions using entropy directly
* comment
2023-12-21 00:12:08 +00:00
Evgeny Poberezkin
8c250ebe19
agent: batch sending messages ( #922 )
...
* agent: batch sending messages (attempt 4)
* handle errors in batch sending
* batch attempt 5 (#923 )
* attempt 5
* remove IORefs
* add liftA2 for 8.10 compat
* remove db-related zipping
* traversable
---------
Co-authored-by: IC Rainbow <aenor.realm@gmail.com >
* s/mapE/bindRight/
* name
Co-authored-by: spaced4ndy <8711996+spaced4ndy@users.noreply.github.com >
* comment
Co-authored-by: spaced4ndy <8711996+spaced4ndy@users.noreply.github.com >
* remove unused funcs
---------
Co-authored-by: IC Rainbow <aenor.realm@gmail.com >
Co-authored-by: spaced4ndy <8711996+spaced4ndy@users.noreply.github.com >
2023-12-19 23:01:34 +00:00
Evgeny Poberezkin
7627ce6b69
5.5.0-beta.0: SMP server/agent 5.5, XFTP server 1.2, NTF server 1.7
v5.5.0-beta.0
2023-12-19 16:07:11 +00:00
Alexander Bondarenko
7c27357eb2
server: stop inactive clients without subscriptions, additional monitoring via control port ( #901 )
...
* fix thread labelling points
* add subscription thread labels
* add explicit sections for sockets/sessions/disconnects
* adjust label threads wrt. next blocking op
* WIP: emit event on server finish
So the event log wouldn't be cut short giving
false impression of unterminated sessions.
* add handshake timeout
* hack server socket stats
* trace closeTLS exceptions
* fix build
* clean up disconnectTransport
* make disconnectTransport terminating
Thus, participating in racyAny_ around it.
* trach snd/rcv time separately, log clients as CSV
* add direct client counting/stats
* add csv dump for socket threads
* guard socket threads dump from older GHC
* cut socket thread listing into socket-threads command
* store client creation time for stats
* wrap tls setup in timeout and labels
* server: expire clients without subscriptions
* fix check for subscriptions
* remove excess tracing
* move hardcoded timeouts to configs
* cleanup
* fix tests
* wrap direct queue waits in timeout
* rewrite old TCP wrappers with their SocketState variants
* add testInactiveWithSubs
---------
Co-authored-by: Evgeny Poberezkin <2769109+epoberezkin@users.noreply.github.com >
2023-12-19 15:50:45 +00:00
Evgeny Poberezkin
18be2709f5
use crypton instead of cryptonite ( #919 )
2023-12-13 09:32:44 +00:00
Evgeny Poberezkin
fb113ff008
agent: include queries longer than 5ms into slow queries (was 50ms)
2023-12-12 15:34:49 +00:00