diff --git a/crypto777/nanosrc/protocols/reqrep/xrep.c b/crypto777/nanosrc/protocols/reqrep/xrep.c index 09b709160..ce697382b 100755 --- a/crypto777/nanosrc/protocols/reqrep/xrep.c +++ b/crypto777/nanosrc/protocols/reqrep/xrep.c @@ -124,7 +124,7 @@ void nn_xrep_rm (struct nn_sockbase *self, struct nn_pipe *pipe) void nn_xrep_in(struct nn_sockbase *self,struct nn_pipe *pipe) { struct nn_xrep *xrep; struct nn_xrep_data *data; - printf("xrep_in.%p pipe.%p\n",self,pipe); + //printf("xrep_in.%p pipe.%p\n",self,pipe); xrep = nn_cont(self,struct nn_xrep,sockbase); data = nn_pipe_getdata(pipe); nn_fq_in(&xrep->inpipes,&data->initem); @@ -253,7 +253,7 @@ int nn_xrep_getopt (NN_UNUSED struct nn_sockbase *self,NN_UNUSED int level, NN_U static int nn_xrep_create(void *hint, struct nn_sockbase **sockbase) { struct nn_xrep *self; - printf("nn_xrep_create\n"); + //printf("nn_xrep_create\n"); self = nn_alloc(sizeof(struct nn_xrep),"socket (xrep)"); alloc_assert(self); nn_xrep_init(self,&nn_xrep_sockbase_vfptr,hint); diff --git a/iguana/SuperNET.c b/iguana/SuperNET.c index d913c1caa..a4dc6295b 100644 --- a/iguana/SuperNET.c +++ b/iguana/SuperNET.c @@ -430,7 +430,7 @@ int32_t SuperNET_send(struct supernet_info *myinfo,int32_t sock,bits256 *dest,ui { 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.(%d)\n",datalen); + else printf("SuperNET_send.(%s).%u sendlen.%d\n",msg->agent,nonce,sendlen); } else printf("error creating %s.msg\n",agent); return(sendlen); } @@ -524,13 +524,14 @@ int32_t SuperNET_LBrequest(struct supernet_info *myinfo,bits256 *dest,uint8_t ty if ( (recvlen= nn_recv(myinfo->reqsock,retmsg,SUPERNET_MAXRECVBUF,0)) > 0 ) { iguana_rwnum(0,retmsg->ser_nonce,sizeof(nonce),&nonce); + printf("LBrequest recvlen.%d nonce.%u\n",recvlen,nonce); if ( retmsg->type == 'R' ) SuperNET_msgresponse(myinfo,msg,retmsg); else if ( retmsg->type == 'F' ) SuperNET_msgnonce(myinfo,msg,nonce); else if ( retmsg->type == 'E' ) printf("error sending LBrequest.(%s) datalen.%d\n",agent,datalen); - } + } else printf("LBrequest recvlen.%d\n",recvlen); } return(sendlen); } @@ -562,6 +563,7 @@ void SuperNET_recv(struct supernet_info *myinfo,int32_t sock,int32_t LBreq) else type = 'F'; retlen = 0; } else type = 'R'; // request handled locally + printf("respond.%c %u\n",type,nonce); SuperNET_send(myinfo,sock,&msg->sender,type,(struct supernet_msghdr *)retbuf,msg->agent,&retbuf[sizeof(*msg)],retlen,60,nonce); } else if ( myinfo->PUBsock >= 0 )