From 1a40985723774c7155e8f3c038ed737b9b6121c4 Mon Sep 17 00:00:00 2001
From: Mark Atwood <mark@fallenpegasus.com>
Date: Sat, 22 Sep 2007 14:24:46 -0700
Subject: [PATCH] add memflush tool

---
 src/Makefile.am |   5 ++-
 src/memflush.c  | 100 ++++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 104 insertions(+), 1 deletion(-)
 create mode 100644 src/memflush.c

diff --git a/src/Makefile.am b/src/Makefile.am
index 57386fae..5648e11f 100644
--- a/src/Makefile.am
+++ b/src/Makefile.am
@@ -1,7 +1,7 @@
 INCLUDES = -I$(top_builddir)/include -Wall
 LDADDS = ../lib/libmemcached.la
 
-bin_PROGRAMS = memcat memcp memstat memrm
+bin_PROGRAMS = memcat memcp memstat memrm memflush
 
 noinst_includes= client_options.h utilities.h
 
@@ -16,3 +16,6 @@ memstat_LDADD = $(LDADDS)
 
 memrm_SOURCES = memrm.c utilities.c
 memrm_LDADD = $(LDADDS)
+
+memflush_SOURCES = memflush.c utilities.c
+memflush_LDADD = $(LDADDS)
diff --git a/src/memflush.c b/src/memflush.c
new file mode 100644
index 00000000..558abcaf
--- /dev/null
+++ b/src/memflush.c
@@ -0,0 +1,100 @@
+#include <stdio.h>
+#include <unistd.h>
+#include <getopt.h>
+#include <memcached.h>
+#include "client_options.h"
+#include "utilities.h"
+
+static int opt_verbose= 0;
+static time_t opt_expire= 0;
+static char *opt_servers= NULL;
+
+/* Prototypes */
+void options_parse(int argc, char *argv[]);
+
+int main(int argc, char *argv[])
+{
+  memcached_st *memc;
+  memcached_return rc;
+  WATCHPOINT;
+  options_parse(argc, argv);
+  WATCHPOINT;
+
+  memc= memcached_init(NULL);
+  WATCHPOINT;
+
+  if (opt_servers)
+    parse_opt_servers(memc, opt_servers);
+  WATCHPOINT;
+  
+  rc = memcached_flush(memc, opt_expire);
+  WATCHPOINT;
+
+  if (rc != MEMCACHED_SUCCESS) 
+  {
+    fprintf(stderr, "memflush: %s: memcache error %s\n", 
+	    argv[optind], memcached_strerror(memc, rc));
+  }
+  WATCHPOINT;
+
+  memcached_deinit(memc);
+  WATCHPOINT;
+
+  free(opt_servers);
+  WATCHPOINT;
+
+  return 0;
+}
+
+
+void options_parse(int argc, char *argv[])
+{
+  static struct option long_options[]=
+  {
+    {"version", no_argument, NULL, OPT_VERSION},
+    {"help", no_argument, NULL, OPT_HELP},
+    {"verbose", no_argument, &opt_verbose, OPT_VERBOSE},
+    {"debug", no_argument, &opt_verbose, OPT_DEBUG},
+    {"servers", required_argument, NULL, OPT_SERVERS},
+    {"expire", required_argument, NULL, OPT_EXPIRE},
+    {0, 0, 0, 0},
+  };
+  int option_index= 0;
+  int option_rv;
+
+  while (1) 
+  {
+    option_rv= getopt_long(argc, argv, "Vhvds:", long_options, &option_index);
+    if (option_rv == -1) break;
+    switch (option_rv)
+    {
+    case 0:
+      break;
+    case OPT_VERBOSE: /* --verbose or -v */
+      opt_verbose = OPT_VERBOSE;
+      break;
+    case OPT_DEBUG: /* --debug or -d */
+      opt_verbose = OPT_DEBUG;
+      break;
+    case OPT_VERSION: /* --version or -V */
+      printf("memcache tools, memflush, v1.0\n");
+      exit(0);
+      break;
+    case OPT_HELP: /* --help or -h */
+      printf("useful help messages go here\n");
+      exit(0);
+      break;
+    case OPT_SERVERS: /* --servers or -s */
+      opt_servers= strdup(optarg);
+      break;
+    case OPT_EXPIRE: /* --expire */
+      opt_expire= (time_t)strtoll(optarg, (char **)NULL, 10);
+      break;
+    case '?':
+      /* getopt_long already printed an error message. */
+      exit(1);
+    default:
+      abort();
+    }
+  }
+}
-- 
2.30.2