| 793 | }; |
| 794 | |
| 795 | IRequesterRef CreateHttpUdpRequester(int port, const IEventsCollectorRef& ec, int physicalCpu) { |
| 796 | TUdpHttp* udpHttp = new TUdpHttp(ec); |
| 797 | IRequesterRef res(udpHttp); |
| 798 | if (!udpHttp->Start(port, physicalCpu)) { |
| 799 | if (port) { |
| 800 | ythrow yexception() << "netliba can't bind port=" << port; |
| 801 | } else { |
| 802 | ythrow yexception() << "netliba can't bind random port"; |
| 803 | } |
| 804 | } |
| 805 | return res; |
| 806 | } |
| 807 | } |
no test coverage detected