Function receiveData

src/shared/sockethelpers.cpp:229–262

}

int receiveData(void* elem, unsigned int size)
{
#ifdef LIBTAS_LIBRARY
    LOG(LL_DEBUG, LCF_SOCKET, "Receive socket data of size %u", size);
#endif

    ssize_t ret = 0;
    do {
        ret = recv(socket_fd, elem, size, MSG_WAITALL);
    } while ((ret == -1) && (errno == EINTR));

    if (ret == -1) {
#ifdef LIBTAS_LIBRARY
        LOG(LL_ERROR, LCF_SOCKET, "recv() returns -1 with error %s", strerror(errno));
#else
        std::cerr << "recv() returns -1 with error " << strerror(errno) << std::endl;
#endif
    }
    else if (ret == 0 && size > 0) { // socket has been closed
#ifdef LIBTAS_LIBRARY
        LOG(LL_WARN, LCF_SOCKET, "recv() returns 0 -> socket closed");
#else
        std::cerr << "recv() returns 0 -> socket closed" << std::endl;
#endif
    }
    else if (ret != static_cast<ssize_t>(size)) {
#ifdef LIBTAS_LIBRARY
        LOG(LL_ERROR, LCF_SOCKET, "recv() %u bytes instead of %u", ret, size);
#else
        std::cerr << "recv() " << ret << " bytes instead of " << size << std::endl;
#endif
    }
    return ret;
}

int receiveMessage()
{