bloccante problema zoccolo recv durante l'utilizzo con epoll
-
01-10-2019 - |
Domanda
Ho un problema: a volte (non regolarmente) restituisce recv -1
e errno == EAGAIN
durante l'utilizzo in modalità epoll
edge-triggered
. pezzo di codice:
server_sock = startup(&port);
if ( (epollfd = epoll_create(4096)) < 0) {
perror("epoll_create error");
exit(EXIT_FAILURE);
}
ev.events = EPOLLIN | EPOLLET;
ev.data.fd = server_sock;
if (epoll_ctl(epollfd, EPOLL_CTL_ADD, server_sock, &ev) == -1) {
perror("epoll_ctl: server_sock");
exit(EXIT_FAILURE);
}
while (1) {
int nfds = epoll_wait(epollfd, events, 4096, -1);
if (nfds == -1) {
perror("epoll_wait");
exit(EXIT_FAILURE);
}
for (int i = 0; i < nfds; i++) {
if (events[i].data.fd == server_sock) {
client_sock = accept(server_sock,
(struct sockaddr *)&client_name,
(socklen_t *)(&client_name_len));
if (client_sock == -1) //server overloaded
continue;
if (events[i].events & EPOLLIN) {
std::cout << "EPOLLIN on " << client_sock << std::endl;
}
Arch::set_nonblocking(client_sock);
ev.events = EPOLLIN | EPOLLRDHUP | EPOLLET; //input data and connection closing
ev.data.fd = client_sock;
if (epoll_ctl(epollfd, EPOLL_CTL_ADD, client_sock, &ev) == -1) {
perror("epoll_ctl: client_socket");
exit(EXIT_FAILURE);
}
accept_request(client_sock);
} else {
if (events[i].events & EPOLLRDHUP) {
epoll_ctl(epollfd, EPOLL_CTL_DEL, events[i].data.fd, &ev);
}
}
}
}
startup(&port)
crea non bloccante presa, vincolante con porto e così via. il mio script invia i seguenti dati:
GET /connect?id=1&secret=1 HTTP/1.0\r\n\r\n
ma recv
ritorno a volte -1
in questa funzione (chiamate all'interno di accept_request
):
/**********************************************************************/
/* Get a line from a socket, whether the line ends in a newline,
* carriage return, or a CRLF combination. Terminates the string read
* with a null character. If no newline indicator is found before the
* end of the buffer, the string is terminated with a null. If any of
* the above three line terminators is read, the last character of the
* string will be a linefeed and the string will be terminated with a
* null character.
* Parameters: the socket descriptor
* the buffer to save the data in
* the size of the buffer
* Returns: the number of bytes stored (excluding null) */
/**********************************************************************/
int get_line(int sock, char *buf, int size) {
int i = 0;
char c = '\0';
int n;
while ((i < size - 1) && (c != '\n')) {
n = recv(sock, &c, 1, 0);
//debug
std::cout << "n = " << n << std::endl;
if (n > 0) {
if (c == '\r') {
n = recv(sock, &c, 1, MSG_PEEK);
if ((n > 0) && (c == '\n'))
recv(sock, &c, 1, 0);
else
c = '\n';
}
buf[i] = c;
i++;
} else {
//debug
if (errno == EWOULDBLOCK)
std::cout << "EWOULDBLOCK" << std::endl;
c = '\n';
}
}
buf[i] = '\0';
return(i);
}
come epoll pagina man ha scritto che ho da lettura / scrittura fino a ottenere EAGAIN
, ma mi sono già! e che il tampone non essere vuoto. che cosa ho fatto di sbagliato?
UPD: ho scoperto una cosa interessante: quando è avvenuto tale situazione che uso nel mio sleep(1)
codice e recc(...)
di nuovo e ottengo i dati che mi aspetto! si tratta di un trucco sporco. c'è qualche approccio più grazioso per risolvere questo problema?
Soluzione
E 'del tutto normale per la prima recv()
in quel caso a EAGAIN
ritorno. epoll()
mai ti ha detto se era leggibile ancora oppure no.
Ogni singolo recv()
dovrebbe essere pronti a gestire EAGAIN
se si sta utilizzando non bloccanti. wakeups spurie sono possibili, quindi, quando un'API come select()
, poll()
o epoll()
ti dice che un socket è leggibile, è solo dicendo " potrebbe essere leggibile - provatelo"