diff options
author | default <nobody@localhost> | 2023-02-06 20:29:18 +0100 |
---|---|---|
committer | default <nobody@localhost> | 2023-02-06 20:29:18 +0100 |
commit | f6d51357afcb047a0804600a19694944f64e82bc (patch) | |
tree | b1679d9557e1b36a309fdf50dfb178900473f0d4 | |
parent | b2d186cd0fc5451dcc336c3efc23450ce918656a (diff) |
process_queue() now posts the q_item to the thread pool.
Instead of calling process_queue_item() itself.
-rw-r--r-- | activitypub.c | 2 | ||||
-rw-r--r-- | snac.h | 4 |
2 files changed, 4 insertions, 2 deletions
diff --git a/activitypub.c b/activitypub.c index 5aae251..651c18c 100644 --- a/activitypub.c +++ b/activitypub.c @@ -1215,7 +1215,7 @@ void process_queue(void) continue; } - process_queue_item(q_item); + job_post(q_item); } } @@ -172,7 +172,6 @@ void process_user_queue(snac *snac); void process_queue_item(xs_dict *q_item); void process_queue(void); -void post(snac *snac, char *msg); int activitypub_get_handler(d_char *req, char *q_path, char **body, int *b_size, char **ctype); int activitypub_post_handler(d_char *req, char *q_path, @@ -189,3 +188,6 @@ int html_post_handler(d_char *req, char *q_path, d_char *payload, int p_size, int snac_init(const char *_basedir); int adduser(const char *uid); int resetpwd(snac *snac); + +void job_post(const xs_val *job); +void job_wait(xs_val **job); |