diff options
| author | osmiy <osmiy@97f52cf1-0a1b-0410-bd0e-c28be96e8082> | 2006-07-12 12:24:51 +0000 |
|---|---|---|
| committer | osmiy <osmiy@97f52cf1-0a1b-0410-bd0e-c28be96e8082> | 2006-07-12 12:24:51 +0000 |
| commit | a62b9e10b87ee280ae3c72f75acbc6777dd92009 (patch) | |
| tree | 1be9fe96eb20da2e3a13382241400c6b639c1b86 /src/alphacode/poller/poller.c | |
| parent | 8a9f232945f6ec241470513933baf6d72d256a06 (diff) | |
| download | zabbix-a62b9e10b87ee280ae3c72f75acbc6777dd92009.tar.gz zabbix-a62b9e10b87ee280ae3c72f75acbc6777dd92009.tar.xz zabbix-a62b9e10b87ee280ae3c72f75acbc6777dd92009.zip | |
minor fixes
git-svn-id: svn://svn.zabbix.com/trunk@3039 97f52cf1-0a1b-0410-bd0e-c28be96e8082
Diffstat (limited to 'src/alphacode/poller/poller.c')
| -rw-r--r-- | src/alphacode/poller/poller.c | 34 |
1 files changed, 18 insertions, 16 deletions
diff --git a/src/alphacode/poller/poller.c b/src/alphacode/poller/poller.c index 570cee64..f39e9518 100644 --- a/src/alphacode/poller/poller.c +++ b/src/alphacode/poller/poller.c @@ -35,7 +35,7 @@ ZBXPOOL char ip[128]; int port; int socket; - int status; // 0 - not connected, 1 - connected, 2 - wrote data + int status; /* 0 - not connected, 1 - connected, 2 - wrote data */ }; ZBXPOOL pool[NUM]; @@ -67,13 +67,14 @@ void wait_connect() for(;;) { -// printf("To process [%d]\n", NUM-READ); -// printf("-----------------------\n"); -// for(j=0;j<NUM-READ;j++) -// { -// printf("[%d] fd [%d] revents [%X]\n",j,poll_cli[j].fd,poll_cli[j].revents); -// } -// printf("-----------------------\n"); +/* printf("To process [%d]\n", NUM-READ); + printf("-----------------------\n"); + for(j=0;j<NUM-READ;j++) + { + printf("[%d] fd [%d] revents [%X]\n",j,poll_cli[j].fd,poll_cli[j].revents); + } + printf("-----------------------\n"); +*/ if(NUM-READ<=0) break; retval = poll(poll_cli,NUM-READ,-1); @@ -90,7 +91,7 @@ void wait_connect() for(i=0;i<NUM-READ;i++) { -// printf("[%d] remote socket [%X]\n",i,poll_cli[i].revents); +/* printf("[%d] remote socket [%X]\n",i,poll_cli[i].revents); */ if ((poll_cli[i].revents&POLLHUP)==POLLHUP) { printf("[%d] remote socket has closed\n",i); @@ -100,13 +101,14 @@ void wait_connect() { memmove(&poll_cli[i], &poll_cli[i+1],(NUM-READ-i-1)*sizeof(struct pollfd)); READ++; -// for(j=i;j<NUM-READ;j++) -// { -// memmove(&poll_cli[j], &poll_cli[j+1],sizeof(struct pollfd)); -// poll_cli[j].fd=poll_cli[j+1].fd; -// poll_cli[j].events=poll_cli[j+1].events; -// poll_cli[j].revents=poll_cli[j+1].revents; -// } +/* for(j=i;j<NUM-READ;j++) + { + memmove(&poll_cli[j], &poll_cli[j+1],sizeof(struct pollfd)); + poll_cli[j].fd=poll_cli[j+1].fd; + poll_cli[j].events=poll_cli[j+1].events; + poll_cli[j].revents=poll_cli[j+1].revents; + } +*/ break; } if ((poll_cli[i].revents&POLLERR)==POLLERR) |
