From bad675684016a5707ad408e1eb1a21efe3555e10 Mon Sep 17 00:00:00 2001
From: jl777 <mac@MacBook-Pro-Vladimir.local>
Date: Sun, 18 Jun 2017 13:39:37 +0300
Subject: [PATCH] Test

---
 iguana/exchanges/LP_forwarding.c |  2 +-
 iguana/exchanges/LP_nativeDEX.c  | 10 +++++++---
 2 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/iguana/exchanges/LP_forwarding.c b/iguana/exchanges/LP_forwarding.c
index c93cfbc8d..b11cbb962 100644
--- a/iguana/exchanges/LP_forwarding.c
+++ b/iguana/exchanges/LP_forwarding.c
@@ -50,7 +50,7 @@ char *LP_lookup(bits256 pubkey)
 
 int32_t LP_pushsock_create(char *pushaddr)
 {
-    int32_t pushsock,timeout,i,n=1000; char msg[512]; struct nn_pollfd pfd;
+    int32_t pushsock,timeout,i,n=10; char msg[512]; struct nn_pollfd pfd;
     if ( (pushsock= nn_socket(AF_SP,NN_PUSH)) < 0 )
     {
         printf("LP_pushsock_create couldnt allocate socket for %s\n",pushaddr);
diff --git a/iguana/exchanges/LP_nativeDEX.c b/iguana/exchanges/LP_nativeDEX.c
index 111e40623..d2c8bc2f8 100644
--- a/iguana/exchanges/LP_nativeDEX.c
+++ b/iguana/exchanges/LP_nativeDEX.c
@@ -227,6 +227,7 @@ int32_t LP_mainloop_iter(char *myipaddr,struct LP_peerinfo *mypeer,int32_t pubso
     }
     HASH_ITER(hh,LP_peerinfos,peer,tmp)
     {
+        nonz += LP_pullsock_check(myipaddr,pubsock,pullsock,profitmargin);
         if ( now > peer->lastpeers+60 && peer->numpeers > 0 && (peer->numpeers != numpeers || (rand() % 10000) == 0) )
         {
             printf("numpeers.%d updatepeer.%s lag.%d\n",numpeers,peer->ipaddr,now-peer->lastpeers);
@@ -246,10 +247,12 @@ int32_t LP_mainloop_iter(char *myipaddr,struct LP_peerinfo *mypeer,int32_t pubso
     }
     if ( (counter % 600) == 60 )
     {
+        nonz += LP_pullsock_check(myipaddr,pubsock,pullsock,profitmargin);
         LP_myutxo_updates(pubsock,passphrase,profitmargin);
         if ( lastforward < now-3600 )
         {
             LP_forwarding_register(LP_mypubkey,pushaddr,10);
+            nonz += LP_pullsock_check(myipaddr,pubsock,pullsock,profitmargin);
             lastforward = now;
         }
     }
@@ -257,10 +260,12 @@ int32_t LP_mainloop_iter(char *myipaddr,struct LP_peerinfo *mypeer,int32_t pubso
     {
         HASH_ITER(hh,LP_utxoinfos[0],utxo,utmp)
         {
+            nonz += LP_pullsock_check(myipaddr,pubsock,pullsock,profitmargin);
             LP_utxo_spentcheck(pubsock,utxo,profitmargin);
         }
         HASH_ITER(hh,LP_utxoinfos[1],utxo,utmp)
         {
+            nonz += LP_pullsock_check(myipaddr,pubsock,pullsock,profitmargin);
             LP_utxo_spentcheck(pubsock,utxo,profitmargin);
             if ( utxo->T.lasttime == 0 )
                 LP_utxo_clientpublish(utxo);
@@ -268,14 +273,14 @@ int32_t LP_mainloop_iter(char *myipaddr,struct LP_peerinfo *mypeer,int32_t pubso
     }
     if ( (counter % 600) == 599 )
     {
+        nonz += LP_pullsock_check(myipaddr,pubsock,pullsock,profitmargin);
         if ( (retstr= basilisk_swapentry(0,0)) != 0 )
         {
             //printf("SWAPS.(%s)\n",retstr);
             free(retstr);
         }
     }
-    if ( pullsock >= 0 )
-        nonz += LP_pullsock_check(myipaddr,pubsock,pullsock,profitmargin);
+    nonz += LP_pullsock_check(myipaddr,pubsock,pullsock,profitmargin);
     counter++;
     return(nonz);
 }
@@ -380,7 +385,6 @@ void LPinit(uint16_t myport,uint16_t mypullport,uint16_t mypubport,double profit
         {
             timeout = 1;
             nn_setsockopt(pullsock,NN_SOL_SOCKET,NN_RCVTIMEO,&timeout,sizeof(timeout));
-            timeout = 1;
             maxsize = 2 * 1024 * 1024;
             nn_setsockopt(pullsock,NN_SOL_SOCKET,NN_RCVBUF,&maxsize,sizeof(maxsize));
         }