Function ClientThread_cancel

Server/src/client_thread.cpp:30–64

* Client thread cancel * @param arg Pointer to ClientThreadInfo struct */

 * @param arg       Pointer to ClientThreadInfo struct
 */
void ClientThread_cancel(void *arg) {
    ClientThreadInfo *cInfo = static_cast<ClientThreadInfo *>(arg);
    Logger *logger = cInfo->log;

    if (not cInfo->closing) {
        cInfo->closing = true;

        LOG_INFO("Thread terminating due to cancel request.");

        LOG_INFO("Closing client connection to %s:%s", cInfo->client->c_ip, cInfo->client->c_port);

        if (cInfo->client->c_sock) {
            shutdown(cInfo->client->c_sock, SHUT_RDWR);
            close(cInfo->client->c_sock);
        }

        usleep(50000);

        close(cInfo->client->pipe_sock);
        close(cInfo->bmp_write_end_sock);

        if (cInfo->bmp_reader_thread->joinable())
            cInfo->bmp_reader_thread->join();

        if (cInfo->bmp_reader_thread != NULL) {
            delete cInfo->bmp_reader_thread;
            cInfo->bmp_reader_thread = NULL;
        }

        if (cInfo->mbus != NULL) {
            delete cInfo->mbus;
            cInfo->mbus = NULL;
        }
    }
}

/**
 * Client thread function