From 10361a661b3c470c4dfea949c98daab1fb310a63 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?IOhannes=20m=20zm=C3=B6lnig?= Date: Wed, 24 Mar 2010 15:58:28 +0000 Subject: made it compile (and run) on w32 svn path=/trunk/externals/iem/iemnet/; revision=13255 --- shared.c | 14 ++++---------- 1 file changed, 4 insertions(+), 10 deletions(-) (limited to 'shared.c') diff --git a/shared.c b/shared.c index 09faaad..1a46a92 100644 --- a/shared.c +++ b/shared.c @@ -387,10 +387,10 @@ static int iemnet__sender_dosend(int sockfd, t_queue*q) { if(c) { unsigned char*data=c->data; unsigned int size=c->size; - + int result=-1; fprintf(stderr, "sending %d bytes at %x to %d\n", size, data, sockfd); - int result = send(sockfd, data, size, 0); + result = send(sockfd, data, size, 0); // shouldn't we do something with the result here? iemnet__chunk_destroy(c); } else { @@ -508,12 +508,13 @@ static void*iemnet__receiver_readthread(void*arg) { for(i=0; irunning=1; while(1) { + t_iemnet_chunk*c=NULL; fprintf(stderr, "reading %d bytes...\n", size); result = recv(sockfd, data, size, 0); fprintf(stderr, "read %d bytes...\n", result); if(result<=0)break; - t_iemnet_chunk*c = iemnet__chunk_create_data(result, data); + c= iemnet__chunk_create_data(result, data); queue_push(q, c); @@ -531,27 +532,20 @@ static void*iemnet__receiver_readthread(void*arg) { return NULL; } -#define WHERE fprintf(stderr, "%s:%d", __FUNCTION__, __LINE__) static void iemnet__receiver_tick(t_iemnet_receiver *x) { - WHERE; fprintf(stderr, "\treceiver=%x", x); // received data t_iemnet_chunk*c=queue_pop_noblock(x->queue); - WHERE; fprintf(stderr, "\tchunk=%x", c); while(NULL!=c) { x->flist = iemnet__chunk2list(c, x->flist); (x->callback)(x->owner, x->sockfd, x->flist->argc, x->flist->argv); iemnet__chunk_destroy(c); c=queue_pop_noblock(x->queue); } - - WHERE; fprintf(stderr, "\trunning=%d", x->running); - if(!x->running) { // read terminated x->callback(x->owner, x->sockfd, 0, NULL); } - WHERE; fprintf(stderr, "\ttick done\n"); } -- cgit v1.2.1