|
@@ -72,15 +72,11 @@ protected:
|
|
|
uint16_t data = tcp.urg_ptr();
|
|
|
protocol.receive((uint8_t *)(&data));
|
|
|
tcp.urg_ptr(0);
|
|
|
- innerSenderMutex.lock();
|
|
|
innerSender.send(pdu);
|
|
|
- innerSenderMutex.unlock();
|
|
|
} else {
|
|
|
// uint16_t urg = tcp.urg_ptr();
|
|
|
// tcp.urg_ptr(0);
|
|
|
- innerSenderMutex.lock();
|
|
|
innerSender.send(pdu);
|
|
|
- innerSenderMutex.unlock();
|
|
|
}
|
|
|
return true;
|
|
|
}
|
|
@@ -97,16 +93,12 @@ protected:
|
|
|
virtual bool handleChannelFromInner(Tins::PDU &pdu) {
|
|
|
Tins::TCP &tcp = pdu.rfind_pdu<Tins::TCP>();
|
|
|
if constexpr (PASSIVE) {
|
|
|
- outerSenderMutex.lock();
|
|
|
outerSender.send(pdu);
|
|
|
- outerSenderMutex.unlock();
|
|
|
} else {
|
|
|
uint16_t data = 0;
|
|
|
protocol.send((uint8_t *)(&data));
|
|
|
tcp.urg_ptr(data);
|
|
|
- outerSenderMutex.lock();
|
|
|
outerSender.send(pdu);
|
|
|
- outerSenderMutex.unlock();
|
|
|
}
|
|
|
return true;
|
|
|
}
|