From 69fa01e2b54cad0ecffcf49d13c57ed59d035030 Mon Sep 17 00:00:00 2001 From: jl777 Date: Tue, 20 Dec 2016 17:45:48 +0200 Subject: [PATCH] test --- iguana/dpow/dpow_network.c | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/iguana/dpow/dpow_network.c b/iguana/dpow/dpow_network.c index 37788ae27..051fb36ab 100755 --- a/iguana/dpow/dpow_network.c +++ b/iguana/dpow/dpow_network.c @@ -797,6 +797,8 @@ void dpow_send(struct supernet_info *myinfo,struct dpow_info *dp,struct dpow_blo break; } } + if ( myinfo->dexsock >= 0 ) + nn_send(myinfo->dexsock,np,size,0); //portable_mutex_unlock(&myinfo->dpowmutex); free(np); if ( bp->myind <= 2 ) @@ -916,12 +918,13 @@ int32_t dpow_nanomsg_update(struct supernet_info *myinfo) if ( (size= nn_recv(myinfo->dexsock,&dexp,NN_MSG,0)) >= 0 ) { num++; - if ( dex_packetcheck(myinfo,dexp,size) == 0 ) + /*if ( dex_packetcheck(myinfo,dexp,size) == 0 ) { printf("FROM BUS.%08x -> pub\n",dexp->crc32); nn_send(myinfo->pubsock,dexp,size,0); dex_packet(myinfo,dexp,size); - } + }*/ + printf("GOT DEX PACKET.%d\n",size); if ( dexp != 0 ) nn_freemsg(dexp), dexp = 0; }