+MsgInfo *msgcache_get_msg(MsgCache *cache, guint num)
+{
+ MsgInfo *msginfo;
+
+ g_return_val_if_fail(cache != NULL, NULL);
+
+ msginfo = g_hash_table_lookup(cache->msgnum_table, &num);
+ if(!msginfo)
+ return NULL;
+ cache->last_access = time(NULL);
+
+ return procmsg_msginfo_new_ref(msginfo);
+}
+
+MsgInfo *msgcache_get_msg_by_id(MsgCache *cache, const gchar *msgid)
+{
+ MsgInfo *msginfo;
+
+ g_return_val_if_fail(cache != NULL, NULL);
+ g_return_val_if_fail(msgid != NULL, NULL);
+
+ msginfo = g_hash_table_lookup(cache->msgid_table, msgid);
+ if(!msginfo)
+ return NULL;
+ cache->last_access = time(NULL);
+
+ return procmsg_msginfo_new_ref(msginfo);
+}
+
+static void msgcache_get_msg_list_func(gpointer key, gpointer value, gpointer user_data)
+{
+ MsgInfoList **listptr = user_data;
+ MsgInfo *msginfo = value;
+
+ *listptr = g_slist_prepend(*listptr, procmsg_msginfo_new_ref(msginfo));
+}
+
+MsgInfoList *msgcache_get_msg_list(MsgCache *cache)
+{
+ MsgInfoList *msg_list = NULL;
+
+ g_return_val_if_fail(cache != NULL, NULL);
+
+ g_hash_table_foreach((GHashTable *)cache->msgnum_table, msgcache_get_msg_list_func, (gpointer)&msg_list);
+ cache->last_access = time(NULL);
+
+ msg_list = g_slist_reverse(msg_list);
+
+ return msg_list;
+}
+
+time_t msgcache_get_last_access_time(MsgCache *cache)
+{
+ g_return_val_if_fail(cache != NULL, 0);
+
+ return cache->last_access;
+}
+
+gint msgcache_get_memory_usage(MsgCache *cache)
+{
+ g_return_val_if_fail(cache != NULL, 0);
+
+ return cache->memusage;
+}
+
+/*
+ * Cache saving functions
+ */
+
+#define READ_CACHE_DATA(data, fp) \
+{ \
+ if (msgcache_read_cache_data_str(fp, &data) < 0) { \
+ procmsg_msginfo_free(msginfo); \
+ error = TRUE; \
+ break; \
+ } \
+}
+
+#define READ_CACHE_DATA_INT(n, fp) \
+{ \
+ guint32 idata; \
+ \
+ if (fread(&idata, sizeof(idata), 1, fp) != 1) { \
+ g_warning("Cache data is corrupted\n"); \
+ procmsg_msginfo_free(msginfo); \
+ error = TRUE; \
+ break; \
+ } else \
+ n = idata;\
+}
+
+#define WRITE_CACHE_DATA_INT(n, fp) \
+{ \
+ guint32 idata; \
+ \
+ idata = (guint32)n; \
+ fwrite(&idata, sizeof(idata), 1, fp); \
+}
+
+#define WRITE_CACHE_DATA(data, fp) \
+{ \
+ size_t len; \
+ if (data == NULL) \
+ len = 0; \
+ else \
+ len = strlen(data); \
+ WRITE_CACHE_DATA_INT(len, fp); \
+ if (len > 0) { \
+ fwrite(data, len, 1, fp); \
+ } \
+}
+
+static FILE *msgcache_open_data_file(const gchar *file, gint version,
+ DataOpenMode mode,
+ gchar *buf, size_t buf_size)
+{
+ FILE *fp;
+ gint data_ver;
+
+ g_return_val_if_fail(file != NULL, NULL);
+
+ if (mode == DATA_WRITE) {
+ if ((fp = fopen(file, "wb")) == NULL) {
+ FILE_OP_ERROR(file, "fopen");
+ return NULL;
+ }
+ if (change_file_mode_rw(fp, file) < 0)
+ FILE_OP_ERROR(file, "chmod");
+
+ WRITE_CACHE_DATA_INT(version, fp);
+ return fp;
+ }
+
+ /* check version */
+ if ((fp = fopen(file, "rb")) == NULL)
+ debug_print("Mark/Cache file not found\n");
+ else {
+ if (buf && buf_size > 0)
+ setvbuf(fp, buf, _IOFBF, buf_size);
+ if (fread(&data_ver, sizeof(data_ver), 1, fp) != 1 ||
+ version != data_ver) {
+ debug_print("Mark/Cache version is different (%d != %d). "
+ "Discarding it.\n", data_ver, version);
+ fclose(fp);
+ fp = NULL;
+ }
+ }
+
+ if (mode == DATA_READ)
+ return fp;
+
+ if (fp) {
+ /* reopen with append mode */
+ fclose(fp);
+ if ((fp = fopen(file, "ab")) == NULL)
+ FILE_OP_ERROR(file, "fopen");
+ } else {
+ /* open with overwrite mode if mark file doesn't exist or
+ version is different */
+ fp = msgcache_open_data_file(file, version, DATA_WRITE, buf,
+ buf_size);
+ }
+
+ return fp;
+}
+
projects / claws.git / blobdiff