Test

iguana/exchanges/LP_include.h

@@ -27,7 +27,7 @@
 void emscripten_usleep(int32_t x);
 #define usleep(x) emscripten_usleep(x)
 // ./autogen.sh
-// emconfigure ./configure CFLAGS="-s PTHREAD_POOL_SIZE=8 -s USE_PTHREADS=1"
+// emconfigure ./configure CFLAGS="-s PTHREAD_POOL_SIZE=8 -s USE_PTHREADS=1 -O2"
 // Edit src/core/sock.c and add here #include <limits.h> for INT_MAX support
 // emmake make
 // cp .libs/libnanomsg.a ~/SuperNET/OSlibs/js

iguana/exchanges/LP_peers.c

@@ -83,6 +83,11 @@ struct LP_peerinfo *LP_addpeer(struct LP_peerinfo *mypeer,int32_t mypubsock,char
             else peer->sessionid = sessionid;
             peer->pushsock = peer->subsock = pushsock = subsock = -1;
             strcpy(peer->ipaddr,ipaddr);
+            //peer->profitmargin = profitmargin;
+            peer->ipbits = ipbits;
+            peer->port = port;
+            peer->ip_port = ((uint64_t)port << 32) | ipbits;
+            printf("allocated peer\n");
 #ifndef FROM_JS
             if ( pushport != 0 && subport != 0 && (pushsock= nn_socket(AF_SP,NN_PUSH)) >= 0 )
             {
@@ -116,32 +121,31 @@ struct LP_peerinfo *LP_addpeer(struct LP_peerinfo *mypeer,int32_t mypubsock,char
                 }
             } else printf("%s pushport.%u subport.%u pushsock.%d\n",ipaddr,pushport,subport,pushsock);
 #endif
-            //peer->profitmargin = profitmargin;
-            peer->ipbits = ipbits;
-            peer->port = port;
-            peer->ip_port = ((uint64_t)port << 32) | ipbits;
-            portable_mutex_lock(&LP_peermutex);
-            HASH_ADD(hh,LP_peerinfos,ip_port,sizeof(peer->ip_port),peer);
-            if ( mypeer != 0 )
+            if ( peer->pushsock >= 0 && peer->subsock >= 0 )
             {
-                mypeer->numpeers++;
-                printf("_LPaddpeer %s -> numpeers.%d mypubsock.%d other.(%d %d)\n",ipaddr,mypeer->numpeers,mypubsock,numpeers,numutxos);
-            } else peer->numpeers = 1; // will become mypeer
-            portable_mutex_unlock(&LP_peermutex);
-            if ( IAMLP != 0 && mypubsock >= 0 )
-            {
-                struct iguana_info *coin,*ctmp; bits256 zero; char busaddr[64];
-                memset(zero.bytes,0,sizeof(zero));
-                //LP_send(mypubsock,msg,(int32_t)strlen(msg)+1,1);
-                LP_reserved_msg("","",zero,jprint(LP_peerjson(peer),1));
-                if ( 0 )
+                portable_mutex_lock(&LP_peermutex);
+                HASH_ADD(hh,LP_peerinfos,ip_port,sizeof(peer->ip_port),peer);
+                if ( mypeer != 0 )
+                {
+                    mypeer->numpeers++;
+                    printf("_LPaddpeer %s -> numpeers.%d mypubsock.%d other.(%d %d)\n",ipaddr,mypeer->numpeers,mypubsock,numpeers,numutxos);
+                } else peer->numpeers = 1; // will become mypeer
+                portable_mutex_unlock(&LP_peermutex);
+                if ( IAMLP != 0 && mypubsock >= 0 )
                 {
-                    HASH_ITER(hh,LP_coins,coin,ctmp)
+                    struct iguana_info *coin,*ctmp; bits256 zero; char busaddr[64];
+                    memset(zero.bytes,0,sizeof(zero));
+                    //LP_send(mypubsock,msg,(int32_t)strlen(msg)+1,1);
+                    LP_reserved_msg("","",zero,jprint(LP_peerjson(peer),1));
+                    if ( 0 )
                     {
-                        if ( coin->bussock >= 0 )
+                        HASH_ITER(hh,LP_coins,coin,ctmp)
                         {
-                            nanomsg_transportname(0,busaddr,peer->ipaddr,coin->busport);
-                            nn_connect(coin->bussock,busaddr);
+                            if ( coin->bussock >= 0 )
+                            {
+                                nanomsg_transportname(0,busaddr,peer->ipaddr,coin->busport);
+                                nn_connect(coin->bussock,busaddr);
+                            }
                         }
                     }
                 }