mirror of
https://repo.dactyloidae.xyz/Dactyloidae/UXP.git
synced 2026-09-03 14:28:39 +09:00
Be more explicit with a lock.
This commit is contained in:
parent
01de5bc76a
commit
6790fd483b
1 changed files with 3 additions and 2 deletions
|
|
@ -646,6 +646,7 @@ DataChannelConnection::SctpDtlsInput(TransportFlow *flow,
|
|||
}
|
||||
}
|
||||
// Pass the data to SCTP
|
||||
MutexAutoLock lock(mLock);
|
||||
usrsctp_conninput(static_cast<void *>(this), data, len, 0);
|
||||
}
|
||||
|
||||
|
|
@ -1016,7 +1017,7 @@ DataChannelConnection::SendDeferredMessages()
|
|||
bool still_blocked = false;
|
||||
|
||||
// This may block while something is modifying channels, but should not block for IO
|
||||
MutexAutoLock lock(mLock);
|
||||
mLock.AssertCurrentThreadOwns();
|
||||
|
||||
// XXX For total fairness, on a still_blocked we'd start next time at the
|
||||
// same index. Sorry, not going to bother for now.
|
||||
|
|
@ -1923,7 +1924,7 @@ DataChannelConnection::ReceiveCallback(struct socket* sock, void *data, size_t d
|
|||
if (!data) {
|
||||
usrsctp_close(sock); // SCTP has finished shutting down
|
||||
} else {
|
||||
MutexAutoLock lock(mLock);
|
||||
mLock.AssertCurrentThreadOwns();
|
||||
if (flags & MSG_NOTIFICATION) {
|
||||
HandleNotification(static_cast<union sctp_notification *>(data), datalen);
|
||||
} else {
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue