Increment the counter to keep track of how many et_net threads * we have started. This function is scheduled at the start of each * et_net thread using schedule_spawn(). We also check immediately * after incrementing the counter to see whether all of the et_net * threads have started such that we can notify main() to call * start_HttpProxyServer(). */
| 307 | * start_HttpProxyServer(). |
| 308 | */ |
| 309 | void |
| 310 | init_HttpProxyServer() |
| 311 | { |
| 312 | if (eventProcessor.has_tg_started(ET_NET)) { |
| 313 | std::unique_lock<std::mutex> lock(proxyServerMutex); |
| 314 | et_net_threads_ready = true; |
| 315 | lock.unlock(); |
| 316 | proxyServerCheck.notify_one(); |
| 317 | } |
| 318 | |
| 319 | #if TS_USE_QUIC == 1 |
| 320 | if (eventProcessor.has_tg_started(ET_UDP)) { |
| 321 | std::unique_lock<std::mutex> lock(etUdpMutex); |
| 322 | et_udp_threads_ready = true; |
| 323 | lock.unlock(); |
| 324 | etUdpCheck.notify_one(); |
| 325 | } |
| 326 | #endif |
| 327 | } |
| 328 | |
| 329 | void |
| 330 | start_HttpProxyServer() |
nothing calls this directly
no test coverage detected