diff options
| -rw-r--r-- | data.c | 8 |
1 files changed, 4 insertions, 4 deletions
| @@ -1977,22 +1977,22 @@ void enqueue_request_replies(snac *user, const char *id) | |||
| 1977 | 1977 | ||
| 1978 | if (type && msg && strcmp(type, "request_replies") == 0 && strcmp(msg, id) == 0) { | 1978 | if (type && msg && strcmp(type, "request_replies") == 0 && strcmp(msg, id) == 0) { |
| 1979 | /* don't requeue */ | 1979 | /* don't requeue */ |
| 1980 | snac_debug(user, 0, xs_fmt("enqueue_request_replies already here %s", id)); | 1980 | snac_debug(user, 1, xs_fmt("enqueue_request_replies already here %s", id)); |
| 1981 | return; | 1981 | return; |
| 1982 | } | 1982 | } |
| 1983 | } | 1983 | } |
| 1984 | } | 1984 | } |
| 1985 | 1985 | ||
| 1986 | /* not there; enqueue the request with a small delay */ | 1986 | /* not there; enqueue the request with a small delay */ |
| 1987 | xs *qmsg = _new_qmsg("request_replies", id, 0); | 1987 | xs *qmsg = _new_qmsg("request_replies", id, 0); |
| 1988 | xs *ntid = tid(10); | 1988 | xs *ntid = tid(10); |
| 1989 | xs *fn = xs_fmt("%s/queue/%s.json", user->basedir, ntid); | 1989 | xs *fn = xs_fmt("%s/queue/%s.json", user->basedir, ntid); |
| 1990 | 1990 | ||
| 1991 | qmsg = xs_dict_set(qmsg, "ntid", ntid); | 1991 | qmsg = xs_dict_set(qmsg, "ntid", ntid); |
| 1992 | 1992 | ||
| 1993 | qmsg = _enqueue_put(fn, qmsg); | 1993 | qmsg = _enqueue_put(fn, qmsg); |
| 1994 | 1994 | ||
| 1995 | snac_debug(user, 0, xs_fmt("enqueue_request_replies %s", id)); | 1995 | snac_debug(user, 1, xs_fmt("enqueue_request_replies %s", id)); |
| 1996 | } | 1996 | } |
| 1997 | 1997 | ||
| 1998 | 1998 | ||