NeoMutt  2025-12-11-435-g4ac674
Teaching an old dog new tricks
DOXYGEN
Loading...
Searching...
No Matches
lib.h File Reference

Header cache multiplexor. More...

#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>
#include "compress/lib.h"
#include "store/lib.h"
+ Include dependency graph for lib.h:
+ This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct  HeaderCache
 Header Cache. More...
 
struct  HCacheEntry
 Wrapper for Email retrieved from the header cache. More...
 

Macros

#define hcache_fetch_raw_obj(hc, key, keylen, dst)
 

Typedefs

typedef void(* hcache_namer_t) (const char *path, struct Buffer *dest)
 

Functions

struct HeaderCachehcache_open (const char *path, const char *folder, hcache_namer_t namer, bool create)
 Open the connection to the header cache.
 
void hcache_close (struct HeaderCache **ptr)
 Close the connection to the header cache.
 
int hcache_store_email (struct HeaderCache *hc, const char *key, size_t keylen, struct Email *e, uint32_t uidvalidity)
 Store a Header along with a validity datum.
 
struct HCacheEntry hcache_fetch_email (struct HeaderCache *hc, const char *key, size_t keylen, uint32_t uidvalidity)
 Fetch and validate a message's header from the cache.
 
char * hcache_fetch_raw_str (struct HeaderCache *hc, const char *key, size_t keylen)
 Fetch a string from the cache.
 
bool hcache_fetch_raw_obj_full (struct HeaderCache *hc, const char *key, size_t keylen, void *dst, size_t dstlen)
 Fetch a message's header from the cache into a destination object.
 
int hcache_store_raw (struct HeaderCache *hc, const char *key, size_t keylen, void *data, size_t dlen)
 Store a key / data pair.
 
int hcache_delete_email (struct HeaderCache *hc, const char *key, size_t keylen)
 Delete a key / data pair.
 
int hcache_delete_raw (struct HeaderCache *hc, const char *key, size_t keylen)
 Delete a key / data pair.
 

Detailed Description

Header cache multiplexor.

Authors
  • Richard Russon
  • Pietro Cerutti
  • Tino Reichardt

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.

You should have received a copy of the GNU General Public License along with this program. If not, see http://www.gnu.org/licenses/.

Definition in file lib.h.

Macro Definition Documentation

◆ hcache_fetch_raw_obj

#define hcache_fetch_raw_obj ( hc,
key,
keylen,
dst )
Value:
hcache_fetch_raw_obj_full(hc, key, keylen, dst, sizeof(*dst))
bool hcache_fetch_raw_obj_full(struct HeaderCache *hc, const char *key, size_t keylen, void *dst, size_t dstlen)
Fetch a message's header from the cache into a destination object.
Definition hcache.c:628

Definition at line 163 of file lib.h.

Typedef Documentation

◆ hcache_namer_t

typedef void(* hcache_namer_t) (const char *path, struct Buffer *dest)

Definition at line 114 of file lib.h.

Function Documentation

◆ hcache_open()

struct HeaderCache * hcache_open ( const char * path,
const char * folder,
hcache_namer_t namer,
bool create )

Open the connection to the header cache.

Parameters
pathLocation of the header cache (often as specified by the user)
folderName of the folder containing the messages
namerOptional (might be NULL) client-specific function to form the final name of the hcache database file.
createCreate the file if it's not there?
Return values
ptrSuccess, struct HeaderCache struct
NULLOtherwise

Open the connection to the header cache.

Definition at line 476 of file hcache.c.

