|
|
@ -108,7 +108,9 @@ int32_t LP_pullsock_check(char *myipaddr,int32_t pubsock,int32_t pullsock,double |
|
|
|
if ( (retstr= stats_JSON(argjson,"127.0.0.1",0)) != 0 ) |
|
|
|
{ |
|
|
|
printf("%s PULL.[%d] %s -> (%s)\n",myipaddr != 0 ? myipaddr : "127.0.0.1",recvsize,jsonstr,retstr); |
|
|
|
free(retstr); |
|
|
|
if ( pubsock >= 0 ) |
|
|
|
LP_send(pubsock,retstr,1); |
|
|
|
else free(retstr); |
|
|
|
} |
|
|
|
} |
|
|
|
portable_mutex_unlock(&LP_commandmutex); |
|
|
@ -133,7 +135,7 @@ int32_t LP_subsock_check(struct LP_peerinfo *peer) |
|
|
|
portable_mutex_lock(&LP_commandmutex); |
|
|
|
if ( (retstr= stats_JSON(argjson,"127.0.0.1",0)) != 0 ) |
|
|
|
{ |
|
|
|
//printf("%s RECV.[%d] %s\n",peer->ipaddr,recvsize,(char *)ptr);
|
|
|
|
printf("%s SUB.[%d] %s\n",peer->ipaddr,recvsize,(char *)ptr); |
|
|
|
free(retstr); |
|
|
|
} |
|
|
|
portable_mutex_unlock(&LP_commandmutex); |
|
|
|