misc
This commit is contained in:
parent
fceea14aa5
commit
7f0627378c
|
@ -70,7 +70,7 @@ proc decodeMsg*(buf: seq[byte]): IdentifyInfo =
|
||||||
var proto = ""
|
var proto = ""
|
||||||
while pb.getString(3, proto) > 0:
|
while pb.getString(3, proto) > 0:
|
||||||
result.protos.add(proto)
|
result.protos.add(proto)
|
||||||
proto = "" # TODO: do i need to clear it up?
|
proto = ""
|
||||||
|
|
||||||
var observableAddr = newSeq[byte]()
|
var observableAddr = newSeq[byte]()
|
||||||
if pb.getBytes(4, observableAddr) > 0: # attempt to read the observed addr
|
if pb.getBytes(4, observableAddr) > 0: # attempt to read the observed addr
|
||||||
|
|
|
@ -55,7 +55,8 @@ type
|
||||||
|
|
||||||
method readExactly*(s: TestLsStream,
|
method readExactly*(s: TestLsStream,
|
||||||
pbytes: pointer,
|
pbytes: pointer,
|
||||||
nbytes: int): Future[void] {.async, gcsafe.} =
|
nbytes: int):
|
||||||
|
Future[void] {.async, gcsafe.} =
|
||||||
case s.step:
|
case s.step:
|
||||||
of 1:
|
of 1:
|
||||||
var buf = newSeq[byte](1)
|
var buf = newSeq[byte](1)
|
||||||
|
@ -101,7 +102,8 @@ type
|
||||||
|
|
||||||
method readExactly*(s: TestNaStream,
|
method readExactly*(s: TestNaStream,
|
||||||
pbytes: pointer,
|
pbytes: pointer,
|
||||||
nbytes: int): Future[void] {.async, gcsafe.} =
|
nbytes: int):
|
||||||
|
Future[void] {.async, gcsafe.} =
|
||||||
case s.step:
|
case s.step:
|
||||||
of 1:
|
of 1:
|
||||||
var buf = newSeq[byte](1)
|
var buf = newSeq[byte](1)
|
||||||
|
|
Loading…
Reference in New Issue