mirror of
https://github.com/vacp2p/nim-quic.git
synced 2026-01-08 21:38:05 -05:00
chore: add newSeqUninit template (#126)
This commit is contained in:
7
quic/helpers/sequninit.nim
Normal file
7
quic/helpers/sequninit.nim
Normal file
@@ -0,0 +1,7 @@
|
||||
{.used.}
|
||||
|
||||
when not declared(newSeqUninit):
|
||||
# newSeqUninit template avoids deprecated errors
|
||||
# for newSeqUninitialized in nim > 2.2
|
||||
template newSeqUninit*[T: byte](len: Natural): seq[byte] =
|
||||
newSeqUninitialized[byte](len)
|
||||
@@ -4,7 +4,7 @@ import bearssl/rand
|
||||
import chronicles
|
||||
import ../../../basics
|
||||
import ../../../udp/congestion
|
||||
import ../../../helpers/openarray
|
||||
import ../../../helpers/[openarray, sequninit]
|
||||
import ../../stream
|
||||
import ../../timeout
|
||||
import ../../connectionid
|
||||
@@ -116,7 +116,7 @@ proc trySend(
|
||||
|
||||
let flags = if isFin: NGTCP2_WRITE_STREAM_FLAG_FIN else: NGTCP2_WRITE_STREAM_FLAG_NONE
|
||||
|
||||
var buffer = newSeqUninitialized[byte](writeBufferSize)
|
||||
var buffer = newSeqUninit[byte](writeBufferSize)
|
||||
var packetInfo: ngtcp2_pkt_info
|
||||
let length = ngtcp2_conn_write_stream_versioned(
|
||||
conn,
|
||||
@@ -238,7 +238,7 @@ proc close*(connection: Ngtcp2Connection): Datagram =
|
||||
ngtcp2_ccerr_default(addr ccerr)
|
||||
|
||||
var packetInfo: ngtcp2_pkt_info
|
||||
var buffer = newSeqUninitialized[byte](writeBufferSize)
|
||||
var buffer = newSeqUninit[byte](writeBufferSize)
|
||||
let length = ngtcp2_conn_write_connection_close_versioned(
|
||||
conn,
|
||||
connection.path.toPathPtr,
|
||||
|
||||
@@ -1,11 +1,11 @@
|
||||
import pkg/ngtcp2
|
||||
import ../../../helpers/openarray
|
||||
import ../../../helpers/[openarray, sequninit]
|
||||
import ../../packetinfo
|
||||
import ../../connectionid
|
||||
import ./errors
|
||||
|
||||
proc toConnectionId(p: ptr byte, length: uint): ConnectionId =
|
||||
var bytes = newSeqUninitialized[byte](length)
|
||||
var bytes = newSeqUninit[byte](length)
|
||||
copyMem(bytes.toPtr, p, length)
|
||||
ConnectionId(bytes)
|
||||
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
import ngtcp2
|
||||
import ../../../helpers/openarray
|
||||
import ../../../helpers/[openarray, sequninit]
|
||||
import ../../stream
|
||||
import ../streamstate/openstate
|
||||
import ./connection
|
||||
@@ -47,7 +47,7 @@ proc onReceiveStreamData(
|
||||
): cint {.cdecl.} =
|
||||
trace "onReceiveStreamData"
|
||||
let state = cast[StreamState](stream_user_data)
|
||||
var bytes = newSeqUninitialized[byte](datalen)
|
||||
var bytes = newSeqUninit[byte](datalen)
|
||||
copyMem(bytes.toUnsafePtr, data, datalen)
|
||||
let isFin = (flags and NGTCP2_STREAM_DATA_FLAG_FIN) != 0
|
||||
if state != nil:
|
||||
|
||||
Reference in New Issue
Block a user