diff options
Diffstat (limited to 'data.c')
| -rw-r--r-- | data.c | 14 |
1 files changed, 13 insertions, 1 deletions
| @@ -1064,7 +1064,7 @@ void enqueue_input(snac *snac, char *msg, char *req, int retries) | |||
| 1064 | 1064 | ||
| 1065 | 1065 | ||
| 1066 | void enqueue_output(snac *snac, char *msg, char *inbox, int retries) | 1066 | void enqueue_output(snac *snac, char *msg, char *inbox, int retries) |
| 1067 | /* enqueues an output message for an actor */ | 1067 | /* enqueues an output message to an inbox */ |
| 1068 | { | 1068 | { |
| 1069 | if (xs_startswith(inbox, snac->actor)) { | 1069 | if (xs_startswith(inbox, snac->actor)) { |
| 1070 | snac_debug(snac, 1, xs_str_new("refusing enqueue to myself")); | 1070 | snac_debug(snac, 1, xs_str_new("refusing enqueue to myself")); |
| @@ -1088,6 +1088,18 @@ void enqueue_output(snac *snac, char *msg, char *inbox, int retries) | |||
| 1088 | } | 1088 | } |
| 1089 | 1089 | ||
| 1090 | 1090 | ||
| 1091 | void enqueue_output_by_actor(snac *snac, char *msg, char *actor, int retries) | ||
| 1092 | /* enqueues an output message for an actor */ | ||
| 1093 | { | ||
| 1094 | xs *inbox = get_actor_inbox(snac, actor); | ||
| 1095 | |||
| 1096 | if (!xs_is_null(inbox)) | ||
| 1097 | enqueue_output(snac, msg, inbox, retries); | ||
| 1098 | else | ||
| 1099 | snac_log(snac, xs_fmt("enqueue_output_by_actor cannot get inbox %s", actor)); | ||
| 1100 | } | ||
| 1101 | |||
| 1102 | |||
| 1091 | void enqueue_email(snac *snac, char *msg, int retries) | 1103 | void enqueue_email(snac *snac, char *msg, int retries) |
| 1092 | /* enqueues an email message to be sent */ | 1104 | /* enqueues an email message to be sent */ |
| 1093 | { | 1105 | { |