X-Git-Url: http://git.madism.org/?p=apps%2Fmadmutt.git;a=blobdiff_plain;f=lib-mx%2Fmx.c;h=05c9e8a3d9af3ccdb51bf86889350ecf8f2b5a94;hp=3aaff522de0700cd57a9a47d56c240c313fa0459;hb=0ab517261694b001d2eb17f06f167a4cdd2c7c07;hpb=56ac9bea51f338d488828ad1114d58b4a9542209 diff --git a/lib-mx/mx.c b/lib-mx/mx.c index 3aaff52..05c9e8a 100644 --- a/lib-mx/mx.c +++ b/lib-mx/mx.c @@ -16,9 +16,9 @@ #include #include #include -#include #include "mutt.h" +#include "crypt.h" #include "pattern.h" #include "buffy.h" #include "mx.h" @@ -40,7 +40,6 @@ static mx_t const *mxfmts[] = { &mbox_mx, - &mmdf_mx, &mh_mx, &maildir_mx, &imap_mx, @@ -70,13 +69,13 @@ static int invoke_dotlock (const char *path, int flags, int retry) mutt_quote_filename (f, sizeof (f), path); snprintf(cmd, sizeof(cmd), "%s %s%s%s%s%s%s%s", - mlua_reggets(LTK_DOTLOCK), - flags & DL_FL_TRY ? "-t " : "", - flags & DL_FL_UNLOCK ? "-u " : "", - flags & DL_FL_USEPRIV ? "-p " : "", - flags & DL_FL_FORCE ? "-f " : "", - flags & DL_FL_UNLINK ? "-d " : "", - flags & DL_FL_RETRY ? r : "", f); + MCore.dotlock, + flags & DL_FL_TRY ? "-t " : "", + flags & DL_FL_UNLOCK ? "-u " : "", + flags & DL_FL_USEPRIV ? "-p " : "", + flags & DL_FL_FORCE ? "-f " : "", + flags & DL_FL_UNLINK ? "-d " : "", + flags & DL_FL_RETRY ? r : "", f); return mutt_system (cmd); } @@ -149,138 +148,138 @@ static int mx_get_idx (const char* path) { int mx_lock_file (const char *path, int fd, int excl, int dot, int time_out) { #if defined (USE_FCNTL) || defined (USE_FLOCK) - int count; - int attempt; - struct stat prev_sb; + int count; + int attempt; + struct stat prev_sb; #endif - int r = 0; + int r = 0; #ifdef USE_FCNTL - struct flock lck; + struct flock lck; - p_clear(&lck, 1); - lck.l_type = excl ? F_WRLCK : F_RDLCK; - lck.l_whence = SEEK_SET; + p_clear(&lck, 1); + lck.l_type = excl ? F_WRLCK : F_RDLCK; + lck.l_whence = SEEK_SET; - count = 0; - attempt = 0; - prev_sb.st_size = 0; - while (fcntl (fd, F_SETLK, &lck) == -1) { - struct stat sb; + count = 0; + attempt = 0; + prev_sb.st_size = 0; + while (fcntl (fd, F_SETLK, &lck) == -1) { + struct stat sb; - if (errno != EAGAIN && errno != EACCES) { - mutt_perror ("fcntl"); - return (-1); - } + if (errno != EAGAIN && errno != EACCES) { + mutt_perror ("fcntl"); + return (-1); + } - if (fstat (fd, &sb) != 0) - sb.st_size = 0; + if (fstat (fd, &sb) != 0) + sb.st_size = 0; - if (count == 0) - prev_sb = sb; + if (count == 0) + prev_sb = sb; - /* only unlock file if it is unchanged */ - if (prev_sb.st_size == sb.st_size - && ++count >= (time_out ? MAXLOCKATTEMPT : 0)) { - if (time_out) - mutt_error _("Timeout exceeded while attempting fcntl lock!"); + /* only unlock file if it is unchanged */ + if (prev_sb.st_size == sb.st_size + && ++count >= (time_out ? MAXLOCKATTEMPT : 0)) { + if (time_out) + mutt_error _("Timeout exceeded while attempting fcntl lock!"); - return (-1); - } + return (-1); + } - prev_sb = sb; + prev_sb = sb; - mutt_message (_("Waiting for fcntl lock... %d"), ++attempt); - sleep (1); - } + mutt_message (_("Waiting for fcntl lock... %d"), ++attempt); + sleep (1); + } #endif /* USE_FCNTL */ #ifdef USE_FLOCK - count = 0; - attempt = 0; - while (flock (fd, (excl ? LOCK_EX : LOCK_SH) | LOCK_NB) == -1) { - struct stat sb; - - if (errno != EWOULDBLOCK) { - mutt_perror ("flock"); - r = -1; - break; - } + count = 0; + attempt = 0; + while (flock (fd, (excl ? LOCK_EX : LOCK_SH) | LOCK_NB) == -1) { + struct stat sb; + + if (errno != EWOULDBLOCK) { + mutt_perror ("flock"); + r = -1; + break; + } - if (fstat (fd, &sb) != 0) - sb.st_size = 0; + if (fstat (fd, &sb) != 0) + sb.st_size = 0; - if (count == 0) - prev_sb = sb; + if (count == 0) + prev_sb = sb; - /* only unlock file if it is unchanged */ - if (prev_sb.st_size == sb.st_size - && ++count >= (time_out ? MAXLOCKATTEMPT : 0)) { - if (time_out) - mutt_error _("Timeout exceeded while attempting flock lock!"); + /* only unlock file if it is unchanged */ + if (prev_sb.st_size == sb.st_size + && ++count >= (time_out ? MAXLOCKATTEMPT : 0)) { + if (time_out) + mutt_error _("Timeout exceeded while attempting flock lock!"); - r = -1; - break; - } + r = -1; + break; + } - prev_sb = sb; + prev_sb = sb; - mutt_message (_("Waiting for flock attempt... %d"), ++attempt); - sleep (1); - } + mutt_message (_("Waiting for flock attempt... %d"), ++attempt); + sleep (1); + } #endif /* USE_FLOCK */ - if (r == 0 && dot) - r = dotlock_file (path, time_out); + if (r == 0 && dot) + r = dotlock_file (path, time_out); - if (r == -1) { - /* release any other locks obtained in this routine */ + if (r == -1) { + /* release any other locks obtained in this routine */ #ifdef USE_FCNTL - lck.l_type = F_UNLCK; - fcntl (fd, F_SETLK, &lck); + lck.l_type = F_UNLCK; + fcntl (fd, F_SETLK, &lck); #endif /* USE_FCNTL */ #ifdef USE_FLOCK - flock (fd, LOCK_UN); + flock (fd, LOCK_UN); #endif /* USE_FLOCK */ - return (-1); - } + return (-1); + } - return 0; + return 0; } int mx_unlock_file (const char *path, int fd, int dot) { #ifdef USE_FCNTL - struct flock unlockit; + struct flock unlockit; - p_clear(&unlockit, 1); - unlockit.l_type = F_UNLCK; - unlockit.l_whence = SEEK_SET; - fcntl (fd, F_SETLK, &unlockit); + p_clear(&unlockit, 1); + unlockit.l_type = F_UNLCK; + unlockit.l_whence = SEEK_SET; + fcntl (fd, F_SETLK, &unlockit); #endif #ifdef USE_FLOCK - flock (fd, LOCK_UN); + flock (fd, LOCK_UN); #endif - if (dot) - undotlock_file (path); + if (dot) + undotlock_file (path); - return 0; + return 0; } static void mx_unlink_empty (const char *path) { - int fd; + int fd; - if ((fd = open (path, O_RDWR)) == -1) - return; + if ((fd = open (path, O_RDWR)) == -1) + return; - if (mx_lock_file (path, fd, 1, 0, 1) == -1) { + if (mx_lock_file (path, fd, 1, 0, 1) == -1) { close (fd); return; } @@ -315,8 +314,6 @@ int mx_set_magic (const char *s) { if (ascii_strcasecmp (s, "mbox") == 0) DefaultMagic = M_MBOX; - else if (ascii_strcasecmp (s, "mmdf") == 0) - DefaultMagic = M_MMDF; else if (ascii_strcasecmp (s, "mh") == 0) DefaultMagic = M_MH; else if (ascii_strcasecmp (s, "maildir") == 0) @@ -422,7 +419,6 @@ static int mx_open_mailbox_append (CONTEXT * ctx, int flags) switch (ctx->magic) { case M_MBOX: - case M_MMDF: if ((ctx->fp = safe_fopen (ctx->path, flags & M_NEWFOLDER ? "w" : "a")) == NULL || mbox_lock_mailbox (ctx, 1, 1) != 0) { @@ -667,7 +663,7 @@ static int _mx_close_mailbox (CONTEXT * ctx, int *index_hint) if (ctx->append) { /* mailbox was opened in write-mode */ - if (ctx->magic == M_MBOX || ctx->magic == M_MMDF) + if (ctx->magic == M_MBOX) mbox_close_mailbox (ctx); else mx_fastclose_mailbox (ctx); @@ -820,10 +816,11 @@ static int _mx_close_mailbox (CONTEXT * ctx, int *index_hint) mutt_message (_("%d kept, %d deleted."), ctx->msgcount - ctx->deleted, ctx->deleted); - if (ctx->msgcount == ctx->deleted && - (ctx->magic == M_MMDF || ctx->magic == M_MBOX) && - !mutt_is_spool (ctx->path) && !option (OPTSAVEEMPTY)) + if (ctx->msgcount == ctx->deleted && ctx->magic == M_MBOX + && !mutt_is_spool (ctx->path) && !option (OPTSAVEEMPTY)) + { mx_unlink_empty (ctx->path); + } if (ctx->cinfo && mutt_slow_close_compressed (ctx)) return (-1); @@ -1004,9 +1001,9 @@ static int _mx_sync_mailbox (CONTEXT * ctx, int *index_hint) mutt_sleep (0); - if (ctx->msgcount == ctx->deleted && - (ctx->magic == M_MBOX || ctx->magic == M_MMDF) && - !mutt_is_spool (ctx->path) && !option (OPTSAVEEMPTY)) { + if (ctx->msgcount == ctx->deleted && ctx->magic == M_MBOX + && !mutt_is_spool (ctx->path) && !option (OPTSAVEEMPTY)) + { unlink (ctx->path); mx_fastclose_mailbox (ctx); return 0; @@ -1067,10 +1064,7 @@ MESSAGE *mx_open_new_message (CONTEXT * dest, HEADER * hdr, int flags) time (&msg->received); if (mxfmts[dest->magic-1]->mx_open_new_message(msg, dest, hdr) == 0) { - if (dest->magic == M_MMDF) - fputs (MMDF_SEP, msg->fp); - - if ((msg->magic == M_MBOX || msg->magic == M_MMDF) && flags & M_ADD_FROM) { + if (msg->magic == M_MBOX && flags & M_ADD_FROM) { if (hdr) { if (hdr->env->return_path) p = hdr->env->return_path; @@ -1080,7 +1074,7 @@ MESSAGE *mx_open_new_message (CONTEXT * dest, HEADER * hdr, int flags) p = hdr->env->from; } - fprintf (msg->fp, "From %s %s", p ? p->mailbox : NONULL (Username), + fprintf (msg->fp, "From %s %s", p ? p->mailbox : NONULL(MCore.username), ctime (&msg->received)); } } @@ -1113,7 +1107,6 @@ MESSAGE *mx_open_message (CONTEXT * ctx, int msgno) msg = p_new(MESSAGE, 1); switch (msg->magic = ctx->magic) { case M_MBOX: - case M_MMDF: msg->fp = ctx->fp; break; @@ -1205,28 +1198,12 @@ int mx_close_message (MESSAGE ** msg) void mx_alloc_memory (CONTEXT * ctx) { - int i; - size_t s = MAX (sizeof (HEADER *), sizeof (int)); + ctx->hdrmax += 25; - if ((ctx->hdrmax + 25) * s < ctx->hdrmax * s) { - mutt_error _("Integer overflow -- can't allocate memory."); - - sleep (1); - mutt_exit (1); - } - - if (ctx->hdrs) { - p_realloc(&ctx->hdrs, ctx->hdrmax += 25); + p_realloc(&ctx->hdrs, ctx->hdrmax); p_realloc(&ctx->v2r, ctx->hdrmax); - } - else { - ctx->hdrs = p_new(HEADER *, (ctx->hdrmax += 25)); - ctx->v2r = p_new(int, ctx->hdrmax); - } - for (i = ctx->msgcount; i < ctx->hdrmax; i++) { - ctx->hdrs[i] = NULL; - ctx->v2r[i] = -1; - } + p_clear(ctx->hdrs + ctx->msgcount, ctx->hdrmax - ctx->msgcount); + p_clear(ctx->v2r + ctx->msgcount, ctx->hdrmax - ctx->msgcount); } /* this routine is called to update the counts in the context structure for @@ -1309,49 +1286,11 @@ int mx_check_empty (const char *path) return (-1); } -int mx_acl_check (CONTEXT* ctx, int flag) { - if (!ctx || !MX_IDX(ctx->magic-1)) - return (0); - /* if no acl_check defined for module, assume permission is granted */ - if (!mxfmts[ctx->magic-1]->mx_acl_check) - return (1); - return (mxfmts[ctx->magic-1]->mx_acl_check(ctx,flag)); -} - -int mx_rebuild_cache (void) { -#ifndef USE_HCACHE - mutt_error (_("Support for header caching was not build in.")); - return (1); -#else - int i = 0, magic = 0; - CONTEXT* ctx = NULL; - BUFFY* b = NULL; - - if (!Incoming.len) { - mutt_error (_("No mailboxes defined.")); - return (1); - } - - for (i = 0; i < Incoming.len; i++) { - b = Incoming.arr[i]; - magic = mx_get_magic (b->path); - if (magic != M_MAILDIR && magic != M_MH && magic != M_IMAP) - continue; - sidebar_set_current (b->path); - sidebar_draw (); - if ((ctx = mx_open_mailbox (b->path, - M_READONLY | M_NOSORT | M_COUNT, - NULL)) != NULL) - mx_close_mailbox (ctx, 0); - } - mutt_clear_error (); - - if (Context && Context->path) - sidebar_set_current (Context->path); - sidebar_draw (); - - return (0); -#endif +int mx_acl_check(CONTEXT *ctx, int flag) +{ + if (!mxfmts[ctx->magic-1]->mx_acl_check) + return 1; + return mxfmts[ctx->magic-1]->mx_acl_check(ctx,flag); } void mutt_parse_mime_message (CONTEXT * ctx, HEADER * cur)