| 545 | } |
| 546 | |
| 547 | inline void ExecuteSend() { |
| 548 | SetHighestThreadPriority(); |
| 549 | |
| 550 | while (true) { |
| 551 | TPacketRef p; |
| 552 | |
| 553 | while (!ToSend_.Dequeue(&p)) { |
| 554 | ToSendEv_.Wait(); |
| 555 | } |
| 556 | |
| 557 | //shutdown |
| 558 | if (!p) { |
| 559 | return; |
| 560 | } |
| 561 | |
| 562 | p->SendTo(S_); |
| 563 | } |
| 564 | } |
| 565 | |
| 566 | inline void Schedule(TPacketRef p) { |
| 567 | ToSend_.Enqueue(p); |
nothing calls this directly
no test coverage detected