diff options
| author | 2023-02-02 04:50:51 +0100 | |
|---|---|---|
| committer | 2023-02-02 04:50:51 +0100 | |
| commit | 8d22c448d473491b959709d29af46c25e3d7f80b (patch) | |
| tree | b3e940795e06cc130498485d98075617698cc174 | |
| parent | queue() renamed to user_queue(). (diff) | |
| download | snac2-8d22c448d473491b959709d29af46c25e3d7f80b.tar.gz snac2-8d22c448d473491b959709d29af46c25e3d7f80b.tar.xz snac2-8d22c448d473491b959709d29af46c25e3d7f80b.zip | |
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) | |||
| 1160 | } | 1160 | } |
| 1161 | 1161 | ||
| 1162 | 1162 | ||
| 1163 | void process_queue(snac *snac) | 1163 | void process_user_queue(snac *snac) |
| 1164 | /* processes the queue */ | 1164 | /* processes a user's queue */ |
| 1165 | { | 1165 | { |
| 1166 | xs *list = user_queue(snac); | 1166 | xs *list = user_queue(snac); |
| 1167 | 1167 | ||
| @@ -274,7 +274,7 @@ static void *queue_thread(void *arg) | |||
| 274 | snac snac; | 274 | snac snac; |
| 275 | 275 | ||
| 276 | if (user_open(&snac, uid)) { | 276 | if (user_open(&snac, uid)) { |
| 277 | process_queue(&snac); | 277 | process_user_queue(&snac); |
| 278 | user_free(&snac); | 278 | user_free(&snac); |
| 279 | } | 279 | } |
| 280 | } | 280 | } |
| @@ -144,7 +144,7 @@ int main(int argc, char *argv[]) | |||
| 144 | } | 144 | } |
| 145 | 145 | ||
| 146 | if (strcmp(cmd, "queue") == 0) { | 146 | if (strcmp(cmd, "queue") == 0) { |
| 147 | process_queue(&snac); | 147 | process_user_queue(&snac); |
| 148 | return 0; | 148 | return 0; |
| 149 | } | 149 | } |
| 150 | 150 | ||
| @@ -165,7 +165,7 @@ int send_to_inbox(snac *snac, char *inbox, char *msg, d_char **payload, int *p_s | |||
| 165 | d_char *get_actor_inbox(snac *snac, char *actor); | 165 | d_char *get_actor_inbox(snac *snac, char *actor); |
| 166 | int send_to_actor(snac *snac, char *actor, char *msg, d_char **payload, int *p_size, int timeout); | 166 | int send_to_actor(snac *snac, char *actor, char *msg, d_char **payload, int *p_size, int timeout); |
| 167 | int is_msg_public(snac *snac, char *msg); | 167 | int is_msg_public(snac *snac, char *msg); |
| 168 | void process_queue(snac *snac); | 168 | void process_user_queue(snac *snac); |
| 169 | void post(snac *snac, char *msg); | 169 | void post(snac *snac, char *msg); |
| 170 | int activitypub_get_handler(d_char *req, char *q_path, | 170 | int activitypub_get_handler(d_char *req, char *q_path, |
| 171 | char **body, int *b_size, char **ctype); | 171 | char **body, int *b_size, char **ctype); |