status-im
/
nim-webrtc
mirror of https://github.com/status-im/nim-webrtc.git
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fixes

This commit is contained in:
Tanguy 2023-01-10 15:51:07 +01:00
parent 8622406f18
commit 597b38fcd4
No known key found for this signature in database
GPG Key ID: 7DD8EC6B6CE6C45E
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
webrtc/sctp.nim
View File

@ -101,7 +101,7 @@ proc write*(self: SctpConnection, buf: seq[byte]) {.async.} =
self.sctp.sentConnection = self self.sctp.sentConnection = self
self.sctp.sentAddress = self.address self.sctp.sentAddress = self.address
let sendvErr = self.sctp.usrsctpAwait: let sendvErr = self.sctp.usrsctpAwait:
self.sctpSocket.usrsctp_sendv(addr buf[0], buf.len.uint, self.sctpSocket.usrsctp_sendv(unsafeAddr buf[0], buf.len.uint,
nil, 0, nil, 0, nil, 0, nil, 0,
SCTP_SENDV_NOINFO, 0) SCTP_SENDV_NOINFO, 0)
@ -254,7 +254,7 @@ proc new*(T: typedesc[Sctp], port: uint16 = 9899): T =
proc onReceive(udp: DatagramTransport, address: TransportAddress) {.async, gcsafe.} = proc onReceive(udp: DatagramTransport, address: TransportAddress) {.async, gcsafe.} =
let let
msg = udp.getMessage() msg = udp.getMessage()
data = usrsctp_dumppacket(addr msg[0], uint(msg.len), SCTP_DUMP_INBOUND) data = usrsctp_dumppacket(unsafeAddr msg[0], uint(msg.len), SCTP_DUMP_INBOUND)
if data != nil: if data != nil:
if sctp.isServer: if sctp.isServer:
trace "onReceive (server)", data = data.packetPretty(), length = msg.len(), address trace "onReceive (server)", data = data.packetPretty(), length = msg.len(), address
@ -264,12 +264,12 @@ proc new*(T: typedesc[Sctp], port: uint16 = 9899): T =
if sctp.isServer: if sctp.isServer:
sctp.sentAddress = address sctp.sentAddress = address
usrsctp_conninput(cast[pointer](sctp), addr msg[0], uint(msg.len), 0) usrsctp_conninput(cast[pointer](sctp), unsafeAddr msg[0], uint(msg.len), 0)
else: else:
let conn = await sctp.getOrCreateConnection(udp, address) let conn = await sctp.getOrCreateConnection(udp, address)
sctp.sentConnection = conn sctp.sentConnection = conn
sctp.sentAddress = address sctp.sentAddress = address
usrsctp_conninput(cast[pointer](sctp), addr msg[0], uint(msg.len), 0) usrsctp_conninput(cast[pointer](sctp), unsafeAddr msg[0], uint(msg.len), 0)
let let
localAddr = TransportAddress(family: AddressFamily.IPv4, port: Port(port)) localAddr = TransportAddress(family: AddressFamily.IPv4, port: Port(port))
laddr = initTAddress("127.0.0.1:" & $port) laddr = initTAddress("127.0.0.1:" & $port)