diff --git a/src/impl/dtlstransport.cpp b/src/impl/dtlstransport.cpp index caad9c710..e2c389bf8 100644 --- a/src/impl/dtlstransport.cpp +++ b/src/impl/dtlstransport.cpp @@ -53,7 +53,8 @@ DtlsTransport::DtlsTransport(shared_ptr lower, certificate_ptr cer verifier_callback verifierCallback, state_callback stateChangeCallback) : Transport(lower, std::move(stateChangeCallback)), mMtu(mtu), mCertificate(certificate), mFingerprintAlgorithm(fingerprintAlgorithm), mVerifierCallback(std::move(verifierCallback)), - mIsClient(lower->role() == Description::Role::Active) { + mIsClient(lower->role() == Description::Role::Active), + mIncomingQueue(RECV_QUEUE_LIMIT, message_size_func) { PLOG_DEBUG << "Initializing DTLS transport (GnuTLS)"; @@ -380,7 +381,8 @@ DtlsTransport::DtlsTransport(shared_ptr lower, certificate_ptr cer verifier_callback verifierCallback, state_callback stateChangeCallback) : Transport(lower, std::move(stateChangeCallback)), mMtu(mtu), mCertificate(certificate), mFingerprintAlgorithm(fingerprintAlgorithm), mVerifierCallback(std::move(verifierCallback)), - mIsClient(lower->role() == Description::Role::Active) { + mIsClient(lower->role() == Description::Role::Active), + mIncomingQueue(RECV_QUEUE_LIMIT, message_size_func) { PLOG_DEBUG << "Initializing DTLS transport (MbedTLS)"; @@ -729,7 +731,9 @@ DtlsTransport::DtlsTransport(shared_ptr lower, certificate_ptr cer verifier_callback verifierCallback, state_callback stateChangeCallback) : Transport(lower, std::move(stateChangeCallback)), mMtu(mtu), mCertificate(certificate), mFingerprintAlgorithm(fingerprintAlgorithm), mVerifierCallback(std::move(verifierCallback)), - mIsClient(lower->role() == Description::Role::Active) { + mIsClient(lower->role() == Description::Role::Active), + mIncomingQueue(RECV_QUEUE_LIMIT, message_size_func) { + PLOG_DEBUG << "Initializing DTLS transport (OpenSSL)"; if (!mCertificate)