diff options
Diffstat (limited to 'sqmail-4.3.07/src/qmail-clean.c')
-rw-r--r-- | sqmail-4.3.07/src/qmail-clean.c | 100 |
1 files changed, 0 insertions, 100 deletions
diff --git a/sqmail-4.3.07/src/qmail-clean.c b/sqmail-4.3.07/src/qmail-clean.c deleted file mode 100644 index df149a5..0000000 --- a/sqmail-4.3.07/src/qmail-clean.c +++ /dev/null @@ -1,100 +0,0 @@ -#include <unistd.h> -#include <sys/types.h> -#include <sys/stat.h> -#include "sig.h" -#include "now.h" -#include "str.h" -#include "direntry.h" -#include "getln.h" -#include "stralloc.h" -#include "buffer.h" -#include "byte.h" -#include "scan.h" -#include "fmt.h" -#include "exit.h" -#include "error.h" -#include "fmtqfn.h" -#include "auto_qmail.h" - -#define OSSIFIED 129600 /* see qmail-send.c */ - -stralloc line = {0}; - -void cleanuppid() -{ - DIR *dir; - direntry *d; - struct stat st; - datetime_sec time; - - time = now(); - dir = opendir("pid"); - if (!dir) return; - - while ((d = readdir(dir))) { - if (str_equal(d->d_name,".")) continue; - if (str_equal(d->d_name,"..")) continue; - if (!stralloc_copys(&line,"pid/")) continue; - if (!stralloc_cats(&line,d->d_name)) continue; - if (!stralloc_0(&line)) continue; - if (stat(line.s,&st) == -1) continue; - if (time < st.st_atime + OSSIFIED) continue; - unlink(line.s); - } - closedir(dir); -} - -char fnbuf[FMTQFN]; - -void respond(char *s) -{ - if (buffer_putflush(buffer_1small,s,1) == -1) _exit(100); -} - -int main() -{ - int i; - int match; - int cleanuploop; - unsigned long id; - - if (chdir(auto_qmail) == -1) _exit(110); - if (chdir("queue") == -1) _exit(110); - - sig_pipeignore(); - - if (!stralloc_ready(&line,200)) _exit(111); - - cleanuploop = 0; - - for (;;) { - if (cleanuploop) --cleanuploop; else { cleanuppid(); cleanuploop = 30; } - if (getln(buffer_0small,&line,&match,'\0') == -1) break; - if (!match) break; - if (line.len < 7) { respond("x"); continue; } - if (line.len > 100) { respond("x"); continue; } - if (line.s[line.len - 1]) { respond("x"); continue; } /* impossible */ - - for (i = line.len - 2; i > 4; --i) { - if (line.s[i] == '/') break; - if ((unsigned char) (line.s[i] - '0') > 9) - { respond("x"); continue; } - } - if (line.s[i] == '/') - if (!scan_ulong(line.s + i + 1,&id)) { respond("x"); continue; } - if (byte_equal(line.s,5,"foop/")) { -#define U(prefix,flag) fmtqfn(fnbuf,prefix,id,flag); \ - if (unlink(fnbuf) == -1) if (errno != ENOENT) { respond("!"); continue; } - U("intd/",1) - U("mess/",1) - respond("+"); - } else if (byte_equal(line.s,4,"todo/")) { - U("intd/",1) - U("todo/",1) - respond("+"); - } - else - respond("x"); - } - _exit(0); -} |