jl777 7 years ago
parent
commit
ff93a1c1d1
  1. 4
      iguana/exchanges/LP_network.c

4
iguana/exchanges/LP_network.c

@ -306,7 +306,7 @@ void LP_broadcast_finish(int32_t pubsock,char *base,char *rel,uint8_t *msg,cJSON
crc32 = calc_crc32(0,&msg[2],msglen - 2); crc32 = calc_crc32(0,&msg[2],msglen - 2);
//printf("crc32.%x IAMLP.%d pubsock.%d\n",crc32,G.LP_IAMLP,pubsock); //printf("crc32.%x IAMLP.%d pubsock.%d\n",crc32,G.LP_IAMLP,pubsock);
#ifdef FROM_MARKETMAKER #ifdef FROM_MARKETMAKER
if ( (G.LP_IAMLP == 0 && IAMLP == 0) || pubsock < 0 ) if ( G.LP_IAMLP == 0 || pubsock < 0 )
#else #else
if ( IAMLP == 0 || pubsock < 0 ) if ( IAMLP == 0 || pubsock < 0 )
#endif #endif
@ -321,6 +321,8 @@ void LP_broadcast_finish(int32_t pubsock,char *base,char *rel,uint8_t *msg,cJSON
msg = (void *)jprint(argjson,0); msg = (void *)jprint(argjson,0);
msglen = (int32_t)strlen((char *)msg) + 1; msglen = (int32_t)strlen((char *)msg) + 1;
LP_queuesend(crc32,-1,base,rel,msg,msglen); LP_queuesend(crc32,-1,base,rel,msg,msglen);
if ( pubsock >= 0 )
LP_queuesend(crc32,pubsock,base,rel,msg,msglen);
} }
else else
{ {

Loading…
Cancel
Save