|
@@ -88,7 +88,7 @@ void SctpTransport::Cleanup() {
|
|
|
SctpTransport::SctpTransport(std::shared_ptr<Transport> lower, uint16_t port,
|
|
|
message_callback recvCallback, amount_callback bufferedAmountCallback,
|
|
|
state_callback stateChangeCallback)
|
|
|
- : Transport(lower, std::move(stateChangeCallback)), mPort(port), mProcessor(RECV_QUEUE_LIMIT),
|
|
|
+ : Transport(lower, std::move(stateChangeCallback)), mPort(port), mProcessor(16),
|
|
|
mSendQueue(0, message_size_func), mBufferedAmountCallback(std::move(bufferedAmountCallback)) {
|
|
|
onRecv(recvCallback);
|
|
|
|