Commit Graph

1196 Commits

Author SHA1 Message Date
Robinson
4f63dbc25c
Fixed typo in variable name 2022-08-10 14:34:36 +02:00
Robinson
ecdd90a657
Updated license 2022-08-10 14:34:14 +02:00
Robinson
5a047e2367
Added support for debugging connections 2022-08-10 14:34:09 +02:00
Robinson
90eab30f48
Updated aeron 2022-08-04 03:49:55 +02:00
Robinson
b4b45ba333
commented out/removed unnecessary dependencies 2022-08-04 03:41:42 +02:00
Robinson
f429ca1414
Updated version 2022-08-04 03:39:48 +02:00
Robinson
dad5cd90b0
Network now uses MDC + unique session id's to initiate/create connections. Prevents issues surrounding handshake conflicts. Now uses exclusive publications, also synchronizes on connection when sending data. Fixed issues when binding to IPv6 Wildcard IPs. RMI events will (attempt) to suppress errors when the connection is closed when the RMI waiter times out. 2022-08-04 03:39:14 +02:00
Robinson
8deee6c0a7
Make sure that the global disconnect handler is also called 2022-08-04 00:34:48 +02:00
Robinson
401f29a9a2
Updated version 2022-08-03 01:52:50 +02:00
Robinson
6d519227df
Fixed issues getting the subscription bind address. 2022-08-03 01:52:30 +02:00
Robinson
77957a8943
Updated version 2022-08-03 00:21:30 +02:00
Robinson
d70a7b1847
Fixed aeron directory typo 2022-08-03 00:21:15 +02:00
Robinson
1ad1110bc6
Updated version 2022-08-03 00:08:35 +02:00
Robinson
2e7c79c1c0
Fixed logging for aeron exceptions 2022-08-03 00:08:13 +02:00
Robinson
9b9ed4d569
Updated the number of clients for the multi-client test to 20 2022-08-02 22:49:28 +02:00
Robinson
31cf33cfab
Updated version 2022-08-02 22:44:17 +02:00
Robinson
bfbd33db00
Cleaned up disconnect notification logic 2022-08-02 22:43:44 +02:00
Robinson
325b463c01
Cleaned up connection close events 2022-08-02 21:15:45 +02:00
Robinson
65c7119d55
Increased unit test timeout 2022-08-02 21:15:02 +02:00
Robinson
8bcbce019e
Cleaned up unused close features. 2022-08-02 21:14:54 +02:00
Robinson
736dafafa2
Added ability for the framework to optionally send a close() event to the remote end. This is not guaranteed to run, but is a hint to the remote endpoint what is going on, and to improve disconnect performance. 2022-08-02 21:13:39 +02:00
Robinson
eea68c059a
Moved closeForRestart() to public scope 2022-08-02 13:24:23 +02:00
Robinson
305d410071
Added support for restarting the network driver for the endpoints 2022-08-02 13:10:06 +02:00
Robinson
8e6a4bcf3c
Added support to start/stop the aeron driver 2022-08-02 12:43:05 +02:00
Robinson
20226468c4
Changed Aeron connections from MDC -> "normal" (so the network connections are initialized more like a standard UDP connection would be, instead of the more complicated MDC method 2022-08-02 12:11:36 +02:00
Robinson
d5397dde7b
Fixed comments. lowered poll frequency - changed function name 2022-08-02 12:04:09 +02:00
Robinson
ecdb762274
Removed un-needed 'suspend' modifiers 2022-08-01 22:13:07 +02:00
Robinson
c42c160652
Reverted change to handshake kryo (fix for dynamic class registration) 2022-07-29 05:00:41 +02:00
Robinson
70ebcdfdcf
Updated version 2022-07-29 04:52:52 +02:00
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