NeoMutt
Teaching an old dog new tricks
DOXYGEN
Loading...
Searching...
No Matches
mbox_check_stats()

Check the Mailbox statistics. More...

+ Collaboration diagram for mbox_check_stats():

Functions

static enum MxStatus imap_mbox_check_stats (struct Mailbox *m, uint8_t flags)
 Check the Mailbox statistics - Implements MxOps::mbox_check_stats() -.
 
static enum MxStatus maildir_mbox_check_stats (struct Mailbox *m, uint8_t flags)
 Check the Mailbox statistics - Implements MxOps::mbox_check_stats() -.
 
static enum MxStatus mh_mbox_check_stats (struct Mailbox *m, uint8_t flags)
 Check the Mailbox statistics - Implements MxOps::mbox_check_stats() -.
 
static enum MxStatus mbox_mbox_check_stats (struct Mailbox *m, uint8_t flags)
 Check the Mailbox statistics - Implements MxOps::mbox_check_stats() -.
 
static enum MxStatus nm_mbox_check_stats (struct Mailbox *m, uint8_t flags)
 Check the Mailbox statistics - Implements MxOps::mbox_check_stats() -.
 

Detailed Description

Check the Mailbox statistics.

Parameters
mMailbox to check
flagsFunction flags
Return values
enumMxStatus
Precondition
m is not NULL

Function Documentation

◆ imap_mbox_check_stats()

static enum MxStatus imap_mbox_check_stats ( struct Mailbox m,
uint8_t  flags 
)
static

Check the Mailbox statistics - Implements MxOps::mbox_check_stats() -.

Definition at line 1140 of file imap.c.

1141{
1142 const bool queue = (flags & MUTT_MAILBOX_CHECK_IMMEDIATE) == 0;
1143 const int new_msgs = imap_mailbox_status(m, queue);
1144 if (new_msgs == -1)
1145 return MX_STATUS_ERROR;
1146 if (new_msgs == 0)
1147 return MX_STATUS_OK;
1148 return MX_STATUS_NEW_MAIL;
1149}
int imap_mailbox_status(struct Mailbox *m, bool queue)
Refresh the number of total and new messages.
Definition: imap.c:1192
#define MUTT_MAILBOX_CHECK_IMMEDIATE
Don't postpone the actual checking.
Definition: mxapi.h:56
@ MX_STATUS_ERROR
An error occurred.
Definition: mxapi.h:64
@ MX_STATUS_OK
No changes.
Definition: mxapi.h:65
@ MX_STATUS_NEW_MAIL
New mail received in Mailbox.
Definition: mxapi.h:66
+ Here is the call graph for this function:

◆ maildir_mbox_check_stats()

static enum MxStatus maildir_mbox_check_stats ( struct Mailbox m,
uint8_t  flags 
)
static

Check the Mailbox statistics - Implements MxOps::mbox_check_stats() -.

Definition at line 1384 of file maildir.c.

1385{
1386 bool check_stats = flags & MUTT_MAILBOX_CHECK_FORCE_STATS;
1387 bool check_new = true;
1388
1389 if (check_stats)
1390 {
1391 m->msg_new = 0;
1392 m->msg_count = 0;
1393 m->msg_unread = 0;
1394 m->msg_flagged = 0;
1395 }
1396
1397 maildir_check_dir(m, "new", check_new, check_stats);
1398
1399 const bool c_maildir_check_cur = cs_subset_bool(NeoMutt->sub, "maildir_check_cur");
1400 check_new = !m->has_new && c_maildir_check_cur;
1401 if (check_new || check_stats)
1402 maildir_check_dir(m, "cur", check_new, check_stats);
1403
1405}
bool cs_subset_bool(const struct ConfigSubset *sub, const char *name)
Get a boolean config item by name.
Definition: helpers.c:48
static void maildir_check_dir(struct Mailbox *m, const char *dir_name, bool check_new, bool check_stats)
Check for new mail / mail counts.
Definition: maildir.c:103
#define MUTT_MAILBOX_CHECK_FORCE_STATS
Ignore MailboxType and calculate statistics.
Definition: mxapi.h:55
bool has_new
Mailbox has new mail.
Definition: mailbox.h:85
int msg_new
Number of new messages.
Definition: mailbox.h:92
int msg_count
Total number of messages.
Definition: mailbox.h:88
int msg_flagged
Number of flagged messages.
Definition: mailbox.h:90
int msg_unread
Number of unread messages.
Definition: mailbox.h:89
Container for Accounts, Notifications.
Definition: neomutt.h:41
struct ConfigSubset * sub
Inherited config items.
Definition: neomutt.h:45
+ Here is the call graph for this function:

