|
@@ -349,6 +349,10 @@ void SctpTransport::incoming(message_ptr message) {
|
|
|
}
|
|
|
|
|
|
PLOG_VERBOSE << "Incoming size=" << message->size();
|
|
|
+
|
|
|
+ // TODO: There seems to be a possible data race between usrsctp_sendv() and usrsctp_conninput()
|
|
|
+ // As a mitigation, lock the send mutex before calling usrsctp_conninput()
|
|
|
+ std::lock_guard lock(mSendMutex);
|
|
|
usrsctp_conninput(this, message->data(), message->size(), 0);
|
|
|
}
|
|
|
|