4afa1432ff
* src/account.c * src/account.h * src/action.c * src/action.h * src/adbookbase.h * src/addr_compl.c * src/addr_compl.h * src/addrbook.c * src/addrcache.c * src/addrcache.h * src/addrcindex.c * src/addrcindex.h * src/addrclip.c * src/addrclip.h * src/addrdefs.h * src/addressadd.c * src/addressadd.h * src/addressbook.c * src/addressbook.h * src/addrgather.c * src/addrgather.h * src/addrharvest.c * src/addrharvest.h * src/addrindex.c * src/addrindex.h * src/addritem.c * src/addritem.h * src/addrquery.c * src/addrquery.h * src/addrselect.c * src/addrselect.h * src/alertpanel.c * src/alertpanel.h * src/browseldap.c * src/browseldap.h * src/codeconv.c * src/codeconv.h * src/compose.c * src/compose.h * src/customheader.c * src/customheader.h * src/displayheader.c * src/displayheader.h * src/editaddress.c * src/editaddress.h * src/editbook.c * src/editbook.h * src/editgroup.c * src/editgroup.h * src/editjpilot.c * src/editjpilot.h * src/editldap.c * src/editldap.h * src/editldap_basedn.c * src/editldap_basedn.h * src/editvcard.c * src/editvcard.h * src/exphtmldlg.c * src/exphtmldlg.h * src/expldifdlg.c * src/expldifdlg.h * src/export.h * src/exporthtml.c * src/exporthtml.h * src/exportldif.c * src/exportldif.h * src/filtering.c * src/filtering.h * src/folder.c * src/folder.h * src/folder_item_prefs.c * src/folder_item_prefs.h * src/foldersel.c * src/foldersel.h * src/folderutils.c * src/folderutils.h * src/folderview.c * src/folderview.h * src/grouplistdialog.c * src/grouplistdialog.h * src/headerview.c * src/html.c * src/html.h * src/image_viewer.c * src/image_viewer.h * src/imap.c * src/imap.h * src/imap_gtk.c * src/imap_gtk.h * src/import.h * src/importldif.c * src/importldif.h * src/importmutt.c * src/importmutt.h * src/importpine.c * src/importpine.h * src/inc.c * src/inc.h * src/jpilot.c * src/jpilot.h * src/ldapctrl.c * src/ldapctrl.h * src/ldaplocate.c * src/ldaplocate.h * src/ldapquery.c * src/ldapquery.h * src/ldapserver.c * src/ldapserver.h * src/ldaputil.c * src/ldaputil.h * src/ldif.c * src/ldif.h * src/main.c * src/main.h * src/mainwindow.c * src/mainwindow.h * src/manual.c * src/manual.h * src/mbox.c * src/mbox.h * src/message_search.c * src/message_search.h * src/messageview.c * src/messageview.h * src/mh.c * src/mh.h * src/mh_gtk.c * src/mh_gtk.h * src/mimeview.c * src/mimeview.h * src/msgcache.c * src/msgcache.h * src/mutt.c * src/mutt.h * src/news.c * src/news.h * src/news_gtk.c * src/news_gtk.h * src/partial_download.c * src/partial_download.h * src/pine.c * src/pine.h * src/pop.c * src/pop.h * src/prefs_account.c * src/prefs_account.h * src/prefs_actions.c * src/prefs_actions.h * src/prefs_common.c * src/prefs_common.h * src/prefs_compose_writing.c * src/prefs_compose_writing.h * src/prefs_customheader.c * src/prefs_customheader.h * src/prefs_display_header.c * src/prefs_display_header.h * src/prefs_filtering.c * src/prefs_filtering.h * src/prefs_filtering_action.c * src/prefs_filtering_action.h * src/prefs_folder_column.c * src/prefs_folder_column.h * src/prefs_folder_item.c * src/prefs_folder_item.h * src/prefs_fonts.c * src/prefs_fonts.h * src/prefs_gtk.c * src/prefs_gtk.h * src/prefs_image_viewer.c * src/prefs_image_viewer.h * src/prefs_matcher.c * src/prefs_matcher.h * src/prefs_message.c * src/prefs_msg_colors.c * src/prefs_msg_colors.h * src/prefs_other.c * src/prefs_quote.c * src/prefs_receive.c * src/prefs_send.c * src/prefs_spelling.c * src/prefs_spelling.h * src/prefs_summaries.c * src/prefs_summaries.h * src/prefs_summary_column.c * src/prefs_summary_column.h * src/prefs_template.c * src/prefs_template.h * src/prefs_themes.c * src/prefs_themes.h * src/prefs_toolbar.c * src/prefs_toolbar.h * src/prefs_wrapping.c * src/prefs_wrapping.h * src/privacy.c * src/privacy.h * src/procheader.c * src/procheader.h * src/procmime.c * src/procmime.h * src/procmsg.c * src/procmsg.h * src/quote_fmt.c * src/quote_fmt_parse.y * src/recv.c * src/recv.h * src/remotefolder.c * src/remotefolder.h * src/send_message.c * src/send_message.h * src/setup.c * src/setup.h * src/sourcewindow.c * src/sourcewindow.h * src/ssl_manager.c * src/ssl_manager.h * src/statusbar.c * src/statusbar.h * src/stock_pixmap.c * src/stock_pixmap.h * src/summary_search.c * src/summary_search.h * src/summaryview.c * src/summaryview.h * src/syldap.c * src/syldap.h * src/textview.c * src/textview.h * src/toolbar.c * src/toolbar.h * src/undo.c * src/undo.h * src/unmime.c * src/unmime.h * src/vcard.c * src/vcard.h * src/wizard.c * src/wizard.h * src/common/base64.c * src/common/base64.h * src/common/defs.h * src/common/hooks.c * src/common/hooks.h * src/common/log.c * src/common/log.h * src/common/mgutils.c * src/common/mgutils.h * src/common/nntp.c * src/common/nntp.h * src/common/passcrypt.c * src/common/passcrypt.h.in * src/common/plugin.c * src/common/plugin.h * src/common/prefs.c * src/common/prefs.h * src/common/progressindicator.c * src/common/progressindicator.h * src/common/quoted-printable.c * src/common/quoted-printable.h * src/common/session.c * src/common/session.h * src/common/smtp.c * src/common/smtp.h * src/common/socket.c * src/common/socket.h * src/common/ssl.c * src/common/ssl.h * src/common/ssl_certificate.c * src/common/ssl_certificate.h * src/common/stringtable.c * src/common/stringtable.h * src/common/sylpheed.c * src/common/sylpheed.h * src/common/template.c * src/common/template.h * src/common/timing.h * src/common/utils.c * src/common/utils.h * src/common/version.h.in * src/common/xml.c * src/common/xml.h * src/common/xmlprops.c * src/common/xmlprops.h * src/gtk/colorlabel.c * src/gtk/colorsel.c * src/gtk/colorsel.h * src/gtk/description_window.c * src/gtk/description_window.h * src/gtk/filesel.c * src/gtk/filesel.h * src/gtk/foldersort.c * src/gtk/foldersort.h * src/gtk/gtkutils.c * src/gtk/gtkutils.h * src/gtk/inputdialog.c * src/gtk/inputdialog.h * src/gtk/logwindow.c * src/gtk/logwindow.h * src/gtk/manage_window.c * src/gtk/manage_window.h * src/gtk/menu.c * src/gtk/menu.h * src/gtk/pluginwindow.c * src/gtk/pluginwindow.h * src/gtk/prefswindow.c * src/gtk/prefswindow.h * src/gtk/progressdialog.c * src/gtk/progressdialog.h * src/gtk/sslcertwindow.c * src/gtk/sslcertwindow.h * src/plugins/clamav/clamav_plugin.c * src/plugins/clamav/clamav_plugin.h * src/plugins/clamav/clamav_plugin_gtk.c * src/plugins/demo/demo.c * src/plugins/dillo_viewer/dillo_prefs.c * src/plugins/dillo_viewer/dillo_prefs.h * src/plugins/dillo_viewer/dillo_viewer.c * src/plugins/pgpcore/passphrase.c * src/plugins/pgpcore/passphrase.h * src/plugins/pgpcore/plugin.c * src/plugins/pgpcore/select-keys.c * src/plugins/pgpcore/select-keys.h * src/plugins/pgpcore/sgpgme.c * src/plugins/pgpcore/sgpgme.h * src/plugins/pgpinline/pgpinline.c * src/plugins/pgpinline/pgpinline.h * src/plugins/pgpinline/plugin.c * src/plugins/pgpmime/pgpmime.c * src/plugins/pgpmime/pgpmime.h * src/plugins/pgpmime/plugin.c * src/plugins/spamassassin/spamassassin.c * src/plugins/spamassassin/spamassassin.h * src/plugins/spamassassin/spamassassin_gtk.c * src/plugins/trayicon/trayicon.c update copyright header
690 lines
18 KiB
C
690 lines
18 KiB
C
/*
|
|
* Sylpheed -- a GTK+ based, lightweight, and fast e-mail client
|
|
* Copyright (C) 1999-2006 Hiroyuki Yamamoto & The Sylpheed Claws Team
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation; either version 2 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* 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, write to the Free Software
|
|
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
|
|
*/
|
|
|
|
#include "defs.h"
|
|
|
|
#include <glib.h>
|
|
#include <glib/gi18n.h>
|
|
|
|
#include <time.h>
|
|
|
|
#include "msgcache.h"
|
|
#include "utils.h"
|
|
#include "procmsg.h"
|
|
#include "codeconv.h"
|
|
|
|
#if G_BYTE_ORDER == G_BIG_ENDIAN
|
|
#define bswap_32(x) \
|
|
((((x) & 0xff000000) >> 24) | (((x) & 0x00ff0000) >> 8) | \
|
|
(((x) & 0x0000ff00) << 8) | (((x) & 0x000000ff) << 24))
|
|
#else
|
|
#define bswap_32(x) (x)
|
|
#endif
|
|
|
|
static gboolean swapping = TRUE;
|
|
|
|
typedef enum
|
|
{
|
|
DATA_READ,
|
|
DATA_WRITE,
|
|
DATA_APPEND
|
|
} DataOpenMode;
|
|
|
|
struct _MsgCache {
|
|
GHashTable *msgnum_table;
|
|
GHashTable *msgid_table;
|
|
guint memusage;
|
|
time_t last_access;
|
|
};
|
|
|
|
typedef struct _StringConverter StringConverter;
|
|
struct _StringConverter {
|
|
gchar *(*convert) (StringConverter *converter, gchar *srcstr);
|
|
void (*free) (StringConverter *converter);
|
|
};
|
|
|
|
typedef struct _StrdupConverter StrdupConverter;
|
|
struct _StrdupConverter {
|
|
StringConverter converter;
|
|
};
|
|
|
|
typedef struct _CharsetConverter CharsetConverter;
|
|
struct _CharsetConverter {
|
|
StringConverter converter;
|
|
|
|
gchar *srccharset;
|
|
gchar *dstcharset;
|
|
};
|
|
|
|
MsgCache *msgcache_new(void)
|
|
{
|
|
MsgCache *cache;
|
|
|
|
cache = g_new0(MsgCache, 1),
|
|
cache->msgnum_table = g_hash_table_new(g_int_hash, g_int_equal);
|
|
cache->msgid_table = g_hash_table_new(g_str_hash, g_str_equal);
|
|
cache->last_access = time(NULL);
|
|
|
|
return cache;
|
|
}
|
|
|
|
static gboolean msgcache_msginfo_free_func(gpointer num, gpointer msginfo, gpointer user_data)
|
|
{
|
|
procmsg_msginfo_free((MsgInfo *)msginfo);
|
|
return TRUE;
|
|
}
|
|
|
|
void msgcache_destroy(MsgCache *cache)
|
|
{
|
|
g_return_if_fail(cache != NULL);
|
|
|
|
g_hash_table_foreach_remove(cache->msgnum_table, msgcache_msginfo_free_func, NULL);
|
|
g_hash_table_destroy(cache->msgid_table);
|
|
g_hash_table_destroy(cache->msgnum_table);
|
|
g_free(cache);
|
|
}
|
|
|
|
void msgcache_add_msg(MsgCache *cache, MsgInfo *msginfo)
|
|
{
|
|
MsgInfo *newmsginfo;
|
|
|
|
g_return_if_fail(cache != NULL);
|
|
g_return_if_fail(msginfo != NULL);
|
|
|
|
newmsginfo = procmsg_msginfo_new_ref(msginfo);
|
|
g_hash_table_insert(cache->msgnum_table, &newmsginfo->msgnum, newmsginfo);
|
|
if(newmsginfo->msgid != NULL)
|
|
g_hash_table_insert(cache->msgid_table, newmsginfo->msgid, newmsginfo);
|
|
cache->memusage += procmsg_msginfo_memusage(msginfo);
|
|
cache->last_access = time(NULL);
|
|
|
|
debug_print("Cache size: %d messages, %d bytes\n", g_hash_table_size(cache->msgnum_table), cache->memusage);
|
|
}
|
|
|
|
void msgcache_remove_msg(MsgCache *cache, guint msgnum)
|
|
{
|
|
MsgInfo *msginfo;
|
|
|
|
g_return_if_fail(cache != NULL);
|
|
g_return_if_fail(msgnum > 0);
|
|
|
|
msginfo = (MsgInfo *) g_hash_table_lookup(cache->msgnum_table, &msgnum);
|
|
if(!msginfo)
|
|
return;
|
|
|
|
cache->memusage -= procmsg_msginfo_memusage(msginfo);
|
|
if(msginfo->msgid)
|
|
g_hash_table_remove(cache->msgid_table, msginfo->msgid);
|
|
g_hash_table_remove(cache->msgnum_table, &msginfo->msgnum);
|
|
procmsg_msginfo_free(msginfo);
|
|
cache->last_access = time(NULL);
|
|
|
|
debug_print("Cache size: %d messages, %d byte\n", g_hash_table_size(cache->msgnum_table), cache->memusage);
|
|
}
|
|
|
|
void msgcache_update_msg(MsgCache *cache, MsgInfo *msginfo)
|
|
{
|
|
MsgInfo *oldmsginfo, *newmsginfo;
|
|
|
|
g_return_if_fail(cache != NULL);
|
|
g_return_if_fail(msginfo != NULL);
|
|
|
|
oldmsginfo = g_hash_table_lookup(cache->msgnum_table, &msginfo->msgnum);
|
|
if(oldmsginfo && oldmsginfo->msgid)
|
|
g_hash_table_remove(cache->msgid_table, oldmsginfo->msgid);
|
|
if (oldmsginfo) {
|
|
g_hash_table_remove(cache->msgnum_table, &oldmsginfo->msgnum);
|
|
cache->memusage -= procmsg_msginfo_memusage(oldmsginfo);
|
|
procmsg_msginfo_free(oldmsginfo);
|
|
}
|
|
|
|
newmsginfo = procmsg_msginfo_new_ref(msginfo);
|
|
g_hash_table_insert(cache->msgnum_table, &newmsginfo->msgnum, newmsginfo);
|
|
if(newmsginfo->msgid)
|
|
g_hash_table_insert(cache->msgid_table, newmsginfo->msgid, newmsginfo);
|
|
cache->memusage += procmsg_msginfo_memusage(newmsginfo);
|
|
cache->last_access = time(NULL);
|
|
|
|
debug_print("Cache size: %d messages, %d byte\n", g_hash_table_size(cache->msgnum_table), cache->memusage);
|
|
|
|
return;
|
|
}
|
|
|
|
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, total_len) \
|
|
{ \
|
|
if ((tmp_len = msgcache_read_cache_data_str(fp, &data, conv)) < 0) { \
|
|
procmsg_msginfo_free(msginfo); \
|
|
error = TRUE; \
|
|
break; \
|
|
} \
|
|
total_len += tmp_len; \
|
|
}
|
|
|
|
#define READ_CACHE_DATA_INT(n, fp) \
|
|
{ \
|
|
guint32 idata; \
|
|
size_t ni; \
|
|
\
|
|
if ((ni = fread(&idata, sizeof(idata), 1, fp)) != 1) { \
|
|
g_warning("read_int: Cache data corrupted, read %d of %d at " \
|
|
"offset %ld\n", ni, sizeof(idata), ftell(fp)); \
|
|
procmsg_msginfo_free(msginfo); \
|
|
error = TRUE; \
|
|
break; \
|
|
} else \
|
|
n = swapping ? bswap_32(idata) : (idata);\
|
|
}
|
|
|
|
#define WRITE_CACHE_DATA_INT(n, fp) \
|
|
{ \
|
|
guint32 idata; \
|
|
\
|
|
idata = (guint32)bswap_32(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, guint version,
|
|
DataOpenMode mode,
|
|
gchar *buf, size_t buf_size)
|
|
{
|
|
FILE *fp;
|
|
gint32 data_ver;
|
|
|
|
g_return_val_if_fail(file != NULL, NULL);
|
|
|
|
if (mode == DATA_WRITE) {
|
|
if ((fp = g_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 = g_fopen(file, "rb")) == NULL)
|
|
debug_print("Mark/Cache file '%s' not found\n", file);
|
|
else {
|
|
if (buf && buf_size > 0)
|
|
setvbuf(fp, buf, _IOFBF, buf_size);
|
|
if (fread(&data_ver, sizeof(data_ver), 1, fp) != 1 ||
|
|
version != bswap_32(data_ver)) {
|
|
g_message("%s: Mark/Cache version is different (%u != %u).\n",
|
|
file, bswap_32(data_ver), version);
|
|
fclose(fp);
|
|
fp = NULL;
|
|
}
|
|
data_ver = bswap_32(data_ver);
|
|
}
|
|
|
|
if (mode == DATA_READ)
|
|
return fp;
|
|
|
|
if (fp) {
|
|
/* reopen with append mode */
|
|
fclose(fp);
|
|
if ((fp = g_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;
|
|
}
|
|
|
|
static gint msgcache_read_cache_data_str(FILE *fp, gchar **str,
|
|
StringConverter *conv)
|
|
{
|
|
gchar *tmpstr = NULL;
|
|
size_t ni;
|
|
guint32 len;
|
|
|
|
*str = NULL;
|
|
if (!swapping) {
|
|
if ((ni = fread(&len, sizeof(len), 1, fp) != 1) ||
|
|
len > G_MAXINT) {
|
|
g_warning("read_data_str: Cache data (len) corrupted, read %d "
|
|
"of %d bytes at offset %ld\n", ni, sizeof(len),
|
|
ftell(fp));
|
|
return -1;
|
|
}
|
|
} else {
|
|
if ((ni = fread(&len, sizeof(len), 1, fp) != 1) ||
|
|
bswap_32(len) > G_MAXINT) {
|
|
g_warning("read_data_str: Cache data (len) corrupted, read %d "
|
|
"of %d bytes at offset %ld\n", ni, sizeof(len),
|
|
ftell(fp));
|
|
return -1;
|
|
}
|
|
len = bswap_32(len);
|
|
}
|
|
|
|
if (len == 0)
|
|
return 0;
|
|
|
|
tmpstr = g_malloc(len + 1);
|
|
|
|
if ((ni = fread(tmpstr, 1, len, fp)) != len) {
|
|
g_warning("read_data_str: Cache data corrupted, read %d of %d "
|
|
"bytes at offset %ld\n",
|
|
ni, len, ftell(fp));
|
|
g_free(tmpstr);
|
|
return -1;
|
|
}
|
|
tmpstr[len] = 0;
|
|
|
|
if (conv != NULL) {
|
|
*str = conv->convert(conv, tmpstr);
|
|
g_free(tmpstr);
|
|
} else
|
|
*str = tmpstr;
|
|
|
|
return len;
|
|
}
|
|
|
|
gchar *strconv_strdup_convert(StringConverter *conv, gchar *srcstr)
|
|
{
|
|
return g_strdup(srcstr);
|
|
}
|
|
|
|
gchar *strconv_charset_convert(StringConverter *conv, gchar *srcstr)
|
|
{
|
|
CharsetConverter *charsetconv = (CharsetConverter *) conv;
|
|
|
|
return conv_codeset_strdup(srcstr, charsetconv->srccharset, charsetconv->dstcharset);
|
|
}
|
|
|
|
void strconv_charset_free(StringConverter *conv)
|
|
{
|
|
CharsetConverter *charsetconv = (CharsetConverter *) conv;
|
|
|
|
g_free(charsetconv->srccharset);
|
|
g_free(charsetconv->dstcharset);
|
|
}
|
|
|
|
MsgCache *msgcache_read_cache(FolderItem *item, const gchar *cache_file)
|
|
{
|
|
MsgCache *cache;
|
|
FILE *fp;
|
|
MsgInfo *msginfo;
|
|
MsgTmpFlags tmp_flags = 0;
|
|
gchar file_buf[BUFFSIZE];
|
|
guint32 num;
|
|
guint refnum;
|
|
gboolean error = FALSE;
|
|
StringConverter *conv = NULL;
|
|
gchar *srccharset = NULL;
|
|
const gchar *dstcharset = NULL;
|
|
gchar *ref = NULL;
|
|
guint memusage = 0;
|
|
guint tmp_len = 0;
|
|
#if 0
|
|
struct timeval start;
|
|
struct timeval end;
|
|
struct timeval diff;
|
|
gettimeofday(&start, NULL);
|
|
#endif
|
|
g_return_val_if_fail(cache_file != NULL, NULL);
|
|
g_return_val_if_fail(item != NULL, NULL);
|
|
|
|
swapping = TRUE;
|
|
|
|
/* In case we can't open the mark file with MARK_VERSION, check if we can open it with the
|
|
* swapped MARK_VERSION. As msgcache_open_data_file swaps it too, if this succeeds,
|
|
* it means it's the old version (not little-endian) on a big-endian machine. The code has
|
|
* no effect on x86 as their file doesn't change. */
|
|
|
|
if ((fp = msgcache_open_data_file
|
|
(cache_file, CACHE_VERSION, DATA_READ, file_buf, sizeof(file_buf))) == NULL) {
|
|
if ((fp = msgcache_open_data_file
|
|
(cache_file, bswap_32(CACHE_VERSION), DATA_READ, file_buf, sizeof(file_buf))) == NULL)
|
|
return NULL;
|
|
else
|
|
swapping = FALSE;
|
|
}
|
|
|
|
debug_print("\tReading %sswapped message cache from %s...\n", swapping?"":"un", cache_file);
|
|
|
|
if (folder_has_parent_of_type(item, F_QUEUE)) {
|
|
tmp_flags |= MSG_QUEUED;
|
|
} else if (folder_has_parent_of_type(item, F_DRAFT)) {
|
|
tmp_flags |= MSG_DRAFT;
|
|
}
|
|
|
|
if (msgcache_read_cache_data_str(fp, &srccharset, NULL) < 0)
|
|
return NULL;
|
|
dstcharset = CS_UTF_8;
|
|
if (srccharset == NULL || dstcharset == NULL) {
|
|
conv = NULL;
|
|
} else if (strcmp(srccharset, dstcharset) == 0) {
|
|
debug_print("using Noop Converter\n");
|
|
|
|
conv = NULL;
|
|
} else {
|
|
CharsetConverter *charsetconv;
|
|
|
|
debug_print("using CharsetConverter\n");
|
|
|
|
charsetconv = g_new0(CharsetConverter, 1);
|
|
charsetconv->converter.convert = strconv_charset_convert;
|
|
charsetconv->converter.free = strconv_charset_free;
|
|
charsetconv->srccharset = g_strdup(srccharset);
|
|
charsetconv->dstcharset = g_strdup(dstcharset);
|
|
|
|
conv = (StringConverter *) charsetconv;
|
|
}
|
|
g_free(srccharset);
|
|
|
|
cache = msgcache_new();
|
|
|
|
while (fread(&num, sizeof(num), 1, fp) == 1) {
|
|
if (swapping)
|
|
num = bswap_32(num);
|
|
|
|
msginfo = procmsg_msginfo_new();
|
|
msginfo->msgnum = num;
|
|
memusage += sizeof(MsgInfo);
|
|
|
|
READ_CACHE_DATA_INT(msginfo->size, fp);
|
|
READ_CACHE_DATA_INT(msginfo->mtime, fp);
|
|
READ_CACHE_DATA_INT(msginfo->date_t, fp);
|
|
READ_CACHE_DATA_INT(msginfo->flags.tmp_flags, fp);
|
|
|
|
READ_CACHE_DATA(msginfo->fromname, fp, memusage);
|
|
|
|
READ_CACHE_DATA(msginfo->date, fp, memusage);
|
|
READ_CACHE_DATA(msginfo->from, fp, memusage);
|
|
READ_CACHE_DATA(msginfo->to, fp, memusage);
|
|
READ_CACHE_DATA(msginfo->cc, fp, memusage);
|
|
READ_CACHE_DATA(msginfo->newsgroups, fp, memusage);
|
|
READ_CACHE_DATA(msginfo->subject, fp, memusage);
|
|
READ_CACHE_DATA(msginfo->msgid, fp, memusage);
|
|
READ_CACHE_DATA(msginfo->inreplyto, fp, memusage);
|
|
READ_CACHE_DATA(msginfo->xref, fp, memusage);
|
|
|
|
READ_CACHE_DATA_INT(msginfo->planned_download, fp);
|
|
READ_CACHE_DATA_INT(msginfo->total_size, fp);
|
|
READ_CACHE_DATA_INT(refnum, fp);
|
|
|
|
for (; refnum != 0; refnum--) {
|
|
ref = NULL;
|
|
|
|
READ_CACHE_DATA(ref, fp, memusage);
|
|
|
|
if (ref && strlen(ref))
|
|
msginfo->references =
|
|
g_slist_prepend(msginfo->references, ref);
|
|
}
|
|
if (msginfo->references)
|
|
msginfo->references =
|
|
g_slist_reverse(msginfo->references);
|
|
|
|
msginfo->folder = item;
|
|
msginfo->flags.tmp_flags |= tmp_flags;
|
|
|
|
g_hash_table_insert(cache->msgnum_table, &msginfo->msgnum, msginfo);
|
|
if(msginfo->msgid)
|
|
g_hash_table_insert(cache->msgid_table, msginfo->msgid, msginfo);
|
|
}
|
|
fclose(fp);
|
|
|
|
if (conv != NULL) {
|
|
if (conv->free != NULL)
|
|
conv->free(conv);
|
|
g_free(conv);
|
|
}
|
|
|
|
if(error) {
|
|
msgcache_destroy(cache);
|
|
return NULL;
|
|
}
|
|
|
|
cache->last_access = time(NULL);
|
|
cache->memusage = memusage;
|
|
|
|
debug_print("done. (%d items read)\n", g_hash_table_size(cache->msgnum_table));
|
|
debug_print("Cache size: %d messages, %d byte\n", g_hash_table_size(cache->msgnum_table), cache->memusage);
|
|
#if 0
|
|
gettimeofday(&end, NULL);
|
|
timersub(&end, &start, &diff);
|
|
printf("spent %d seconds %d usages %d;%d\n", diff.tv_sec, diff.tv_usec, cache->memusage, memusage);
|
|
#endif
|
|
return cache;
|
|
}
|
|
|
|
void msgcache_read_mark(MsgCache *cache, const gchar *mark_file)
|
|
{
|
|
FILE *fp;
|
|
MsgInfo *msginfo;
|
|
MsgPermFlags perm_flags;
|
|
guint32 num;
|
|
|
|
swapping = TRUE;
|
|
|
|
/* In case we can't open the mark file with MARK_VERSION, check if we can open it with the
|
|
* swapped MARK_VERSION. As msgcache_open_data_file swaps it too, if this succeeds,
|
|
* it means it's the old version (not little-endian) on a big-endian machine. The code has
|
|
* no effect on x86 as their file doesn't change. */
|
|
|
|
if ((fp = msgcache_open_data_file(mark_file, MARK_VERSION, DATA_READ, NULL, 0)) == NULL) {
|
|
/* see if it isn't swapped ? */
|
|
if ((fp = msgcache_open_data_file(mark_file, bswap_32(MARK_VERSION), DATA_READ, NULL, 0)) == NULL)
|
|
return;
|
|
else
|
|
swapping = FALSE; /* yay */
|
|
}
|
|
debug_print("reading %sswapped mark file.\n", swapping?"":"un");
|
|
while (fread(&num, sizeof(num), 1, fp) == 1) {
|
|
if (swapping)
|
|
num = bswap_32(num);
|
|
if (fread(&perm_flags, sizeof(perm_flags), 1, fp) != 1) break;
|
|
if (swapping)
|
|
perm_flags = bswap_32(perm_flags);
|
|
msginfo = g_hash_table_lookup(cache->msgnum_table, &num);
|
|
if(msginfo) {
|
|
msginfo->flags.perm_flags = perm_flags;
|
|
}
|
|
}
|
|
fclose(fp);
|
|
}
|
|
|
|
void msgcache_write_cache(MsgInfo *msginfo, FILE *fp)
|
|
{
|
|
MsgTmpFlags flags = msginfo->flags.tmp_flags & MSG_CACHED_FLAG_MASK;
|
|
GSList *cur;
|
|
|
|
WRITE_CACHE_DATA_INT(msginfo->msgnum, fp);
|
|
WRITE_CACHE_DATA_INT(msginfo->size, fp);
|
|
WRITE_CACHE_DATA_INT(msginfo->mtime, fp);
|
|
WRITE_CACHE_DATA_INT(msginfo->date_t, fp);
|
|
WRITE_CACHE_DATA_INT(flags, fp);
|
|
|
|
WRITE_CACHE_DATA(msginfo->fromname, fp);
|
|
|
|
WRITE_CACHE_DATA(msginfo->date, fp);
|
|
WRITE_CACHE_DATA(msginfo->from, fp);
|
|
WRITE_CACHE_DATA(msginfo->to, fp);
|
|
WRITE_CACHE_DATA(msginfo->cc, fp);
|
|
WRITE_CACHE_DATA(msginfo->newsgroups, fp);
|
|
WRITE_CACHE_DATA(msginfo->subject, fp);
|
|
WRITE_CACHE_DATA(msginfo->msgid, fp);
|
|
WRITE_CACHE_DATA(msginfo->inreplyto, fp);
|
|
WRITE_CACHE_DATA(msginfo->xref, fp);
|
|
WRITE_CACHE_DATA_INT(msginfo->planned_download, fp);
|
|
WRITE_CACHE_DATA_INT(msginfo->total_size, fp);
|
|
|
|
WRITE_CACHE_DATA_INT(g_slist_length(msginfo->references), fp);
|
|
|
|
for (cur = msginfo->references; cur != NULL; cur = cur->next) {
|
|
WRITE_CACHE_DATA((gchar *)cur->data, fp);
|
|
}
|
|
}
|
|
|
|
static void msgcache_write_flags(MsgInfo *msginfo, FILE *fp)
|
|
{
|
|
MsgPermFlags flags = msginfo->flags.perm_flags;
|
|
|
|
WRITE_CACHE_DATA_INT(msginfo->msgnum, fp);
|
|
WRITE_CACHE_DATA_INT(flags, fp);
|
|
}
|
|
|
|
struct write_fps
|
|
{
|
|
FILE *cache_fp;
|
|
FILE *mark_fp;
|
|
};
|
|
|
|
static void msgcache_write_func(gpointer key, gpointer value, gpointer user_data)
|
|
{
|
|
MsgInfo *msginfo;
|
|
struct write_fps *write_fps;
|
|
|
|
msginfo = (MsgInfo *)value;
|
|
write_fps = user_data;
|
|
|
|
msgcache_write_cache(msginfo, write_fps->cache_fp);
|
|
msgcache_write_flags(msginfo, write_fps->mark_fp);
|
|
}
|
|
|
|
gint msgcache_write(const gchar *cache_file, const gchar *mark_file, MsgCache *cache)
|
|
{
|
|
struct write_fps write_fps;
|
|
|
|
g_return_val_if_fail(cache_file != NULL, -1);
|
|
g_return_val_if_fail(mark_file != NULL, -1);
|
|
g_return_val_if_fail(cache != NULL, -1);
|
|
|
|
write_fps.cache_fp = msgcache_open_data_file(cache_file, CACHE_VERSION,
|
|
DATA_WRITE, NULL, 0);
|
|
if (write_fps.cache_fp == NULL)
|
|
return -1;
|
|
|
|
WRITE_CACHE_DATA(CS_UTF_8, write_fps.cache_fp);
|
|
|
|
write_fps.mark_fp = msgcache_open_data_file(mark_file, MARK_VERSION,
|
|
DATA_WRITE, NULL, 0);
|
|
if (write_fps.mark_fp == NULL) {
|
|
fclose(write_fps.cache_fp);
|
|
return -1;
|
|
}
|
|
|
|
debug_print("\tWriting message cache to %s and %s...\n", cache_file, mark_file);
|
|
|
|
if (change_file_mode_rw(write_fps.cache_fp, cache_file) < 0)
|
|
FILE_OP_ERROR(cache_file, "chmod");
|
|
|
|
g_hash_table_foreach(cache->msgnum_table, msgcache_write_func, (gpointer)&write_fps);
|
|
|
|
fclose(write_fps.cache_fp);
|
|
fclose(write_fps.mark_fp);
|
|
|
|
cache->last_access = time(NULL);
|
|
|
|
debug_print("done.\n");
|
|
return 0;
|
|
}
|
|
|