X-Git-Url: http://git.indexdata.com/?p=yaz-moved-to-github.git;a=blobdiff_plain;f=zoom%2Fzoom-benchmark.c;h=a91aef9061e76bfa878b47782c5ef94f478ada0a;hp=c7edd95c404fc032cecfa683644261d13fc7317c;hb=a041518cb98067d3f7c7130258b09de83cde8821;hpb=66aa379343ce353b8faa99b86c666641bd0b1577 diff --git a/zoom/zoom-benchmark.c b/zoom/zoom-benchmark.c index c7edd95..a91aef9 100644 --- a/zoom/zoom-benchmark.c +++ b/zoom/zoom-benchmark.c @@ -1,7 +1,6 @@ -/* - * $Id: zoom-benchmark.c,v 1.10 2005-09-20 09:36:18 marc Exp $ - * - * Asynchronous multi-target client doing search and piggyback retrieval +/* This file is part of the YAZ toolkit. + * Copyright (C) 1995-2008 Index Data + * See the file LICENSE for details. */ #include @@ -16,18 +15,22 @@ /* naming events */ -static char* zoom_events[10]; +static char* zoom_events[ZOOM_EVENT_MAX+1]; /* re-sorting event numbers to progress numbers */ -static int zoom_progress[10]; +static int zoom_progress[ZOOM_EVENT_MAX+1]; /* commando line parameters */ static struct parameters_t { - char host[4096]; - char query[4096]; - char progress[4096]; + char host[1024]; + char query[1024]; + int progress[4096]; int concurrent; + int repeat; int timeout; + char proxy[1024]; + int piggypack; + int gnuplot; } parameters; struct event_line_t @@ -52,8 +55,8 @@ void print_event_line(struct event_line_t *pel) pel->error, pel->errmsg); } - void update_events(int *elc, struct event_line_t *els, + int repeat, int conn, long sec, long usec, @@ -62,28 +65,43 @@ void update_events(int *elc, struct event_line_t *els, const char * eventmsg, int error, const char * errmsg){ - - els[conn * 10 + elc[conn]].connection = conn; - els[conn * 10 + elc[conn]].time_sec = sec; - els[conn * 10 + elc[conn]].time_usec = usec; - els[conn * 10 + elc[conn]].progress = prog; - els[conn * 10 + elc[conn]].event = event; - strcpy(els[conn * 10 + elc[conn]].zoom_event, eventmsg); - els[conn * 10 + elc[conn]].error = error; - strcpy(els[conn * 10 + elc[conn]].errmsg, errmsg); - - //print_event_line(&els[conn*10 + elc[conn]]); - - elc[conn] += 1; + + int ielc = repeat*parameters.concurrent + conn; + int iels = repeat*parameters.concurrent*10 + conn*10 + elc[ielc]; + + els[iels].connection = conn; + els[iels].time_sec = sec; + els[iels].time_usec = usec; + els[iels].progress = prog; + els[iels].event = event; + + if (eventmsg) + strcpy(els[iels].zoom_event, eventmsg); + else + strcpy(els[iels].zoom_event, "---"); + + els[iels].error = error; + strcpy(els[iels].errmsg, errmsg); + /* print_event_line(&els[iels]); */ + elc[ielc] += 1; } void print_events(int *elc, struct event_line_t *els, int connections){ int i; int j; - for (i=0; i < connections; i++){ - for (j=0; j < elc[i]; j++){ - print_event_line(&els[i*10 + j]); + int k; + int ielc; + int iels; + + for (k=0; k < parameters.repeat; k++){ + for (i=0; i < connections; i++){ + ielc = k * parameters.concurrent + i; + for (j=0; j < elc[ielc]; j++){ + iels = k * parameters.concurrent * 10 + i * 10 + j; + print_event_line(&els[iels]); + } + printf("\n"); } printf("\n"); } @@ -91,9 +109,10 @@ void print_events(int *elc, struct event_line_t *els, -void init_statics() +void init_statics(void) { int i; + char nullstring[1] = ""; /* naming events */ zoom_events[ZOOM_EVENT_NONE] = "ZOOM_EVENT_NONE"; @@ -106,22 +125,28 @@ void init_statics() zoom_events[ZOOM_EVENT_RECV_APDU] = "ZOOM_EVENT_RECV_APDU"; zoom_events[ZOOM_EVENT_RECV_RECORD] = "ZOOM_EVENT_RECV_RECORD"; zoom_events[ZOOM_EVENT_RECV_SEARCH] = "ZOOM_EVENT_RECV_SEARCH"; + zoom_events[ZOOM_EVENT_END] = "ZOOM_EVENT_END"; /* re-sorting event numbers to progress numbers */ zoom_progress[ZOOM_EVENT_NONE] = 0; zoom_progress[ZOOM_EVENT_CONNECT] = 1; zoom_progress[ZOOM_EVENT_SEND_DATA] = 3; zoom_progress[ZOOM_EVENT_RECV_DATA] = 4; - zoom_progress[ZOOM_EVENT_TIMEOUT] = 8; - zoom_progress[ZOOM_EVENT_UNKNOWN] = 9; + zoom_progress[ZOOM_EVENT_TIMEOUT] = 9; + zoom_progress[ZOOM_EVENT_UNKNOWN] = 10; zoom_progress[ZOOM_EVENT_SEND_APDU] = 2; zoom_progress[ZOOM_EVENT_RECV_APDU] = 5; zoom_progress[ZOOM_EVENT_RECV_RECORD] = 7; zoom_progress[ZOOM_EVENT_RECV_SEARCH] = 6; + zoom_progress[ZOOM_EVENT_END] = 8; /* parameters */ parameters.concurrent = 1; parameters.timeout = 0; + parameters.repeat = 1; + strcpy(parameters.proxy, nullstring); + parameters.gnuplot = 0; + parameters.piggypack = 0; /* progress initializing */ for (i = 0; i < 4096; i++){ @@ -167,12 +192,16 @@ long time_usec(struct time_type *ptime) return ptime->usec; } -void print_option_error() +void print_option_error(void) { fprintf(stderr, "zoom-benchmark: Call error\n"); fprintf(stderr, "zoom-benchmark -h host:port -q pqf-query " - "[-c no_concurrent] " - "[-t timeout] \n"); + "[-c no_concurrent (max 4096)] " + "[-n no_repeat] " + "[-b (piggypack)] " + "[-g (gnuplot outfile)] " + "[-p proxy] \n"); + /* "[-t timeout] \n"); */ exit(1); } @@ -180,7 +209,7 @@ void print_option_error() void read_params(int argc, char **argv, struct parameters_t *p_parameters){ char *arg; int ret; - while ((ret = options("h:q:c:t:", argv, argc, &arg)) != -2) + while ((ret = options("h:q:c:t:p:bgn:", argv, argc, &arg)) != -2) { switch (ret) { @@ -190,11 +219,25 @@ void read_params(int argc, char **argv, struct parameters_t *p_parameters){ case 'q': strcpy(p_parameters->query, arg); break; + case 'p': + strcpy(p_parameters->proxy, arg); + break; case 'c': p_parameters->concurrent = atoi(arg); break; - case 't': +#if 0 + case 't': p_parameters->timeout = atoi(arg); + break; +#endif + case 'b': + p_parameters->piggypack = 1; + break; + case 'g': + p_parameters->gnuplot = 1; + break; + case 'n': + p_parameters->repeat = atoi(arg); break; case 0: print_option_error(); @@ -209,7 +252,13 @@ void read_params(int argc, char **argv, struct parameters_t *p_parameters){ printf(" host: %s \n", p_parameters->host); printf(" query: %s \n", p_parameters->query); printf(" concurrent: %d \n", p_parameters->concurrent); - printf(" timeout: %d \n\n", p_parameters->timeout); + printf(" repeat: %d \n", p_parameters->repeat); +#if 0 + printf(" timeout: %d \n", p_parameters->timeout); +#endif + printf(" proxy: %s \n", p_parameters->proxy); + printf(" piggypack: %d \n\n", p_parameters->piggypack); + printf(" gnuplot: %d \n\n", p_parameters->gnuplot); } if (! strlen(p_parameters->host)) @@ -218,12 +267,18 @@ void read_params(int argc, char **argv, struct parameters_t *p_parameters){ print_option_error(); if (! (p_parameters->concurrent > 0)) print_option_error(); + if (! (p_parameters->repeat > 0)) + print_option_error(); if (! (p_parameters->timeout >= 0)) print_option_error(); + if (! ( p_parameters->concurrent <= 4096)) + print_option_error(); } -void print_table_header() +void print_table_header(void) { + if (parameters.gnuplot) + printf("#"); printf ("target\tsecond.usec\tprogress\tevent\teventname\t"); printf("error\terrorname\n"); } @@ -238,22 +293,30 @@ int main(int argc, char **argv) struct event_line_t *els; ZOOM_options o; int i; + int k; init_statics(); read_params(argc, argv, ¶meters); - z = xmalloc(sizeof(*z) * parameters.concurrent); - r = xmalloc(sizeof(*r) * parameters.concurrent); - elc = xmalloc(sizeof(*elc) * parameters.concurrent); - els = xmalloc(sizeof(*els) * parameters.concurrent * 10); + z = (ZOOM_connection *) xmalloc(sizeof(*z) * parameters.concurrent); + r = (ZOOM_resultset *) xmalloc(sizeof(*r) * parameters.concurrent); + elc = (int *) xmalloc(sizeof(*elc) * parameters.concurrent * parameters.repeat); + els = (struct event_line_t *) xmalloc( + sizeof(*els) * parameters.concurrent * parameters.repeat * 10); o = ZOOM_options_create(); /* async mode */ ZOOM_options_set (o, "async", "1"); - /* get first record of result set (using piggyback) */ - ZOOM_options_set (o, "count", "1"); + /* get first record of result set (using piggypack) */ + if (parameters.piggypack) + ZOOM_options_set (o, "count", "1"); + + /* set proxy */ + if (strlen(parameters.proxy)) + ZOOM_options_set (o, "proxy", parameters.proxy); + /* preferred record syntax */ if (0){ @@ -261,65 +324,100 @@ int main(int argc, char **argv) ZOOM_options_set (o, "elementSetName", "F"); } + time_init(&time); + /* repeat loop */ + for (k = 0; k < parameters.repeat; k++){ - /* connect to all concurrent connections*/ - for ( i = 0; i < parameters.concurrent; i++){ - /* set event count to zero */ - elc[i] = 0; + /* progress zeroing */ + for (i = 0; i < 4096; i++){ + parameters.progress[i] = k * 5 -1; + } - /* create connection - pass options (they are the same for all) */ - z[i] = ZOOM_connection_create(o); + /* connect to all concurrent connections*/ + for ( i = 0; i < parameters.concurrent; i++){ + /* set event count to zero */ + elc[k * parameters.concurrent + i] = 0; + + /* create connection - pass options (they are the same for all) */ + z[i] = ZOOM_connection_create(o); + + /* connect and init */ + ZOOM_connection_connect(z[i], parameters.host, 0); + } + /* search all */ + for (i = 0; i < parameters.concurrent; i++) + r[i] = ZOOM_connection_search_pqf (z[i], parameters.query); + + /* network I/O. pass number of connections and array of connections */ + while ((i = ZOOM_event (parameters.concurrent, z))){ + int event = ZOOM_connection_last_event(z[i-1]); + const char *errmsg; + const char *addinfo; + int error = 0; + //int progress = zoom_progress[event]; + + if (event == ZOOM_EVENT_SEND_DATA || event == ZOOM_EVENT_RECV_DATA) + continue; + + time_stamp(&time); + + /* updating events and event list */ + error = ZOOM_connection_error(z[i-1] , &errmsg, &addinfo); + if (error) + parameters.progress[i] = zoom_progress[ZOOM_EVENT_UNKNOWN]; + //parameters.progress[i] = zoom_progress[ZOOM_EVENT_NONE]; + else if (event == ZOOM_EVENT_CONNECT) + parameters.progress[i] = zoom_progress[event]; + else + //parameters.progress[i] = zoom_progress[event]; + parameters.progress[i] += 1; + + update_events(elc, els, + k, i-1, + time_sec(&time), time_usec(&time), + parameters.progress[i], + event, zoom_events[event], + error, errmsg); + } + + /* destroy connections */ + for (i = 0; i