diff options
| author |  default | 2023-02-06 20:07:29 +0100 |
|---|---|---|
| committer | default | 2023-02-06 20:07:29 +0100 |
| commit | b2d186cd0fc5451dcc336c3efc23450ce918656a (patch) | |
| tree | 10008c9889c7c1f6cffa12f40b7e78f662308b32 /activitypub.c | |
| parent | Identify the job threads by number. (diff) | |
| download | snac2-b2d186cd0fc5451dcc336c3efc23450ce918656a.tar.gz snac2-b2d186cd0fc5451dcc336c3efc23450ce918656a.tar.xz snac2-b2d186cd0fc5451dcc336c3efc23450ce918656a.zip | |
The pool of threads now process q_items.
Also, the purge is commanded as a q_item.
Diffstat (limited to 'activitypub.c')
| -rw-r--r-- | activitypub.c | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/activitypub.c b/activitypub.c index 42558f4..5aae251 100644 --- a/activitypub.c +++ b/activitypub.c | |||
| @@ -1188,6 +1188,14 @@ void process_queue_item(xs_dict *q_item) | |||
| 1188 | } | 1188 | } |
| 1189 | } | 1189 | } |
| 1190 | } | 1190 | } |
| 1191 | else | ||
| 1192 | if (strcmp(type, "purge") == 0) { | ||
| 1193 | srv_log(xs_dup("purge start")); | ||
| 1194 | |||
| 1195 | purge_all(); | ||
| 1196 | |||
| 1197 | srv_log(xs_dup("purge end")); | ||
| 1198 | } | ||
| 1191 | } | 1199 | } |
| 1192 | 1200 | ||
| 1193 | 1201 | ||