summaryrefslogtreecommitdiffstats
path: root/src/alphacode/poller/poller.c
diff options
context:
space:
mode:
authorosmiy <osmiy@97f52cf1-0a1b-0410-bd0e-c28be96e8082>2006-07-12 12:24:51 +0000
committerosmiy <osmiy@97f52cf1-0a1b-0410-bd0e-c28be96e8082>2006-07-12 12:24:51 +0000
commita62b9e10b87ee280ae3c72f75acbc6777dd92009 (patch)
tree1be9fe96eb20da2e3a13382241400c6b639c1b86 /src/alphacode/poller/poller.c
parent8a9f232945f6ec241470513933baf6d72d256a06 (diff)
downloadzabbix-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.c34
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)