Lines Matching refs:recvd
347 ssize_t recvd; in process_ingress() local
356 recvd = recv(sockfd, buf, bufsize, 0); in process_ingress()
357 if((recvd < 0) && ((SOCKERRNO == EAGAIN) || (SOCKERRNO == EWOULDBLOCK))) in process_ingress()
360 if(recvd < 0) { in process_ingress()
362 "(errno: %d, socket %d)", recvd, SOCKERRNO, sockfd); in process_ingress()
366 recvd = quiche_conn_recv(qs->conn, buf, recvd); in process_ingress()
367 if(recvd == QUICHE_ERR_DONE) in process_ingress()
370 if(recvd < 0) { in process_ingress()
371 failf(conn->data, "quiche_conn_recv() == %d", recvd); in process_ingress()
456 ssize_t recvd = -1; in h3_stream_recv() local
475 while(recvd < 0) { in h3_stream_recv()
496 recvd = headers.nlen; in h3_stream_recv()
506 recvd = 2; /* two bytes already */ in h3_stream_recv()
509 recvd = 0; in h3_stream_recv()
513 recvd = -1; in h3_stream_recv()
516 recvd += rcode; in h3_stream_recv()
521 recvd = 0; /* end of stream */ in h3_stream_recv()
534 *curlcode = (-1 == recvd)? CURLE_AGAIN : CURLE_OK; in h3_stream_recv()
535 if(recvd >= 0) in h3_stream_recv()
539 data->state.drain = (recvd >= 0) ? 1 : 0; in h3_stream_recv()
540 return recvd; in h3_stream_recv()