478{
479 if (!path || (path[0] == '\0'))
480 return NULL;
481
482 if (HcacheVer == 0x0)
484
485 struct HeaderCache *hc = hcache_new();
486
488 hc->crc = HcacheVer;
489
490 const char *const c_header_cache_backend = cs_subset_string(NeoMutt->sub, "header_cache_backend");
491 hc->store_ops = store_get_backend_ops(c_header_cache_backend);
492 if (!hc->store_ops)
493 {
494 hcache_free(&hc);
495 return NULL;
496 }
497
498#ifdef USE_HCACHE_COMPRESSION
499 const char *const c_header_cache_compress_method = cs_subset_string(NeoMutt->sub, "header_cache_compress_method");
500 if (c_header_cache_compress_method)
501 {
502 hc->compr_ops = compress_get_ops(c_header_cache_compress_method);
503
504 const short c_header_cache_compress_level = cs_subset_number(NeoMutt->sub, "header_cache_compress_level");
505 hc->compr_handle = hc->compr_ops->open(c_header_cache_compress_level);
506 if (!hc->compr_handle)
507 {
508 hcache_free(&hc);
509 return NULL;
510 }
511
512 /* remember the buffer of database backend */
513 mutt_debug(LL_DEBUG3, "Header cache will use %s compression\n",
514 hc->compr_ops->name);
515 }
516#endif
517
518 struct Buffer *hcpath = buf_pool_get();
519 hcache_per_folder(hc, hcpath, path, namer);
520
521 hc->store_handle = hc->store_ops->open(buf_string(hcpath), create);
522 if (!hc->store_handle)
523 {
524 /* remove a possibly incompatible version */
525 if (unlink(buf_string(hcpath)) == 0)
526 {
527 hc->store_handle = hc->store_ops->open(buf_string(hcpath), create);
528 }
529 }
530
531 if (!hc->store_handle)
532 {
533 if (hc->compr_ops)
534 {
535 hc->compr_ops->close(&hc->compr_handle);
536 }
537 hcache_free(&hc);
538 }
539
540 buf_pool_release(&hcpath);
541 return hc;
542}
static const char * buf_string(const struct Buffer *buf)
Convert a buffer to a const char * "string".
Definition buffer.h:96
const struct ComprOps * compress_get_ops(const char *compr)
Get the API functions for a compress backend.
Definition compress.c:78
const char * cs_subset_string(const struct ConfigSubset *sub, const char *name)
Get a string config item by name.
Definition helpers.c:291
short cs_subset_number(const struct ConfigSubset *sub, const char *name)
Get a number config item by name.
Definition helpers.c:143
#define mutt_debug(LEVEL,...)
Definition logging2.h:91
static unsigned int HcacheVer
Header Cache version.
Definition hcache.c:63
static void hcache_free(struct HeaderCache **ptr)
Free a header cache.
Definition hcache.c:105
static struct HeaderCache * hcache_new(void)
Create a new header cache.
Definition hcache.c:120
static unsigned int generate_hcachever(void)
Calculate hcache version from dynamic configuration.
Definition hcache.c:434
static void hcache_per_folder(struct HeaderCache *hc, struct Buffer *hcpath, const char *path, hcache_namer_t namer)
Generate the hcache pathname.
Definition hcache.c:358
static char * get_foldername(const char *folder)
Where should the cache be stored?
Definition hcache.c:411
@ LL_DEBUG3
Log at debug level 3.
Definition logging2.h:47
struct Buffer * buf_pool_get(void)
Get a Buffer from the pool.
Definition pool.c:91
void buf_pool_release(struct Buffer **ptr)
Return a Buffer to the pool.
Definition pool.c:111
const struct StoreOps * store_get_backend_ops(const char *str)
Get the API functions for an store backend.
Definition store.c:104
String manipulation buffer.
Definition buffer.h:36
ComprHandle *(* open)(short level)
Definition lib.h:79
const char * name
Compression name.
Definition lib.h:66
void(* close)(ComprHandle **ptr)
Definition lib.h:124
Header Cache.
Definition lib.h:87
ComprHandle * compr_handle
Compression handle.
Definition lib.h:93
unsigned int crc
CRC of the cache entry.
Definition lib.h:89
char * folder
Folder name.
Definition lib.h:88
const struct StoreOps * store_ops
Store backend.
Definition lib.h:90
StoreHandle * store_handle
Store handle.
Definition lib.h:91
const struct ComprOps * compr_ops
Compression backend.
Definition lib.h:92
Container for Accounts, Notifications.
Definition neomutt.h:41
struct ConfigSubset * sub
Inherited config items.
Definition neomutt.h:49
StoreHandle *(* open)(const char *path, bool create)
Definition lib.h:87
+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ hcache_close()

