From 5ec0ba4b33283beead3d7aaa743691c142dbb8fd Mon Sep 17 00:00:00 2001 From: =?utf8?q?Michal=20Voc=C5=AF?= Date: Mon, 12 Sep 2005 14:21:00 +0000 Subject: [PATCH] * use the modified il_msg --- org.glite.lb.logger/src/send_event.c | 24 ++++++++++++++++-------- 1 file changed, 16 insertions(+), 8 deletions(-) diff --git a/org.glite.lb.logger/src/send_event.c b/org.glite.lb.logger/src/send_event.c index 6ed63d4..65e2c01 100644 --- a/org.glite.lb.logger/src/send_event.c +++ b/org.glite.lb.logger/src/send_event.c @@ -91,19 +91,22 @@ confirm_msg(struct server_msg *msg, int code, int code_min) #endif -static edg_wll_GssConnection *tmp_gss; + +struct reader_data { + edg_wll_GssConnection *gss; + struct timeval *timeout; +}; + static int -gss_reader(char *buffer, int max_len) +gss_reader(void *user_data, char *buffer, int max_len) { int ret, len; - struct timeval tv; + struct reader_data *data = (struct reader_data *)user_data; edg_wll_GssStatus gss_stat; - tv.tv_sec = TIMEOUT; - tv.tv_usec = 0; - ret = edg_wll_gss_read_full(tmp_gss, buffer, max_len, &tv, &len, &gss_stat); + ret = edg_wll_gss_read_full(data->gss, buffer, max_len, data->timeout, &len, &gss_stat); if(ret < 0) { char *gss_err = NULL; @@ -130,9 +133,14 @@ get_reply(struct event_queue *eq, char **buf, int *code_min) char *msg; int ret, code; size_t len, l; + struct timeval tv; + struct reader_data data; - tmp_gss = &eq->gss; - len = read_il_data(&msg, gss_reader); + tv.tv_sec = TIMEOUT; + tv.tv_usec = 0; + data.gss = &eq->gss; + data.timeout = &tv; + len = read_il_data(&data, &msg, gss_reader); if(len < 0) return(-1); -- 1.8.2.3