|
|
@ -107,7 +107,7 @@ void LP_psockloop(void *_ptr) |
|
|
|
{ |
|
|
|
if ( (sentbytes= LP_send(sendsock,buf,size,0)) > 0 ) |
|
|
|
{ |
|
|
|
//printf("PSOCKS (%d %d %d) (%s) -> %d/%d bytes %s\n",ptr->publicsock,ptr->sendsock,sendsock,(char *)buf,size,sentbytes,ptr->sendaddr);
|
|
|
|
printf("PSOCKS (%d %d %d) (%s) -> %d/%d bytes %s\n",ptr->publicsock,ptr->sendsock,sendsock,(char *)buf,size,sentbytes,ptr->sendaddr); |
|
|
|
} |
|
|
|
else |
|
|
|
{ |
|
|
@ -150,7 +150,7 @@ void LP_psockloop(void *_ptr) |
|
|
|
} |
|
|
|
else if ( (pfds[n].revents & POLLIN) != 0 ) |
|
|
|
{ |
|
|
|
//printf("publicsock.%d %s has pollin\n",ptr->publicsock,ptr->publicaddr);
|
|
|
|
printf("publicsock.%d %s has pollin\n",ptr->publicsock,ptr->publicaddr); |
|
|
|
if ( (size= nn_recv(ptr->publicsock,&buf,NN_MSG,0)) > 0 ) |
|
|
|
{ |
|
|
|
ptr->lasttime = now; |
|
|
@ -176,7 +176,7 @@ void LP_psockloop(void *_ptr) |
|
|
|
{ |
|
|
|
if ( (size= nn_recv(ptr->sendsock,&buf,NN_MSG,0)) > 0 ) |
|
|
|
{ |
|
|
|
//printf("%s paired has pollin (%s)\n",ptr->sendaddr,(char *)buf);
|
|
|
|
printf("%s paired has pollin (%s)\n",ptr->sendaddr,(char *)buf); |
|
|
|
ptr->lasttime = now; |
|
|
|
if ( ptr->ispaired != 0 ) |
|
|
|
{ |
|
|
@ -201,7 +201,7 @@ void LP_psockloop(void *_ptr) |
|
|
|
if ( retval != 0 ) |
|
|
|
printf("nn_poll retval.%d\n",retval); |
|
|
|
break; |
|
|
|
} // else printf("num pfds.%d retval.%d\n",n,retval);
|
|
|
|
} else printf("num pfds.%d retval.%d\n",n,retval); |
|
|
|
} |
|
|
|
} |
|
|
|
//free(pfds);
|
|
|
|