summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--activitypub.c2
-rw-r--r--data.c4
-rw-r--r--snac.h2
3 files changed, 4 insertions, 4 deletions
diff --git a/activitypub.c b/activitypub.c
index ba6e45e..bd99c26 100644
--- a/activitypub.c
+++ b/activitypub.c
@@ -1169,7 +1169,7 @@ void process_queue(snac *snac)
1169 xs_str *fn; 1169 xs_str *fn;
1170 1170
1171 while (xs_list_iter(&p, &fn)) { 1171 while (xs_list_iter(&p, &fn)) {
1172 xs *q_item = dequeue(snac, fn); 1172 xs *q_item = dequeue(fn);
1173 1173
1174 if (q_item == NULL) { 1174 if (q_item == NULL) {
1175 snac_log(snac, xs_fmt("process_queue q_item error")); 1175 snac_log(snac, xs_fmt("process_queue q_item error"));
diff --git a/data.c b/data.c
index fd191a5..8e91579 100644
--- a/data.c
+++ b/data.c
@@ -1439,11 +1439,11 @@ d_char *queue(snac *snac)
1439} 1439}
1440 1440
1441 1441
1442d_char *dequeue(snac *snac, char *fn) 1442xs_dict *dequeue(const char *fn)
1443/* dequeues a message */ 1443/* dequeues a message */
1444{ 1444{
1445 FILE *f; 1445 FILE *f;
1446 d_char *obj = NULL; 1446 xs_dict *obj = NULL;
1447 1447
1448 if ((f = fopen(fn, "r")) != NULL) { 1448 if ((f = fopen(fn, "r")) != NULL) {
1449 /* delete right now */ 1449 /* delete right now */
diff --git a/snac.h b/snac.h
index 6185e8b..4b01064 100644
--- a/snac.h
+++ b/snac.h
@@ -130,7 +130,7 @@ void enqueue_email(snac *snac, xs_str *msg, int retries);
130void enqueue_message(snac *snac, char *msg); 130void enqueue_message(snac *snac, char *msg);
131 131
132d_char *queue(snac *snac); 132d_char *queue(snac *snac);
133d_char *dequeue(snac *snac, char *fn); 133xs_dict *dequeue(const char *fn);
134 134
135void purge(snac *snac); 135void purge(snac *snac);
136void purge_all(void); 136void purge_all(void);