utils.cpp

#include "utils.hpp"
#include <poll.h>
#include <errno.h>
#include <cstring>
#include "logger.cpp"

POOL_STATE waitForRead(int fd, uint64_t timeoutMs)
{
    struct pollfd pfd;
    pfd.fd = fd;
    pfd.events = POLLIN;
    pfd.revents = 0;

    int ret = poll(&pfd, 1, timeoutMs);
    if (ret < 0) {
        if (errno == EINTR) return INTR;
        LOG_ERROR("Poll error: " + std::string(strerror(errno)));
        return FAIL;
    } else if (ret > 0 && (pfd.revents & POLLIN)) {
        return SUCCESS;
    } else {
        return TIMEOUT;  
    }
}

POOL_STATE waitForReadWithRetry(int fd, uint64_t timeoutMs, uint32_t maxRetries)
{
    uint8_t retries = 0;
    POOL_STATE pollState;

    while (retries < maxRetries)
    {
        pollState = waitForRead(fd, timeoutMs);
        if (pollState == SUCCESS) return SUCCESS;
        if (pollState == INTR) continue;  
        if (pollState == FAIL) return FAIL;
        retries++;  
    }
    LOG_ERROR("[WAIT-FOR-READ-RETRY] All retry attempts exhausted. Total attempts: " + std::to_string(maxRetries));
    return TIMEOUT;
}