void hcache_close ( struct HeaderCache ** ptr)

Close the connection to the header cache.

Parameters
ptrPointer to the struct HeaderCache structure got by hcache_open()
Note
The pointer will be set to NULL

Close the connection to the header cache.

Definition at line 547 of file hcache.c.

548{
549 if (!ptr || !*ptr)
550 return;
551
552 struct HeaderCache *hc = *ptr;
553
554#ifdef USE_HCACHE_COMPRESSION
555 if (hc->compr_ops)
556 hc->compr_ops->close(&hc->compr_handle);
557#endif
558
559 hc->store_ops->close(&hc->store_handle);
560
561 hcache_free(ptr);
562}
void(* close)(StoreHandle **ptr)
Definition lib.h:148
+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ hcache_store_email()

int hcache_store_email ( struct HeaderCache * hc,
const char * key,
size_t keylen,
struct Email * e,
uint32_t uidvalidity )

Store a Header along with a validity datum.

Parameters
hcPointer to the struct HeaderCache structure got by hcache_open()
keyMessage identification string
keylenLength of the key string
eEmail to store
uidvalidityIMAP-specific UIDVALIDITY value, or 0 to use the current time
Return values
0Success
numGeneric or backend-specific error code otherwise

Store a Header along with a validity datum.

Definition at line 675 of file hcache.c.

677{
678 if (!hc)
679 return -1;
680
681 int dlen = 0;
682 char *data = dump_email(hc, e, &dlen, uidvalidity);
683
684#ifdef USE_HCACHE_COMPRESSION
685 if (hc->compr_ops)
686 {
687 /* We don't compress uidvalidity and the crc, so we can check them before
688 * decompressing on fetch(). */
689 size_t hlen = header_size();
690
691 /* data / dlen gets ptr to compressed data here */
692 size_t clen = dlen;
693 void *cdata = hc->compr_ops->compress(hc->compr_handle, data + hlen, dlen - hlen, &clen);
694 if (!cdata)
695 {
696 FREE(&data);
697 return -1;
698 }
699
700 char *whole = MUTT_MEM_MALLOC(hlen + clen, char);
701 memcpy(whole, data, hlen);
702 memcpy(whole + hlen, cdata, clen);
703
704 FREE(&data);
705
706 data = whole;
707 dlen = hlen + clen;
708 }
709#endif
710
711 struct RealKey *rk = realkey(hc, key, keylen, true);
712 int rc = hc->store_ops->store(hc->store_handle, rk->key, rk->keylen, data, dlen);
713
714 FREE(&data);
715
716 return rc;
717}
static void * dump_email(struct HeaderCache *hc, const struct Email *e, int *off, uint32_t uidvalidity)
Serialise an Email object.
Definition hcache.c:229
static struct RealKey * realkey(struct HeaderCache *hc, const char *key, size_t keylen, bool compress)
Compute the real key used in the backend, taking into account the compression method.
Definition hcache.c:82
static size_t header_size(void)
Compute the size of the header with uuid validity and crc.
Definition hcache.c:129
#define FREE(x)
Free memory and set the pointer to NULL.
Definition memory.h:68
#define MUTT_MEM_MALLOC(n, type)
Definition memory.h:53
void *(* compress)(ComprHandle *handle, const char *data, size_t dlen, size_t *clen)
Definition lib.h:96
Hcache key name (including compression method)
Definition hcache.c:69
char key[1024]
Key name.
Definition hcache.c:70
size_t keylen
Length of key.
Definition hcache.c:71
int(* store)(StoreHandle *store, const char *key, size_t klen, void *value, size_t vlen)
Definition lib.h:126
+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ hcache_fetch_email()

