index/maildir/maildir-mail.c

	maildir-mail.c revision 8fcff4c5b52f24d9c681805fdf06b486f1d0fcbe
561N/A/* Copyright (C) 2003 Timo Sirainen */
561N/A
911N/A#include "lib.h"
837N/A#include "istream.h"
561N/A#include "index-mail.h"
561N/A#include "maildir-storage.h"
919N/A#include "maildir-uidlist.h"
919N/A
919N/A#include <fcntl.h>
919N/A#include <unistd.h>
919N/A#include <sys/stat.h>
919N/A
919N/Astatic int do_open(struct index_mailbox *ibox, const char *path, void *context)
919N/A{
919N/A    int *fd = context;
919N/A
919N/A    *fd = open(path, O_RDONLY);
919N/A    if (*fd != -1)
919N/A        return 1;
919N/A    if (errno == ENOENT)
919N/A        return 0;
919N/A
919N/A    mail_storage_set_critical(ibox->box.storage,
561N/A                  "open(%s) failed: %m", path);
561N/A    return -1;
561N/A}
561N/A
561N/Astatic int do_stat(struct index_mailbox *ibox, const char *path, void *context)
561N/A{
561N/A    struct stat *st = context;
837N/A
837N/A    if (stat(path, st) == 0)
911N/A        return 1;
911N/A    if (errno == ENOENT)
911N/A        return 0;
911N/A
837N/A    mail_storage_set_critical(ibox->box.storage,
837N/A                  "stat(%s) failed: %m", path);
561N/A    return -1;
561N/A}
837N/A
static struct istream *
maildir_open_mail(struct index_mailbox *ibox, uint32_t uid, int *deleted)
{
    int fd;

    *deleted = FALSE;

    fd = -1;
    if (maildir_file_do(ibox, uid, do_open, &fd) < 0)
        return NULL;

    if (fd == -1) {
        *deleted = TRUE;
        return NULL;
    }

    if (ibox->mail_read_mmaped) {
        return i_stream_create_mmap(fd, default_pool,
                        MAIL_MMAP_BLOCK_SIZE, 0, 0, TRUE);
    } else {
        return i_stream_create_file(fd, default_pool,
                        MAIL_READ_BLOCK_SIZE, TRUE);
    }
}

static const struct mail_full_flags *maildir_mail_get_flags(struct mail *_mail)
{
    struct index_mail *mail = (struct index_mail *)_mail;
    struct index_mail_data *data = &mail->data;

    (void)index_mail_get_flags(_mail);

    if (maildir_uidlist_is_recent(mail->ibox->uidlist, _mail->uid))
        data->flags.flags |= MAIL_RECENT;
    return &data->flags;
}

static time_t maildir_mail_get_received_date(struct mail *_mail)
{
    struct index_mail *mail = (struct index_mail *) _mail;
    struct index_mail_data *data = &mail->data;
    struct stat st;
    int fd;

    (void)index_mail_get_received_date(_mail);
    if (data->received_date != (time_t)-1)
        return data->received_date;

    if (data->stream != NULL) {
        fd = i_stream_get_fd(data->stream);
        i_assert(fd != -1);

        if (fstat(fd, &st) < 0) {
            mail_storage_set_critical(mail->ibox->box.storage,
                          "fstat(maildir) failed: %m");
            return (time_t)-1;
        }
    } else {
        if (maildir_file_do(mail->ibox, mail->mail.uid,
                    do_stat, &st) <= 0)
            return (time_t)-1;
    }

    data->received_date = st.st_mtime;
    index_mail_cache_add(mail, MAIL_CACHE_RECEIVED_DATE,
                 &data->received_date, sizeof(data->received_date));
    return data->received_date;
}

static uoff_t maildir_mail_get_size(struct mail *_mail)
{
    struct index_mail *mail = (struct index_mail *) _mail;
    struct index_mail_data *data = &mail->data;
    const char *fname, *p;
    uoff_t virtual_size;
        enum maildir_uidlist_rec_flag flags;

    if (data->size != (uoff_t)-1)
        return data->size;

    if ((mail->wanted_fields & MAIL_FETCH_SIZE) == 0) {
        data->size = index_mail_get_cached_virtual_size(mail);
        if (data->size != (uoff_t)-1)
            return data->size;
    }

    fname = maildir_uidlist_lookup(mail->ibox->uidlist,
                       mail->mail.uid, &flags);
    if (fname == NULL)
        return (uoff_t)-1;

    /* size can be included in filename */
    p = strstr(fname, ",W=");
    if (p != NULL) {
        p += 3;
        virtual_size = 0;
        while (*p >= '0' && *p <= '9') {
            virtual_size = virtual_size * 10 + (*p - '0');
            p++;
        }

        if (*p == ':' || *p == ',' || *p != '\0') {
            index_mail_cache_add(mail, MAIL_CACHE_VIRTUAL_FULL_SIZE,
                         &virtual_size,
                         sizeof(virtual_size));
            return virtual_size;
        }
    }

    return index_mail_get_size(_mail);
}

static struct istream *maildir_mail_get_stream(struct mail *_mail,
                           struct message_size *hdr_size,
                           struct message_size *body_size)
{
    struct index_mail *mail = (struct index_mail *) _mail;
    struct index_mail_data *data = &mail->data;
    int deleted;

    if (data->stream == NULL) {
        data->stream = maildir_open_mail(mail->ibox, mail->mail.uid,
                         &deleted);
        if (data->stream == NULL)
            return NULL;
    }

    return index_mail_init_stream(mail, hdr_size, body_size);
}

struct mail maildir_mail = {
    0, 0, 0, 0, 0, 0,

    maildir_mail_get_flags,
    index_mail_get_parts,
    maildir_mail_get_received_date,
    index_mail_get_date,
    maildir_mail_get_size,
    index_mail_get_header,
    index_mail_get_headers,
    maildir_mail_get_stream,
    index_mail_get_special,
    index_mail_update_flags,
    index_mail_expunge
};