◆ mh_mbox_check_stats()

static enum MxStatus mh_mbox_check_stats ( struct Mailbox m,
uint8_t  flags 
)
static

Check the Mailbox statistics - Implements MxOps::mbox_check_stats() -.

Definition at line 190 of file mh.c.

191{
192 struct MhSequences mhs = { 0 };
193 DIR *dir = NULL;
194 struct dirent *de = NULL;
195
196 /* when $mail_check_recent is set and the .mh_sequences file hasn't changed
197 * since the last m visit, there is no "new mail" */
198 const bool c_mail_check_recent = cs_subset_bool(NeoMutt->sub, "mail_check_recent");
199 if (c_mail_check_recent && (mh_seq_changed(m) <= 0))
200 {
201 return MX_STATUS_OK;
202 }
203
204 if (mh_seq_read(&mhs, mailbox_path(m)) < 0)
205 return MX_STATUS_ERROR;
206
207 m->msg_count = 0;
208 m->msg_unread = 0;
209 m->msg_flagged = 0;
210
211 enum MxStatus rc = MX_STATUS_OK;
212 bool check_new = true;
213 for (int i = mhs.max; i > 0; i--)
214 {
215 if ((mh_seq_check(&mhs, i) & MH_SEQ_FLAGGED))
216 m->msg_flagged++;
217 if (mh_seq_check(&mhs, i) & MH_SEQ_UNSEEN)
218 {
219 m->msg_unread++;
220 if (check_new)
221 {
222 /* if the first unseen message we encounter was in the m during the
223 * last visit, don't notify about it */
224 if (!c_mail_check_recent || (mh_already_notified(m, i) == 0))
225 {
226 m->has_new = true;
228 }
229 /* Because we are traversing from high to low, we can stop
230 * checking for new mail after the first unseen message.
231 * Whether it resulted in "new mail" or not. */
232 check_new = false;
233 }
234 }
235 }
236
237 mh_seq_free(&mhs);
238
240 if (dir)
241 {
242 while ((de = readdir(dir)))
243 {
244 if (*de->d_name == '.')
245 continue;
246 if (mh_valid_message(de->d_name))
247 m->msg_count++;
248 }
249 closedir(dir);
250 }
251
252 return rc;
253}
DIR * mutt_file_opendir(const char *path, enum MuttOpenDirMode mode)
Open a directory.
Definition: file.c:616
@ MUTT_OPENDIR_NONE
Plain opendir()
Definition: file.h:73
static const char * mailbox_path(const struct Mailbox *m)
Get the Mailbox's path string.
Definition: mailbox.h:210
static bool mh_valid_message(const char *s)
Is this a valid MH message filename.
Definition: mh.c:149
static int mh_already_notified(struct Mailbox *m, int msgno)
Has the message changed.
Definition: mh.c:126
MxStatus
Return values from mbox_check(), mbox_check_stats(), mbox_snc(), and mbox_close()
Definition: mxapi.h:63
MhSeqFlags mh_seq_check(struct MhSequences *mhs, int i)
Get the flags for a given sequence.
Definition: sequence.c:78
void mh_seq_free(struct MhSequences *mhs)
Free some sequences.
Definition: sequence.c:67
int mh_seq_changed(struct Mailbox *m)
Has the mailbox changed.
Definition: sequence.c:438
int mh_seq_read(struct MhSequences *mhs, const char *path)
Read a set of MH sequences.
Definition: sequence.c:377
#define MH_SEQ_UNSEEN
Email hasn't been read.
Definition: sequence.h:33
#define MH_SEQ_FLAGGED
Email is flagged.
Definition: sequence.h:35
Set of MH sequence numbers.
Definition: sequence.h:41
int max
Number of flags stored.
Definition: sequence.h:42
+ Here is the call graph for this function:

◆ mbox_mbox_check_stats()

static enum MxStatus mbox_mbox_check_stats ( struct Mailbox m,
uint8_t  flags 
)
static

Check the Mailbox statistics - Implements MxOps::mbox_check_stats() -.

Definition at line 1688 of file mbox.c.

