Блог

У меня есть приложение, которое отправляет данные о событиях 10 сообщений в промежуток 5 секунд каждые 5 минут, размер буфера может составлять 10 КБ. его неблокирующее соединение. По этой причине я использовал bufferevent. Но я не в состоянии добиться того же самого. все 10 сообщений я соберу вместе.

Клиент :

 
void fnTimeExpired(evutil_socket_t listener, short event, void *arg)
{
    char buffer[iMesssageSize   10];
    memset(buffer, 'A', sizeof(buffer));
    cout << "fnTimeExpired" << endl;
    char Buffer[100];
    uint64_t exp;
    read(iTimerFd, amp;exp, sizeof(uint64_t));

    for (int iCount = 0; iCount < iNoOfMessage; iCount  )
    {
        bufferevent_write(bev, buffer, iMesssageSize);
        bufferevent_flush(bev, EV_WRITE, BEV_FLUSH);
        sleep(5);
    }
}