X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;ds=sidebyside;f=src%2Futilities.c;h=1dfd60b254e841680f49b59084bae0ab3ccb8991;hb=462ca3337e78759724dcd7379f71c68b50cfb81f;hp=a2dc944f05d3e27e9a1399c58953179f17a36554;hpb=113160884d25c401dc352cfab093b5b7b1a4fde0;p=awesomized%2Flibmemcached diff --git a/src/utilities.c b/src/utilities.c index a2dc944f..1dfd60b2 100644 --- a/src/utilities.c +++ b/src/utilities.c @@ -1,68 +1,72 @@ +#include #include -#include -#include +#include +#include "utilities.h" -memcached_server_st *parse_opt_servers(char *server_strings) + +long int timedif(struct timeval a, struct timeval b) { - char *string; - unsigned int port; - char *begin_ptr; - char *end_ptr; - memcached_server_st *servers= NULL; - memcached_return rc; + register int us, s; - assert(server_strings); + us = a.tv_usec - b.tv_usec; + us /= 1000; + s = a.tv_sec - b.tv_sec; + s *= 1000; + return s + us; +} - end_ptr= server_strings + strlen(server_strings); +void version_command(char *command_name) +{ + printf("%s v%u.%u\n", command_name, 1, 0); + exit(0); +} - for (begin_ptr= server_strings, string= index(server_strings, ','); - begin_ptr != end_ptr; - string= index(begin_ptr, ',')) +char *lookup_help(memcached_options option) +{ + switch (option) { - char buffer[HUGE_STRING_LEN]; - char *ptr; - port= 0; - - memset(buffer, 0, HUGE_STRING_LEN); - if (string) - { - memcpy(buffer, begin_ptr, string - begin_ptr); - begin_ptr= string+1; - } - else - { - size_t length= strlen(begin_ptr); - memcpy(buffer, begin_ptr, length); - begin_ptr= end_ptr; - } - - ptr= index(buffer, ':'); + case OPT_SERVERS: return("List which servers you wish to connect to."); + case OPT_VERSION: return("Display the version of the application and then exit."); + case OPT_HELP: return("Diplay this message and then exit."); + case OPT_VERBOSE: return("Give more details on the progression of the application."); + case OPT_DEBUG: return("Provide output only useful for debugging."); + case OPT_FLAG: return("Provide flag information for storage operation."); + case OPT_EXPIRE: return("Set the expire option for the object."); + case OPT_SET: return("Use set command with memcached when storing."); + case OPT_REPLACE: return("Use replace command with memcached when storing."); + case OPT_ADD: return("Use add command with memcached when storing."); + case OPT_SLAP_EXECUTE_NUMBER: return("Number of times to execute the given test."); + case OPT_SLAP_INITIAL_LOAD: return("Number of key pairs to load before executing tests."); + case OPT_SLAP_TEST: return("Test to run."); + case OPT_SLAP_CONCURRENCY: return("Number of users to simulate with load."); + case OPT_SLAP_NON_BLOCK: return("Set TCP up to use non-blocking IO."); + case OPT_SLAP_TCP_NODELAY: return("Set TCP socket up to use nodelay."); + case OPT_FLUSH: return("Flush servers before running tests."); + }; - if (ptr) - { - ptr[0]= 0; + return "forgot to document this one :)"; +} - ptr++; +void help_command(char *command_name, char *description, + const struct option *long_options, + memcached_programs_help_st *options) +{ + unsigned int x; - port= strtol(ptr, (char **)NULL, 10); - } + printf("%s v%u.%u\n\n", command_name, 1, 0); + printf("\t%s\n\n", description); + printf("Current options. A '=' means the option takes a value.\n\n"); - servers= memcached_server_list_append(servers, buffer, port, &rc); + for (x= 0; long_options[x].name; x++) + { + char *help_message; - if (isspace(*begin_ptr)) - begin_ptr++; + printf("\t --%s%c\n", long_options[x].name, + long_options[x].has_arg ? '=' : ' '); + if ((help_message= lookup_help(long_options[x].val))) + printf("\t\t%s\n", help_message); } - return servers; -} - -long int timedif(struct timeval a, struct timeval b) -{ - register int us, s; - - us = a.tv_usec - b.tv_usec; - us /= 1000; - s = a.tv_sec - b.tv_sec; - s *= 1000; - return s + us; + printf("\n"); + exit(0); }