mirror of
https://codeberg.org/grunfink/snac2.git
synced 2024-11-25 14:35:04 +00:00
Always log process_queue sending.
This commit is contained in:
parent
aa371bd0c9
commit
e6bf647b98
1 changed files with 2 additions and 2 deletions
|
@ -964,6 +964,8 @@ void process_queue(snac *snac)
|
||||||
/* deliver */
|
/* deliver */
|
||||||
status = send_to_inbox(snac, inbox, msg, &payload, &p_size);
|
status = send_to_inbox(snac, inbox, msg, &payload, &p_size);
|
||||||
|
|
||||||
|
snac_log(snac, xs_fmt("process_queue sent to inbox %s %d", inbox, status));
|
||||||
|
|
||||||
if (!valid_status(status)) {
|
if (!valid_status(status)) {
|
||||||
/* error sending; requeue? */
|
/* error sending; requeue? */
|
||||||
if (retries > queue_retry_max)
|
if (retries > queue_retry_max)
|
||||||
|
@ -974,8 +976,6 @@ void process_queue(snac *snac)
|
||||||
snac_log(snac, xs_fmt("process_queue requeue %s %d", inbox, retries + 1));
|
snac_log(snac, xs_fmt("process_queue requeue %s %d", inbox, retries + 1));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
else
|
|
||||||
snac_log(snac, xs_fmt("process_queue sent to inbox %s %d", inbox, status));
|
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
if (strcmp(type, "input") == 0) {
|
if (strcmp(type, "input") == 0) {
|
||||||
|
|
Loading…
Reference in a new issue