Commit Graph

1167 Commits

Author SHA1 Message Date
Robinson
b942c691fc
Changed aeron connections from MDC (similar to udp multicast), to single and unique connections. Fixed issues with duplicate handshake messages. Fixed issues when trying to connect too quickly. Sped up handshake a LOT when multiple clients are connecting. Dynamic class registrations (server-side only) broken 2022-07-29 04:52:11 +02:00
Robinson
3ef3d28d24
Removed coroutines from parts of the networking message processing. 2022-07-27 00:20:34 +02:00
Robinson
5c59a142ff
Updated version 2022-07-17 23:59:35 -04:00
Robinson
72b95b5cbe
Connection retries are SLIGHTLY slower than the aeron driver timeout. 2022-07-17 23:12:06 -04:00
Robinson
9073769e15
Better Logging during the connection handshake 2022-07-17 23:08:01 -04:00
Robinson
14aa087eda
Network dispatcher is now it's own thread pool, separate from the standard kotlin coroutine dispatcher (this was to prevent thread starvation) 2022-07-17 23:05:32 -04:00
Robinson
6ebd4afa90
Code cleanup. Aeron counters can now return null 2022-07-17 23:04:41 -04:00
Robinson
fb0e973cbf
Cleaned up comments surrounding the Aeron conductor thread factories 2022-07-17 23:03:53 -04:00
Robinson
f24b73f497
Exposed streamId, added better logging 2022-07-17 23:03:19 -04:00
Robinson
a552eb5fa7
Handshake now uses coroutines. Exposed Aeron init(), so it can be called externally to connect()/bind() methods 2022-07-17 23:02:52 -04:00
Robinson
d22bcb29ca
Formatting 2022-07-17 23:01:54 -04:00
Robinson
bfb0eff14b
Added support for shutdown actions in unit tests if the test takes too long 2022-07-17 23:01:46 -04:00
Robinson
6b5d9ff698
Working on tests for small changes in ipv4/6 2022-07-16 10:26:47 -04:00
Robinson
85efa25f0a
Fixed unit tests for suspending functions 2022-07-16 10:26:12 -04:00
Robinson
00b426fa18
Changed default socket options to 2mb 2022-07-16 10:25:37 -04:00
Robinson
440512aedc
AeronDriver now uses suspend instead of blocking 2022-07-16 10:25:15 -04:00
Robinson
c30e2cde4c
Better support for how we free resources on connection close 2022-07-15 08:15:40 -04:00
Robinson
0e652c2331
Added backlock info to aeron 2022-07-15 01:04:35 -04:00
Robinson
9eb0bbee5f
Added suspend to initEndPoint 2022-07-15 00:59:17 -04:00
Robinson
165cfb9d7e
Cleaned up logging 2022-07-15 00:57:48 -04:00
Robinson
995f0b1795
Added toString 2022-07-15 00:57:32 -04:00
Robinson
21a6eceebd
Pulled out the aeron context into its own class 2022-07-13 22:57:40 -04:00
Robinson
0b09073a4c
Tweak unit tests 2022-07-13 22:54:50 -04:00
Robinson
7e60f6b64b
Code formatting 2022-07-13 22:54:22 -04:00
Robinson
e1db5c42a5
Removed DYNAMIC aeron control mode 2022-07-13 22:53:43 -04:00
Robinson
c8d9573bb9
code format 2022-07-13 22:53:25 -04:00
Robinson
6a466ae88a
Fixed errors with allocator memory leaks, added validation when server closes 2022-07-13 22:53:09 -04:00
Robinson
1d35827d16
added support for allocator size checks 2022-07-13 22:49:25 -04:00
Robinson
5b8268b2ea
compiler warnings 2022-07-12 22:21:59 -04:00
Robinson
3a43dea3ad
Added driver backlock information, cleaned how pub/sub are added to areon 2022-07-12 11:02:11 -04:00
Robinson
3893a9be5a
Added starting the aeron driver if necessary when clients are reconnecting 2022-07-12 10:56:47 -04:00
Robinson
2c1155943e
Updated library 2022-07-03 13:13:44 +02:00
Robinson
ceb5fe208a
Inverted close check 2022-07-03 13:13:38 +02:00
Robinson
aea56477fa
Updated version 2022-06-29 21:56:35 +02:00
Robinson
55e777860b
Fixed streamed data chunk mis-alignment. 2022-06-29 21:56:12 +02:00
Robinson
1a6ac7048b
Random stream ID is unique per JVM now 2022-06-29 20:08:35 +02:00
Robinson
fafcb30e1a
Updated version 2022-06-29 19:38:29 +02:00
Robinson
09f367963f
Fixed race condition when we reassemble streaming/chunked data. 2022-06-29 19:38:10 +02:00
Robinson
683abcbe59
Updated version 2022-06-29 17:30:28 +02:00
Robinson
58eb8c2300
suspending cache addition for RMI waiters 2022-06-29 16:57:31 +02:00
Robinson
7370ae15e9
Separated ping and roundtrip message unit tests 2022-06-29 16:39:27 +02:00
Robinson
61aa509a17
Stream and Session ID allocation cannot be re-used so quickly, as ALL other IDs must first be used, before a previously used ID is reused. 2022-06-29 16:37:47 +02:00
Robinson
c6c3c4cc2e
Updated version 2022-06-27 15:32:00 +02:00
Robinson
f228bd1de3
Changed how handshake connection errors are managed 2022-06-27 15:31:40 +02:00
Robinson
da4dc4d9c9
Better handshake control during generic exceptions 2022-06-27 01:45:10 +02:00
Robinson
16119bdf7d
updated version 2022-06-27 01:43:50 +02:00
Robinson
3e092ffd54
Formatting and logging cleanup 2022-06-27 01:43:29 +02:00
Robinson
4a0357d92b
Added internal closeBlocking 2022-06-27 00:10:48 +02:00
Robinson
d734c2555a
Formatting 2022-06-26 23:49:56 +02:00
Robinson
cccb3b65ae
Added this qualifier 2022-06-26 23:49:49 +02:00