| 1733 | } |
| 1734 | |
| 1735 | void TUdpHost::StepLow() { |
| 1736 | TXUserQueue.DequeueAndRun(); |
| 1737 | ProcessIBSendResults(); |
| 1738 | ProcessStatsRequest(); |
| 1739 | ProcessDebugRequests(); |
| 1740 | size_t i = 0; |
| 1741 | for (;;) { // it should break sometimes |
| 1742 | i++; |
| 1743 | OneStep(); |
| 1744 | |
| 1745 | // reducing "CancelWait" packets between local connections |
| 1746 | if (MaxWaitTime != 0) { |
| 1747 | break; |
| 1748 | } |
| 1749 | if (Connections.IsFinished()) { |
| 1750 | break; |
| 1751 | } |
| 1752 | if (i > 10000) { |
| 1753 | fprintf(stderr, "too many OneStep() call, breaking loop. Adjust timeout?\n"); |
| 1754 | break; |
| 1755 | } |
| 1756 | } |
| 1757 | } |
| 1758 | |
| 1759 | void TUdpHost::WaitLow(float seconds) { |
| 1760 | if (seconds < 1e-3) |
no test coverage detected