diff --git a/iguana/SuperNET.c b/iguana/SuperNET.c index b181aced7..663437eb0 100644 --- a/iguana/SuperNET.c +++ b/iguana/SuperNET.c @@ -423,14 +423,14 @@ int32_t nn_reqsocket(struct supernet_info *myinfo,uint16_t LBport,uint16_t PUBpo int32_t SuperNET_send(struct supernet_info *myinfo,int32_t sock,bits256 *dest,uint8_t type,struct supernet_msghdr *msg,char *agent,uint8_t *data,int32_t datalen,uint32_t duration,uint32_t nonce) { - int32_t i,sendlen = -1; + int32_t sendlen = -1; if ( nonce == 0 ) OS_randombytes((void *)&nonce,sizeof(nonce)); if ( (msg= SuperNET_msgcreate(myinfo,type,&myinfo->myaddr.pubkey,dest,msg,sizeof(*msg)+datalen,agent,data,datalen,duration,nonce)) != 0 ) { - for (i=0; i<10; i++) - if ( (nn_socket_status(sock,1) & NN_POLLOUT) != 0 ) - break; + //for (i=0; i<10; i++) + // if ( (nn_socket_status(sock,1) & NN_POLLOUT) != 0 ) + // break; if ( (sendlen= nn_send(sock,msg,sizeof(*msg)+datalen,0)) != sizeof(*msg)+datalen ) printf("SuperNET_send sendlen.%d != len.%ld\n",sendlen,sizeof(*msg)+datalen); else printf("SuperNET_send.(%s).%u sendlen.%d\n",msg->agent,nonce,sendlen); @@ -534,9 +534,9 @@ int32_t SuperNET_LBrequest(struct supernet_info *myinfo,bits256 *dest,uint8_t ty { retmsg = (void *)myinfo->recvbuf[1]; iguana_rwnum(0,msg->ser_nonce,sizeof(nonce),&nonce); - for (i=0; i<10; i++) - if ( (nn_socket_status(sock,1) & NN_POLLIN) != 0 ) - break; + //for (i=0; i<10; i++) + // if ( (nn_socket_status(sock,1) & NN_POLLIN) != 0 ) + // break; if ( (recvlen= nn_recv(sock,retmsg,SUPERNET_MAXRECVBUF,0)) > 0 ) { printf("LBrequest recvlen.%d nonce.%u\n",recvlen,nonce); @@ -564,9 +564,9 @@ void SuperNET_recv(struct supernet_info *myinfo,int32_t sock,int32_t LBreq) myinfo->recvbuf[LBreq] = calloc(1,SUPERNET_MAXRECVBUF+sizeof(*msg)); if ( myinfo->recvbuf[LBreq + 1] == 0 ) myinfo->recvbuf[LBreq + 1] = calloc(1,SUPERNET_MAXRECVBUF+sizeof(*msg)); - for (i=0; i<10; i++) - if ( (nn_socket_status(sock,1) & NN_POLLIN) != 0 ) - break; + //for (i=0; i<10; i++) + // if ( (nn_socket_status(sock,1) & NN_POLLIN) != 0 ) + // break; if ( (recvlen= nn_recv(sock,myinfo->recvbuf[LBreq],SUPERNET_MAXRECVBUF,0)) > 0 ) { msg = (void *)myinfo->recvbuf[LBreq];