summaryrefslogtreecommitdiff
path: root/ares__close_sockets.c
diff options
context:
space:
mode:
authorDaniel Stenberg <daniel@haxx.se>2003-10-07 21:54:04 +0000
committerDaniel Stenberg <daniel@haxx.se>2003-10-07 21:54:04 +0000
commit5e847a14bd65383ce65f143c578e120899981fd9 (patch)
tree0072e647fe22e05aee94cf4e4bf101209e30626c /ares__close_sockets.c
downloadc-ares-5e847a14bd65383ce65f143c578e120899981fd9.tar.gz
c-ares-5e847a14bd65383ce65f143c578e120899981fd9.tar.bz2
c-ares-5e847a14bd65383ce65f143c578e120899981fd9.zip
ares 1.1.1 with collected applied patches
Diffstat (limited to 'ares__close_sockets.c')
-rw-r--r--ares__close_sockets.c57
1 files changed, 57 insertions, 0 deletions
diff --git a/ares__close_sockets.c b/ares__close_sockets.c
new file mode 100644
index 0000000..2b8be10
--- /dev/null
+++ b/ares__close_sockets.c
@@ -0,0 +1,57 @@
+/* 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 <stdlib.h>
+#ifdef WIN32
+#else
+#include <unistd.h>
+#endif
+#include "ares.h"
+#include "ares_private.h"
+
+void ares__close_sockets(struct server_state *server)
+{
+ struct send_request *sendreq;
+
+ /* Free all pending output buffers. */
+ while (server->qhead)
+ {
+ /* Advance server->qhead; pull out query as we go. */
+ sendreq = server->qhead;
+ server->qhead = sendreq->next;
+ free(sendreq);
+ }
+ server->qtail = NULL;
+
+ /* Reset any existing input buffer. */
+ if (server->tcp_buffer)
+ free(server->tcp_buffer);
+ server->tcp_buffer = NULL;
+ server->tcp_lenbuf_pos = 0;
+
+ /* Close the TCP and UDP sockets. */
+ if (server->tcp_socket != -1)
+ {
+ closesocket(server->tcp_socket);
+ server->tcp_socket = -1;
+ }
+ if (server->udp_socket != -1)
+ {
+ closesocket(server->udp_socket);
+ server->udp_socket = -1;
+ }
+}