| 1884 | } |
| 1885 | |
| 1886 | ReliablePacket* FlowTransport::sendReliable(ISerializeSource const& what, const Endpoint& destination) { |
| 1887 | if (self->isLocalAddress(destination.getPrimaryAddress())) { |
| 1888 | sendLocal(self, what, destination); |
| 1889 | return nullptr; |
| 1890 | } |
| 1891 | Reference<Peer> peer = self->getOrOpenPeer(destination.getPrimaryAddress()); |
| 1892 | return sendPacket(self, peer, what, destination, true); |
| 1893 | } |
| 1894 | |
| 1895 | void FlowTransport::cancelReliable(ReliablePacket* p) { |
| 1896 | if (p) |
no test coverage detected