TiagoRG
/
it2s-itss-facilities
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Syslog packet efforts

This commit is contained in:
emanuel 2022-03-02 10:37:58 +00:00
parent 21e8946d9e
commit d1314904c4
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/facilities.c
View File

@ -661,13 +661,13 @@ void* tx(void* fc) {
for (int i = 0; i < stream->len; ++i) { for (int i = 0; i < stream->len; ++i) {
switch (stream->destination[i]) { switch (stream->destination[i]) {
case 3: case 3:
syslog_debug("[facilities]-> sending BDR to ->[transport] (%dB)", stream->packet_len[i]); syslog_debug("[facilities]-> sending BDR to ->[transport] | size:%dB", stream->packet_len[i]);
zmq_send(transport_socket, stream->packet[i], stream->packet_len[i], 0); zmq_send(transport_socket, stream->packet[i], stream->packet_len[i], 0);
rv = zmq_recv(transport_socket, &code, 1, 0); rv = zmq_recv(transport_socket, &code, 1, 0);
if (rv == -1) {syslog_err("[facilities]-> timeout sending BDR to ->[transport]");} if (rv == -1) {syslog_err("[facilities]-> timeout sending BDR to ->[transport]");}
break; break;
case 5: case 5:
syslog_debug("[facilities]-> sending FDI to ->[applications] (%dB)", stream->packet_len[i]); syslog_debug("[facilities]-> sending FDI to ->[applications] | size:%dB", stream->packet_len[i]);
zmq_send(applications_socket, stream->packet[i], stream->packet_len[i], 0); zmq_send(applications_socket, stream->packet[i], stream->packet_len[i], 0);
rv = zmq_recv(applications_socket, &code, 1, 0); rv = zmq_recv(applications_socket, &code, 1, 0);
if (rv == -1) {syslog_err("[facilities]-> timeout sending FDI to ->[applications]");} if (rv == -1) {syslog_err("[facilities]-> timeout sending FDI to ->[applications]");}