Commit Graph

1188 Commits

Author SHA1 Message Date
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
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