| 493 | } |
| 494 | |
| 495 | Sender* getSender(sockaddr_in addr) { |
| 496 | const int64_t iSender = sockaddrToint64(addr); |
| 497 | Sender *ss = m_mapSender.count(iSender) ? m_mapSender[iSender] : NULL; |
| 498 | if (ss) { |
| 499 | return ss; |
| 500 | } |
| 501 | ss = new Sender(); |
| 502 | m_mapSender[iSender] = ss; |
| 503 | ss->status = SYN_SENT; |
| 504 | ss->toaddr = addr; |
| 505 | ss->seq = 100000; |
| 506 | ss->synTimeoutEvent.udpPkg = new UdpPkg(); |
| 507 | sendPackage(&addr, PACKAGE_SYN, ss->seq, ss->synTimeoutEvent.udpPkg); |
| 508 | pwrn("NEW SENDER %s", ss->toString().c_str()); |
| 509 | return ss; |
| 510 | } |
| 511 | |
| 512 | |
| 513 | int dataRecv(UdpPkg *udpPkg, Receiver *rs) { |
nothing calls this directly
no test coverage detected