New hooklist for rendering avatars and some utils
[claws.git] / src / main.c
index df8a6d40a47406218d51c62b2e7fdac76ee82681..70f8da4b5bf460824314abfacf4b9bb36a9832e6 100644 (file)
@@ -1,6 +1,6 @@
 /*
  * Sylpheed -- a GTK+ based, lightweight, and fast e-mail client
- * Copyright (C) 1999-2012 Hiroyuki Yamamoto and the Claws Mail team
+ * Copyright (C) 1999-2013 Hiroyuki Yamamoto and the Claws Mail 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
@@ -19,6 +19,7 @@
 
 #ifdef HAVE_CONFIG_H
 #  include "config.h"
+#include "claws-features.h"
 #endif
 
 #include "defs.h"
 #include <X11/SM/SMlib.h>
 #endif
 
+#if HAVE_FLOCK
+#include <sys/file.h>
+#endif
+
+#include "file_checker.h"
 #include "wizard.h"
 #ifdef HAVE_STARTUP_NOTIFICATION
 # define SN_API_NOT_YET_FROZEN
@@ -89,6 +95,9 @@
 #include "account.h"
 #include "procmsg.h"
 #include "inc.h"
+#include "imap.h"
+#include "send_message.h"
+#include "md5.h"
 #include "import.h"
 #include "manage_window.h"
 #include "alertpanel.h"
 #endif
 #include "compose.h"
 #include "folder.h"
+#include "folder_item_prefs.h"
 #include "setup.h"
 #include "utils.h"
 #include "gtkutils.h"
 #include "hooks.h"
 #include "menu.h"
 #include "quicksearch.h"
+#include "advsearch.h"
+#include "avatars.h"
 
 #ifdef HAVE_LIBETPAN
 #include "imap-thread.h"
 
 #include "timing.h"
 
-#ifdef MAEMO
-#ifdef CHINOOK
-#include <hildon/hildon-banner.h>
-#include <hildon/hildon-program.h>
-#else
-#include <hildon-widgets/hildon-banner.h>
-#include <hildon-widgets/hildon-program.h>
-#endif
-#include <libosso.h>
-#include <libgnomevfs/gnome-vfs-volume.h>
-#include <libgnomevfs/gnome-vfs-volume-monitor.h>
-#include <libgnomevfs/gnome-vfs-utils.h>
-
-#define OSSO_NAME    "claws_mail"
-#define OSSO_SERVICE "com.nokia."OSSO_NAME
-#define OSSO_OBJECT  "/com/nokia/"OSSO_NAME
-#define OSSO_IFACE   "com.nokia."OSSO_NAME
-
-typedef struct _AppData AppData;
-struct _AppData {
-    HildonProgram *program;
-    HildonWindow *window;
-    osso_context_t *osso_context;
-};
-
-static GnomeVFSVolumeMonitor *volmon;
-#endif
-
 #ifdef HAVE_NETWORKMANAGER_SUPPORT
 /* Went offline due to NetworkManager */
 static gboolean went_offline_nm;
@@ -175,10 +159,6 @@ static DBusGProxy *awn_proxy = NULL;
 gchar *prog_version;
 gchar *argv0;
 
-#ifdef MAEMO
-HildonProgram *hildon_program;
-#endif
-
 #ifdef HAVE_STARTUP_NOTIFICATION
 static SnLauncheeContext *sn_context = NULL;
 static SnDisplay *sn_display = NULL;
