|
|
@ -798,7 +798,10 @@ void dpow_send(struct supernet_info *myinfo,struct dpow_info *dp,struct dpow_blo |
|
|
|
} |
|
|
|
} |
|
|
|
if ( myinfo->dexsock >= 0 ) |
|
|
|
{ |
|
|
|
printf("SEND DEX PACKET\n"); |
|
|
|
nn_send(myinfo->dexsock,np,size,0); |
|
|
|
} |
|
|
|
portable_mutex_unlock(&myinfo->dpowmutex); |
|
|
|
free(np); |
|
|
|
if ( bp->myind <= 2 ) |
|
|
@ -927,6 +930,9 @@ int32_t dpow_nanomsg_update(struct supernet_info *myinfo) |
|
|
|
if ( dexp != 0 ) |
|
|
|
nn_freemsg(dexp), dexp = 0; |
|
|
|
} |
|
|
|
} |
|
|
|
if ( myinfo->repsock >= 0 ) |
|
|
|
{ |
|
|
|
if ( (size= nn_recv(myinfo->repsock,&dexp,NN_MSG,0)) >= 0 ) |
|
|
|
{ |
|
|
|
num++; |
|
|
|