+ /* Get the message max size */
+ max_size = modest_conf_get_int (modest_runtime_get_conf (),
+ MODEST_CONF_MSG_SIZE_LIMIT, NULL);
+ if (max_size == 0)
+ max_size = G_MAXINT;
+ else
+ max_size = max_size * KB;
+
+ /* Create the new headers array. We need it to sort the
+ new headers by date */
+ new_headers_array = g_ptr_array_new ();
+ new_headers_iter = tny_list_create_iterator (((InternalFolderObserver *) info->inbox_observer)->new_headers);
+ while (!tny_iterator_is_done (new_headers_iter)) {
+ TnyHeader *header = NULL;
+
+ header = TNY_HEADER (tny_iterator_get_current (new_headers_iter));
+ /* Apply per-message size limits */
+ if (tny_header_get_message_size (header) < max_size)
+ g_ptr_array_add (new_headers_array, g_object_ref (header));
+
+ g_object_unref (header);
+ tny_iterator_next (new_headers_iter);
+ }
+ g_object_unref (new_headers_iter);
+ tny_folder_remove_observer (inbox, info->inbox_observer);
+ g_object_unref (info->inbox_observer);
+ info->inbox_observer = NULL;
+
+ /* Update the last updated key, even if we don't have to get new headers */
+ modest_account_mgr_set_last_updated (mgr, tny_account_get_id (priv->account), time (NULL));
+ if (!canceled && !err)
+ modest_account_mgr_set_server_account_username_has_succeeded (mgr, tny_account_get_id (priv->account), TRUE);
+
+ if (new_headers_array->len == 0)
+ goto send_mail;
+
+ /* Get per-account message amount retrieval limit */
+ retrieve_limit = modest_account_mgr_get_retrieve_limit (mgr, info->account_name);
+ if (retrieve_limit == 0)
+ retrieve_limit = G_MAXINT;
+
+ /* Get per-account retrieval type */
+ retrieve_type = modest_account_mgr_get_retrieve_type (mgr, info->account_name);
+ headers_only = (retrieve_type == MODEST_ACCOUNT_RETRIEVE_HEADERS_ONLY);
+
+ /* Order by date */
+ g_ptr_array_sort (new_headers_array, (GCompareFunc) compare_headers_by_date);
+
+ /* Ask the users if they want to retrieve all the messages
+ even though the limit was exceeded */
+ ignore_limit = FALSE;
+ if (new_headers_array->len > retrieve_limit) {
+ /* Ask the user if a callback has been specified and
+ if the mail operation has a source (this means that
+ was invoked by the user and not automatically by a
+ D-Bus method) */
+ if (info->retrieve_all_cb && priv->source)
+ ignore_limit = info->retrieve_all_cb (priv->source,
+ new_headers_array->len,
+ retrieve_limit);
+ }
+
+ if (!headers_only) {
+ gint msg_num = 0;
+ const gint msg_list_size = compute_message_array_size (new_headers_array);
+
+ priv->done = 0;
+ if (ignore_limit)
+ priv->total = new_headers_array->len;
+ else
+ priv->total = MIN (new_headers_array->len, retrieve_limit);
+ while (msg_num < priv->total) {
+ TnyHeader *header = TNY_HEADER (g_ptr_array_index (new_headers_array, msg_num));
+ TnyFolder *folder = tny_header_get_folder (header);
+ GetMsgInfo *msg_info;
+
+ /* Create the message info */
+ msg_info = g_slice_new0 (GetMsgInfo);
+ msg_info->mail_op = g_object_ref (info->mail_op);
+ msg_info->header = g_object_ref (header);
+ msg_info->total_bytes = msg_list_size;
+
+ /* Get message in an async way */
+ tny_folder_get_msg_async (folder, header, update_account_get_msg_async_cb,
+ get_msg_status_cb, msg_info);
+
+ g_object_unref (folder);
+
+ msg_num++;
+ }
+ }
+
+ /* Copy the headers to a list and free the array */
+ new_headers = tny_simple_list_new ();
+ for (i=0; i < new_headers_array->len; i++) {
+ TnyHeader *header = TNY_HEADER (g_ptr_array_index (new_headers_array, i));
+ tny_list_append (new_headers, G_OBJECT (header));
+ }
+ g_ptr_array_foreach (new_headers_array, (GFunc) g_object_unref, NULL);
+ g_ptr_array_free (new_headers_array, FALSE);
+
+ if (priv->error)
+ succeeded = FALSE;
+ else
+ succeeded = TRUE;
+ modest_account_mgr_set_server_account_username_has_succeeded (modest_runtime_get_account_mgr (),
+ tny_account_get_name (priv->account),
+ succeeded);
+ send_mail:
+ /* Get the transport account */
+ transport_account = (TnyTransportAccount *)
+ modest_tny_account_store_get_transport_account_for_open_connection (modest_runtime_get_account_store(),
+ info->account_name);
+
+ if (transport_account) {
+ ModestTnySendQueue *send_queue;
+ TnyFolder *outbox;
+ guint num_messages;
+
+ send_queue = modest_runtime_get_send_queue (transport_account);
+ g_object_unref (transport_account);
+
+ /* Get outbox folder */
+ outbox = tny_send_queue_get_outbox (TNY_SEND_QUEUE (send_queue));
+ if (outbox) { /* this could fail in some cases */
+ num_messages = tny_folder_get_all_count (outbox);
+ g_object_unref (outbox);
+ } else {
+ g_warning ("%s: could not get outbox", __FUNCTION__);
+ num_messages = 0;
+ }
+
+ if (num_messages != 0) {
+ /* Send mails */
+ g_object_unref (priv->account);
+
+ /* Reenable suspended items */
+ modest_tny_send_queue_wakeup (MODEST_TNY_SEND_QUEUE (send_queue));
+
+ /* Try to send */
+ tny_camel_send_queue_flush (TNY_CAMEL_SEND_QUEUE (send_queue));
+ }
+ }
+
+ /* Check if the operation was a success */
+ if (!priv->error)
+ priv->status = MODEST_MAIL_OPERATION_STATUS_SUCCESS;
+
+ /* Set the account back to not busy */
+ modest_account_mgr_set_account_busy (mgr, info->account_name, FALSE);
+
+ /* Call the user callback */
+ if (info->callback)
+ info->callback (info->mail_op, new_headers, info->user_data);
+
+ /* Notify about operation end */
+ modest_mail_operation_notify_end (info->mail_op);
+
+ /* Frees */
+ if (new_headers)
+ g_object_unref (new_headers);
+ destroy_update_account_info (info);