Robinson
|
5847ad14e3
|
Updated version
|
2021-07-26 20:42:55 +02:00 |
|
Robinson
|
6a7fe7b1dc
|
Added support for filtering aeron driver exceptions, onError listeners are now notified if there is an aeron driver error.
|
2021-07-26 20:40:43 +02:00 |
|
Robinson
|
a4a3057f39
|
Added comments. Fixed onErrorGlobal (it is now a separate name, since the function signatures had issues), made it a unit function instead of method, so it can be passed around
|
2021-07-26 20:18:04 +02:00 |
|
Robinson
|
7908ef2593
|
Fixed comments, tweaked shutdown delay
|
2021-07-26 20:17:03 +02:00 |
|
Robinson
|
388e4bda60
|
connections are now created via a unit function instead of overriding the method.
|
2021-07-09 15:16:12 +02:00 |
|
Robinson
|
c725806727
|
Cleaned up heap vs stack access, fixed ping support, fixed coroutine errors during serialization
|
2021-07-08 14:33:24 +02:00 |
|
Robinson
|
632603c8c7
|
WIP RMI and message performance/ping testing
|
2021-07-07 21:32:36 +02:00 |
|
Robinson
|
33f3ca8ebc
|
Supports the newest version of Aeron. Updated error log usage and notifications. Refactored RMI API (now RMI is accessible via '.rmi' calls). Updated unit tests. Added 'delete' to rmi methods (opposite of 'create').
|
2021-07-07 00:04:47 +02:00 |
|
Robinson
|
b8caa3b7c9
|
WIP JPMS
|
2021-07-02 11:41:05 +02:00 |
|
Robinson
|
ad9729b0ff
|
Added comments
|
2021-07-01 20:15:07 +02:00 |
|
Robinson
|
9d507f1937
|
Added more comments
|
2021-07-01 20:13:54 +02:00 |
|
Robinson
|
649148dc08
|
better error message
|
2021-07-01 09:30:09 +02:00 |
|
Robinson
|
e62f8eba2e
|
Changed line endings to LF from CRLF
|
2021-06-28 15:27:35 +02:00 |
|
Robinson
|
b5f7c109b2
|
Fixed deprecated channel offer method
|
2021-06-27 20:51:58 +02:00 |
|
Robinson
|
ab2af26b48
|
Fixed JPMS object casting
|
2021-05-02 21:56:10 +02:00 |
|
Robinson
|
7c5a935105
|
Added server global RMI delete()
|
2021-05-01 00:19:21 +02:00 |
|
Robinson
|
5196fa2d66
|
updated version
|
2021-04-30 22:42:37 +02:00 |
|
Robinson
|
ef4b76d303
|
Changed scope for onMessage/disconnect/connect/etc callbacks from 'connection' -> 'this'.
|
2021-04-30 22:39:36 +02:00 |
|
Robinson
|
048b780e2f
|
Added tests for restarting a client via client.close() . connection.close() with a onDisconnect listener also works. The instance that started the aeron instance, is the one that cleans it up
|
2021-04-30 21:18:57 +02:00 |
|
Robinson
|
ae53cc333e
|
Moved class registration info to trace
|
2021-04-30 19:52:57 +02:00 |
|
Robinson
|
bfccc6f7a5
|
WIP removeObject
|
2021-04-30 18:22:25 +02:00 |
|
Robinson
|
beb99d42da
|
Removed 'config.enableIpcForLoopback'. it's behavior was rolled into 'enableIpc'
|
2021-04-30 18:22:08 +02:00 |
|
Robinson
|
3a4f4ff4b3
|
removed unnecessary code
|
2021-04-30 18:21:26 +02:00 |
|
Robinson
|
4507cf9f87
|
Removed RemoteObject.close()
|
2021-04-30 18:21:01 +02:00 |
|
Robinson
|
0b95a4503d
|
more info in comments
|
2021-04-30 18:19:46 +02:00 |
|
Robinson
|
dfaf583f4f
|
Added extension function for "eventLoop" dispatch to coroutines
|
2021-04-30 18:15:54 +02:00 |
|
Robinson
|
cffca943f5
|
No longer using coroutines for adding publication/subscription and closing certain calsses. Better aeron error handling/reporting. Better aeron startup/shutdown. The pending connections cache no longer is ThreadSafe, and no longer is protected via RW lock.
|
2021-04-30 18:14:33 +02:00 |
|
Robinson
|
3f016672e6
|
WIP ping mangement
|
2021-04-30 14:58:49 +02:00 |
|
Robinson
|
a3c0d9881a
|
Fixed unnecessary errors when calling "connection.close()" from inside an RMI method.
|
2021-04-30 14:26:04 +02:00 |
|
Robinson
|
e7d13520df
|
Updated kryo comments
|
2021-04-29 19:45:56 +02:00 |
|
Robinson
|
ad06f768f8
|
Fixed state with driver already running during shutdown
|
2021-04-29 13:34:45 +02:00 |
|
Robinson
|
402c5a0ccd
|
Fixed missing Inet4.toAddress conversion
|
2021-04-29 11:19:31 +02:00 |
|
Robinson
|
a3b5cbcc89
|
WIP ping functionality
|
2021-04-29 10:25:25 +02:00 |
|
Robinson
|
7a6926df93
|
Changed handshake write to be THREAD strategy instead of COROUTINE strategy
|
2021-04-29 10:04:53 +02:00 |
|
Robinson
|
47b63173ac
|
Added cloneToNormal , which converts the coroutine strategy -> thread strategy
|
2021-04-29 10:04:02 +02:00 |
|
Robinson
|
1e077c2d98
|
Added ability to add to an endpoint configuration
|
2021-04-29 10:02:22 +02:00 |
|
Robinson
|
2828758fee
|
Updated how to access storage (via a property now)
|
2021-04-29 10:01:07 +02:00 |
|
Robinson
|
f5ab178948
|
Suppressed errors when starting/stopping an endpoint VERY quickly (as usually done in unit tests). These warnings, while noramlly VERY important, can be safely ignored.
|
2021-04-29 09:59:42 +02:00 |
|
Robinson
|
841b9959ac
|
Fixed issues when reconnecting. 'onDisconnect' is now guaranteed to be called before 'onConnect'
|
2021-04-29 02:10:34 +02:00 |
|
Robinson
|
6d70313687
|
aeron driver is now properly start during reconnect event
|
2021-04-29 01:48:29 +02:00 |
|
Robinson
|
52d5f4b189
|
proper inet address resolution
|
2021-04-29 01:48:04 +02:00 |
|
Robinson
|
8068b1a5df
|
Added version info
|
2021-04-29 01:47:53 +02:00 |
|
Robinson
|
37fbfe6ac1
|
cleaned up stacktrace, code polish
|
2021-04-29 01:47:25 +02:00 |
|
Robinson
|
9c7fa4de8d
|
MediaDriver + aeron states are now reset on close
|
2021-04-29 01:46:18 +02:00 |
|
Robinson
|
36318690a2
|
Cleaned up RMI response manager object construction
|
2021-04-28 11:19:55 +02:00 |
|
Robinson
|
e747b52373
|
WIP ping infrastructure
|
2021-04-28 11:19:13 +02:00 |
|
Robinson
|
32cd2822ee
|
Changed session ID -> ID for RandomIdAllocator.kt
|
2021-04-28 11:18:34 +02:00 |
|
Robinson
|
31f559accc
|
updated version
|
2021-04-27 14:20:51 +02:00 |
|
Robinson
|
ad1c2450b9
|
Fixed deprecated methods
|
2021-04-27 14:19:56 +02:00 |
|
Robinson
|
8d47b8b0b8
|
Fixed missing parameter
|
2021-04-27 14:17:19 +02:00 |
|
Robinson
|
c706969005
|
Fixed package name
|
2021-04-27 14:00:31 +02:00 |
|
Robinson
|
f53e705432
|
Fixed "fast" reconnect issues, where sometimes the media driver would be disconnected from the aeron driver
|
2021-04-27 13:57:47 +02:00 |
|
Robinson
|
9e0bc0da3e
|
Fixed stackframe index
|
2021-04-27 13:31:54 +02:00 |
|
Robinson
|
ed76209925
|
Changed RMI object callback to only be "this", instead of passing the (internal) rmiID around. The RMI-ID is used for internal rmi messages, so that a request+response can be paired.
|
2021-04-27 13:31:18 +02:00 |
|
Robinson
|
09087b470a
|
Stack frame cleanup removes ALL coroutines
|
2021-04-27 10:55:29 +02:00 |
|
Robinson
|
bb245e2f8e
|
Code cleanup
|
2021-04-27 10:28:36 +02:00 |
|
Robinson
|
29b0ee8199
|
Fixed connection filter on connect
|
2021-04-27 10:28:18 +02:00 |
|
Robinson
|
ef598b0b72
|
WIP connection setup
|
2021-04-27 10:27:03 +02:00 |
|
Robinson
|
1765b4e367
|
Fixed server-client pair connection address info
|
2021-04-27 10:26:37 +02:00 |
|
Robinson
|
7d39f70450
|
Removed filter notify for IPC connections
|
2021-04-27 10:26:04 +02:00 |
|
Robinson
|
ea857da883
|
Better stack frame cleanup
|
2021-04-27 10:25:19 +02:00 |
|
Robinson
|
f3637219c3
|
Code polish/cleanup
|
2021-04-25 22:01:50 +02:00 |
|
Robinson
|
bcbdaf167f
|
code/library cleanup
|
2021-04-24 00:09:11 +02:00 |
|
Robinson
|
dccc46d16b
|
Updated to kotlin
|
2021-04-24 00:07:49 +02:00 |
|
Robinson
|
a229b85ee7
|
Rename .java to .kt
|
2021-04-24 00:07:48 +02:00 |
|
Robinson
|
5a7b6a159a
|
Proper null checking
|
2021-04-24 00:07:26 +02:00 |
|
Robinson
|
3a9d63858f
|
Converted to kotlin
|
2021-04-24 00:06:43 +02:00 |
|
Robinson
|
6f3615d211
|
Rename .java to .kt
|
2021-04-24 00:06:42 +02:00 |
|
Robinson
|
f60ec9d10f
|
updated libraries, added updates
|
2021-04-09 20:24:45 +02:00 |
|
Robinson
|
bb77a17158
|
Removed unchecked cast suppression
|
2021-04-02 15:15:01 +02:00 |
|
Robinson
|
ec5dd55fee
|
Moved unused code
|
2021-01-15 14:11:33 +01:00 |
|
Robinson
|
7ecb920ed0
|
Added type definitions and github links
|
2021-01-15 02:29:04 +01:00 |
|
Robinson
|
bda3082d41
|
Set field access scope to private
|
2021-01-15 02:21:21 +01:00 |
|
Robinson
|
47e202901a
|
remove duplicated key strings, now uses common fields
|
2021-01-15 02:19:09 +01:00 |
|
nathan
|
96b4a78104
|
Updated to use the object pool. Release 5.0!
|
2020-10-06 02:08:12 +02:00 |
|
nathan
|
df1eab1509
|
Removed stack trace from internal logging on client handshake errors (they mean nothing, other than it's an exception and the message)
|
2020-09-29 21:43:39 +02:00 |
|
nathan
|
62dff03df9
|
Fixed issue with multi-client handshakes. Made error messages cleaner
|
2020-09-29 16:05:17 +02:00 |
|
nathan
|
f4401d425c
|
Formatting
|
2020-09-29 15:26:40 +02:00 |
|
nathan
|
61260b02ce
|
Updated comments
|
2020-09-29 14:38:06 +02:00 |
|
nathan
|
e5c35ea24e
|
Async allocation and branch cleanup
|
2020-09-29 14:36:18 +02:00 |
|
nathan
|
cc9742fe14
|
Handshake validate is only done based on the one-time key (instead off session id) as the session ID was shared in some situations (the aeron session ID is not guarateed to be unique, unless it is manually set)
|
2020-09-28 16:30:38 +02:00 |
|
nathan
|
4dc58f2485
|
exposed secureRandom
|
2020-09-28 16:12:50 +02:00 |
|
nathan
|
1040cf14f5
|
Crypto code polish. wrapped crypto stuff in try/catch
|
2020-09-25 19:54:49 +02:00 |
|
nathan
|
2b2e185c4a
|
Added settings store for server (in addition to the existing client one)
|
2020-09-25 19:54:27 +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
|
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
|
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
|
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 |
|