From 27dca0a493f755e74c6e72431aa5642d1936ec45 Mon Sep 17 00:00:00 2001 From: Adam Dickmeiss Date: Sat, 13 Mar 2010 00:59:58 +0100 Subject: [PATCH] Observe number of concurrent record ingests --- src/client.c | 20 ++++++++++++++++++-- 1 file changed, 18 insertions(+), 2 deletions(-) diff --git a/src/client.c b/src/client.c index 01267cd..7c5a01c 100644 --- a/src/client.c +++ b/src/client.c @@ -24,7 +24,7 @@ Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA #if HAVE_CONFIG_H #include #endif - +#include #include #include #include @@ -428,6 +428,8 @@ void client_got_records(struct client *cl) void client_record_response(struct client *cl) { + static pthread_mutex_t ingest_mutex = PTHREAD_MUTEX_INITIALIZER; + static int ingest_counter = 0, ingest_max = 0; struct connection *co = cl->connection; ZOOM_connection link = connection_get_link(co); ZOOM_resultset resultset = cl->resultset; @@ -475,8 +477,19 @@ void client_record_response(struct client *cl) struct session_database *sdb = client_get_database(cl); NMEM nmem = nmem_create(); const char *xmlrec; + int new_max = 0; char type[80]; yaz_log(YLOG_LOG, "Record ingest begin client=%p session=%p", cl, cl->session); + pthread_mutex_lock(&ingest_mutex); + ++ingest_counter; + if (ingest_counter > ingest_max) + { + ingest_max = ingest_counter; + new_max = ingest_max; + } + pthread_mutex_unlock(&ingest_mutex); + if (new_max) + yaz_log(YLOG_LOG, "New max client=%p new_max=%d", cl, new_max); if (nativesyntax_to_type(sdb, type, rec)) yaz_log(YLOG_WARN, "Failed to determine record type"); xmlrec = ZOOM_record_get(rec, type, NULL); @@ -489,8 +502,11 @@ void client_record_response(struct client *cl) yaz_log(YLOG_WARN, "Failed to ingest from %s", client_get_url(cl)); } + pthread_mutex_lock(&ingest_mutex); + --ingest_counter; + pthread_mutex_unlock(&ingest_mutex); nmem_destroy(nmem); - yaz_log(YLOG_LOG, "Record ingest end client=%p session=%p", cl, cl->session); + yaz_log(YLOG_LOG, "Record ingest end client=%p session=%p max=%d", cl, cl->session, ingest_max); } } else -- 1.7.10.4