dorkbox/Network
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Code polish with the fragment handler

Browse Source
This commit is contained in:
nathan 2020-08-26 16:24:40 +02:00
parent 986585f073
commit efa032740a
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/dorkbox/network/Server.kt
View File

@ -184,7 +184,7 @@ open class Server<CONNECTION : Connection>(config: ServerConfiguration = ServerC
* Messages larger than this should chunked using an application level chunking protocol. Chunking has better recovery * Messages larger than this should chunked using an application level chunking protocol. Chunking has better recovery
* properties from failure and streams with mechanical sympathy. * properties from failure and streams with mechanical sympathy.
*/ */
val initialConnectionHandler = FragmentAssembler { buffer: DirectBuffer, offset: Int, length: Int, header: Header -> val handshakeHandler = FragmentAssembler { buffer: DirectBuffer, offset: Int, length: Int, header: Header ->
// this is processed on the thread that calls "poll". Subscriptions are NOT multi-thread safe! // this is processed on the thread that calls "poll". Subscriptions are NOT multi-thread safe!
// The sessionId is unique within a Subscription and unique across all Publication's from a sourceIdentity. // The sessionId is unique within a Subscription and unique across all Publication's from a sourceIdentity.
@ -230,7 +230,7 @@ open class Server<CONNECTION : Connection>(config: ServerConfiguration = ServerC
pollCount = 0 pollCount = 0
// this checks to see if there are NEW clients on the handshake ports // this checks to see if there are NEW clients on the handshake ports
pollCount += handshakeSubscription.poll(initialConnectionHandler, 100) pollCount += handshakeSubscription.poll(handshakeHandler, 4)
// this checks to see if there are NEW clients via IPC // this checks to see if there are NEW clients via IPC
// pollCount += ipcHandshakeSubscription.poll(ipcInitialConnectionHandler, 100) // pollCount += ipcHandshakeSubscription.poll(ipcInitialConnectionHandler, 100)