1689{
1690 struct stat st = { 0 };
1691 if (stat(mailbox_path(m), &st) != 0)
1692 return MX_STATUS_ERROR;
1693
1694 bool new_or_changed;
1695
1696 const bool c_check_mbox_size = cs_subset_bool(NeoMutt->sub, "check_mbox_size");
1697 if (c_check_mbox_size)
1698 {
1699 new_or_changed = (st.st_size > m->size);
1700 }
1701 else
1702 {
1703 new_or_changed =
1705 (m->newly_created &&
1708 }
1709
1710 if (new_or_changed)
1711 {
1712 const bool c_mail_check_recent = cs_subset_bool(NeoMutt->sub, "mail_check_recent");
1713 if (!c_mail_check_recent ||
1715 {
1716 m->has_new = true;
1717 }
1718 }
1719 else if (c_check_mbox_size)
1720 {
1721 /* some other program has deleted mail from the folder */
1722 m->size = (off_t) st.st_size;
1723 }
1724
1725 if (m->newly_created && ((st.st_ctime != st.st_mtime) || (st.st_ctime != st.st_atime)))
1726 m->newly_created = false;
1727
1729 {
1732 &adata->stats_last_checked) > 0)
1733 {
1734 bool old_peek = m->peekonly;
1736 mx_mbox_close(m);
1737 m->peekonly = old_peek;
1738 adata->stats_last_checked.tv_sec = mutt_date_now();
1739 }
1740 }
1741
1742 if (m->has_new || m->msg_new)
1743 return MX_STATUS_NEW_MAIL;
1744 return MX_STATUS_OK;
1745}
int mutt_file_stat_compare(struct stat *st1, enum MuttStatType st1_type, struct stat *st2, enum MuttStatType st2_type)
Compare two stat infos.
Definition: file.c:1682
int mutt_file_stat_timespec_compare(struct stat *st, enum MuttStatType type, struct timespec *b)
Compare stat info with a time value.
Definition: file.c:1660
@ MUTT_STAT_CTIME
File/dir's ctime - creation time.
Definition: file.h:65
@ MUTT_STAT_ATIME
File/dir's atime - last accessed time.
Definition: file.h:63
@ MUTT_STAT_MTIME
File/dir's mtime - last modified time.
Definition: file.h:64
static struct MboxAccountData * mbox_adata_get(struct Mailbox *m)
Get the private data associated with a Mailbox.
Definition: mbox.c:123
time_t mutt_date_now(void)
Return the number of seconds since the Unix epoch.
Definition: date.c:446
bool mx_mbox_open(struct Mailbox *m, OpenMailboxFlags flags)
Open a mailbox and parse it.
Definition: mx.c:304
enum MxStatus mx_mbox_close(struct Mailbox *m)
Save changes and close mailbox.
Definition: mx.c:615
#define MUTT_QUIET
Do not print any messages.
Definition: mxapi.h:44
#define MUTT_PEEK
Revert atime back after taking a look (if applicable)
Definition: mxapi.h:48
#define MUTT_NOSORT
Do not sort the mailbox after opening it.
Definition: mxapi.h:41
#define MUTT_MAILBOX_CHECK_FORCE
Ignore MailboxTime and check for new mail.
Definition: mxapi.h:54
void * adata
Private data (for Mailbox backends)
Definition: account.h:43
bool newly_created
Mbox or mmdf just popped into existence.
Definition: mailbox.h:103
bool peekonly
Just taking a glance, revert atime.
Definition: mailbox.h:113
off_t size
Size of the Mailbox.
Definition: mailbox.h:84
struct timespec last_visited
Time of last exit from this mailbox.
Definition: mailbox.h:104
Mbox-specific Account data -.
Definition: lib.h:49
+ Here is the call graph for this function:

◆ nm_mbox_check_stats()

static enum MxStatus nm_mbox_check_stats ( struct Mailbox m,
uint8_t  flags 
)
static

Check the Mailbox statistics - Implements MxOps::mbox_check_stats() -.

Definition at line 1774 of file notmuch.c.