struct HCacheEntry hcache_fetch_email ( struct HeaderCache * hc,
const char * key,
size_t keylen,
uint32_t uidvalidity )

Fetch and validate a message's header from the cache.

Parameters
hcPointer to the struct HeaderCache structure got by hcache_open()
keyMessage identification string
keylenLength of the string pointed to by key
uidvalidityOnly restore if it matches the stored uidvalidity
Return values
objHCacheEntry containing an Email, empty on failure
Note
This function performs a check on the validity of the data found by comparing it with the crc value of the struct HeaderCache structure.

Fetch and validate a message's header from the cache.

Definition at line 567 of file hcache.c.

569{
570 struct HCacheEntry hce = { 0 };
571 if (!hc)
572 return hce;
573
574 size_t dlen = 0;
575 struct RealKey *rk = realkey(hc, key, keylen, true);
576 void *data = hc->store_ops->fetch(hc->store_handle, rk->key, rk->keylen, &dlen);
577 void *to_free = data;
578 if (!data)
579 {
580 goto end;
581 }
582
583 /* restore uidvalidity and crc */
584 size_t hlen = header_size();
585 if (hlen > dlen)
586 {
587 goto end;
588 }
589 int off = 0;
590 serial_restore_uint32_t(&hce.uidvalidity, data, &off);
591 serial_restore_int(&hce.crc, data, &off);
592 ASSERT((size_t) off == hlen);
593 if ((hce.crc != hc->crc) || ((uidvalidity != 0) && (uidvalidity != hce.uidvalidity)))
594 {
595 goto end;
596 }
597
598#ifdef USE_HCACHE_COMPRESSION
599 if (hc->compr_ops)
600 {
601 void *dblob = hc->compr_ops->decompress(hc->compr_handle,
602 (char *) data + hlen, dlen - hlen);
603 if (!dblob)
604 {
605 goto end;
606 }
607 data = (char *) dblob - hlen; /* restore skips uidvalidity and crc */
608 }
609#endif
610
611 hce.email = restore_email(data);
612
613end:
614 free_raw(hc, &to_free);
615 return hce;
616}
static struct Email * restore_email(const unsigned char *d)
Restore an Email from data retrieved from the cache.
Definition hcache.c:269
static void free_raw(struct HeaderCache *hc, void **data)
Multiplexor for StoreOps::free.
Definition hcache.c:425
void serial_restore_int(unsigned int *i, const unsigned char *d, int *off)
Unpack an integer from a binary blob.
Definition serialize.c:114
void serial_restore_uint32_t(uint32_t *s, const unsigned char *d, int *off)
Unpack an uint32_t from a binary blob.
Definition serialize.c:126
#define ASSERT(COND)
Definition signal2.h:59
void *(* decompress)(ComprHandle *handle, const char *cbuf, size_t clen)
Definition lib.h:112
Wrapper for Email retrieved from the header cache.
Definition lib.h:100
uint32_t uidvalidity
IMAP-specific UIDVALIDITY.
Definition lib.h:101
struct Email * email
Retrieved email.
Definition lib.h:103
unsigned int crc
CRC of Email/Body/etc structs.
Definition lib.h:102
void *(* fetch)(StoreHandle *store, const char *key, size_t klen, size_t *vlen)
Definition lib.h:101
+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ hcache_fetch_raw_str()

char * hcache_fetch_raw_str ( struct HeaderCache * hc,
const char * key,
size_t keylen )

Fetch a string from the cache.

Parameters
[in]hcPointer to the struct HeaderCache structure got by hcache_open()
[in]keyMessage identification string
[in]keylenLength of the string pointed to by key
Return values
ptrSuccess, the data if found
NULLOtherwise

Definition at line 657 of file hcache.c.

