From f0e17d67537ee020ec391cd4459b77dfdad7ef24 Mon Sep 17 00:00:00 2001 From: default Date: Thu, 17 Nov 2022 18:33:54 +0100 Subject: Queue messages to inboxes instead of actors. --- data.c | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'data.c') diff --git a/data.c b/data.c index 3c25123..2fbb49e 100644 --- a/data.c +++ b/data.c @@ -1063,11 +1063,11 @@ void enqueue_input(snac *snac, char *msg, char *req, int retries) } -void enqueue_output(snac *snac, char *msg, char *actor, int retries) +void enqueue_output(snac *snac, char *msg, char *inbox, int retries) /* enqueues an output message for an actor */ { - if (strcmp(actor, snac->actor) == 0) { - snac_debug(snac, 1, xs_str_new("enqueue refused to myself")); + if (xs_startswith(inbox, snac->actor)) { + snac_debug(snac, 1, xs_str_new("refusing enqueue to myself")); return; } @@ -1078,13 +1078,13 @@ void enqueue_output(snac *snac, char *msg, char *actor, int retries) xs *rn = xs_number_new(retries); qmsg = xs_dict_append(qmsg, "type", "output"); - qmsg = xs_dict_append(qmsg, "actor", actor); + qmsg = xs_dict_append(qmsg, "inbox", inbox); qmsg = xs_dict_append(qmsg, "object", msg); qmsg = xs_dict_append(qmsg, "retries", rn); _enqueue_put(fn, qmsg); - snac_debug(snac, 1, xs_fmt("enqueue_output %s %s %d", actor, fn, retries)); + snac_debug(snac, 1, xs_fmt("enqueue_output %s %s %d", inbox, fn, retries)); } -- cgit v1.2.3