X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=clients%2Fmemstat.c;h=27c34a41c2caf4ad048c3bb4f8320cfe5950142a;hb=acce29c292b435fef4fd486495dca7d653be2bf2;hp=809d78e03d439e3ccd5b78e471a2ea974735b57f;hpb=f8111ea2d1eb2fa4bb6c23386ca10bd39ac8889a;p=awesomized%2Flibmemcached diff --git a/clients/memstat.c b/clients/memstat.c index 809d78e0..27c34a41 100644 --- a/clients/memstat.c +++ b/clients/memstat.c @@ -1,3 +1,4 @@ +#include "libmemcached/common.h" #include #include #include @@ -6,6 +7,7 @@ #include #include #include +#include #include @@ -17,9 +19,9 @@ /* Prototypes */ static void options_parse(int argc, char *argv[]); -static void run_analyzer(memcached_st *memc, memcached_stat_st *stat, - memcached_server_st *server_list, char *mode); -static void print_server_listing(memcached_st *memc, memcached_stat_st *stat, +static void run_analyzer(memcached_st *memc, memcached_stat_st *memc_stat, + memcached_server_st *server_list); +static void print_server_listing(memcached_st *memc, memcached_stat_st *memc_stat, memcached_server_st *server_list); static void print_analysis_report(memcached_st *memc, memcached_analysis_st *report, @@ -47,7 +49,7 @@ int main(int argc, char *argv[]) { memcached_return rc; memcached_st *memc; - memcached_stat_st *stat; + memcached_stat_st *memc_stat; memcached_server_st *servers; memcached_server_st *server_list; @@ -73,7 +75,7 @@ int main(int argc, char *argv[]) memcached_server_push(memc, servers); memcached_server_list_free(servers); - stat= memcached_stat(memc, NULL, &rc); + memc_stat= memcached_stat(memc, NULL, &rc); if (rc != MEMCACHED_SUCCESS && rc != MEMCACHED_SOME_ERRORS) { @@ -85,11 +87,11 @@ int main(int argc, char *argv[]) server_list= memcached_server_list(memc); if (opt_analyze) - run_analyzer(memc, stat, server_list, analyze_mode); + run_analyzer(memc, memc_stat, server_list); else - print_server_listing(memc, stat, server_list); + print_server_listing(memc, memc_stat, server_list); - free(stat); + free(memc_stat); free(opt_servers); memcached_free(memc); @@ -97,15 +99,15 @@ int main(int argc, char *argv[]) return 0; } -static void run_analyzer(memcached_st *memc, memcached_stat_st *stat, - memcached_server_st *server_list, char *mode) +static void run_analyzer(memcached_st *memc, memcached_stat_st *memc_stat, + memcached_server_st *server_list) { memcached_return rc; if (analyze_mode == NULL) { memcached_analysis_st *report; - report= memcached_analyze(memc, stat, &rc); + report= memcached_analyze(memc, memc_stat, &rc); if (rc != MEMCACHED_SUCCESS || report == NULL) { printf("Failure to analyze servers (%s)\n", @@ -115,14 +117,105 @@ static void run_analyzer(memcached_st *memc, memcached_stat_st *stat, print_analysis_report(memc, report, server_list); free(report); } + else if (strcmp(analyze_mode, "latency") == 0) + { + memcached_st **servers; + uint32_t x, y, flags, server_count= memcached_server_count(memc); + uint32_t num_of_tests= 32; + const char *test_key= "libmemcached_test_key"; + + servers= malloc(sizeof(memcached_st*) * server_count); + if (!servers) + { + fprintf(stderr, "Failed to allocate memory\n"); + return; + } + + for (x= 0; x < server_count; x++) + { + if((servers[x]= memcached_create(NULL)) == NULL) + { + fprintf(stderr, "Failed to memcached_create()\n"); + if (x > 0) + memcached_free(servers[0]); + x--; + for (; x > 0; x--) + memcached_free(servers[x]); + + free(servers); + return; + } + memcached_server_add(servers[x], + memcached_server_name(memc, server_list[x]), + memcached_server_port(memc, server_list[x])); + } + + printf("Network Latency Test:\n\n"); + struct timeval start_time, end_time; + long elapsed_time, slowest_time= 0, slowest_server= 0; + + for (x= 0; x < server_count; x++) + { + gettimeofday(&start_time, NULL); + for (y= 0; y < num_of_tests; y++) + { + size_t vlen; + char *val= memcached_get(servers[x], test_key, strlen(test_key), + &vlen, &flags, &rc); + if (rc != MEMCACHED_NOTFOUND && rc != MEMCACHED_SUCCESS) + break; + free(val); + } + gettimeofday(&end_time, NULL); + + elapsed_time= timedif(end_time, start_time); + elapsed_time /= num_of_tests; + + if (elapsed_time > slowest_time) + { + slowest_server= x; + slowest_time= elapsed_time; + } + + if (rc != MEMCACHED_NOTFOUND && rc != MEMCACHED_SUCCESS) + { + printf("\t %s (%d) => failed to reach the server\n", + memcached_server_name(memc, server_list[x]), + memcached_server_port(memc, server_list[x])); + } + else + { + printf("\t %s (%d) => %ld.%ld seconds\n", + memcached_server_name(memc, server_list[x]), + memcached_server_port(memc, server_list[x]), + elapsed_time / 1000, elapsed_time % 1000); + } + } + + if (server_count > 1 && slowest_time > 0) + { + printf("---\n"); + printf("Slowest Server: %s (%d) => %ld.%ld seconds\n", + memcached_server_name(memc, server_list[slowest_server]), + memcached_server_port(memc, server_list[slowest_server]), + slowest_time / 1000, slowest_time % 1000); + } + printf("\n"); + + for (x= 0; x < server_count; x++) + memcached_free(servers[x]); + + free(servers); + free(analyze_mode); + } else { - /* More code here in the next patch */ - free(mode); + fprintf(stderr, "Invalid Analyzer Option provided\n"); + free(analyze_mode); } } -static void print_server_listing(memcached_st *memc, memcached_stat_st *stat, +static void print_server_listing(memcached_st *memc, memcached_stat_st *memc_stat, memcached_server_st *server_list) { unsigned int x; @@ -134,14 +227,13 @@ static void print_server_listing(memcached_st *memc, memcached_stat_st *stat, char **list; char **ptr; - list= memcached_stat_get_keys(memc, &stat[x], &rc); + list= memcached_stat_get_keys(memc, &memc_stat[x], &rc); printf("Server: %s (%u)\n", memcached_server_name(memc, server_list[x]), memcached_server_port(memc, server_list[x])); for (ptr= list; *ptr; ptr++) { - memcached_return rc; - char *value= memcached_stat_get_value(memc, &stat[x], *ptr, &rc); + char *value= memcached_stat_get_value(memc, &memc_stat[x], *ptr, &rc); printf("\t %s: %s\n", *ptr, value); free(value);