git.m6w6.name Git - m6w6/libmemcached/blob - libmemcached/stats.cc

   1 /*  vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
   2  *
   3  *  Libmemcached library
   4  *
   5  *  Copyright (C) 2011 Data Differential, http://datadifferential.com/
   6  *
   7  *  Redistribution and use in source and binary forms, with or without
   8  *  modification, are permitted provided that the following conditions are
   9  *  met:
  10  *
  11  *      * Redistributions of source code must retain the above copyright
  12  *  notice, this list of conditions and the following disclaimer.
  13  *
  14  *      * Redistributions in binary form must reproduce the above
  15  *  copyright notice, this list of conditions and the following disclaimer
  16  *  in the documentation and/or other materials provided with the
  17  *  distribution.
  18  *
  19  *      * The names of its contributors may not be used to endorse or
  20  *  promote products derived from this software without specific prior
  21  *  written permission.
  22  *
  23  *  THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  24  *  "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  25  *  LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  26  *  A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  27  *  OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  28  *  SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  29  *  LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  30  *  DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  31  *  THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  32  *  (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  33  *  OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  34  *
  35  */
  36
  37 #include <libmemcached/common.h>
  38
  39 static const char *memcached_stat_keys[] = {
  40   "pid",
  41   "uptime",
  42   "time",
  43   "version",
  44   "pointer_size",
  45   "rusage_user",
  46   "rusage_system",
  47   "curr_items",
  48   "total_items",
  49   "bytes",
  50   "curr_connections",
  51   "total_connections",
  52   "connection_structures",
  53   "cmd_get",
  54   "cmd_set",
  55   "get_hits",
  56   "get_misses",
  57   "evictions",
  58   "bytes_read",
  59   "bytes_written",
  60   "limit_maxbytes",
  61   "threads",
  62   NULL
  63 };
  64
  65 struct local_context
  66 {
  67   memcached_stat_fn func;
  68   void *context;
  69   const char *args;
  70   const size_t args_length;
  71
  72   local_context(memcached_stat_fn func_arg,
  73                 void *context_arg,
  74                 const char *args_arg,
  75                 const size_t args_length_arg) :
  76     func(func_arg),
  77     context(context_arg),
  78     args(args_arg),
  79     args_length(args_length_arg)
  80   { }
  81 };
  82
  83
  84 static memcached_return_t set_data(memcached_stat_st *memc_stat, const char *key, const char *value)
  85 {
  86
  87   if (strlen(key) < 1)
  88   {
  89     WATCHPOINT_STRING(key);
  90     return MEMCACHED_UNKNOWN_STAT_KEY;
  91   }
  92   else if (strcmp("pid", key) == 0)
  93   {
  94     int64_t temp= strtoll(value, (char **)NULL, 10);
  95
  96     if (temp <= INT32_MAX and ( sizeof(pid_t) == sizeof(int32_t) ))
  97     {
  98       memc_stat->pid= pid_t(temp);
  99     }
 100     else if (temp > -1)
 101     {
 102       memc_stat->pid= pid_t(temp);
 103     }
 104     else
 105     {
 106       // If we got a value less then -1 then something went wrong in the
 107       // protocol
 108     }
 109   }
 110   else if (not strcmp("uptime", key))
 111   {
 112     memc_stat->uptime= strtoul(value, (char **)NULL, 10);
 113   }
 114   else if (not strcmp("time", key))
 115   {
 116     memc_stat->time= strtoul(value, (char **)NULL, 10);
 117   }
 118   else if (not strcmp("version", key))
 119   {
 120     memcpy(memc_stat->version, value, strlen(value));
 121     memc_stat->version[strlen(value)]= 0;
 122   }
 123   else if (not strcmp("pointer_size", key))
 124   {
 125     memc_stat->pointer_size= strtoul(value, (char **)NULL, 10);
 126   }
 127   else if (not strcmp("rusage_user", key))
 128   {
 129     char *walk_ptr;
 130     for (walk_ptr= (char*)value; (!ispunct(*walk_ptr)); walk_ptr++) {};
 131     *walk_ptr= 0;
 132     walk_ptr++;
 133     memc_stat->rusage_user_seconds= strtoul(value, (char **)NULL, 10);
 134     memc_stat->rusage_user_microseconds= strtoul(walk_ptr, (char **)NULL, 10);
 135   }
 136   else if (not strcmp("rusage_system", key))
 137   {
 138     char *walk_ptr;
 139     for (walk_ptr= (char*)value; (!ispunct(*walk_ptr)); walk_ptr++) {};
 140     *walk_ptr= 0;
 141     walk_ptr++;
 142     memc_stat->rusage_system_seconds= strtoul(value, (char **)NULL, 10);
 143     memc_stat->rusage_system_microseconds= strtoul(walk_ptr, (char **)NULL, 10);
 144   }
 145   else if (not strcmp("curr_items", key))
 146   {
 147     memc_stat->curr_items= strtoul(value, (char **)NULL, 10);
 148   }
 149   else if (not strcmp("total_items", key))
 150   {
 151     memc_stat->total_items= strtoul(value, (char **)NULL, 10);
 152   }
 153   else if (not strcmp("bytes_read", key))
 154   {
 155     memc_stat->bytes_read= strtoull(value, (char **)NULL, 10);
 156   }
 157   else if (not strcmp("bytes_written", key))
 158   {
 159     memc_stat->bytes_written= strtoull(value, (char **)NULL, 10);
 160   }
 161   else if (not strcmp("bytes", key))
 162   {
 163     memc_stat->bytes= strtoull(value, (char **)NULL, 10);
 164   }
 165   else if (not strcmp("curr_connections", key))
 166   {
 167     memc_stat->curr_connections= strtoull(value, (char **)NULL, 10);
 168   }
 169   else if (not strcmp("total_connections", key))
 170   {
 171     memc_stat->total_connections= strtoull(value, (char **)NULL, 10);
 172   }
 173   else if (not strcmp("connection_structures", key))
 174   {
 175     memc_stat->connection_structures= strtoul(value, (char **)NULL, 10);
 176   }
 177   else if (not strcmp("cmd_get", key))
 178   {
 179     memc_stat->cmd_get= strtoull(value, (char **)NULL, 10);
 180   }
 181   else if (not strcmp("cmd_set", key))
 182   {
 183     memc_stat->cmd_set= strtoull(value, (char **)NULL, 10);
 184   }
 185   else if (not strcmp("get_hits", key))
 186   {
 187     memc_stat->get_hits= strtoull(value, (char **)NULL, 10);
 188   }
 189   else if (not strcmp("get_misses", key))
 190   {
 191     memc_stat->get_misses= strtoull(value, (char **)NULL, 10);
 192   }
 193   else if (not strcmp("evictions", key))
 194   {
 195     memc_stat->evictions= strtoull(value, (char **)NULL, 10);
 196   }
 197   else if (not strcmp("limit_maxbytes", key))
 198   {
 199     memc_stat->limit_maxbytes= strtoull(value, (char **)NULL, 10);
 200   }
 201   else if (not strcmp("threads", key))
 202   {
 203     memc_stat->threads= strtoul(value, (char **)NULL, 10);
 204   }
 205   else if (not (strcmp("delete_misses", key) == 0 or /* New stats in the 1.3 beta */
 206                 strcmp("delete_hits", key) == 0 or /* Just swallow them for now.. */
 207                 strcmp("incr_misses", key) == 0 or
 208                 strcmp("incr_hits", key) == 0 or
 209                 strcmp("decr_misses", key) == 0 or
 210                 strcmp("decr_hits", key) == 0 or
 211                 strcmp("cas_misses", key) == 0 or
 212                 strcmp("cas_hits", key) == 0 or
 213                 strcmp("cas_badval", key) == 0 or
 214                 strcmp("cmd_flush", key) == 0 or
 215                 strcmp("accepting_conns", key) == 0 or
 216                 strcmp("listen_disabled_num", key) == 0 or
 217                 strcmp("conn_yields", key) == 0 or
 218                 strcmp("auth_cmds", key) == 0 or
 219                 strcmp("auth_errors", key) == 0 or
 220                 strcmp("reclaimed", key) == 0))
 221   {
 222     WATCHPOINT_STRING(key);
 223     /* return MEMCACHED_UNKNOWN_STAT_KEY; */
 224     return MEMCACHED_SUCCESS;
 225   }
 226
 227   return MEMCACHED_SUCCESS;
 228 }
 229
 230 char *memcached_stat_get_value(const memcached_st *, memcached_stat_st *memc_stat,
 231                                const char *key, memcached_return_t *error)
 232 {
 233   memcached_return_t not_used;
 234   if (error == NULL)
 235   {
 236     error= &not_used;
 237   }
 238
 239   if (memc_stat == NULL)
 240   {
 241     *error= MEMCACHED_INVALID_ARGUMENTS;
 242     return NULL;
 243   }
 244
 245   char buffer[SMALL_STRING_LEN];
 246   int length;
 247
 248   *error= MEMCACHED_SUCCESS;
 249
 250   if (memcmp("pid", key, sizeof("pid") -1) == 0)
 251   {
 252     length= snprintf(buffer, SMALL_STRING_LEN,"%lld", (signed long long)memc_stat->pid);
 253   }
 254   else if (not memcmp("uptime", key, sizeof("uptime") -1))
 255   {
 256     length= snprintf(buffer, SMALL_STRING_LEN,"%lu", memc_stat->uptime);
 257   }
 258   else if (not memcmp("time", key, sizeof("time") -1))
 259   {
 260     length= snprintf(buffer, SMALL_STRING_LEN,"%llu", (unsigned long long)memc_stat->time);
 261   }
 262   else if (not memcmp("version", key, sizeof("version") -1))
 263   {
 264     length= snprintf(buffer, SMALL_STRING_LEN,"%s", memc_stat->version);
 265   }
 266   else if (not memcmp("pointer_size", key, sizeof("pointer_size") -1))
 267   {
 268     length= snprintf(buffer, SMALL_STRING_LEN,"%lu", memc_stat->pointer_size);
 269   }
 270   else if (not memcmp("rusage_user", key, sizeof("rusage_user") -1))
 271   {
 272     length= snprintf(buffer, SMALL_STRING_LEN,"%lu.%lu", memc_stat->rusage_user_seconds, memc_stat->rusage_user_microseconds);
 273   }
 274   else if (not memcmp("rusage_system", key, sizeof("rusage_system") -1))
 275   {
 276     length= snprintf(buffer, SMALL_STRING_LEN,"%lu.%lu", memc_stat->rusage_system_seconds, memc_stat->rusage_system_microseconds);
 277   }
 278   else if (not memcmp("curr_items", key, sizeof("curr_items") -1))
 279   {
 280     length= snprintf(buffer, SMALL_STRING_LEN,"%lu", memc_stat->curr_items);
 281   }
 282   else if (not memcmp("total_items", key, sizeof("total_items") -1))
 283   {
 284     length= snprintf(buffer, SMALL_STRING_LEN,"%lu", memc_stat->total_items);
 285   }
 286   else if (not memcmp("curr_connections", key, sizeof("curr_connections") -1))
 287   {
 288     length= snprintf(buffer, SMALL_STRING_LEN,"%lu", memc_stat->curr_connections);
 289   }
 290   else if (not memcmp("total_connections", key, sizeof("total_connections") -1))
 291   {
 292     length= snprintf(buffer, SMALL_STRING_LEN,"%lu", memc_stat->total_connections);
 293   }
 294   else if (not memcmp("connection_structures", key, sizeof("connection_structures") -1))
 295   {
 296     length= snprintf(buffer, SMALL_STRING_LEN,"%lu", memc_stat->connection_structures);
 297   }
 298   else if (not memcmp("cmd_get", key, sizeof("cmd_get") -1))
 299   {
 300     length= snprintf(buffer, SMALL_STRING_LEN,"%llu", (unsigned long long)memc_stat->cmd_get);
 301   }
 302   else if (not memcmp("cmd_set", key, sizeof("cmd_set") -1))
 303   {
 304     length= snprintf(buffer, SMALL_STRING_LEN,"%llu", (unsigned long long)memc_stat->cmd_set);
 305   }
 306   else if (not memcmp("get_hits", key, sizeof("get_hits") -1))
 307   {
 308     length= snprintf(buffer, SMALL_STRING_LEN,"%llu", (unsigned long long)memc_stat->get_hits);
 309   }
 310   else if (not memcmp("get_misses", key, sizeof("get_misses") -1))
 311   {
 312     length= snprintf(buffer, SMALL_STRING_LEN,"%llu", (unsigned long long)memc_stat->get_misses);
 313   }
 314   else if (not memcmp("evictions", key, sizeof("evictions") -1))
 315   {
 316     length= snprintf(buffer, SMALL_STRING_LEN,"%llu", (unsigned long long)memc_stat->evictions);
 317   }
 318   else if (not memcmp("bytes_read", key, sizeof("bytes_read") -1))
 319   {
 320     length= snprintf(buffer, SMALL_STRING_LEN,"%llu", (unsigned long long)memc_stat->bytes_read);
 321   }
 322   else if (not memcmp("bytes_written", key, sizeof("bytes_written") -1))
 323   {
 324     length= snprintf(buffer, SMALL_STRING_LEN,"%llu", (unsigned long long)memc_stat->bytes_written);
 325   }
 326   else if (not memcmp("bytes", key, sizeof("bytes") -1))
 327   {
 328     length= snprintf(buffer, SMALL_STRING_LEN,"%llu", (unsigned long long)memc_stat->bytes);
 329   }
 330   else if (not memcmp("limit_maxbytes", key, sizeof("limit_maxbytes") -1))
 331   {
 332     length= snprintf(buffer, SMALL_STRING_LEN,"%llu", (unsigned long long)memc_stat->limit_maxbytes);
 333   }
 334   else if (not memcmp("threads", key, sizeof("threads") -1))
 335   {
 336     length= snprintf(buffer, SMALL_STRING_LEN,"%lu", memc_stat->threads);
 337   }
 338   else
 339   {
 340     *error= MEMCACHED_NOTFOUND;
 341     return NULL;
 342   }
 343
 344   if (length >= SMALL_STRING_LEN || length < 0)
 345   {
 346     *error= MEMCACHED_FAILURE;
 347     return NULL;
 348   }
 349
 350   // User is responsible for free() memory, so use malloc()
 351   char *ret= static_cast<char *>(malloc(size_t(length +1)));
 352   memcpy(ret, buffer, (size_t) length);
 353   ret[length]= '\0';
 354
 355   return ret;
 356 }
 357
 358 static memcached_return_t binary_stats_fetch(memcached_stat_st *memc_stat,
 359                                              const char *args,
 360                                              const size_t args_length,
 361                                              org::libmemcached::Instance* instance,
 362                                              struct local_context *check)
 363 {
 364   char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE];
 365   protocol_binary_request_stats request= {}; // = {.bytes= {0}};
 366
 367   initialize_binary_request(instance, request.message.header);
 368
 369   request.message.header.request.opcode= PROTOCOL_BINARY_CMD_STAT;
 370   request.message.header.request.datatype= PROTOCOL_BINARY_RAW_BYTES;
 371
 372   if (args_length)
 373   {
 374     request.message.header.request.keylen= htons(uint16_t(args_length));
 375     request.message.header.request.bodylen= htonl(uint32_t( args_length));
 376
 377     libmemcached_io_vector_st vector[]=
 378     {
 379       { request.bytes, sizeof(request.bytes) },
 380       { args, args_length }
 381     };
 382
 383     if (memcached_vdo(instance, vector, 2, true) != MEMCACHED_SUCCESS)
 384     {
 385       memcached_io_reset(instance);
 386       return MEMCACHED_WRITE_FAILURE;
 387     }
 388   }
 389   else
 390   {
 391     libmemcached_io_vector_st vector[]=
 392     {
 393       { request.bytes, sizeof(request.bytes) }
 394     };
 395
 396     if (memcached_vdo(instance, vector, 1, true) != MEMCACHED_SUCCESS)
 397     {
 398       memcached_io_reset(instance);
 399       return MEMCACHED_WRITE_FAILURE;
 400     }
 401   }
 402
 403   memcached_server_response_decrement(instance);
 404   while (1)
 405   {
 406     memcached_return_t rc= memcached_response(instance, buffer, sizeof(buffer), NULL);
 407
 408     if (rc == MEMCACHED_END)
 409     {
 410       break;
 411     }
 412
 413     if (rc != MEMCACHED_SUCCESS)
 414     {
 415       memcached_io_reset(instance);
 416       return rc;
 417     }
 418
 419     if (check && check->func)
 420     {
 421       size_t key_length= strlen(buffer);
 422
 423       check->func(instance,
 424                   buffer, key_length,
 425                   buffer+key_length+1, strlen(buffer+key_length+1),
 426                   check->context);
 427     }
 428
 429     if (memc_stat)
 430     {
 431       if ((set_data(memc_stat, buffer, buffer + strlen(buffer) + 1)) == MEMCACHED_UNKNOWN_STAT_KEY)
 432       {
 433         WATCHPOINT_ERROR(MEMCACHED_UNKNOWN_STAT_KEY);
 434         WATCHPOINT_ASSERT(0);
 435       }
 436     }
 437   }
 438
 439   /*
 440    * memcached_response will decrement the counter, so I need to reset it..
 441    * todo: look at this and try to find a better solution.
 442    * */
 443   instance->cursor_active_= 0;
 444
 445   return MEMCACHED_SUCCESS;
 446 }
 447
 448 static memcached_return_t ascii_stats_fetch(memcached_stat_st *memc_stat,
 449                                             const char *args,
 450                                             const size_t args_length,
 451                                             org::libmemcached::Instance* instance,
 452                                             struct local_context *check)
 453 {
 454   libmemcached_io_vector_st vector[]=
 455   {
 456     { memcached_literal_param("stats ") },
 457     { args, args_length },
 458     { memcached_literal_param("\r\n") }
 459   };
 460
 461   memcached_return_t rc= memcached_vdo(instance, vector, 3, true);
 462   if (memcached_success(rc))
 463   {
 464     char buffer[MEMCACHED_DEFAULT_COMMAND_SIZE];
 465     while ((rc= memcached_response(instance, buffer, sizeof(buffer), NULL)) == MEMCACHED_STAT)
 466     {
 467       char *string_ptr= buffer;
 468       string_ptr+= 5; /* Move past STAT */
 469
 470       char *end_ptr;
 471       for (end_ptr= string_ptr; isgraph(*end_ptr); end_ptr++) {};
 472       char *key= string_ptr;
 473       key[size_t(end_ptr-string_ptr)]= 0;
 474
 475       string_ptr= end_ptr + 1;
 476       for (end_ptr= string_ptr; !(isspace(*end_ptr)); end_ptr++) {};
 477       char *value= string_ptr;
 478       value[(size_t)(end_ptr -string_ptr)]= 0;
 479 #if 0
 480       bool check_bool= bool(check);
 481       bool check_func_bool= bool(check) ? bool(check->func) : false;
 482       fprintf(stderr, "%s:%d %s %s %d:%d\n", __FILE__, __LINE__, key, value, check_bool, check_func_bool);
 483 #endif
 484
 485       if (check and check->func)
 486       {
 487         check->func(instance,
 488                     key, strlen(key),
 489                     value, strlen(value),
 490                     check->context);
 491       }
 492
 493       if (memc_stat)
 494       {
 495         if((set_data(memc_stat, key, value)) == MEMCACHED_UNKNOWN_STAT_KEY)
 496         {
 497           WATCHPOINT_ERROR(MEMCACHED_UNKNOWN_STAT_KEY);
 498           WATCHPOINT_ASSERT(0);
 499         }
 500       }
 501     }
 502   }
 503
 504   if (rc == MEMCACHED_ERROR)
 505   {
 506     return MEMCACHED_INVALID_ARGUMENTS;
 507   }
 508
 509   if (rc == MEMCACHED_END)
 510   {
 511     return MEMCACHED_SUCCESS;
 512   }
 513
 514   return rc;
 515 }
 516
 517 memcached_stat_st *memcached_stat(memcached_st *self, char *args, memcached_return_t *error)
 518 {
 519   memcached_return_t unused;
 520   if (error == NULL)
 521   {
 522     error= &unused;
 523   }
 524
 525   if (memcached_failed(*error= initialize_query(self, true)))
 526   {
 527     return NULL;
 528   }
 529
 530   if (memcached_is_udp(self))
 531   {
 532     *error= memcached_set_error(*self, MEMCACHED_NOT_SUPPORTED, MEMCACHED_AT);
 533     return NULL;
 534   }
 535
 536   memcached_return_t rc;
 537   size_t args_length= 0;
 538   if (args)
 539   {
 540     args_length= strlen(args);
 541     rc= memcached_validate_key_length(args_length, self->flags.binary_protocol);
 542     if (memcached_failed(rc))
 543     {
 544       *error= memcached_set_error(*self, rc, MEMCACHED_AT);
 545       return NULL;
 546     }
 547   }
 548
 549   WATCHPOINT_ASSERT(error);
 550
 551   memcached_stat_st *stats= libmemcached_xcalloc(self, memcached_server_count(self), memcached_stat_st);
 552   if (stats == NULL)
 553   {
 554     *error= memcached_set_error(*self, MEMCACHED_MEMORY_ALLOCATION_FAILURE, MEMCACHED_AT);
 555     return NULL;
 556   }
 557
 558   WATCHPOINT_ASSERT(rc == MEMCACHED_SUCCESS);
 559   rc= MEMCACHED_SUCCESS;
 560   for (uint32_t x= 0; x < memcached_server_count(self); x++)
 561   {
 562     memcached_stat_st* stat_instance= stats +x;
 563
 564     stat_instance->pid= -1;
 565     stat_instance->root= self;
 566
 567     org::libmemcached::Instance* instance= memcached_instance_fetch(self, x);
 568
 569     memcached_return_t temp_return;
 570     if (memcached_is_binary(self))
 571     {
 572       temp_return= binary_stats_fetch(stat_instance, args, args_length, instance, NULL);
 573     }
 574     else
 575     {
 576       temp_return= ascii_stats_fetch(stat_instance, args, args_length, instance, NULL);
 577     }
 578
 579     // Special case where "args" is invalid
 580     if (temp_return == MEMCACHED_INVALID_ARGUMENTS)
 581     {
 582       rc= MEMCACHED_INVALID_ARGUMENTS;
 583       break;
 584     }
 585
 586     if (memcached_failed(temp_return))
 587     {
 588       rc= MEMCACHED_SOME_ERRORS;
 589     }
 590   }
 591
 592   *error= rc;
 593
 594   return stats;
 595 }
 596
 597 memcached_return_t memcached_stat_servername(memcached_stat_st *memc_stat, char *args,
 598                                              const char *hostname, in_port_t port)
 599 {
 600   memcached_st memc;
 601
 602   memcached_stat_st unused_memc_stat;
 603   if (memc_stat == NULL)
 604   {
 605     memc_stat= &unused_memc_stat;
 606   }
 607
 608   memset(memc_stat, 0, sizeof(memcached_stat_st));
 609
 610   memcached_st *memc_ptr= memcached_create(&memc);
 611   if (memc_ptr == NULL)
 612   {
 613     return MEMCACHED_MEMORY_ALLOCATION_FAILURE;
 614   }
 615
 616   memcached_return_t rc;
 617   if (memcached_failed(rc= memcached_server_add(&memc, hostname, port)))
 618   {
 619     memcached_free(&memc);
 620     return rc;
 621   }
 622
 623   if (memcached_success(rc= initialize_query(memc_ptr, true)))
 624   {
 625     size_t args_length= 0;
 626     if (args)
 627     {
 628       args_length= strlen(args);
 629       rc= memcached_validate_key_length(args_length, memc.flags.binary_protocol);
 630     }
 631
 632     if (memcached_success(rc))
 633     {
 634       org::libmemcached::Instance* instance= memcached_instance_fetch(memc_ptr, 0);
 635       if (memc.flags.binary_protocol)
 636       {
 637         rc= binary_stats_fetch(memc_stat, args, args_length, instance, NULL);
 638       }
 639       else
 640       {
 641         rc= ascii_stats_fetch(memc_stat, args, args_length, instance, NULL);
 642       }
 643     }
 644   }
 645
 646   memcached_free(&memc);
 647
 648   return rc;
 649 }
 650
 651 /*
 652   We make a copy of the keys since at some point in the not so distant future
 653   we will add support for "found" keys.
 654 */
 655 char ** memcached_stat_get_keys(memcached_st *memc,
 656                                 memcached_stat_st *,
 657                                 memcached_return_t *error)
 658 {
 659   if (memc)
 660   {
 661     char **list= static_cast<char **>(libmemcached_malloc(memc, sizeof(memcached_stat_keys)));
 662     if (list == NULL)
 663     {
 664       if (error)
 665       {
 666         *error= memcached_set_error(*memc, MEMCACHED_MEMORY_ALLOCATION_FAILURE, MEMCACHED_AT);
 667       }
 668
 669       return NULL;
 670     }
 671
 672     memcpy(list, memcached_stat_keys, sizeof(memcached_stat_keys));
 673
 674     if (error)
 675     {
 676       *error= MEMCACHED_SUCCESS;
 677     }
 678
 679     return list;
 680   }
 681
 682   return NULL;
 683 }
 684
 685 void memcached_stat_free(const memcached_st *, memcached_stat_st *memc_stat)
 686 {
 687   WATCHPOINT_ASSERT(memc_stat); // Be polite, but when debugging catch this as an error
 688   if (memc_stat)
 689   {
 690     libmemcached_free(memc_stat->root, memc_stat);
 691   }
 692 }
 693
 694 static memcached_return_t call_stat_fn(memcached_st *memc,
 695                                        org::libmemcached::Instance* instance,
 696                                        void *context)
 697 {
 698   if (memc)
 699   {
 700     local_context *check= (struct local_context *)context;
 701
 702     if (memcached_is_binary(memc))
 703     {
 704       return binary_stats_fetch(NULL, check->args, check->args_length, instance, check);
 705     }
 706     else
 707     {
 708       return ascii_stats_fetch(NULL, check->args, check->args_length, instance, check);
 709     }
 710   }
 711
 712   return MEMCACHED_INVALID_ARGUMENTS;
 713 }
 714
 715 memcached_return_t memcached_stat_execute(memcached_st *memc, const char *args,  memcached_stat_fn func, void *context)
 716 {
 717   if (memcached_fatal(memcached_version(memc)))
 718   {
 719     return memcached_last_error(memc);
 720   }
 721
 722  local_context check(func, context, args, args ? strlen(args) : 0);
 723
 724  return memcached_server_execute(memc, call_stat_fn, (void *)&check);
 725 }