@@ -197,6 +177,8 @@ typedef enum
 static struct RemoteCmd {
        gboolean receive;
        gboolean receive_all;
+       gboolean cancel_receiving;
+       gboolean cancel_sending;
        gboolean compose;
        const gchar *compose_mailto;
        GList *attach_files;
@@ -219,6 +201,7 @@ static struct RemoteCmd {
        gboolean subscribe;
        const gchar *subscribe_uri;
        const gchar *target;
+       gboolean debug;
 } cmd;
 
 SessionStats session_stats;
@@ -268,51 +251,6 @@ static void networkmanager_state_change_cb(DBusGProxy *proxy, gchar *dev,
 
 static MainWindow *static_mainwindow;
 
-#ifdef MAEMO
-static osso_context_t *static_osso_context;
-
-void exit_event_handler(gboolean die_now, gpointer data)
-{
-       AppData *appdata;
-       appdata = (AppData *) data;
-       /* Do whatever application needs to do before exiting */
-       exit_claws(static_mainwindow);
-       hildon_banner_show_information(GTK_WIDGET(appdata->window), NULL,
-                                   _("Exiting..."));
-
-}
-
-/* Callback for hardware D-BUS events */
-void hw_event_handler(osso_hw_state_t *state, gpointer data)
-{
-       AppData *appdata;
-       appdata = (AppData *) data;
-
-       if (state->shutdown_ind) {
-               exit_claws(static_mainwindow);
-               hildon_banner_show_information(GTK_WIDGET(appdata->window), NULL,
-                       _("Exiting..."));
-       }
-}
-
-/* Callback for normal D-BUS messages */
-gint dbus_req_handler(const gchar * interface, const gchar * method,
-                      GArray * arguments, gpointer data,
-                      osso_rpc_t * retval)
-{
-    AppData *appdata;
-    appdata = (AppData *) data;
-
-    if (!strcmp(method, "top_application")) {
-           osso_rpc_free_val(retval);
-           return OSSO_OK;
-    }
-    osso_system_note_infoprint(appdata->osso_context, method, retval);
-    osso_rpc_free_val(retval);
-
-    return OSSO_OK;
-}
-#endif
 static gboolean emergency_exit = FALSE;
 
 #ifdef HAVE_STARTUP_NOTIFICATION
@@ -607,7 +545,7 @@ static gboolean sc_process_ice_messages (GIOChannel   *source,
        if (status == IceProcessMessagesIOError) {
                IcePointer context = IceGetConnectionContext (connection);
 
-               if (context && GTK_IS_OBJECT (context)) {
+               if (context && G_IS_OBJECT(context)) {
                guint disconnect_id = g_signal_lookup ("disconnect", G_OBJECT_TYPE (context));
 
                if (disconnect_id > 0)
@@ -723,35 +661,6 @@ void main_set_show_at_startup(gboolean show)
        show_at_startup = show;
 }
 
-#ifdef MAEMO
-static void main_vol_mount_cb(GnomeVFSVolumeMonitor *vfs, GnomeVFSVolume *vol, MainWindow *mainwin)
-{
-       gchar *uri = gnome_vfs_volume_get_activation_uri (vol);
-       gchar *mount_path = uri?gnome_vfs_get_local_path_from_uri (uri):NULL;
-       g_free (uri);
-       if (mount_path) {
-               if(!strcmp(mount_path, prefs_common.data_root)) {
-                       gtk_widget_set_sensitive(mainwin->window, TRUE);
-                       inc_unlock();
-               }
-       }
-       g_free(mount_path);
-}
-static void main_vol_unmount_cb(GnomeVFSVolumeMonitor *vfs, GnomeVFSVolume *vol, MainWindow *mainwin)
-{
-       gchar *uri = gnome_vfs_volume_get_activation_uri (vol);
-       gchar *mount_path = uri?gnome_vfs_get_local_path_from_uri (uri):NULL;
-       g_free (uri);
-       if (mount_path) {
-               if(!strcmp(mount_path, prefs_common.data_root)) {
-                       gtk_widget_set_sensitive(mainwin->window, FALSE);
-                       inc_lock();
-               }
-       }
-       g_free(mount_path);
-}
-#endif
-
 #ifdef G_OS_WIN32
 static FILE* win32_debug_fp=NULL;
 static guint win32_log_handler_app_id;
@@ -761,7 +670,7 @@ static guint win32_log_handler_gtk_id;
 static void win32_print_stdout(const gchar *string)
 {
        if (win32_debug_fp) {
-               fprintf(win32_debug_fp, string);
+               fprintf(win32_debug_fp, "%s", string);
                fflush(win32_debug_fp);
        }
 }
@@ -769,7 +678,7 @@ static void win32_print_stdout(const gchar *string)
 static void win32_print_stderr(const gchar *string)
 {
        if (win32_debug_fp) {
-               fprintf(win32_debug_fp, string);
+               fprintf(win32_debug_fp, "%s", string);
                fflush(win32_debug_fp);
        }
 }
@@ -883,21 +792,21 @@ static void main_dump_features_list(gboolean show_debug_only)
 #endif
 #if USE_ENCHANT
        if (show_debug_only)
-               debug_print(" aspell\n");
+               debug_print(" Enchant\n");
        else
-               g_print(" aspell\n");
+               g_print(" Enchant\n");
 #endif
 #if USE_GNUTLS
        if (show_debug_only)
-               debug_print(" gnutls\n");
+               debug_print(" GnuTLS\n");
        else
-               g_print(" gnutls\n");
+               g_print(" GnuTLS\n");
 #endif
 #if INET6
        if (show_debug_only)
-               debug_print(" ipv6\n");
+               debug_print(" IPv6\n");
        else
-               g_print(" ipv6\n");
+               g_print(" IPv6\n");
 #endif
 #if HAVE_ICONV
        if (show_debug_only)
@@ -907,15 +816,15 @@ static void main_dump_features_list(gboolean show_debug_only)
 #endif
 #if USE_JPILOT
        if (show_debug_only)
-               debug_print(" jpilot\n");
+               debug_print(" JPilot\n");
        else
-               g_print(" jpilot\n");
+               g_print(" JPilot\n");
 #endif
 #if USE_LDAP
        if (show_debug_only)
-               debug_print(" ldap\n");
+               debug_print(" LDAP\n");
        else
-               g_print(" ldap\n");
+               g_print(" LDAP\n");
 #endif
 #if HAVE_LIBETPAN
        if (show_debug_only)
@@ -925,9 +834,9 @@ static void main_dump_features_list(gboolean show_debug_only)
 #endif
 #if HAVE_LIBSM
        if (show_debug_only)
-               debug_print(" libsm\n");
+               debug_print(" libSM\n");
        else
-               g_print(" libsm\n");
+               g_print(" libSM\n");
 #endif
 #if HAVE_NETWORKMANAGER_SUPPORT
        if (show_debug_only)
@@ -1049,10 +958,6 @@ static void reset_statistics(void)
                
 int main(int argc, char *argv[])
 {
-#ifdef MAEMO
-       osso_context_t *osso_context;
-       osso_return_t result;
-#endif
 #ifdef HAVE_DBUS_GLIB
        DBusGConnection *connection;
        GError *error;
@@ -1068,9 +973,10 @@ int main(int argc, char *argv[])
        gint num_folder_class = 0;
        gboolean asked_for_migration = FALSE;
        gboolean start_done = TRUE;
-       GtkUIManager *gui_manager = NULL;
        GSList *plug_list = NULL;
        gboolean never_ran = FALSE;
+       gboolean mainwin_shown = FALSE;
+
        START_TIMING("startup");
 
        sc_starting = TRUE;
@@ -1085,18 +991,31 @@ int main(int argc, char *argv[])
                return 0;
        }
 
-       main_dump_features_list(TRUE);
-
        prog_version = PROG_VERSION;
        argv0 = g_strdup(argv[0]);
 
        parse_cmd_opt(argc, argv);
 
+       sock_init();
+
+       /* check and create unix domain socket for remote operation */
+       lock_socket = prohibit_duplicate_launch();
+       if (lock_socket < 0) {
+#ifdef HAVE_STARTUP_NOTIFICATION
+               if(gtk_init_check(&argc, &argv))
+                       startup_notification_complete(TRUE);
+#endif
+               return 0;
+       }
+
+       main_dump_features_list(TRUE);
        prefs_prepare_cache();
 
 #ifdef CRASH_DIALOG
        if (cmd.crash) {
+#if !GTK_CHECK_VERSION(3, 0, 0)
                gtk_set_locale();
+#endif
                gtk_init(&argc, &argv);
                crash_main(cmd.crash_params);
 #ifdef G_OS_WIN32
@@ -1110,20 +1029,11 @@ int main(int argc, char *argv[])
 #if (defined linux && defined SIGIO)
        install_memory_sighandler();
 #endif
-       sock_init();
-
-       /* check and create unix domain socket for remote operation */
-       lock_socket = prohibit_duplicate_launch();
-       if (lock_socket < 0) {
-#ifdef HAVE_STARTUP_NOTIFICATION
-               if(gtk_init_check(&argc, &argv))
-                       startup_notification_complete(TRUE);
-#endif
-               return 0;
-       }
 
        if (cmd.status || cmd.status_full || cmd.search ||
-               cmd.statistics || cmd.reset_statistics) {
+               cmd.statistics || cmd.reset_statistics || 
+               cmd.cancel_receiving || cmd.cancel_sending ||
+               cmd.debug) {
                puts("0 Claws Mail not running.");
                lock_socket_remove();
                return 0;
@@ -1131,12 +1041,16 @@ int main(int argc, char *argv[])
        
        if (cmd.exit)
                return 0;
+#if !GLIB_CHECK_VERSION(2,32,0)
        if (!g_thread_supported())
                g_thread_init(NULL);
+#endif
 
        reset_statistics();
        
+#if !GTK_CHECK_VERSION(3, 0, 0)
        gtk_set_locale();
+#endif
        gtk_init(&argc, &argv);
 
 #ifdef G_OS_WIN32
@@ -1182,20 +1096,13 @@ int main(int argc, char *argv[])
        }
 #endif
 
-
-#ifdef MAEMO
-       osso_context = osso_initialize(OSSO_SERVICE, "2.8.1", TRUE, NULL);
-       if (osso_context == NULL) {
-               return OSSO_ERROR;
-       }
-       hildon_program = HILDON_PROGRAM(hildon_program_get_instance());
-       static_osso_context = osso_context;
-#endif 
+#if !GTK_CHECK_VERSION(3, 0, 0)
        gtk_widget_set_default_colormap(
                gdk_screen_get_system_colormap(
                        gdk_screen_get_default()));
+#endif
 
-       gui_manager = gtkut_create_ui_manager();
+       gtkut_create_ui_manager();
 
        /* Create container for all the menus we will be adding */
        MENUITEM_ADDUI("/", "Menus", NULL, GTK_UI_MANAGER_MENUBAR);
@@ -1329,11 +1236,21 @@ int main(int argc, char *argv[])
        prefs_receive_init();
        prefs_send_init();
        tags_read_tags();
+       matcher_init();
 #ifdef USE_ENCHANT
        gtkaspell_checkers_init();
        prefs_spelling_init();
 #endif
 
+#ifdef G_OS_WIN32
+       if(prefs_common.gtk_theme && strcmp(prefs_common.gtk_theme, DEFAULT_W32_GTK_THEME))
+               gtk_settings_set_string_property(gtk_settings_get_default(),
+                       "gtk-theme-name",
+                       prefs_common.gtk_theme,
+                       "XProperty");
+#endif
+
+
        sock_set_io_timeout(prefs_common.io_timeout_secs);
        prefs_actions_read_config();
        prefs_display_header_read_config();
@@ -1362,50 +1279,19 @@ int main(int argc, char *argv[])
 
        mainwin = main_window_create();
 
+       if (!check_file_integrity())
+               exit(1);
+
 #ifdef HAVE_NETWORKMANAGER_SUPPORT
        networkmanager_state_change_cb(nm_proxy,NULL,mainwin);
 #endif
 
-#ifdef MAEMO
-       AppData *appdata;
-       appdata = g_new0(AppData, 1);
-       appdata->program = hildon_program;
-       appdata->window = HILDON_WINDOW(mainwin->window);
-       appdata->osso_context = osso_context;
-       result = osso_rpc_set_cb_f(appdata->osso_context, 
-                OSSO_SERVICE, 
-                OSSO_OBJECT, 
-                OSSO_IFACE,
-                dbus_req_handler, appdata);
-       if (result != OSSO_OK) {
-               return OSSO_ERROR;
-       }
-
-#ifndef CHINOOK
-       /* Add handler for Exit D-BUS messages */
-       result = osso_application_set_exit_cb(appdata->osso_context,
-                                               exit_event_handler,
-                                               (gpointer) appdata);
-       if (result != OSSO_OK) {
-               return OSSO_ERROR;
-       }
-#endif
-       osso_hw_set_event_cb( appdata->osso_context,
-                               NULL, hw_event_handler, (gpointer) appdata );
-#endif
        manage_window_focus_in(mainwin->window, NULL, NULL);
        folderview = mainwin->folderview;
 
        gtk_cmclist_freeze(GTK_CMCLIST(mainwin->folderview->ctree));
        folder_item_update_freeze();
 
-       /* register the callback of unix domain socket input */
-       lock_socket_tag = claws_input_add(lock_socket,
-                                       G_IO_IN | G_IO_HUP | G_IO_ERR | G_IO_PRI,
-                                       lock_socket_input_cb,
-                                       mainwin, TRUE);
-
-
        prefs_account_init();
        account_read_config_all();
 
@@ -1466,8 +1352,10 @@ int main(int argc, char *argv[])
 
        /* if crashed, show window early so that the user
         * sees what's happening */
-       if (claws_crashed())
+       if (claws_crashed()) {
                main_window_popup(mainwin);
+               mainwin_shown = TRUE;
+       }
 
        account_set_missing_folder();
        folder_set_missing_folders();
@@ -1516,6 +1404,7 @@ int main(int argc, char *argv[])
 
        claws_register_idle_function(claws_gtk_idle);
 
+       avatars_init();
        prefs_toolbar_init();
 
        num_folder_class = g_list_length(folder_get_list());
@@ -1542,6 +1431,7 @@ int main(int argc, char *argv[])
                }
                main_window_cursor_normal(mainwin);
                main_window_popup(mainwin);
+               mainwin_shown = TRUE;
                alertpanel_warning(ngettext(
                                     "The following plugin failed to load. "
                                     "Check the Plugins configuration "
@@ -1561,7 +1451,7 @@ int main(int argc, char *argv[])
                plugin_load_standard_plugins ();
        }
        /* if not crashed, show window now */
-       if (!claws_crashed()) {
+       if (!mainwin_shown) {
                /* apart if something told not to show */
                if (show_at_startup)
                        main_window_popup(mainwin);
@@ -1592,36 +1482,6 @@ int main(int argc, char *argv[])
        
        static_mainwindow = mainwin;
 
-#ifdef MAEMO
-       if (prefs_common.data_root != NULL && *prefs_common.data_root != '\0') {
-               GnomeVFSVolume *vol = NULL;
-               gchar *uri, *mount_path;
-
-               volmon = gnome_vfs_get_volume_monitor();
-               vol = gnome_vfs_volume_monitor_get_volume_for_path(volmon, prefs_common.data_root);
-
-               uri = gnome_vfs_volume_get_activation_uri (vol);
-               mount_path = uri?gnome_vfs_get_local_path_from_uri (uri):NULL;
-               g_free(uri);
-
-               if (vol == NULL || !gnome_vfs_volume_is_mounted(vol) 
-                   || strcmp(mount_path, prefs_common.data_root)) {
-                       alertpanel_error(_("Claws Mail can not start without its data volume (%s)."), 
-                               prefs_common.data_root);
-                       g_free(mount_path);
-                       gnome_vfs_volume_unref(vol);
-                       exit_claws(mainwin);
-                       exit(1);
-               }
-               g_free(mount_path);
-               gnome_vfs_volume_unref(vol);
-               g_signal_connect(G_OBJECT(volmon), 
-                               "volume-mounted", G_CALLBACK(main_vol_mount_cb), mainwin);
-               g_signal_connect(G_OBJECT(volmon), 
-                               "volume-unmounted", G_CALLBACK(main_vol_unmount_cb), mainwin);
-       }
-#endif
-
 #ifdef HAVE_STARTUP_NOTIFICATION
        startup_notification_complete(FALSE);
 #endif
@@ -1681,13 +1541,17 @@ int main(int argc, char *argv[])
                main_window_set_menu_sensitive(mainwin);
                toolbar_main_set_sensitive(mainwin);
        }
+
+       /* register the callback of unix domain socket input */
+       lock_socket_tag = claws_input_add(lock_socket,
+                                       G_IO_IN | G_IO_HUP | G_IO_ERR | G_IO_PRI,
+                                       lock_socket_input_cb,
+                                       mainwin, TRUE);
+
        END_TIMING();
 
        gtk_main();
 
-#ifdef MAEMO
-       osso_deinitialize(osso_context);
-#endif
 #ifdef HAVE_NETWORKMANAGER_SUPPORT
        if(nm_proxy)
                g_object_unref(nm_proxy);
@@ -1791,7 +1655,9 @@ static void exit_claws(MainWindow *mainwin)
        
        plugin_unload_all("GTK2");
 
+       matcher_done();
        prefs_toolbar_done();
+       avatars_done();
 
 #ifndef USE_NEW_ADDRBOOK
        addressbook_destroy();
@@ -1918,6 +1784,10 @@ static void parse_cmd_opt(int argc, char *argv[])
                        cmd.receive_all = TRUE;
                } else if (!strncmp(argv[i], "--receive", 9)) {
                        cmd.receive = TRUE;
+               } else if (!strncmp(argv[i], "--cancel-receiving", 18)) {
+                       cmd.cancel_receiving = TRUE;
+               } else if (!strncmp(argv[i], "--cancel-sending", 16)) {
+                       cmd.cancel_sending = TRUE;
                } else if (!strncmp(argv[i], "--compose-from-file", 19)) {
                        const gchar *p = (i+1 < argc)?argv[i+1]:NULL;
 
@@ -2019,6 +1889,8 @@ static void parse_cmd_opt(int argc, char *argv[])
                        cmd.online_mode = ONLINE_MODE_ONLINE;
                } else if (!strncmp(argv[i], "--offline", 9)) {
                        cmd.online_mode = ONLINE_MODE_OFFLINE;
+               } else if (!strncmp(argv[i], "--toggle-debug", 14)) {
+                       cmd.debug = TRUE;
                } else if (!strncmp(argv[i], "--statistics", 12)) {
                        cmd.statistics = TRUE;
                } else if (!strncmp(argv[i], "--reset-statistics", 18)) {
@@ -2040,6 +1912,8 @@ static void parse_cmd_opt(int argc, char *argv[])
                                          "                         attached"));
                        g_print("%s\n", _("  --receive              receive new messages"));
                        g_print("%s\n", _("  --receive-all          receive new messages of all accounts"));
+                       g_print("%s\n", _("  --cancel-receiving     cancel receiving of messages"));
+                       g_print("%s\n", _("  --cancel-sending       cancel sending of messages"));
                        g_print("%s\n", _("  --search folder type request [recursive]\n"
                                          "                         searches mail\n"
                                          "                         folder ex.: \"#mh/Mailbox/inbox\" or \"Mail\"\n"
@@ -2059,6 +1933,7 @@ static void parse_cmd_opt(int argc, char *argv[])
                        g_print("%s\n", _("  --offline              switch to offline mode"));
                        g_print("%s\n", _("  --exit --quit -q       exit Claws Mail"));
                        g_print("%s\n", _("  --debug                debug mode"));
+                       g_print("%s\n", _("  --toggle-debug         toggle debug mode"));
                        g_print("%s\n", _("  --help -h              display this help and exit"));
                        g_print("%s\n", _("  --version -v           output version information and exit"));
                        g_print("%s\n", _("  --version-full -V      output version and built-in features information and exit"));
@@ -2249,6 +2124,7 @@ gboolean claws_is_starting(void)
        return sc_starting;
 }
 
+#ifdef G_OS_UNIX
 /*
  * CLAWS: want this public so crash dialog can delete the
  * lock file too
@@ -2257,23 +2133,42 @@ gchar *claws_get_socket_name(void)
 {
        static gchar *filename = NULL;
        const gchar *socket_dir = NULL;
-       
-       if (rc_dir_is_alt())
-               socket_dir = get_rc_dir();
-       else
-               socket_dir = g_get_tmp_dir();
+       gchar md5sum[33];
+
        if (filename == NULL) {
-               filename = g_strdup_printf("%s%cclaws-mail-%d",
-                                          socket_dir, G_DIR_SEPARATOR,
+               struct stat st;
+               socket_dir = g_strdup_printf("%s%cclaws-mail-%d",
+                                          g_get_tmp_dir(), G_DIR_SEPARATOR,
 #if HAVE_GETUID
                                           getuid());
 #else
-                                          0);                                          
-#endif
+                                          0);
+#endif
+               if (stat(socket_dir, &st) < 0 && errno != ENOENT) {
+                       g_print("Error stat'ing socket_dir %s: %s\n",
+                               socket_dir, strerror(errno));
+               } else if (S_ISSOCK(st.st_mode)) {
+                       /* old versions used a sock in $TMPDIR/claws-mail-$UID */
+                       debug_print("Using legacy socket %s\n", socket_dir);
+                       filename = g_strdup(socket_dir);
+                       return filename;
+               }
+
+               if (!is_dir_exist(socket_dir) && make_dir(socket_dir) < 0) {
+                       g_print("Error creating socket_dir %s: %s\n",
+                               socket_dir, strerror(errno));
+               }
+
+               md5_hex_digest(md5sum, get_rc_dir());
+
+               filename = g_strdup_printf("%s%c%s", socket_dir, G_DIR_SEPARATOR,
+                                          md5sum);
+               debug_print("Using control socket %s\n", filename);
        }
 
        return filename;
 }
+#endif
 
 static gchar *get_crashfile_name(void)
 {
@@ -2295,14 +2190,51 @@ static gint prohibit_duplicate_launch(void)
        gchar *path;
 
        path = claws_get_socket_name();
+       /* Try to connect to the control socket */
        uxsock = fd_connect_unix(path);
        
        if (x_display == NULL)
                x_display = g_strdup(g_getenv("DISPLAY"));
 
        if (uxsock < 0) {
+               gint ret;
+#if HAVE_FLOCK
+               gchar *socket_lock;
+               gint lock_fd;
+               /* If connect failed, no other process is running.
+                * Unlink the potentially existing socket, then
+                * open it. This has to be done locking a temporary
+                * file to avoid the race condition where another
+                * process could have created the socket just in
+                * between.
+                */
+               socket_lock = g_strconcat(path, ".lock",
+                                         NULL);
+               lock_fd = g_open(socket_lock, O_RDWR|O_CREAT, 0);
+               if (lock_fd < 0) {
+                       debug_print("Couldn't open %s: %s (%d)\n", socket_lock,
+                               strerror(errno), errno);
+                       g_free(socket_lock);
+                       return -1;
+               }
+               if (flock(lock_fd, LOCK_EX) < 0) {
+                       debug_print("Couldn't lock %s: %s (%d)\n", socket_lock,
+                               strerror(errno), errno);
+                       close(lock_fd);
+                       g_free(socket_lock);
+                       return -1;
+               }
+#endif
+
                claws_unlink(path);
-               return fd_open_unix(path);
+               debug_print("Opening socket %s\n", path);
+               ret = fd_open_unix(path);
+#if HAVE_FLOCK
+               flock(lock_fd, LOCK_UN);
+               claws_unlink(socket_lock);
+               g_free(socket_lock);
+#endif
+               return ret;
        }
 #else
         HANDLE hmutex;
@@ -2331,6 +2263,10 @@ static gint prohibit_duplicate_launch(void)
                fd_write_all(uxsock, "receive_all\n", 12);
        } else if (cmd.receive) {
                fd_write_all(uxsock, "receive\n", 8);
+       } else if (cmd.cancel_receiving) {
+               fd_write_all(uxsock, "cancel_receiving\n", 17);
+       } else if (cmd.cancel_sending) {
+               fd_write_all(uxsock, "cancel_sending\n", 15);
        } else if (cmd.compose && cmd.attach_files) {
                gchar *str, *compose_str;
 
@@ -2373,6 +2309,8 @@ static gint prohibit_duplicate_launch(void)
                fd_write(uxsock, "online\n", 6);
        } else if (cmd.online_mode == ONLINE_MODE_OFFLINE) {
                fd_write(uxsock, "offline\n", 7);
+       } else if (cmd.debug) {
+               fd_write(uxsock, "debug\n", 7);
        } else if (cmd.status || cmd.status_full) {
                gchar buf[BUFFSIZE];
                gint i;
@@ -2451,7 +2389,7 @@ static gint prohibit_duplicate_launch(void)
 static gint lock_socket_remove(void)
 {
 #ifdef G_OS_UNIX
-       gchar *filename;
+       gchar *filename, *dirname;
 #endif
        if (lock_socket < 0) {
                return -1;
@@ -2464,7 +2402,10 @@ static gint lock_socket_remove(void)
 
 #ifdef G_OS_UNIX
        filename = claws_get_socket_name();
+       dirname = g_path_get_dirname(filename);
        claws_unlink(filename);
+       g_rmdir(dirname);
+       g_free(dirname);
 #endif
 
        return 0;
@@ -2503,8 +2444,6 @@ static void lock_socket_input_cb(gpointer data,
        MainWindow *mainwin = (MainWindow *)data;
        gint sock;
        gchar buf[BUFFSIZE];
-       /* re-use the same quicksearch (& avoid matcher_list mem.leaks) */
-       static QuickSearch *quicksearch = NULL;
 
        sock = fd_accept(source);
        fd_gets(sock, buf, sizeof(buf));
@@ -2518,6 +2457,11 @@ static void lock_socket_input_cb(gpointer data,
                                     prefs_common.newmail_notify_manu);
        } else if (!strncmp(buf, "receive", 7)) {
                inc_mail(mainwin, prefs_common.newmail_notify_manu);
+       } else if (!strncmp(buf, "cancel_receiving", 16)) {
+               inc_cancel_all();
+               imap_cancel_all();
+       } else if (!strncmp(buf, "cancel_sending", 14)) {
+               send_cancel();
        } else if (!strncmp(buf, "compose_attach", 14)) {
                GList *files = NULL, *curr;
                AttachInfo *ainfo;
@@ -2555,6 +2499,8 @@ static void lock_socket_input_cb(gpointer data,
                main_window_toggle_work_offline(mainwin, FALSE, FALSE);
        } else if (!strncmp(buf, "offline", 7)) {
                main_window_toggle_work_offline(mainwin, TRUE, FALSE);
+       } else if (!strncmp(buf, "debug", 5)) {
+               debug_set_mode(debug_get_mode() ? FALSE : TRUE);
        } else if (!strncmp(buf, "status-full", 11) ||
                   !strncmp(buf, "status", 6)) {
                gchar *status;
@@ -2573,10 +2519,22 @@ static void lock_socket_input_cb(gpointer data,
                g_snprintf(tmp, sizeof(tmp), _("Session statistics\n"));
                fd_write_all(sock, tmp, strlen(tmp));
 
-               g_snprintf(tmp, sizeof(tmp), _("Started: %s\n"),
-                               ctime(&session_stats.time_started));
+               if (prefs_common.date_format) {
+                       struct tm *lt;
+                       gint len = 100;
+                       gchar date[len];
+
+                       lt = localtime(&session_stats.time_started);
+                       fast_strftime(date, len, prefs_common.date_format, lt);
+                       g_snprintf(tmp, sizeof(tmp), _("Started: %s\n"),
+                                       lt ? date : ctime(&session_stats.time_started));
+               } else
+                       g_snprintf(tmp, sizeof(tmp), _("Started: %s\n"),
+                                       ctime(&session_stats.time_started));
                fd_write_all(sock, tmp, strlen(tmp));
 
+               fd_write_all(sock, "\n", 1);
+
                g_snprintf(tmp, sizeof(tmp), _("Incoming traffic\n"));
                fd_write_all(sock, tmp, strlen(tmp));
 
@@ -2615,37 +2573,44 @@ static void lock_socket_input_cb(gpointer data,
        } else if (!strncmp(buf, "search ", 7)) {
                FolderItem* folderItem = NULL;
                GSList *messages = NULL;
-               gchar *folder_name, *request;
-               QuickSearchType searchType = QUICK_SEARCH_EXTENDED;
+               gchar *folder_name = NULL;
+               gchar *request = NULL;
+               AdvancedSearch *search;
                gboolean recursive;
-
-               if (quicksearch==NULL)
-                       quicksearch = quicksearch_new_nogui();
+               AdvancedSearchType searchType = ADVANCED_SEARCH_EXTENDED;
                
+               search = advsearch_new();
+
                folder_name = g_strdup(buf+7);
                strretchomp(folder_name);
 
-               if (fd_gets(sock, buf, sizeof(buf)) <= 0) {
-                       g_free(folder_name);
-                       folder_name=NULL;
-               }
-               searchType = quicksearch_type(buf);
-               if (fd_gets(sock, buf, sizeof(buf)) <= 0) {
-                       g_free(folder_name);
-                       folder_name=NULL;
+               if (fd_gets(sock, buf, sizeof(buf)) <= 0) 
+                       goto search_exit;
+
+               switch (toupper(buf[0])) {
+               case 'S': searchType = ADVANCED_SEARCH_SUBJECT; break;
+               case 'F': searchType = ADVANCED_SEARCH_FROM; break;
+               case 'T': searchType = ADVANCED_SEARCH_TO; break;
+               case 'M': searchType = ADVANCED_SEARCH_MIXED; break;
+               case 'G': searchType = ADVANCED_SEARCH_TAG; break;
+               case 'E': searchType = ADVANCED_SEARCH_EXTENDED; break;
                }
+
+               if (fd_gets(sock, buf, sizeof(buf)) <= 0) 
+                       goto search_exit;
+
                request = g_strdup(buf);
                strretchomp(request);
 
                recursive = TRUE;
                if (fd_gets(sock, buf, sizeof(buf)) > 0)
-                       if (buf[0]=='0')
-                               recursive = FALSE;
+                       recursive = buf[0] != '0';
 
-               debug_print("search: %s %i %s %i\n",folder_name,searchType,request,recursive);
+               debug_print("search: %s %i %s %i\n", folder_name, searchType, request, recursive);
 
                if (folder_name)
                        folderItem = folder_find_item_from_identifier(folder_name);
+
                if (folder_name && folderItem == NULL) {
                        debug_print("Unknown folder item : '%s', searching folder\n",folder_name);
                        Folder* folder = folder_find_from_path(folder_name);
@@ -2656,16 +2621,16 @@ static void lock_socket_input_cb(gpointer data,
                } else {
                        debug_print("%s %s\n",folderItem->name, folderItem->path);
                }
+
                if (folderItem != NULL) {
-                       quicksearch_set(quicksearch, searchType, request);
-                       quicksearch_set_recursive(quicksearch, recursive);
-                       search_msgs_in_folders(&messages, quicksearch, folderItem);
+                       advsearch_set(search, searchType, request);
+                       advsearch_search_msgs_in_folders(search, &messages, folderItem, recursive);
                } else {
                        g_print("Folder '%s' not found.\n'", folder_name);
                }
 
                GSList *cur;
-               for (cur=messages; cur != NULL; cur = cur->next) {
+               for (cur = messages; cur != NULL; cur = cur->next) {
                        MsgInfo* msg = (MsgInfo *)cur->data;
                        gchar *file = procmsg_get_message_file_path(msg);
                        fd_write_all(sock, file, strlen(file));
@@ -2674,10 +2639,12 @@ static void lock_socket_input_cb(gpointer data,
                }
                fd_write_all(sock, ".\n", 2);
 
-               if (messages != NULL)
-                       procmsg_msg_list_free(messages);
+search_exit:
                g_free(folder_name);
                g_free(request);
+               advsearch_free(search);
+               if (messages != NULL)
+                       procmsg_msg_list_free(messages);
        } else if (!strncmp(buf, "exit", 4)) {
                if (prefs_common.clean_on_exit && !prefs_common.ask_on_clean) {
                        procmsg_empty_all_trash();
@@ -2825,14 +2792,6 @@ static void install_memory_sighandler()
 }
 #endif /* linux && SIGIO */
 
-#ifdef MAEMO
-osso_context_t *get_osso_context(void)
-{
-       return static_osso_context;
-}
-#endif
-
-
 #ifdef HAVE_NETWORKMANAGER_SUPPORT
 static void networkmanager_state_change_cb(DBusGProxy *proxy, gchar *dev,
                                         gpointer data)