upstream/bind9
1
0
Fork 0
mirror of https://github.com/isc-projects/bind9.git synced 2026-06-09 14:02:05 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

implement timeouts

Browse source
This commit is contained in:
Michael Graff 2000-02-01 02:59:40 +00:00
parent db1259453c
commit b91bbaf50c
2 changed files with 36 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
lib/lwres/context.c
View file

@ -19,6 +19,7 @@
#include <config.h>
#include <assert.h>
#include <fcntl.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
@ -190,8 +191,16 @@ lwres_context_sendrecv(lwres_context_t *ctx,
int *recvd_len)
{
int ret;
int ret2;
int flags;
struct sockaddr_in sin;
int fromlen;
fd_set readfds;
fd_set emptyfds;
struct timeval timeout;
timeout.tv_sec = LWRES_R_TIMEOUT;
timeout.tv_usec = 0;
ret = sendto(ctx->sock, sendbase, sendlen, 0, NULL, 0);
if (ret < 0)
@ -200,9 +209,35 @@ lwres_context_sendrecv(lwres_context_t *ctx,
return (LWRES_R_IOERROR);
again:
flags = fcntl(ctx->sock, F_GETFL, 0);
flags |= O_NONBLOCK;
ret = fcntl(ctx->sock, F_SETFL, flags);
if (ret < 0)
return (LWRES_R_IOERROR);
FD_ZERO(&readfds);
FD_ZERO(&emptyfds);
FD_SET(ctx->sock, &readfds);
ret2 = select(ctx->sock + 1, &readfds, &emptyfds, &emptyfds, &timeout);
flags = fcntl(ctx->sock, F_GETFL, 0);
flags &= ~O_NONBLOCK;
ret = fcntl(ctx->sock, F_SETFL, flags);
if (ret < 0)
return (LWRES_R_IOERROR);
/*
* What happened with select?
*/
if (ret2 < 0)
return (LWRES_R_IOERROR);
if (ret2 == 0)
return (LWRES_R_TIMEOUT);
fromlen = sizeof(sin);
ret = recvfrom(ctx->sock, recvbase, recvlen, 0,
(struct sockaddr *)&sin, &fromlen);
if (ret < 0)
return (LWRES_R_IOERROR);

2
lib/lwres/include/lwres/result.h
View file

@ -20,7 +20,7 @@
#define LWRES_R_SUCCESS 0
#define LWRES_R_NOMEMORY -1
#define LWRES_R_TIMEDOUT -2
#define LWRES_R_TIMEOUT -2
#define LWRES_R_NOTFOUND -3
#define LWRES_R_UNEXPECTEDEND -4 /* unexpected end of input */
#define LWRES_R_FAILURE -5 /* generic failure */