NeoMutt  2025-12-11-694-ga89709
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 struct StoreOps *store_ops, 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:631

Definition at line 168 of file lib.h.

Typedef Documentation

◆ hcache_namer_t

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

Definition at line 119 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 479 of file hcache.c.

481{
482 if (!path || (path[0] == '\0'))
483 return NULL;
484
485 if (HcacheVer == 0x0)
487
488 struct HeaderCache *hc = hcache_new();
489
491 hc->crc = HcacheVer;
492
493 const char *const c_header_cache_backend = cs_subset_string(NeoMutt->sub, "header_cache_backend");
494 hc->store_ops = store_get_backend_ops(c_header_cache_backend);
495 if (!hc->store_ops)
496 {
497 hcache_free(&hc);
498 return NULL;
499 }
500
501#ifdef USE_HCACHE_COMPRESSION
502 const char *const c_header_cache_compress_method = cs_subset_string(NeoMutt->sub, "header_cache_compress_method");
503 if (c_header_cache_compress_method)
504 {
505 hc->compr_ops = compress_get_ops(c_header_cache_compress_method);
506
507 const short c_header_cache_compress_level = cs_subset_number(NeoMutt->sub, "header_cache_compress_level");
508 hc->compr_handle = hc->compr_ops->open(c_header_cache_compress_level);
509 if (!hc->compr_handle)
510 {
511 hcache_free(&hc);
512 return NULL;
513 }
514
515 /* remember the buffer of database backend */
516 mutt_debug(LL_DEBUG3, "Header cache will use %s compression\n",
517 hc->compr_ops->name);
518 }
519#endif
520
521 struct Buffer *hcpath = buf_pool_get();
522 hcache_per_folder(hc, hcpath, path, namer);
523
524 hc->store_handle = hc->store_ops->open(buf_string(hcpath), create);
525 if (!hc->store_handle)
526 {
527 /* remove a possibly incompatible version */
528 if (unlink(buf_string(hcpath)) == 0)
529 {
530 hc->store_handle = hc->store_ops->open(buf_string(hcpath), create);
531 }
532 }
533
534 if (!hc->store_handle)
535 {
536 if (hc->compr_ops)
537 {
538 hc->compr_ops->close(&hc->compr_handle);
539 }
540 hcache_free(&hc);
541 }
542
543 buf_pool_release(&hcpath);
544 return hc;
545}
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:61
static void hcache_free(struct HeaderCache **ptr)
Free a header cache.
Definition hcache.c:108
static struct HeaderCache * hcache_new(void)
Create a new header cache.
Definition hcache.c:123
static unsigned int generate_hcachever(void)
Calculate hcache version from dynamic configuration.
Definition hcache.c:437
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:361
static char * get_foldername(const char *folder)
Where should the cache be stored?
Definition hcache.c:414
@ 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:88
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:83
+ 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 550 of file hcache.c.

551{
552 if (!ptr || !*ptr)
553 return;
554
555 struct HeaderCache *hc = *ptr;
556
557#ifdef USE_HCACHE_COMPRESSION
558 if (hc->compr_ops)
559 hc->compr_ops->close(&hc->compr_handle);
560#endif
561
562 hc->store_ops->close(&hc->store_handle);
563
564 hcache_free(ptr);
565}
void(* close)(StoreHandle **ptr)
Definition lib.h:144
+ 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 684 of file hcache.c.

686{
687 if (!hc)
688 return -1;
689
690 int dlen = 0;
691 char *data = dump_email(hc, e, &dlen, uidvalidity);
692
693#ifdef USE_HCACHE_COMPRESSION
694 if (hc->compr_ops)
695 {
696 /* We don't compress uidvalidity and the crc, so we can check them before
697 * decompressing on fetch(). */
698 size_t hlen = header_size();
699
700 /* data / dlen gets ptr to compressed data here */
701 size_t clen = dlen;
702 void *cdata = hc->compr_ops->compress(hc->compr_handle, data + hlen, dlen - hlen, &clen);
703 if (!cdata)
704 {
705 FREE(&data);
706 return -1;
707 }
708
709 char *whole = MUTT_MEM_MALLOC(hlen + clen, char);
710 memcpy(whole, data, hlen);
711 memcpy(whole + hlen, cdata, clen);
712
713 FREE(&data);
714
715 data = whole;
716 dlen = hlen + clen;
717 }
718#endif
719
720 struct RealKey *rk = realkey(hc, key, keylen, true);
721 int rc = hc->store_ops->store(hc->store_handle, rk->key, rk->keylen, data, dlen);
722
723 FREE(&data);
724
725 return rc;
726}
static void * dump_email(struct HeaderCache *hc, const struct Email *e, int *off, uint32_t uidvalidity)
Serialise an Email object.
Definition hcache.c:232
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:80
static size_t header_size(void)
Compute the size of the header with uuid validity and crc.
Definition hcache.c:132
#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:67
char key[1024]
Key name.
Definition hcache.c:68
size_t keylen
Length of key.
Definition hcache.c:69
int(* store)(StoreHandle *store, const char *key, size_t klen, void *value, size_t vlen)
Definition lib.h:122
+ 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 570 of file hcache.c.

