From 29f2b2b9168fd2d45ec5a2699dab2e5ab44ad10b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?IOhannes=20m=20zm=C3=B6lnig?= Date: Thu, 25 Mar 2010 08:28:36 +0000 Subject: most of the tcp-objects seem to work now; performance increase as measured until now is great :-) svn path=/trunk/externals/iem/iemnet/; revision=13265 --- iemnet.c | 26 +++++++++++++------------- 1 file changed, 13 insertions(+), 13 deletions(-) (limited to 'iemnet.c') diff --git a/iemnet.c b/iemnet.c index 5c739c7..7586c7a 100644 --- a/iemnet.c +++ b/iemnet.c @@ -4,8 +4,6 @@ #include "iemnet.h" -#include "s_stuff.h" - #include #include #include @@ -488,7 +486,7 @@ int iemnet__sender_setsockopt(t_iemnet_sender*s, int level, int optname, const v struct _iemnet_receiver { pthread_t thread; int sockfd; /* owned outside; you must call iemnet__receiver_destroy() before freeing socket yourself */ - void*owner; + void*userdata; t_iemnet_chunk*data; t_iemnet_receivecallback callback; t_queue*queue; @@ -542,20 +540,20 @@ static void iemnet__receiver_tick(t_iemnet_receiver *x) t_iemnet_chunk*c=queue_pop_noblock(x->queue); while(NULL!=c) { x->flist = iemnet__chunk2list(c, x->flist); - (x->callback)(x->owner, x->sockfd, x->flist->argc, x->flist->argv); + (x->callback)(x->userdata, x->flist->argc, x->flist->argv); iemnet__chunk_destroy(c); c=queue_pop_noblock(x->queue); } if(!x->running) { // read terminated - x->callback(x->owner, x->sockfd, 0, NULL); + x->callback(x->userdata, 0, NULL); } } -t_iemnet_receiver*iemnet__receiver_create(int sock, void*owner, t_iemnet_receivecallback callback) { +t_iemnet_receiver*iemnet__receiver_create(int sock, void*userdata, t_iemnet_receivecallback callback) { t_iemnet_receiver*rec=(t_iemnet_receiver*)getbytes(sizeof(t_iemnet_receiver)); - //fprintf(stderr, "new receiver for %d\t%x\t%x\n", sock, owner, callback); + //fprintf(stderr, "new receiver for %d\t%x\t%x\n", sock, userdata, callback); if(rec) { t_iemnet_chunk*data=iemnet__chunk_create_empty(INBUFSIZE); int res=0; @@ -564,7 +562,7 @@ t_iemnet_receiver*iemnet__receiver_create(int sock, void*owner, t_iemnet_receive return NULL; } rec->sockfd=sock; - rec->owner=owner; + rec->userdata=userdata; rec->data=data; rec->callback=callback; rec->flist=iemnet__floatlist_create(1024); @@ -590,7 +588,7 @@ void iemnet__receiver_destroy(t_iemnet_receiver*rec) { rec->sockfd=0; pthread_join(rec->thread, NULL); - rec->owner=NULL; + rec->userdata=NULL; rec->data=NULL; rec->callback=NULL; rec->clock=NULL; @@ -609,15 +607,17 @@ void iemnet__receiver_destroy(t_iemnet_receiver*rec) { #ifdef _MSC_VER - void tcpclient_setup(void); - void tcpserver_setup(void); +void tcpclient_setup(void); +void tcpserver_setup(void); +void tcpsend_setup(void); #endif IEMNET_EXTERN void iemnet_setup(void) { #ifdef _MSC_VER - tcpclient_setup(); - tcpserver_setup(); + tcpclient_setup(); + tcpserver_setup(); + tcpserver_setup(); #endif } -- cgit v1.2.1