diff options
author | Daniel Stenberg <daniel@haxx.se> | 2003-10-07 21:54:04 +0000 |
---|---|---|
committer | Daniel Stenberg <daniel@haxx.se> | 2003-10-07 21:54:04 +0000 |
commit | 0436fbe226ca8ea71a751f4a86a228632e5cbc63 (patch) | |
tree | 5cf6478e89608a8000bd36014ba4032bcc9c0528 /ares/ares_fds.c | |
parent | 6494889e3ba6b1432258f0a8ed402723607cff21 (diff) | |
download | curl-0436fbe226ca8ea71a751f4a86a228632e5cbc63.tar.gz |
ares 1.1.1 with collected applied patches
Diffstat (limited to 'ares/ares_fds.c')
-rw-r--r-- | ares/ares_fds.c | 58 |
1 files changed, 58 insertions, 0 deletions
diff --git a/ares/ares_fds.c b/ares/ares_fds.c new file mode 100644 index 000000000..d26499841 --- /dev/null +++ b/ares/ares_fds.c @@ -0,0 +1,58 @@ +/* Copyright 1998 by the Massachusetts Institute of Technology. + * + * Permission to use, copy, modify, and distribute this + * software and its documentation for any purpose and without + * fee is hereby granted, provided that the above copyright + * notice appear in all copies and that both that copyright + * notice and this permission notice appear in supporting + * documentation, and that the name of M.I.T. not be used in + * advertising or publicity pertaining to distribution of the + * software without specific, written prior permission. + * M.I.T. makes no representations about the suitability of + * this software for any purpose. It is provided "as is" + * without express or implied warranty. + */ + +static const char rcsid[] = "$Id$"; + +#include <sys/types.h> + +#ifdef WIN32 + +#else +#include <sys/time.h> +#endif + +#include "ares.h" +#include "ares_private.h" + +int ares_fds(ares_channel channel, fd_set *read_fds, fd_set *write_fds) +{ + struct server_state *server; + int i, nfds; + + /* No queries, no file descriptors. */ + if (!channel->queries) + return 0; + + nfds = 0; + for (i = 0; i < channel->nservers; i++) + { + server = &channel->servers[i]; + if (server->udp_socket != -1) + { + FD_SET(server->udp_socket, read_fds); + if (server->udp_socket >= nfds) + nfds = server->udp_socket + 1; + } + if (server->tcp_socket != -1) + { + FD_SET(server->tcp_socket, read_fds); + if (server->qhead) + FD_SET(server->tcp_socket, write_fds); + if (server->tcp_socket >= nfds) + nfds = server->tcp_socket + 1; + } + } + return nfds; +} |