Commit Graph

874 Commits

Author SHA1 Message Date
nathan
2b2e185c4a Added settings store for server (in addition to the existing client one) 2020-09-25 19:54:27 +02:00
nathan
49eb431da0 Added test for when the Settings Store is shared 2020-09-25 19:53:41 +02:00
nathan
4fb5ec8517 Code polish. Added extra failure if registration data or public key data is null 2020-09-25 19:52:46 +02:00
nathan
21a84bb9d2 Fixed issue with getting private key (was getting public key instead) 2020-09-25 19:33:15 +02:00
nathan
dfec897f83 connectionTimeoutMS == 0, now (correctly) means wait forever 2020-09-25 18:32:18 +02:00
nathan
6d63401fba Suppressed warnings 2020-09-25 14:51:35 +02:00
nathan
80c4ed6fcc Endpoint custom settingsStore can now be created (instead of just specifying a type) 2020-09-25 14:51:16 +02:00
nathan
816191a5b3 Marked methods final that should not be allowed to be overridden 2020-09-25 14:49:17 +02:00
nathan
1688a11000 Property Store only saves values if they have changed 2020-09-24 10:30:52 +02:00
nathan
9d77245639 Updated version, made LMDB and ChronicleMap explicit 2020-09-24 00:56:58 +02:00
nathan
09eb16f7b5 Added better connection check intervals and connection expiration timeouts 2020-09-23 22:32:29 +02:00
nathan
c869306ebe Added more log information when stopping the AeronMediaDriver. Code polish 2020-09-23 17:09:34 +02:00
nathan
93e406289c Fixed issues with connection handshake with the same computer, on multiple clients. 2020-09-23 17:08:25 +02:00
nathan
8605040819 Safer closing of the aeron client during close process 2020-09-23 16:59:58 +02:00
nathan
9bac797541 code polish 2020-09-23 16:00:47 +02:00
nathan
feb146e8d8 Code polish 2020-09-23 16:00:29 +02:00
nathan
25c20fbf3f Removed timeout for waiting for threads (it should close naturally, otherwise there are problems) 2020-09-23 16:00:16 +02:00
nathan
0b12f36507 improved close() messages/meanings in log 2020-09-23 15:52:45 +02:00
nathan
a4ccbd4b6a Cleaned up comments. Cleaned up forEachConnection() (it's only on server now) 2020-09-22 21:06:31 +02:00
nathan
0a3a08fb8f code polish 2020-09-22 21:05:50 +02:00
nathan
d7eef22091 Added sub/pub retries for both UDP and IPC 2020-09-22 21:01:06 +02:00
nathan
a82c5724f5 Added IPC addPub/Sub retries when aeron is restarted to quickly 2020-09-22 19:42:46 +02:00
nathan
af7e35fcf9 Changed client.send() to return true/false if the message was sent, added client.sendWithException() to throw an exception if the message was unable to be sent 2020-09-22 19:42:04 +02:00
nathan
c6e12e7872 Fixed IPC auto-fallback connection issues 2020-09-22 19:41:19 +02:00
nathan
56fc7e54f1 Fixed IPv6 connection issue 2020-09-22 19:40:56 +02:00
nathan
e035d86ee0 Added forEachConnection() method to run a function callback against each connection 2020-09-22 19:39:24 +02:00
nathan
4008dd6470 wait for close on server 2020-09-22 17:40:39 +02:00
nathan
ed60b68e77 Updated aeron (and other libraries) to fix IPv6 bug (removed class override) 2020-09-22 17:24:35 +02:00
nathan
64a36cb4f8 code polish to more straightforward logic 2020-09-22 17:05:49 +02:00
nathan
7d67cc86b7 Renaming RmiResponseManager for a more general use case (ResponseManager) 2020-09-22 17:05:25 +02:00
nathan
8f39813ccf Renamed RmiWaiter -> ResponseWaiter 2020-09-21 01:42:31 +02:00
nathan
04ca513cc3 suppressed experimental warnings 2020-09-19 22:07:38 +02:00
nathan
7ae3762603 Code polish 2020-09-19 22:07:09 +02:00
nathan
5017437a7a Updated networkutils, code polish 2020-09-19 22:06:54 +02:00
nathan
2429810fd7 Correct usage of no host name 2020-09-19 22:06:30 +02:00
nathan
dc30c18e97 Changed how internal storage operates (major performance improvement), added more types of storage. Set the default to PropertyStore (so settings are saved in a property file) 2020-09-19 19:41:39 +02:00
nathan
50783a7ae9 reworked how stopDriver operates 2020-09-19 19:38:55 +02:00
nathan
1703bc5449 Crypto now works with the raw public/private key byte arrays (instead of encoded bytearrays) 2020-09-19 01:32:32 +02:00
nathan
32d3023814 Serialization can now be extended 2020-09-18 01:12:53 +02:00
nathan
6548ad86e7 Added read(buffer: DirectBuffer), now returns writerBuffer on write 2020-09-18 01:12:25 +02:00
nathan
a8a6a517f7 Added setBuffer(DirectBuffer) method 2020-09-18 01:10:57 +02:00
nathan
bb2a7d8c41 Fixed error typo 2020-09-18 01:09:56 +02:00
nathan
bf457b6d69 Better error when client subscrition cannot connect. Added comments about publications 2020-09-18 01:09:18 +02:00
nathan
b9c0e6b29f Handshake should be using the endpoint store, not the config store 2020-09-16 15:52:25 +02:00
nathan
f9623a616c No longer require KryoExtra to register (normal Kryo is enough) 2020-09-16 14:28:49 +02:00
nathan
b08b7a13cd Simplified SettingsStore, it now uses it's own serializer 2020-09-15 21:17:47 +02:00
nathan
e08d5a3d2b No longer have a dependency on Storage serialization manager 2020-09-15 21:17:18 +02:00
nathan
8af039265b Fixed comment typo 2020-09-15 18:55:28 +02:00
nathan
fd3050bfb4 Updated version info 2020-09-15 17:26:15 +02:00
nathan
f4e451d917 Cleaned up how we interact with the storage system. Simplified storage configuration/init 2020-09-15 17:08:21 +02:00