572{
573 struct HCacheEntry hce = { 0 };
574 if (!hc)
575 return hce;
576
577 size_t dlen = 0;
578 struct RealKey *rk = realkey(hc, key, keylen, true);
579 void *data = hc->store_ops->fetch(hc->store_handle, rk->key, rk->keylen, &dlen);
580 void *to_free = data;
581 if (!data)
582 {
583 goto end;
584 }
585
586 /* restore uidvalidity and crc */
587 size_t hlen = header_size();
588 if (hlen > dlen)
589 {
590 goto end;
591 }
592 int off = 0;
593 serial_restore_uint32_t(&hce.uidvalidity, data, &off);
594 serial_restore_int(&hce.crc, data, &off);
595 ASSERT((size_t) off == hlen);
596 if ((hce.crc != hc->crc) || ((uidvalidity != 0) && (uidvalidity != hce.uidvalidity)))
597 {
598 goto end;
599 }
600
601#ifdef USE_HCACHE_COMPRESSION
602 if (hc->compr_ops)
603 {
604 void *dblob = hc->compr_ops->decompress(hc->compr_handle,
605 (char *) data + hlen, dlen - hlen);
606 if (!dblob)
607 {
608 goto end;
609 }
610 data = (char *) dblob - hlen; /* restore skips uidvalidity and crc */
611 }
612#endif
613
614 hce.email = restore_email(data);
615
616end:
617 free_raw(hc, &to_free);
618 return hce;
619}
static struct Email * restore_email(const unsigned char *d)
Restore an Email from data retrieved from the cache.
Definition hcache.c:272
static void free_raw(struct HeaderCache *hc, void **data)
Multiplexor for StoreOps::free.
Definition hcache.c:428
void serial_restore_int(unsigned int *i, const unsigned char *d, int *off)
Unpack an integer from a binary blob.
Definition serialize.c:120
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:132
#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:97
+ 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 663 of file hcache.c.

664{
665 if (!hc)
666 return NULL;
667
668 char *res = NULL;
669 size_t dlen = 0;
670
671 struct RealKey *rk = realkey(hc, key, keylen, false);
672 void *data = hc->store_ops->fetch(hc->store_handle, rk->key, rk->keylen, &dlen);
673 if (data)
674 {
675 res = mutt_strn_dup(data, dlen);
676 free_raw(hc, &data);
677 }
678 return res;
679}
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 631 of file hcache.c.

633{
634 if (!hc)
635 return false;
636
637 bool rc = true;
638 size_t srclen = 0;
639
640 struct RealKey *rk = realkey(hc, key, keylen, false);
641 void *src = hc->store_ops->fetch(hc->store_handle, rk->key, rk->keylen, &srclen);
642
643 if (src && (srclen == dstlen))
644 {
645 memcpy(dst, src, dstlen);
646 }
647 else
648 {
649 rc = false;
650 }
651 free_raw(hc, &src);
652 return rc;
653}
+ 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 738 of file hcache.c.

740{
741 if (!hc)
742 return -1;
743
744 struct RealKey *rk = realkey(hc, key, keylen, false);
745 int rc = hc->store_ops->store(hc->store_handle, rk->key, rk->keylen, data, dlen);
746
747 return rc;
748}
+ 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 753 of file hcache.c.

754{
755 if (!hc)
756 return -1;
757
758 struct RealKey *rk = realkey(hc, key, keylen, true);
759
760 return hc->store_ops->delete_record(hc->store_handle, rk->key, rk->keylen);
761}
int(* delete_record)(StoreHandle *store, const char *key, size_t klen)
Definition lib.h:135
+ 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 766 of file hcache.c.

767{
768 if (!hc)
769 return -1;
770
771 struct RealKey *rk = realkey(hc, key, keylen, false);
772
773 return hc->store_ops->delete_record(hc->store_handle, rk->key, rk->keylen);
774}
+ Here is the call graph for this function:
+ Here is the caller graph for this function: