diff options
author | default <nobody@localhost> | 2023-02-02 04:50:51 +0100 |
---|---|---|
committer | default <nobody@localhost> | 2023-02-02 04:50:51 +0100 |
commit | 8d22c448d473491b959709d29af46c25e3d7f80b (patch) | |
tree | b3e940795e06cc130498485d98075617698cc174 | |
parent | 106c94ef86c5c8eb05c3e8ac62f1af3504d8aba0 (diff) |
process_queue() has been renamed to process_user_queue().
-rw-r--r-- | activitypub.c | 4 | ||||
-rw-r--r-- | httpd.c | 2 | ||||
-rw-r--r-- | main.c | 2 | ||||
-rw-r--r-- | snac.h | 2 |
4 files changed, 5 insertions, 5 deletions
diff --git a/activitypub.c b/activitypub.c index b2f42f2..3249e80 100644 --- a/activitypub.c +++ b/activitypub.c @@ -1160,8 +1160,8 @@ void process_queue_item(snac *snac, xs_dict *q_item) } -void process_queue(snac *snac) -/* processes the queue */ +void process_user_queue(snac *snac) +/* processes a user's queue */ { xs *list = user_queue(snac); @@ -274,7 +274,7 @@ static void *queue_thread(void *arg) snac snac; if (user_open(&snac, uid)) { - process_queue(&snac); + process_user_queue(&snac); user_free(&snac); } } @@ -144,7 +144,7 @@ int main(int argc, char *argv[]) } if (strcmp(cmd, "queue") == 0) { - process_queue(&snac); + process_user_queue(&snac); return 0; } @@ -165,7 +165,7 @@ int send_to_inbox(snac *snac, char *inbox, char *msg, d_char **payload, int *p_s d_char *get_actor_inbox(snac *snac, char *actor); int send_to_actor(snac *snac, char *actor, char *msg, d_char **payload, int *p_size, int timeout); int is_msg_public(snac *snac, char *msg); -void process_queue(snac *snac); +void process_user_queue(snac *snac); void post(snac *snac, char *msg); int activitypub_get_handler(d_char *req, char *q_path, char **body, int *b_size, char **ctype); |