2 * Sylpheed -- a GTK+ based, lightweight, and fast e-mail client
3 * Copyright (C) 1999-2001 Hiroyuki Yamamoto
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; either version 2 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
15 * You should have received a copy of the GNU General Public License
16 * along with this program; if not, write to the Free Software
17 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
39 GHashTable *msgnum_table;
40 GHashTable *msgid_table;
45 MsgCache *msgcache_new(void)
49 cache = g_new0(MsgCache, 1),
50 cache->msgnum_table = g_hash_table_new(g_int_hash, g_int_equal);
51 cache->msgid_table = g_hash_table_new(g_str_hash, g_str_equal);
52 cache->last_access = time(NULL);
57 static gboolean msgcache_msginfo_free_func(gpointer num, gpointer msginfo, gpointer user_data)
59 procmsg_msginfo_free((MsgInfo *)msginfo);
63 void msgcache_destroy(MsgCache *cache)
65 g_return_if_fail(cache != NULL);
67 g_hash_table_foreach_remove(cache->msgnum_table, msgcache_msginfo_free_func, NULL);
68 g_hash_table_destroy(cache->msgid_table);
69 g_hash_table_destroy(cache->msgnum_table);
73 void msgcache_add_msg(MsgCache *cache, MsgInfo *msginfo)
77 g_return_if_fail(cache != NULL);
78 g_return_if_fail(msginfo != NULL);
80 newmsginfo = procmsg_msginfo_new_ref(msginfo);
81 g_hash_table_insert(cache->msgnum_table, &newmsginfo->msgnum, newmsginfo);
82 if(newmsginfo->msgid != NULL)
83 g_hash_table_insert(cache->msgid_table, newmsginfo->msgid, newmsginfo);
84 cache->memusage += procmsg_msginfo_memusage(msginfo);
85 cache->last_access = time(NULL);
87 debug_print("Cache size: %d messages, %d bytes\n", g_hash_table_size(cache->msgnum_table), cache->memusage);
90 void msgcache_remove_msg(MsgCache *cache, guint msgnum)
94 g_return_if_fail(cache != NULL);
95 g_return_if_fail(msgnum > 0);
97 msginfo = (MsgInfo *) g_hash_table_lookup(cache->msgnum_table, &msgnum);
101 cache->memusage -= procmsg_msginfo_memusage(msginfo);
103 g_hash_table_remove(cache->msgid_table, msginfo->msgid);
104 g_hash_table_remove(cache->msgnum_table, &msginfo->msgnum);
105 procmsg_msginfo_free(msginfo);
106 cache->last_access = time(NULL);
108 debug_print("Cache size: %d messages, %d byte\n", g_hash_table_size(cache->msgnum_table), cache->memusage);
111 void msgcache_update_msg(MsgCache *cache, MsgInfo *msginfo)
113 MsgInfo *oldmsginfo, *newmsginfo;
115 g_return_if_fail(cache != NULL);
116 g_return_if_fail(msginfo != NULL);
118 oldmsginfo = g_hash_table_lookup(cache->msgnum_table, &msginfo->msgnum);
119 if(oldmsginfo && oldmsginfo->msgid) {
120 g_hash_table_remove(cache->msgid_table, oldmsginfo->msgid);
121 g_hash_table_remove(cache->msgnum_table, &oldmsginfo->msgnum);
124 procmsg_msginfo_free(oldmsginfo);
126 cache->memusage -= procmsg_msginfo_memusage(oldmsginfo);
128 newmsginfo = procmsg_msginfo_new_ref(msginfo);
129 g_hash_table_insert(cache->msgnum_table, &newmsginfo->msgnum, newmsginfo);
130 if(newmsginfo->msgid)
131 g_hash_table_insert(cache->msgid_table, newmsginfo->msgid, newmsginfo);
132 cache->memusage += procmsg_msginfo_memusage(newmsginfo);
133 cache->last_access = time(NULL);
135 debug_print("Cache size: %d messages, %d byte\n", g_hash_table_size(cache->msgnum_table), cache->memusage);
140 MsgInfo *msgcache_get_msg(MsgCache *cache, guint num)
144 g_return_val_if_fail(cache != NULL, NULL);
146 msginfo = g_hash_table_lookup(cache->msgnum_table, &num);
149 cache->last_access = time(NULL);
151 return procmsg_msginfo_new_ref(msginfo);
154 MsgInfo *msgcache_get_msg_by_id(MsgCache *cache, const gchar *msgid)
158 g_return_val_if_fail(cache != NULL, NULL);
159 g_return_val_if_fail(msgid != NULL, NULL);
161 msginfo = g_hash_table_lookup(cache->msgid_table, msgid);
164 cache->last_access = time(NULL);
166 return procmsg_msginfo_new_ref(msginfo);
169 static void msgcache_get_msg_list_func(gpointer key, gpointer value, gpointer user_data)
171 MsgInfoList **listptr = user_data;
172 MsgInfo *msginfo = value;
174 *listptr = g_slist_prepend(*listptr, procmsg_msginfo_new_ref(msginfo));
177 MsgInfoList *msgcache_get_msg_list(MsgCache *cache)
179 MsgInfoList *msg_list = NULL;
181 g_return_val_if_fail(cache != NULL, NULL);
183 g_hash_table_foreach((GHashTable *)cache->msgnum_table, msgcache_get_msg_list_func, (gpointer)&msg_list);
184 cache->last_access = time(NULL);
186 msg_list = g_slist_reverse(msg_list);
191 time_t msgcache_get_last_access_time(MsgCache *cache)
193 g_return_val_if_fail(cache != NULL, 0);
195 return cache->last_access;
198 gint msgcache_get_memory_usage(MsgCache *cache)
200 g_return_val_if_fail(cache != NULL, 0);
202 return cache->memusage;
206 * Cache saving functions
209 #define READ_CACHE_DATA(data, fp) \
211 if (msgcache_read_cache_data_str(fp, &data) < 0) { \
212 procmsg_msginfo_free(msginfo); \
218 #define READ_CACHE_DATA_INT(n, fp) \
222 if (fread(&idata, sizeof(idata), 1, fp) != 1) { \
223 g_warning("Cache data is corrupted\n"); \
224 procmsg_msginfo_free(msginfo); \
231 #define WRITE_CACHE_DATA_INT(n, fp) \
235 idata = (guint32)n; \
236 fwrite(&idata, sizeof(idata), 1, fp); \
239 #define WRITE_CACHE_DATA(data, fp) \
245 len = strlen(data); \
246 WRITE_CACHE_DATA_INT(len, fp); \
248 fwrite(data, len, 1, fp); \
252 static FILE *msgcache_open_data_file(const gchar *file, gint version,
254 gchar *buf, size_t buf_size)
259 g_return_val_if_fail(file != NULL, NULL);
261 if (mode == DATA_WRITE) {
262 if ((fp = fopen(file, "wb")) == NULL) {
263 FILE_OP_ERROR(file, "fopen");
266 if (change_file_mode_rw(fp, file) < 0)
267 FILE_OP_ERROR(file, "chmod");
269 WRITE_CACHE_DATA_INT(version, fp);
274 if ((fp = fopen(file, "rb")) == NULL)
275 debug_print("Mark/Cache file not found\n");
277 if (buf && buf_size > 0)
278 setvbuf(fp, buf, _IOFBF, buf_size);
279 if (fread(&data_ver, sizeof(data_ver), 1, fp) != 1 ||
280 version != data_ver) {
281 debug_print("Mark/Cache version is different (%d != %d). "
282 "Discarding it.\n", data_ver, version);
288 if (mode == DATA_READ)
292 /* reopen with append mode */
294 if ((fp = fopen(file, "ab")) == NULL)
295 FILE_OP_ERROR(file, "fopen");
297 /* open with overwrite mode if mark file doesn't exist or
298 version is different */
299 fp = msgcache_open_data_file(file, version, DATA_WRITE, buf,
306 static gint msgcache_read_cache_data_str(FILE *fp, gchar **str)
312 if (fread(&len, sizeof(len), 1, fp) == 1) {
319 size_t size = MIN(len, BUFFSIZE - 1);
321 if (fread(buf, size, 1, fp) != 1) {
323 if (tmp) g_free(tmp);
330 *str = g_strconcat(tmp, buf, NULL);
334 tmp = *str = g_strdup(buf);
343 g_warning("Cache data is corrupted\n");
348 MsgCache *msgcache_read_cache(FolderItem *item, const gchar *cache_file)
353 MsgTmpFlags tmp_flags = 0;
354 gchar file_buf[BUFFSIZE];
356 gboolean error = FALSE;
358 g_return_val_if_fail(cache_file != NULL, NULL);
359 g_return_val_if_fail(item != NULL, NULL);
361 if ((fp = msgcache_open_data_file
362 (cache_file, CACHE_VERSION, DATA_READ, file_buf, sizeof(file_buf))) == NULL)
365 debug_print("\tReading message cache from %s...\n", cache_file);
367 if (item->stype == F_QUEUE) {
368 tmp_flags |= MSG_QUEUED;
369 } else if (item->stype == F_DRAFT) {
370 tmp_flags |= MSG_DRAFT;
373 cache = msgcache_new();
375 g_hash_table_freeze(cache->msgnum_table);
377 while (fread(&num, sizeof(num), 1, fp) == 1) {
378 msginfo = procmsg_msginfo_new();
379 msginfo->msgnum = num;
380 READ_CACHE_DATA_INT(msginfo->size, fp);
381 READ_CACHE_DATA_INT(msginfo->mtime, fp);
382 READ_CACHE_DATA_INT(msginfo->date_t, fp);
383 READ_CACHE_DATA_INT(msginfo->flags.tmp_flags, fp);
385 READ_CACHE_DATA(msginfo->fromname, fp);
387 READ_CACHE_DATA(msginfo->date, fp);
388 READ_CACHE_DATA(msginfo->from, fp);
389 READ_CACHE_DATA(msginfo->to, fp);
390 READ_CACHE_DATA(msginfo->cc, fp);
391 READ_CACHE_DATA(msginfo->newsgroups, fp);
392 READ_CACHE_DATA(msginfo->subject, fp);
393 READ_CACHE_DATA(msginfo->msgid, fp);
394 READ_CACHE_DATA(msginfo->inreplyto, fp);
395 READ_CACHE_DATA(msginfo->references, fp);
396 READ_CACHE_DATA(msginfo->xref, fp);
397 READ_CACHE_DATA_INT(msginfo->planned_download, fp);
399 msginfo->folder = item;
400 msginfo->flags.tmp_flags |= tmp_flags;
402 g_hash_table_insert(cache->msgnum_table, &msginfo->msgnum, msginfo);
404 g_hash_table_insert(cache->msgid_table, msginfo->msgid, msginfo);
405 cache->memusage += procmsg_msginfo_memusage(msginfo);
408 g_hash_table_thaw(cache->msgnum_table);
411 msgcache_destroy(cache);
415 cache->last_access = time(NULL);
417 debug_print("done. (%d items read)\n", g_hash_table_size(cache->msgnum_table));
418 debug_print("Cache size: %d messages, %d byte\n", g_hash_table_size(cache->msgnum_table), cache->memusage);
423 void msgcache_read_mark(MsgCache *cache, const gchar *mark_file)
427 MsgPermFlags perm_flags;
430 if ((fp = msgcache_open_data_file(mark_file, MARK_VERSION, DATA_READ, NULL, 0)) == NULL)
433 debug_print("\tReading message marks from %s...\n", mark_file);
435 while (fread(&num, sizeof(num), 1, fp) == 1) {
436 if (fread(&perm_flags, sizeof(perm_flags), 1, fp) != 1) break;
438 msginfo = g_hash_table_lookup(cache->msgnum_table, &num);
440 msginfo->flags.perm_flags = perm_flags;
446 void msgcache_write_cache(MsgInfo *msginfo, FILE *fp)
448 MsgTmpFlags flags = msginfo->flags.tmp_flags & MSG_CACHED_FLAG_MASK;
450 WRITE_CACHE_DATA_INT(msginfo->msgnum, fp);
451 WRITE_CACHE_DATA_INT(msginfo->size, fp);
452 WRITE_CACHE_DATA_INT(msginfo->mtime, fp);
453 WRITE_CACHE_DATA_INT(msginfo->date_t, fp);
454 WRITE_CACHE_DATA_INT(flags, fp);
456 WRITE_CACHE_DATA(msginfo->fromname, fp);
458 WRITE_CACHE_DATA(msginfo->date, fp);
459 WRITE_CACHE_DATA(msginfo->from, fp);
460 WRITE_CACHE_DATA(msginfo->to, fp);
461 WRITE_CACHE_DATA(msginfo->cc, fp);
462 WRITE_CACHE_DATA(msginfo->newsgroups, fp);
463 WRITE_CACHE_DATA(msginfo->subject, fp);
464 WRITE_CACHE_DATA(msginfo->msgid, fp);
465 WRITE_CACHE_DATA(msginfo->inreplyto, fp);
466 WRITE_CACHE_DATA(msginfo->references, fp);
467 WRITE_CACHE_DATA(msginfo->xref, fp);
468 WRITE_CACHE_DATA_INT(msginfo->planned_download, fp);
471 static void msgcache_write_flags(MsgInfo *msginfo, FILE *fp)
473 MsgPermFlags flags = msginfo->flags.perm_flags;
475 WRITE_CACHE_DATA_INT(msginfo->msgnum, fp);
476 WRITE_CACHE_DATA_INT(flags, fp);
485 static void msgcache_write_func(gpointer key, gpointer value, gpointer user_data)
488 struct write_fps *write_fps;
490 msginfo = (MsgInfo *)value;
491 write_fps = user_data;
493 msgcache_write_cache(msginfo, write_fps->cache_fp);
494 msgcache_write_flags(msginfo, write_fps->mark_fp);
497 gint msgcache_write(const gchar *cache_file, const gchar *mark_file, MsgCache *cache)
499 struct write_fps write_fps;
501 g_return_val_if_fail(cache_file != NULL, -1);
502 g_return_val_if_fail(mark_file != NULL, -1);
503 g_return_val_if_fail(cache != NULL, -1);
505 write_fps.cache_fp = msgcache_open_data_file(cache_file, CACHE_VERSION,
506 DATA_WRITE, NULL, 0);
507 if (write_fps.cache_fp == NULL)
510 write_fps.mark_fp = msgcache_open_data_file(mark_file, MARK_VERSION,
511 DATA_WRITE, NULL, 0);
512 if (write_fps.mark_fp == NULL) {
513 fclose(write_fps.cache_fp);
517 debug_print("\tWriting message cache to %s and %s...\n", cache_file, mark_file);
519 if (change_file_mode_rw(write_fps.cache_fp, cache_file) < 0)
520 FILE_OP_ERROR(cache_file, "chmod");
522 g_hash_table_foreach(cache->msgnum_table, msgcache_write_func, (gpointer)&write_fps);
524 fclose(write_fps.cache_fp);
525 fclose(write_fps.mark_fp);
527 cache->last_access = time(NULL);
529 debug_print("done.\n");