MultiChannelCommunication: Use generic handleInput
This way redirection, and any other changes we make to the packetizer/dispatch flow, apply to MultiChannelCommunication as well.pull/35/head
parent
f8355df770
commit
8e2883bca9
|
|
@ -163,14 +163,7 @@ void MultiChannelCommunication::vnetReadTask(size_t vnetIndex) {
|
|||
if(closing)
|
||||
break;
|
||||
|
||||
if(vnetPacketizer->input(payloadBytes)) {
|
||||
for(const auto& packet : vnetPacketizer->output()) {
|
||||
std::shared_ptr<Message> msg;
|
||||
if(!decoder->decode(msg, packet))
|
||||
continue; // Error will have been reported from within decoder
|
||||
dispatchMessage(msg);
|
||||
}
|
||||
}
|
||||
handleInput(*vnetPacketizer, payloadBytes);
|
||||
}
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue