Compare commits
2 Commits
f710419ead
...
83113aea6f
Author | SHA1 | Date |
---|---|---|
|
83113aea6f | |
|
ec15716298 |
|
@ -1 +1 @@
|
||||||
Subproject commit a466930e6e4663b06f173fe692ce46b59138231f
|
Subproject commit 1cf0df255f0f18d2e07fe43943f114a66ddb89e9
|
|
@ -358,7 +358,11 @@ proc connectUnix*(turn: var Turn; path: string; cap: SturdyRef; bootProc: During
|
||||||
buffered = false)
|
buffered = false)
|
||||||
proc socketWriter(packet: seq[byte]): Future[void] =
|
proc socketWriter(packet: seq[byte]): Future[void] =
|
||||||
socket.send cast[string](packet)
|
socket.send cast[string](packet)
|
||||||
const recvSize = 4096
|
const recvSize = 1 shl 18
|
||||||
|
# this is an excessive buffer size but the PEG parser
|
||||||
|
# can only read complete documents
|
||||||
|
# TODO: use a binary protocol and improve that
|
||||||
|
# parser to stream data in chunks
|
||||||
var shutdownRef: Ref
|
var shutdownRef: Ref
|
||||||
let reenable = turn.activeFacet.preventInertCheck()
|
let reenable = turn.activeFacet.preventInertCheck()
|
||||||
let connectionClosedRef = newRef(turn, newShutdownEntity())
|
let connectionClosedRef = newRef(turn, newShutdownEntity())
|
||||||
|
|
Loading…
Reference in New Issue