658{
659 char *res = NULL;
660 size_t dlen = 0;
661
662 struct RealKey *rk = realkey(hc, key, keylen, false);
663 void *data = hc->store_ops->fetch(hc->store_handle, rk->key, rk->keylen, &dlen);
664 if (data)
665 {
666 res = mutt_strn_dup(data, dlen);
667 free_raw(hc, &data);
668 }
669 return res;
670}
char * mutt_strn_dup(const char *begin, size_t len)
Duplicate a sub-string.
Definition string.c:384
+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ hcache_fetch_raw_obj_full()

bool hcache_fetch_raw_obj_full ( struct HeaderCache * hc,
const char * key,
size_t keylen,
void * dst,
size_t dstlen )

Fetch a message's header from the cache into a destination object.

Parameters
[in]hcPointer to the struct HeaderCache structure got by hcache_open()
[in]keyMessage identification string
[in]keylenLength of the string pointed to by key
[out]dstPointer to the destination object
[in]dstlenSize of the destination object
Return values
trueSuccess, the data was found and the length matches
falseOtherwise

Definition at line 628 of file hcache.c.

630{
631 bool rc = true;
632 size_t srclen = 0;
633
634 struct RealKey *rk = realkey(hc, key, keylen, false);
635 void *src = hc->store_ops->fetch(hc->store_handle, rk->key, rk->keylen, &srclen);
636
637 if (src && (srclen == dstlen))
638 {
639 memcpy(dst, src, dstlen);
640 }
641 else
642 {
643 rc = false;
644 }
645 free_raw(hc, &src);
646 return rc;
647}
+ Here is the call graph for this function:

◆ hcache_store_raw()

int hcache_store_raw ( struct HeaderCache * hc,
const char * key,
size_t keylen,
void * data,
size_t dlen )

Store a key / data pair.

Parameters
hcPointer to the struct HeaderCache structure got by hcache_open()
keyMessage identification string
keylenLength of the string pointed to by key
dataPayload to associate with key
dlenLength of the buffer pointed to by the data parameter
Return values
0Success
numGeneric or backend-specific error code otherwise

Definition at line 729 of file hcache.c.

731{
732 if (!hc)
733 return -1;
734
735 struct RealKey *rk = realkey(hc, key, keylen, false);
736 int rc = hc->store_ops->store(hc->store_handle, rk->key, rk->keylen, data, dlen);
737
738 return rc;
739}
+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ hcache_delete_email()

int hcache_delete_email ( struct HeaderCache * hc,
const char * key,
size_t keylen )

Delete a key / data pair.

Parameters
hcPointer to the struct HeaderCache structure got by hcache_open()
keyMessage identification string
keylenLength of the string pointed to by key
Return values
0Success
numGeneric or backend-specific error code otherwise

Delete a key / data pair.

Definition at line 744 of file hcache.c.

745{
746 if (!hc)
747 return -1;
748
749 struct RealKey *rk = realkey(hc, key, keylen, true);
750
751 return hc->store_ops->delete_record(hc->store_handle, rk->key, rk->keylen);
752}
int(* delete_record)(StoreHandle *store, const char *key, size_t klen)
Definition lib.h:139
+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ hcache_delete_raw()

int hcache_delete_raw ( struct HeaderCache * hc,
const char * key,
size_t keylen )

Delete a key / data pair.

Parameters
hcPointer to the struct HeaderCache structure got by hcache_open()
keyMessage identification string
keylenLength of the string pointed to by key
Return values
0Success
numGeneric or backend-specific error code otherwise

Delete a key / data pair.

Definition at line 757 of file hcache.c.

758{
759 if (!hc)
760 return -1;
761
762 struct RealKey *rk = realkey(hc, key, keylen, false);
763
764 return hc->store_ops->delete_record(hc->store_handle, rk->key, rk->keylen);
765}
+ Here is the call graph for this function:
+ Here is the caller graph for this function: