| 487 | } |
| 488 | |
| 489 | bool TUdpHost::Start(const TIntrusivePtr<ISocket>& socket) { |
| 490 | if (S.IsValid()) { |
| 491 | Y_ASSERT(0); |
| 492 | return false; |
| 493 | } |
| 494 | S.Open(socket); |
| 495 | if (!S.IsValid()) |
| 496 | return false; |
| 497 | |
| 498 | if (IBDetection) |
| 499 | IB = CreateIBClientServer(); |
| 500 | |
| 501 | NHPTimer::GetTime(&CurrentT); |
| 502 | UdpHostThread.Start(); |
| 503 | HasStarted.Wait(); |
| 504 | return true; |
| 505 | } |
| 506 | |
| 507 | bool TUdpHost::ProcessIBRequest() { |
| 508 | if (IB.Get()) { |
no test coverage detected