| 2456 | } |
| 2457 | |
| 2458 | void StreamingDestination::CleanupExpiredNumConnectionsPerSecond (std::list<uint64_t>& numConnectionsList, uint64_t ts) |
| 2459 | { |
| 2460 | if (numConnectionsList.empty ()) return; |
| 2461 | auto it = numConnectionsList.begin (); |
| 2462 | while (it != numConnectionsList.end ()) |
| 2463 | { |
| 2464 | if (*it + 60 >= ts) break; // 1 minute |
| 2465 | it++; |
| 2466 | } |
| 2467 | numConnectionsList.erase (numConnectionsList.begin (), it); |
| 2468 | } |
| 2469 | } |
| 2470 | } |
nothing calls this directly
no outgoing calls
no test coverage detected