monkee.ch/snac2
1
0
Fork 0
mirror of https://codeberg.org/grunfink/snac2.git synced 2024-11-25 14:35:04 +00:00
Code Issues Projects Releases Packages Wiki Activity

process_queue() now posts the q_item to the thread pool.

Browse source 
Instead of calling process_queue_item() itself.
This commit is contained in:
default 2023-02-06 20:29:18 +01:00
parent b2d186cd0f
commit f6d51357af
2 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
activitypub.c
View file

@ -1215,7 +1215,7 @@ void process_queue(void)
continue; continue;
} }
process_queue_item(q_item); job_post(q_item);
} }
} }

4
snac.h
View file

@ -172,7 +172,6 @@ void process_user_queue(snac *snac);
void process_queue_item(xs_dict *q_item); void process_queue_item(xs_dict *q_item);
void process_queue(void); void process_queue(void);
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);
int activitypub_post_handler(d_char *req, char *q_path, 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 snac_init(const char *_basedir);
int adduser(const char *uid); int adduser(const char *uid);
int resetpwd(snac *snac); int resetpwd(snac *snac);
void job_post(const xs_val *job);
void job_wait(xs_val **job);