| 28 | }; |
| 29 | |
| 30 | struct ClientThreadInfo { |
| 31 | msgBus_kafka *mbus; |
| 32 | BMPListener::ClientInfo *client; |
| 33 | Logger *log; |
| 34 | |
| 35 | std::thread *bmp_reader_thread; |
| 36 | int bmp_write_end_sock; |
| 37 | |
| 38 | bool closing; // Indicates if client is closing normally (set when socket is disconnected) |
| 39 | |
| 40 | }; |
| 41 | |
| 42 | /** |
| 43 | * Client thread function |
nothing calls this directly
no outgoing calls
no test coverage detected