Commit Graph

1617 Commits

Author SHA1 Message Date
Robinson
06b5f30948
Only check if a connection is closed now. We now wait for pub+sub to be "connected" before continuing to build the connection object (so it will always be in the connected state) 2023-07-23 13:39:27 +02:00
Robinson
ad3fdfc64d
Updated text names for idle strategies 2023-07-23 13:30:38 +02:00
Robinson
daec762e30
More specific errors when connection is closed during poll event 2023-07-23 01:20:16 +02:00
Robinson
949a863aca
Fixed instance assignment 2023-07-23 01:17:37 +02:00
Robinson
a087dfa9bd
Faster startup when aeron is already running and we force-allow a driver to be running on startup (usually we don't want this) 2023-07-23 01:17:09 +02:00
Robinson
936a5e2d67
Added ability for subscription to wait for a publication to connect 2023-07-23 01:16:23 +02:00
Robinson
2d8956c78c
Client waits for server publication to connect before continuing. 2023-07-22 14:18:38 +02:00
Robinson
781d530294
added comments 2023-07-21 22:46:41 +02:00
Robinson
ed2ddb239d
Tweaked aeron idle strategies 2023-07-21 22:46:30 +02:00
Robinson
ee558e666d
Added additional idle strategies 2023-07-21 21:16:49 +02:00
Robinson
ed89b634a2
Added comments 2023-07-21 21:16:37 +02:00
Robinson
4e232aa18e
Fixed unit tests shutdown lifecycle ordering 2023-07-21 00:20:47 +02:00
Robinson
c4129f25fa
Updated test app 2023-07-21 00:20:23 +02:00
Robinson
2620a06409
Cleaned up how kryo's are used
Changed idleStrategy
StreamingManager no longer copies bytes (it just uses a pooled kryo instance)
2023-07-21 00:19:31 +02:00
Robinson
7ed474111a
Code cleanup 2023-07-20 22:31:27 +02:00
Robinson
081ee42a2e
removed dead code 2023-07-20 20:41:33 +02:00
Robinson
916ddb857f
fixed comment typo 2023-07-20 20:41:23 +02:00
Robinson
2c0680b513
Simplified setting aeron initial window length 2023-07-20 20:41:13 +02:00
Robinson
0e37689c2c
better logs when retrying the connect sequence 2023-07-20 20:40:43 +02:00
Robinson
7bd653db2a
Better IPC checking 2023-07-20 20:40:17 +02:00
Robinson
e2a4887a19
Changed order of cleanup when done with handshake 2023-07-20 20:39:58 +02:00
Robinson
0e3cc803b2
More detailed logging when in debug mode 2023-07-20 20:39:26 +02:00
Robinson
80d77f2f51
Better lock-step and checks when closing an endpoint 2023-07-20 20:39:12 +02:00
Robinson
d787045149
Updated version 2023-07-16 14:58:01 +02:00
Robinson
94048cfe8f
Added file transport to streaming manager 2023-07-16 14:57:04 +02:00
Robinson
bb026f377b
WIP compression/crypto 2023-07-15 13:12:59 +02:00
Robinson
411a4c54b8
Better error checking. added kryo-exception checking/failures for unittests 2023-07-15 13:12:25 +02:00
Robinson
c4eda86bfe
Optimized how we send data (we use our own stream/block data structures for fragmentation/reassembly. 2023-07-15 13:11:50 +02:00
Robinson
93a7c9008d
Code cleanup and fixed issues when sending non-perfect multiples of our data limit. 2023-07-15 13:07:17 +02:00
Robinson
85d716e572
Changed which data structure is evaluated when saving data 2023-07-15 13:05:57 +02:00
Robinson
5583948961
Added AeronWriter size initialization 2023-07-15 13:05:19 +02:00
Robinson
307b8f558f
Updated comments/dependencies 2023-07-14 13:47:59 +02:00
Robinson
2f8c78ddee
Added ipcMTU to aeron config (it will be the same as the network MTU). This must be the same value, since our internal read/write serialization buffers) 2023-07-14 13:39:08 +02:00
Robinson
215ed20056
Changed wording of chunk -> block 2023-07-14 13:33:36 +02:00
Robinson
290c5bd768
Cleaned up comments 2023-07-12 14:20:04 +02:00
Robinson
09748326c9
Cleaned up crypto management, removed dead code 2023-07-12 14:19:54 +02:00
Robinson
6bf870bd7b
Split kryo TYPES into read/write types, so usage is very clear. Now use a kryo pool for concurrent serialization 2023-07-12 14:08:46 +02:00
Robinson
d3c3bf50d6
Changed applicationId -> appId 2023-07-12 14:04:32 +02:00
Robinson
2f7a365f75
Moved errorCodeName into the driver 2023-07-11 11:50:48 +02:00
Robinson
90830128e6
Removed dead code 2023-07-11 11:50:32 +02:00
Robinson
f1ebd076bf
Removed dependency on aeron-aal (which was only for samples) 2023-07-11 09:48:26 +02:00
Robinson
87b65d061a
Now supports JPMS (kotlin-only 9+ projects must use a workaround) 2023-07-11 00:27:39 +02:00
Robinson
c4ddfe8675
Fixed unnecessary non-null assertions 2023-07-11 00:23:08 +02:00
Robinson
990652288e
Code cleanup 2023-07-11 00:12:09 +02:00
Robinson
4797b7e816
Added port1/2 settings to server + client.
Fixed relevant unit tests
2023-07-11 00:11:58 +02:00
Robinson
ebad4d234b
Fixed driver liveliness checks 2023-07-11 00:02:40 +02:00
Robinson
cba66a6959
Removed SigInt catch. It should be managed by the application, not the library. 2023-07-05 12:53:21 +02:00
Robinson
897db748e7
Removed dead code 2023-07-05 12:52:36 +02:00
Robinson
ce6ffec197
When an endpoint restarts too quickly, wait a more appropriate timeout 2023-07-05 12:52:23 +02:00
Robinson
a8903b2382
Cleaned up close API 2023-07-04 01:00:01 +02:00