#include <modest-platform.h>
#include <widgets/modest-window-mgr.h>
#include <modest-marshal.h>
+#include <modest-debug.h>
#include <string.h> /* strcmp */
/* 'private'/'protected' functions */
*/
static int
-on_modest_tny_send_queue_compare_id(gconstpointer info, gconstpointer msg_id)
+on_modest_tny_send_queue_compare_id (gconstpointer info, gconstpointer msg_id)
{
g_return_val_if_fail (info && ((SendInfo*)info)->msg_id && msg_id, -1);
}
static void
-modest_tny_send_queue_info_free(SendInfo *info)
+modest_tny_send_queue_info_free (SendInfo *info)
{
g_free(info->msg_id);
g_slice_free(SendInfo, info);
{
ModestTnySendQueuePrivate *priv;
priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
-
+
return g_queue_find_custom (priv->queue, msg_id, on_modest_tny_send_queue_compare_id);
}
+
+static void
+queue_item_to_string (gpointer data, gchar **user_data)
+{
+ SendInfo *info = (SendInfo*)data;
+ const gchar *status;
+ gchar *tmp;
+
+ if (!(user_data && *user_data))
+ return;
+
+ switch (info->status) {
+ case MODEST_TNY_SEND_QUEUE_UNKNOWN: status = "UNKNOWN"; break;
+ case MODEST_TNY_SEND_QUEUE_WAITING: status = "WAITING"; break;
+ case MODEST_TNY_SEND_QUEUE_SUSPENDED: status = "SUSPENDED"; break;
+ case MODEST_TNY_SEND_QUEUE_SENDING: status = "SENDING"; break;
+ case MODEST_TNY_SEND_QUEUE_FAILED: status = "FAILED"; break;
+ default: status= "UNEXPECTED"; break;
+ }
+
+ tmp = g_strdup_printf ("%s\"%s\" => [%s]\n",
+ *user_data, info->msg_id, status);
+ g_free (*user_data);
+ *user_data = tmp;
+}
+
+gchar*
+modest_tny_send_queue_to_string (ModestTnySendQueue *self)
+{
+ gchar *str;
+ ModestTnySendQueuePrivate *priv;
+
+ g_return_val_if_fail (MODEST_IS_TNY_SEND_QUEUE(self), NULL);
+ priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
+
+ str = g_strdup_printf ("items in the send queue: %d\n",
+ g_queue_get_length (priv->queue));
+
+ g_queue_foreach (priv->queue, (GFunc)queue_item_to_string, &str);
+
+ return str;
+}
+
static void
modest_tny_send_queue_cancel (TnySendQueue *self, gboolean remove, GError **err)
{
/* Set flags to supend sending operaiton (if removed, this is not necessary) */
if (!remove) {
outbox = modest_tny_send_queue_get_outbox (TNY_SEND_QUEUE(self));
+ if (!outbox) {
+ g_warning ("%s: modest_tny_send_queue_get_outbox(..) returned NULL\n", __FUNCTION__);
+ goto frees;
+ }
tny_folder_get_headers (outbox, headers, TRUE, err);
if (err != NULL) goto frees;
iter = tny_list_create_iterator (headers);
while (!tny_iterator_is_done (iter)) {
header = TNY_HEADER (tny_iterator_get_current (iter));
- if (header) {
- tny_header_unset_flags (header, TNY_HEADER_FLAG_PRIORITY);
- tny_header_set_flags (header, TNY_HEADER_FLAG_SUSPENDED_PRIORITY);
+ if (header) {
+ tny_header_set_flag (header, TNY_HEADER_FLAG_SUSPENDED);
tny_iterator_next (iter);
g_object_unref (header);
}
}
static void
-_on_added_to_outbox (TnySendQueue *self, gboolean cancelled, TnyMsg *msg, GError *err, gpointer user_data)
+_on_added_to_outbox (TnySendQueue *self, gboolean cancelled, TnyMsg *msg, GError *err,
+ gpointer user_data)
{
ModestTnySendQueuePrivate *priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE(self);
TnyHeader *header = NULL;
SendInfo *info = NULL;
GList* existing = NULL;
- const gchar* msg_id = NULL;
+ gchar* msg_id = NULL;
g_return_if_fail (TNY_IS_SEND_QUEUE(self));
g_return_if_fail (TNY_IS_CAMEL_MSG(msg));
/* Put newly added message in WAITING state */
existing = modest_tny_send_queue_lookup_info (MODEST_TNY_SEND_QUEUE(self), msg_id);
- if(existing != NULL)
- {
+ if(existing != NULL) {
info = existing->data;
info->status = MODEST_TNY_SEND_QUEUE_WAITING;
- }
- else
- {
-
+ } else {
info = g_slice_new (SendInfo);
-
- info->msg_id = strdup(msg_id);
+ info->msg_id = msg_id;
info->status = MODEST_TNY_SEND_QUEUE_WAITING;
g_queue_push_tail (priv->queue, info);
}
case MODEST_TNY_SEND_QUEUE_UNKNOWN:
case MODEST_TNY_SEND_QUEUE_SUSPENDED:
case MODEST_TNY_SEND_QUEUE_FAILED:
- if (status != MODEST_TNY_SEND_QUEUE_SUSPENDED)
- tny_header_unset_flags (header, TNY_HEADER_FLAG_PRIORITY);
-
+
/* Check if it already exists on queue */
existing = modest_tny_send_queue_lookup_info (MODEST_TNY_SEND_QUEUE(self), msg_uid);
if(existing != NULL)
TnyHeader *header = NULL;
GError *err = NULL;
+ g_return_if_fail (MODEST_IS_TNY_SEND_QUEUE(self));
+
outbox = modest_tny_send_queue_get_outbox (TNY_SEND_QUEUE(self));
if (!outbox)
return;
modest_tny_send_queue_sending_in_progress (ModestTnySendQueue* self)
{
ModestTnySendQueuePrivate *priv;
+
+ g_return_val_if_fail (MODEST_IS_TNY_SEND_QUEUE(self), FALSE);
+
priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
return priv->current != NULL;
ModestTnySendQueueStatus
modest_tny_send_queue_get_msg_status (ModestTnySendQueue *self, const gchar *msg_id)
{
- GList *item;
- item = modest_tny_send_queue_lookup_info (self, msg_id);
- if(item == NULL) return MODEST_TNY_SEND_QUEUE_UNKNOWN;
- return ((SendInfo*)item->data)->status;
+ GList *item;
+
+ g_return_val_if_fail (MODEST_IS_TNY_SEND_QUEUE(self), MODEST_TNY_SEND_QUEUE_UNKNOWN);
+ g_return_val_if_fail (msg_id, MODEST_TNY_SEND_QUEUE_UNKNOWN);
+
+ item = modest_tny_send_queue_lookup_info (self, msg_id);
+ if (!item)
+ return MODEST_TNY_SEND_QUEUE_UNKNOWN;
+ else
+ return ((SendInfo*)item->data)->status;
}
gchar *
const gchar *subject;
time_t date_received;
+ g_return_val_if_fail (header && TNY_IS_HEADER(header), NULL);
+
/* Get message uid */
subject = tny_header_get_subject (header);
date_received = tny_header_get_date_received (header);
/* Get status info */
item = modest_tny_send_queue_lookup_info (MODEST_TNY_SEND_QUEUE (self), msg_id);
if (!item)
- g_warning ("%s: item should not be NULL", __FUNCTION__);
+ g_warning ("%s: item (%s) should not be NULL",
+ __FUNCTION__, msg_id ? msg_id : "<none>");
else {
info = item->data;
info->status = MODEST_TNY_SEND_QUEUE_SENDING;
ModestTnySendQueuePrivate *priv;
gchar *msg_id = NULL;
GList *item;
+
priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
/* Get message uid */
msg_id = modest_tny_send_queue_get_msg_id (header);
- tny_header_set_flags (header, TNY_HEADER_FLAG_SEEN);
+ tny_header_set_flag (header, TNY_HEADER_FLAG_SEEN);
/* Get status info */
item = modest_tny_send_queue_lookup_info (MODEST_TNY_SEND_QUEUE (self), msg_id);
msg_uid);
if (item == NULL) {
info = g_slice_new (SendInfo);
- info->msg_id = strdup(msg_uid);
+ info->msg_id = (msg_uid != NULL)? strdup(msg_uid) : NULL;
g_queue_push_tail (priv->queue, info);
} else
info = item->data;
/* Keep in queue so that we remember that the opertion has failed */
/* and was not just cancelled */
info->status = MODEST_TNY_SEND_QUEUE_FAILED;
+ priv->current = NULL;
/* Notify status has changed */
g_signal_emit (self, signals[STATUS_CHANGED], 0, info->msg_id, info->status);
/* free */
g_free(msg_uid);
}
+
+static void
+fill_list_of_caches (gpointer key, gpointer value, gpointer userdata)
+{
+ GSList **send_queues = (GSList **) userdata;
+ *send_queues = g_slist_prepend (*send_queues, value);
+}
+
+ModestTnySendQueueStatus
+modest_tny_all_send_queues_get_msg_status (TnyHeader *header)
+{
+ ModestCacheMgr *cache_mgr = NULL;
+ GHashTable *send_queue_cache = NULL;
+ ModestTnyAccountStore *accounts_store = NULL;
+ TnyList *accounts = NULL;
+ TnyIterator *iter = NULL;
+ TnyTransportAccount *account = NULL;
+ GSList *send_queues = NULL, *node;
+ /* get_msg_status returns suspended by default, so we want to detect changes */
+ ModestTnySendQueueStatus status = MODEST_TNY_SEND_QUEUE_UNKNOWN;
+ ModestTnySendQueueStatus queue_status = MODEST_TNY_SEND_QUEUE_UNKNOWN;
+ gchar *msg_uid = NULL;
+ ModestTnySendQueue *send_queue = NULL;
+
+ g_return_val_if_fail (TNY_IS_HEADER(header), MODEST_TNY_SEND_QUEUE_UNKNOWN);
+
+ msg_uid = modest_tny_send_queue_get_msg_id (header);
+ cache_mgr = modest_runtime_get_cache_mgr ();
+ send_queue_cache = modest_cache_mgr_get_cache (cache_mgr,
+ MODEST_CACHE_MGR_CACHE_TYPE_SEND_QUEUE);
+
+ g_hash_table_foreach (send_queue_cache, (GHFunc) fill_list_of_caches, &send_queues);
+ if (send_queues == NULL) {
+ accounts = tny_simple_list_new ();
+ accounts_store = modest_runtime_get_account_store ();
+ tny_account_store_get_accounts (TNY_ACCOUNT_STORE(accounts_store),
+ accounts,
+ TNY_ACCOUNT_STORE_TRANSPORT_ACCOUNTS);
+
+ iter = tny_list_create_iterator (accounts);
+ while (!tny_iterator_is_done (iter)) {
+ account = TNY_TRANSPORT_ACCOUNT(tny_iterator_get_current (iter));
+ send_queue = modest_runtime_get_send_queue(TNY_TRANSPORT_ACCOUNT(account));
+ g_object_unref(account);
+
+ queue_status = modest_tny_send_queue_get_msg_status (send_queue, msg_uid);
+ if (queue_status != MODEST_TNY_SEND_QUEUE_UNKNOWN) {
+ status = queue_status;
+ break;
+ }
+ tny_iterator_next (iter);
+ }
+ g_object_unref (iter);
+ g_object_unref (accounts);
+ }
+ else {
+ for (node = send_queues; node != NULL; node = g_slist_next (node)) {
+ send_queue = MODEST_TNY_SEND_QUEUE (node->data);
+
+ queue_status = modest_tny_send_queue_get_msg_status (send_queue, msg_uid);
+ if (queue_status != MODEST_TNY_SEND_QUEUE_UNKNOWN) {
+ status = queue_status;
+ break;
+ }
+ }
+ }
+
+ g_free(msg_uid);
+ g_slist_free (send_queues);
+ return status;
+}