1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177
|
/* folder_read.c -- initialize folder structure and read folder
*
* This code is Copyright (c) 2002, by the authors of nmh. See the
* COPYRIGHT file in the root directory of the nmh distribution for
* complete copyright information.
*/
#include "h/mh.h"
#include "seq_read.h"
#include "m_atoi.h"
#include "folder_read.h"
#include "error.h"
#include "utils.h"
#include "m_maildir.h"
#include "globals.h"
/* We allocate the `mi' array 1024 elements at a time */
#define NUMMSGS 1024
/*
* 1) Create the folder/message structure
* 2) Read the directory (folder) and temporarily
* record the numbers of the messages we have seen.
* 3) Then allocate the array for message attributes and
* set the initial flags for all messages we've seen.
* 4) Read and initialize the sequence information.
*/
struct msgs *
folder_read (char *name, int lockflag)
{
int msgnum, len, *mi;
struct msgs *mp;
struct dirent *dp;
DIR *dd;
struct bvector *v;
size_t i;
name = m_mailpath (name);
if (!(dd = opendir (name))) {
free (name);
return NULL;
}
/* Allocate the main structure for folder information */
NEW(mp);
clear_folder_flags (mp);
mp->foldpath = name;
mp->lowmsg = 0;
mp->hghmsg = 0;
mp->curmsg = 0;
mp->lowsel = 0;
mp->hghsel = 0;
mp->numsel = 0;
mp->nummsg = 0;
mp->seqhandle = NULL;
mp->seqname = NULL;
if (access (name, W_OK) == -1)
set_readonly (mp);
/*
* Allocate a temporary place to record the
* name of the messages in this folder.
*/
len = NUMMSGS;
mi = mh_xmalloc ((size_t) (len * sizeof(*mi)));
while ((dp = readdir (dd))) {
if ((msgnum = m_atoi (dp->d_name)) && msgnum > 0) {
/*
* Check if we need to allocate more
* temporary elements for message names.
*/
if (mp->nummsg >= len) {
len += NUMMSGS;
mi = mh_xrealloc (mi, (size_t) (len * sizeof(*mi)));
}
/* Check if this is the first message we've seen */
if (mp->nummsg == 0) {
mp->lowmsg = msgnum;
mp->hghmsg = msgnum;
} else {
/* Is this lowest or highest we've seen? */
if (msgnum < mp->lowmsg)
mp->lowmsg = msgnum;
else if (msgnum > mp->hghmsg)
mp->hghmsg = msgnum;
}
/*
* Now increment count, and record message
* number in a temporary place for now.
*/
mi[mp->nummsg++] = msgnum;
} else {
/* See if there are other files or directories in the folder. */
/* skip . and .. */
if (strcmp (dp->d_name, ".") == 0 ||
strcmp (dp->d_name, "..") == 0)
continue;
/* skip any files beginning with backup prefix */
if (has_prefix(dp->d_name, BACKUP_PREFIX))
continue;
/* skip the mh_seq file */
if (strcmp (dp->d_name, mh_seq) == 0)
continue;
/* skip the LINK file */
if (strcmp (dp->d_name, LINK) == 0)
continue;
/* indicate that there are other files in folder */
set_other_files (mp);
}
}
closedir (dd);
mp->lowoff = max (mp->lowmsg, 1);
/* Go ahead and allocate space for 100 additional messages. */
mp->hghoff = mp->hghmsg + 100;
/* for testing, allocate minimal necessary space */
/* mp->hghoff = max (mp->hghmsg, 1); */
/*
* If for some reason hghoff < lowoff (like we got an integer overflow)
* the complain about this now.
*/
if (mp->hghoff < mp->lowoff) {
die("Internal failure: high message limit < low message "
"limit; possible overflow?");
}
/*
* Allocate space for status of each message.
*/
mp->num_msgstats = MSGSTATNUM (mp->lowoff, mp->hghoff);
mp->msgstats = mh_xmalloc (MSGSTATSIZE(mp));
for (i = 0, v = mp->msgstats; i < mp->num_msgstats; ++i, ++v) {
bvector_init(v);
}
mp->msgattrs = svector_create (0);
/*
* Scan through the array of messages we've seen and
* setup the initial flags for those messages in the
* newly allocated mp->msgstats area.
*/
for (msgnum = 0; msgnum < mp->nummsg; msgnum++)
set_exists (mp, mi[msgnum]);
free (mi); /* We don't need this anymore */
/*
* Read and initialize the sequence information.
*/
if (seq_read (mp, lockflag) == NOTOK) {
char seqfile[PATH_MAX];
/* Failed to lock sequence file. */
snprintf (seqfile, sizeof(seqfile), "%s/%s", mp->foldpath, mh_seq);
advise (seqfile, "failed to lock");
return NULL;
}
return mp;
}
|