|
|
@ -1087,13 +1087,13 @@ void queue_loop(void *ctx) |
|
|
|
ptr->sock = -1; |
|
|
|
} |
|
|
|
} |
|
|
|
printf("k.%d flag.%d SEND.(%s) sock.%d\n",k,flag,(char *)ptr->msg,ptr->sock); |
|
|
|
//printf("k.%d flag.%d SEND.(%s) sock.%d\n",k,flag,(char *)ptr->msg,ptr->sock);
|
|
|
|
} |
|
|
|
free_json(json); |
|
|
|
} |
|
|
|
if ( flag == 0 ) |
|
|
|
{ |
|
|
|
printf("non-encoded len.%d SEND.(%s) sock.%d\n",ptr->msglen,(char *)ptr->msg,ptr->sock); |
|
|
|
// printf("non-encoded len.%d SEND.(%s) sock.%d\n",ptr->msglen,(char *)ptr->msg,ptr->sock);
|
|
|
|
if ( (sentbytes= nn_send(ptr->sock,ptr->msg,ptr->msglen,0)) != ptr->msglen ) |
|
|
|
printf("%d LP_send sent %d instead of %d\n",n,sentbytes,ptr->msglen); |
|
|
|
else |
|
|
@ -1180,7 +1180,7 @@ void LP_reserved_msgs(void *ignore) |
|
|
|
if ( num_Reserved_msgs[1] > 0 ) |
|
|
|
{ |
|
|
|
num_Reserved_msgs[1]--; |
|
|
|
printf("PRIORITY BROADCAST.(%s)\n",Reserved_msgs[1][num_Reserved_msgs[1]]); |
|
|
|
//printf("PRIORITY BROADCAST.(%s)\n",Reserved_msgs[1][num_Reserved_msgs[1]]);
|
|
|
|
LP_broadcast_message(LP_mypubsock,"","",zero,Reserved_msgs[1][num_Reserved_msgs[1]]); |
|
|
|
Reserved_msgs[1][num_Reserved_msgs[1]] = 0; |
|
|
|
} |
|
|
|