1775{
1776 struct UrlQuery *item = NULL;
1777 struct Url *url = NULL;
1778 const char *db_filename = NULL;
1779 char *db_query = NULL;
1780 notmuch_database_t *db = NULL;
1781 enum MxStatus rc = MX_STATUS_ERROR;
1782 const short c_nm_db_limit = cs_subset_number(NeoMutt->sub, "nm_db_limit");
1783 int limit = c_nm_db_limit;
1784 mutt_debug(LL_DEBUG1, "nm: count\n");
1785
1786 url = url_parse(mailbox_path(m));
1787 if (!url)
1788 {
1789 mutt_error(_("failed to parse notmuch url: %s"), mailbox_path(m));
1790 goto done;
1791 }
1792
1793 STAILQ_FOREACH(item, &url->query_strings, entries)
1794 {
1795 if (item->value && (mutt_str_equal(item->name, "query")))
1796 {
1797 db_query = item->value;
1798 }
1799 else if (item->value && (mutt_str_equal(item->name, "limit")))
1800 {
1801 // Try to parse the limit
1802 if (!mutt_str_atoi_full(item->value, &limit))
1803 {
1804 mutt_error(_("failed to parse limit: %s"), item->value);
1805 goto done;
1806 }
1807 }
1808 }
1809
1810 if (!db_query)
1811 goto done;
1812
1813 db_filename = url->path;
1814 if (!db_filename)
1815 db_filename = nm_db_get_filename(m);
1816
1817 /* don't be verbose about connection, as we're called from
1818 * sidebar/mailbox very often */
1819 db = nm_db_do_open(db_filename, false, false);
1820 if (!db)
1821 goto done;
1822
1823 /* all emails */
1824 m->msg_count = count_query(db, db_query, limit);
1826
1827 // holder variable for extending query to unread/flagged
1828 char *qstr = NULL;
1829
1830 // unread messages
1831 const char *const c_nm_unread_tag = cs_subset_string(NeoMutt->sub, "nm_unread_tag");
1832 mutt_str_asprintf(&qstr, "( %s ) tag:%s", db_query, c_nm_unread_tag);
1833 m->msg_unread = count_query(db, qstr, limit);
1834 FREE(&qstr);
1835
1836 // flagged messages
1837 const char *const c_nm_flagged_tag = cs_subset_string(NeoMutt->sub, "nm_flagged_tag");
1838 mutt_str_asprintf(&qstr, "( %s ) tag:%s", db_query, c_nm_flagged_tag);
1839 m->msg_flagged = count_query(db, qstr, limit);
1840 FREE(&qstr);
1841
1842 rc = (m->msg_new > 0) ? MX_STATUS_NEW_MAIL : MX_STATUS_OK;
1843done:
1844 if (db)
1845 {
1846 nm_db_free(db);
1847 mutt_debug(LL_DEBUG1, "nm: count close DB\n");
1848 }
1849 url_free(&url);
1850
1851 mutt_debug(LL_DEBUG1, "nm: count done [rc=%d]\n", rc);
1852 return rc;
1853}
const char * cs_subset_string(const struct ConfigSubset *sub, const char *name)
Get a string config item by name.
Definition: helpers.c:292
short cs_subset_number(const struct ConfigSubset *sub, const char *name)
Get a number config item by name.
Definition: helpers.c:144
#define mutt_error(...)
Definition: logging2.h:92
#define mutt_debug(LEVEL,...)
Definition: logging2.h:89
@ LL_DEBUG1
Log at debug level 1.
Definition: logging2.h:43
#define FREE(x)
Definition: memory.h:45
#define _(a)
Definition: message.h:28
int mutt_str_asprintf(char **strp, const char *fmt,...)
Definition: string.c:1022
bool mutt_str_equal(const char *a, const char *b)
Compare two strings.
Definition: string.c:798
void mx_alloc_memory(struct Mailbox *m, int req_size)
Create storage for the emails.
Definition: mx.c:1232
notmuch_database_t * nm_db_do_open(const char *filename, bool writable, bool verbose)
Open a Notmuch database.
Definition: db.c:111
const char * nm_db_get_filename(struct Mailbox *m)
Get the filename of the Notmuch database.
Definition: db.c:54
void nm_db_free(notmuch_database_t *db)
Decoupled way to close a Notmuch database.
Definition: db.c:241
static unsigned int count_query(notmuch_database_t *db, const char *qstr, int limit)
Count the results of a query.
Definition: notmuch.c:1426
#define STAILQ_FOREACH(var, head, field)
Definition: queue.h:352
Parsed Query String.
Definition: url.h:58
char * name
Query name.
Definition: url.h:59
char * value
Query value.
Definition: url.h:60
A parsed URL proto://user:password@host:port/path?a=1&b=2
Definition: url.h:69
struct UrlQueryList query_strings
List of query strings.
Definition: url.h:76
char * path
Path.
Definition: url.h:75
struct Url * url_parse(const char *src)
Fill in Url.
Definition: url.c:238
void url_free(struct Url **ptr)
Free the contents of a URL.
Definition: url.c:123
+ Here is the call graph for this function: