Changed streaming payload size (we let aeron manage fragmentation as much as possible, as they do it more efficiently than we can
This commit is contained in:
parent
7394b6abe2
commit
29dec146aa
@ -281,10 +281,9 @@ internal class StreamingManager<CONNECTION : Connection>(private val logger: KLo
|
|||||||
|
|
||||||
// payload size is for a PRODUCER, and not SUBSCRIBER, so we have to include this amount every time.
|
// payload size is for a PRODUCER, and not SUBSCRIBER, so we have to include this amount every time.
|
||||||
// MINOR fragmentation by aeron is OK, since that will greatly speed up data transfer rates!
|
// MINOR fragmentation by aeron is OK, since that will greatly speed up data transfer rates!
|
||||||
var maxPayloadLength = publication.maxPayloadLength()
|
|
||||||
if ((maxPayloadLength * 8) < publication.maxMessageLength()) {
|
// the maxPayloadLength MUST ABSOLUTELY be less that the max size + header!
|
||||||
maxPayloadLength *= 8
|
var maxPayloadLength = publication.maxMessageLength() - 200
|
||||||
}
|
|
||||||
|
|
||||||
val header: ByteArray
|
val header: ByteArray
|
||||||
val headerSize: Int
|
val headerSize: Int
|
||||||
|
Loading…
Reference in New Issue
Block a user