Неблокирующий сокет libev + постоянно вызывает обратный вызов

Я использую неблокирующие сокеты libev + для отправки запроса на сервер. Я использую Keep Alive, потому что мне нужно отправлять будущие запросы в пункт назначения по тому же соединению.

Поведение
Запустите программу, и она получит URL-адрес и войдет в консоль, как и ожидалось.
После этого подождите и не нажимайте Ctrl + C для выхода из программы.

ожидаемый
Приложение должно оставаться открытым, потому что цикл обработки событий ожидает будущих ответов, но не должен ничего сохранять в консоли после первоначального ответа.

фактический
Оставьте приложение запущенным. Через 30 с лишним секунд консоль начнет регистрировать один и тот же ответ снова и снова и снова без конца.

Вопрос
Почему libev неоднократно вызывает мой обратный вызов (example_cb), когда новый запрос не был отправлен и новые данные ответа не были получены? Как я могу это исправить?

#include <ev.h>
#include <stdio.h>
#include <iostream>
#include <ctype.h>
#include <cstring>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <fcntl.h>
#include <netdb.h>
#include <netinet/in.h>
#include <unistd.h>
#include <sstream>
#include <fstream>
#include <string>

using namespace std;

void sendRequest(int sockfd)
{
puts("------");
puts("sendRequest() was called");
stringstream ss;
ss << "GET /posts/11 HTTP/1.1\r\n"<< "Host: jsonplaceholder.typicode.com\r\n"<< "Accept: application/json\r\n"<< "\r\n";
string request = ss.str();

if (send(sockfd, request.c_str(), request.length(), 0) != (int)request.length()) {
cout << "Error sending request." << endl;
exit(1);
}
cout << "Request sent. No err occured." << endl;
}

static void delay_cb(EV_P_ ev_timer *w, int revents)
{
puts("------");
puts("delay_cb() was called");
sendRequest(3);
}static void example_cb(EV_P_ ev_io *w, int revents)
{
puts("------");
puts("example_cb() was called");
int sockfd = 3;

size_t len = 80*1024, nparsed; // response must be <= 80 Kb
char buf[len];
ssize_t recved;

recved = recv(sockfd, &buf, len, 0);

if (recved < 0) {
perror("recved was <1");
}

// don't process keep alives
if (buf[0] != '\0') {
std::cout << buf << std::endl;
}

// clear buf
buf[0] = '\0';
std::cout << "buf after clear attempt: " << buf << std::endl;
}

int example_request()
{
std::string hostname = "jsonplaceholder.typicode.com";
int PORT = 80;

struct sockaddr_in client;
struct hostent * host = gethostbyname(hostname.c_str());
if (host == NULL || host->h_addr == NULL) {
cout << "Error retrieving DNS information." << endl;
exit(1);
}

bzero(&client, sizeof(client));
client.sin_family = AF_INET;
client.sin_port = htons( PORT );
memcpy(&client.sin_addr, host->h_addr, host->h_length);

// create a socket
int sockfd = socket(PF_INET, SOCK_STREAM, 0);
if (sockfd < 0) {
cout << "Error creating socket." << endl;
exit(1);
}
cout << "Socket created" << endl;

// enable keep alive
int val = 1;
setsockopt(sockfd, SOL_SOCKET, SO_KEEPALIVE, &val, sizeof val);

if (connect(sockfd, (struct sockaddr *)&client, sizeof(client)) < 0) {
close(sockfd);
cout << "Could not connect" << endl;
exit(1);
}
cout << "Socket connected" << endl;

// make non-blocking
int status = fcntl(sockfd, F_SETFL, fcntl(sockfd, F_GETFL, 0) | O_NONBLOCK);
if (status == -1) {
perror("ERROR making socket non-blocking");
}
std::cout << "Socket set to non-blocking" << std::endl;

std::cout << "Sockfd is: " << sockfd << std::endl;
return sockfd;
}

int main(void)
{
// establish socket connection
int sockfd = example_request();

struct ev_loop *loop = EV_DEFAULT;

ev_io example_watcher;
ev_io_init(&example_watcher, example_cb, sockfd, EV_READ);
ev_io_start(loop, &example_watcher);

// used to send the request 2 sec later
ev_timer delay_watcher;
ev_timer_init(&delay_watcher, delay_cb, 2, 0.0);
ev_timer_start(loop, &delay_watcher);

ev_run(loop, 0);

return 0;
}

Изменить: Код обновлен с предложениями из комментариев