NeoMutt  2024-11-14-138-ge5ca67
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)   hcache_fetch_raw_obj_full(hc, key, keylen, dst, sizeof(*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 
)    hcache_fetch_raw_obj_full(hc, key, keylen, dst, sizeof(*dst))

Definition at line 162 of file lib.h.

Typedef Documentation

◆ hcache_namer_t

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

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

473{
474 if (!path || (path[0] == '\0'))
475 return NULL;
476
477 if (HcacheVer == 0x0)
479
480 struct HeaderCache *hc = hcache_new();
481
483 hc->crc = HcacheVer;
484
485 const char *const c_header_cache_backend = cs_subset_string(NeoMutt->sub, "header_cache_backend");
486 hc->store_ops = store_get_backend_ops(c_header_cache_backend);
487 if (!hc->store_ops)
488 {
489 hcache_free(&hc);
490 return NULL;
491 }
492
493#ifdef USE_HCACHE_COMPRESSION
494 const char *const c_header_cache_compress_method = cs_subset_string(NeoMutt->sub, "header_cache_compress_method");
495 if (c_header_cache_compress_method)
496 {
497 hc->compr_ops = compress_get_ops(c_header_cache_compress_method);
498
499 const short c_header_cache_compress_level = cs_subset_number(NeoMutt->sub, "header_cache_compress_level");
500 hc->compr_handle = hc->compr_ops->open(c_header_cache_compress_level);
501 if (!hc->compr_handle)
502 {
503 hcache_free(&hc);
504 return NULL;
505 }
506
507 /* remember the buffer of database backend */
508 mutt_debug(LL_DEBUG3, "Header cache will use %s compression\n",
509 hc->compr_ops->name);
510 }
511#endif
512
513 struct Buffer *hcpath = buf_pool_get();
514 hcache_per_folder(hc, hcpath, path, namer);
515
516 hc->store_handle = hc->store_ops->open(buf_string(hcpath), create);
517 if (!hc->store_handle)
518 {
519 /* remove a possibly incompatible version */
520 if (unlink(buf_string(hcpath)) == 0)
521 {
522 hc->store_handle = hc->store_ops->open(buf_string(hcpath), create);
523 }
524 }
525
526 if (!hc->store_handle)
527 {
528 if (hc->compr_ops)
529 {
530 hc->compr_ops->close(&hc->compr_handle);
531 }
532 hcache_free(&hc);
533 }
534
535 buf_pool_release(&hcpath);
536 return hc;
537}
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:81
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:89
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:103
static struct HeaderCache * hcache_new(void)
Create a new header cache.
Definition: hcache.c:118
static unsigned int generate_hcachever(void)
Calculate hcache version from dynamic configuration.
Definition: hcache.c:432
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:356
static char * get_foldername(const char *folder)
Where should the cache be stored?
Definition: hcache.c:409
@ LL_DEBUG3
Log at debug level 3.
Definition: logging2.h:45
struct Buffer * buf_pool_get(void)
Get a Buffer from the pool.
Definition: pool.c:82
void buf_pool_release(struct Buffer **ptr)
Return a Buffer to the pool.
Definition: pool.c:96
const struct StoreOps * store_get_backend_ops(const char *str)
Get the API functions for an store backend.
Definition: store.c:107
String manipulation buffer.
Definition: buffer.h:36
ComprHandle *(* open)(short level)
Definition: lib.h:78
const char * name
Compression name.
Definition: lib.h:65
void(* close)(ComprHandle **ptr)
Definition: lib.h:123
Header Cache.
Definition: lib.h:86
ComprHandle * compr_handle
Compression handle.
Definition: lib.h:92
unsigned int crc
CRC of the cache entry.
Definition: lib.h:88
char * folder
Folder name.
Definition: lib.h:87
const struct StoreOps * store_ops
Store backend.
Definition: lib.h:89
StoreHandle * store_handle
Store handle.
Definition: lib.h:90
const struct ComprOps * compr_ops
Compression backend.
Definition: lib.h:91
Container for Accounts, Notifications.
Definition: neomutt.h:42
struct ConfigSubset * sub
Inherited config items.
Definition: neomutt.h:46
StoreHandle *(* open)(const char *path, bool create)
Definition: lib.h:86
+ 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 542 of file hcache.c.

543{
544 if (!ptr || !*ptr)
545 return;
546
547 struct HeaderCache *hc = *ptr;
548
549#ifdef USE_HCACHE_COMPRESSION
550 if (hc->compr_ops)
551 hc->compr_ops->close(&hc->compr_handle);
552#endif
553
554 hc->store_ops->close(&hc->store_handle);
555
556 hcache_free(ptr);
557}
void(* close)(StoreHandle **ptr)
Definition: lib.h:147
+ 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 670 of file hcache.c.

672{
673 if (!hc)
674 return -1;
675
676 int dlen = 0;
677 char *data = dump_email(hc, e, &dlen, uidvalidity);
678
679#ifdef USE_HCACHE_COMPRESSION
680 if (hc->compr_ops)
681 {
682 /* We don't compress uidvalidity and the crc, so we can check them before
683 * decompressing on fetch(). */
684 size_t hlen = header_size();
685
686 /* data / dlen gets ptr to compressed data here */
687 size_t clen = dlen;
688 void *cdata = hc->compr_ops->compress(hc->compr_handle, data + hlen, dlen - hlen, &clen);
689 if (!cdata)
690 {
691 FREE(&data);
692 return -1;
693 }
694
695 char *whole = MUTT_MEM_MALLOC(hlen + clen, char);
696 memcpy(whole, data, hlen);
697 memcpy(whole + hlen, cdata, clen);
698
699 FREE(&data);
700
701 data = whole;
702 dlen = hlen + clen;
703 }
704#endif
705
706 struct RealKey *rk = realkey(hc, key, keylen, true);
707 int rc = hc->store_ops->store(hc->store_handle, rk->key, rk->keylen, data, dlen);
708
709 FREE(&data);
710
711 return rc;
712}
static void * dump_email(struct HeaderCache *hc, const struct Email *e, int *off, uint32_t uidvalidity)
Serialise an Email object.
Definition: hcache.c:227
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:127
#define FREE(x)
Definition: memory.h:55
#define MUTT_MEM_MALLOC(n, type)
Definition: memory.h:41
void *(* compress)(ComprHandle *handle, const char *data, size_t dlen, size_t *clen)
Definition: lib.h:95
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:125
+ 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 562 of file hcache.c.

564{
565 struct HCacheEntry hce = { 0 };
566 if (!hc)
567 return hce;
568
569 size_t dlen = 0;
570 struct RealKey *rk = realkey(hc, key, keylen, true);
571 void *data = hc->store_ops->fetch(hc->store_handle, rk->key, rk->keylen, &dlen);
572 void *to_free = data;
573 if (!data)
574 {
575 goto end;
576 }
577
578 /* restore uidvalidity and crc */
579 size_t hlen = header_size();
580 if (hlen > dlen)
581 {
582 goto end;
583 }
584 int off = 0;
585 serial_restore_uint32_t(&hce.uidvalidity, data, &off);
586 serial_restore_int(&hce.crc, data, &off);
587 ASSERT((size_t) off == hlen);
588 if ((hce.crc != hc->crc) || ((uidvalidity != 0) && (uidvalidity != hce.uidvalidity)))
589 {
590 goto end;
591 }
592
593#ifdef USE_HCACHE_COMPRESSION
594 if (hc->compr_ops)
595 {
596 void *dblob = hc->compr_ops->decompress(hc->compr_handle,
597 (char *) data + hlen, dlen - hlen);
598 if (!dblob)
599 {
600 goto end;
601 }
602 data = (char *) dblob - hlen; /* restore skips uidvalidity and crc */
603 }
604#endif
605
606 hce.email = restore_email(data);
607
608end:
609 free_raw(hc, &to_free);
610 return hce;
611}
static struct Email * restore_email(const unsigned char *d)
Restore an Email from data retrieved from the cache.
Definition: hcache.c:267
static void free_raw(struct HeaderCache *hc, void **data)
Multiplexor for StoreOps::free.
Definition: hcache.c:423
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:58
void *(* decompress)(ComprHandle *handle, const char *cbuf, size_t clen)
Definition: lib.h:111
Wrapper for Email retrieved from the header cache.
Definition: lib.h:99
uint32_t uidvalidity
IMAP-specific UIDVALIDITY.
Definition: lib.h:100
struct Email * email
Retrieved email.
Definition: lib.h:102
unsigned int crc
CRC of Email/Body/etc structs.
Definition: lib.h:101
void *(* fetch)(StoreHandle *store, const char *key, size_t klen, size_t *vlen)
Definition: lib.h:100
+ 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 652 of file hcache.c.

653{
654 char *res = NULL;
655 size_t dlen = 0;
656
657 struct RealKey *rk = realkey(hc, key, keylen, false);
658 void *data = hc->store_ops->fetch(hc->store_handle, rk->key, rk->keylen, &dlen);
659 if (data)
660 {
661 res = mutt_strn_dup(data, dlen);
662 free_raw(hc, &data);
663 }
664 return res;
665}
char * mutt_strn_dup(const char *begin, size_t len)
Duplicate a sub-string.
Definition: string.c:380
+ 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 623 of file hcache.c.

625{
626 bool rc = true;
627 size_t srclen = 0;
628
629 struct RealKey *rk = realkey(hc, key, keylen, false);
630 void *src = hc->store_ops->fetch(hc->store_handle, rk->key, rk->keylen, &srclen);
631
632 if (src && (srclen == dstlen))
633 {
634 memcpy(dst, src, dstlen);
635 }
636 else
637 {
638 rc = false;
639 }
640 free_raw(hc, &src);
641 return rc;
642}
+ 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 724 of file hcache.c.

726{
727 if (!hc)
728 return -1;
729
730 struct RealKey *rk = realkey(hc, key, keylen, false);
731 int rc = hc->store_ops->store(hc->store_handle, rk->key, rk->keylen, data, dlen);
732
733 return rc;
734}
+ 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 739 of file hcache.c.

740{
741 if (!hc)
742 return -1;
743
744 struct RealKey *rk = realkey(hc, key, keylen, true);
745
746 return hc->store_ops->delete_record(hc->store_handle, rk->key, rk->keylen);
747}
int(* delete_record)(StoreHandle *store, const char *key, size_t klen)
Definition: lib.h:138
+ 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 752 of file hcache.c.

753{
754 if (!hc)
755 return -1;
756
757 struct RealKey *rk = realkey(hc, key, keylen, false);
758
759 return hc->store_ops->delete_record(hc->store_handle, rk->key, rk->keylen);
760}
+ Here is the call graph for this function:
+ Here is the caller graph for this function: