process_queue() has been renamed to process_user_queue().

This commit is contained in:
default 2023-02-02 04:50:51 +01:00
parent 106c94ef86
commit 8d22c448d4
4 changed files with 5 additions and 5 deletions

View file

@ -1160,8 +1160,8 @@ void process_queue_item(snac *snac, xs_dict *q_item)
} }
void process_queue(snac *snac) void process_user_queue(snac *snac)
/* processes the queue */ /* processes a user's queue */
{ {
xs *list = user_queue(snac); xs *list = user_queue(snac);

View file

@ -274,7 +274,7 @@ static void *queue_thread(void *arg)
snac snac; snac snac;
if (user_open(&snac, uid)) { if (user_open(&snac, uid)) {
process_queue(&snac); process_user_queue(&snac);
user_free(&snac); user_free(&snac);
} }
} }

2
main.c
View file

@ -144,7 +144,7 @@ int main(int argc, char *argv[])
} }
if (strcmp(cmd, "queue") == 0) { if (strcmp(cmd, "queue") == 0) {
process_queue(&snac); process_user_queue(&snac);
return 0; return 0;
} }

2
snac.h
View file

@ -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); 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 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); 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); void post(snac *snac, char *msg);
int activitypub_get_handler(d_char *req, char *q_path, int activitypub_get_handler(d_char *req, char *q_path,
char **body, int *b_size, char **ctype); char **body, int *b_size, char **ctype);