summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSunghyun Kwon <sh0701.kwon@samsung.com>2015-09-03 11:28:41 +0900
committerSunghyun Kwon <sh0701.kwon@samsung.com>2015-09-03 11:28:41 +0900
commit922c841dc14b6a4021952113f2290ddcae9c2053 (patch)
treed7551ecec44bcbfae54ea6aa15255c9069b92854
parent625bc4976517f13363b5ffc5c388f804ae924279 (diff)
downloademail-service-922c841dc14b6a4021952113f2290ddcae9c2053.tar.gz
email-service-922c841dc14b6a4021952113f2290ddcae9c2053.tar.bz2
email-service-922c841dc14b6a4021952113f2290ddcae9c2053.zip
Change-Id: Icb826abd987e4751cf8f473219e597e56009e2e2
-rwxr-xr-xemail-common-use/email-convert.c4
-rwxr-xr-xemail-common-use/email-utilities.c4
-rw-r--r--email-core/email-core-key-manager.c2
-rwxr-xr-xemail-core/email-core-smtp.c5
-rwxr-xr-xemail-core/email-core-task-manager.c1320
-rwxr-xr-xemail-core/email-core-tasks.c1306
-rwxr-xr-xemail-core/email-core-utils.c45
-rwxr-xr-xemail-core/email-storage/email-storage.c31
-rwxr-xr-xemail-core/email-storage/include/email-storage.h20
-rwxr-xr-xemail-core/include/email-core-mail.h1
-rwxr-xr-xemail-core/include/email-core-task-manager.h2
-rwxr-xr-xemail-core/include/email-core-utils.h2
-rwxr-xr-xemail-daemon/email-daemon-etc.c2
-rwxr-xr-xemail-daemon/email-daemon-mail.c13
-rwxr-xr-xemail-daemon/main.c9
-rwxr-xr-xemail-ipc/include/email-ipc.h1
-rwxr-xr-xutilities/test-application/testapp-mail.c4
17 files changed, 1417 insertions, 1354 deletions
diff --git a/email-common-use/email-convert.c b/email-common-use/email-convert.c
index e48c02f..8299cd5 100755
--- a/email-common-use/email-convert.c
+++ b/email-common-use/email-convert.c
@@ -1236,7 +1236,7 @@ INTERNAL_FUNC void em_convert_byte_stream_to_rule(char *stream, int stream_len,
converted_fmt = convert_format(EMAIL_RULE_FMT);
if (converted_fmt == NULL) {
EM_DEBUG_EXCEPTION("converting failed");
- return NULL;
+ return;
}
tn = tpl_map(converted_fmt, rule);
@@ -1326,7 +1326,7 @@ INTERNAL_FUNC void em_convert_byte_stream_to_meeting_req(char *stream, int strea
converted_fmt = convert_format(EMAIL_MEETING_REQUEST_FMT);
if (converted_fmt == NULL) {
EM_DEBUG_EXCEPTION("converting failed");
- return NULL;
+ return;
}
tn = tpl_map(converted_fmt,
diff --git a/email-common-use/email-utilities.c b/email-common-use/email-utilities.c
index 770aa85..9c86fb5 100755
--- a/email-common-use/email-utilities.c
+++ b/email-common-use/email-utilities.c
@@ -112,10 +112,10 @@ INTERNAL_FUNC char *em_trim_right(char *str)
if (!str) return NULL;
p = str+EM_SAFE_STRLEN(str)-1;
- while (((int)p >= (int)str) && (*p == ' ' || *p == '\t' || *p == LF || *p == CR))
+ while ((p >= str) && (*p == ' ' || *p == '\t' || *p == LF || *p == CR))
*p --= '\0';
- if ((int) p < (int)str)
+ if (p < str)
return NULL;
return str;
diff --git a/email-core/email-core-key-manager.c b/email-core/email-core-key-manager.c
index aed326b..ddd9ed5 100644
--- a/email-core/email-core-key-manager.c
+++ b/email-core/email-core-key-manager.c
@@ -124,7 +124,7 @@ INTERNAL_FUNC int emcore_get_password_in_key_manager(char *data_name, char **sto
FINISH_OFF:
if (stored_data) {
- if (email_data) *stored_data = g_strndup(email_data->data, email_data->size);
+ if (email_data) *stored_data = g_strndup((const gchar *)email_data->data, email_data->size);
}
if (email_data)
diff --git a/email-core/email-core-smtp.c b/email-core/email-core-smtp.c
index 91f9d23..449bb32 100755
--- a/email-core/email-core-smtp.c
+++ b/email-core/email-core-smtp.c
@@ -2090,7 +2090,7 @@ INTERNAL_FUNC int emcore_send_saved_mail(char *multi_user_name, int account_id,
int err2 = EMAIL_ERROR_NONE;
int status = EMAIL_SEND_FAIL;
int *mail_ids = NULL;
- int handle = 0;
+ DB_STMT handle;
int i = 0;
int total = 0;
int attachment_tbl_count = 0;
@@ -4485,7 +4485,8 @@ INTERNAL_FUNC int emcore_schedule_sending_mail(char *multi_user_name, int input_
}
FINISH_OFF:
- if(mail_data)
+
+ if (mail_data)
emstorage_free_mail(&mail_data, 1, NULL);
EM_DEBUG_FUNC_END("err [%d]", err);
diff --git a/email-core/email-core-task-manager.c b/email-core/email-core-task-manager.c
index 776ce33..2d2bc0a 100755
--- a/email-core/email-core-task-manager.c
+++ b/email-core/email-core-task-manager.c
@@ -1,659 +1,681 @@
-/*
-* email-service
-*
-* Copyright (c) 2012 - 2013 Samsung Electronics Co., Ltd. All rights reserved.
-*
-* Contact: Kyuho Jo <kyuho.jo@samsung.com>, Sunghyun Kwon <sh0701.kwon@samsung.com>
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
-
-/*
- * email-core-task-manager.c
- *
- * Created on: 2012. 11. 1.
- * Author: kyuho.jo@samsung.com
- */
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <pthread.h>
-#include <dbus/dbus.h>
-
-#include "email-internal-types.h"
-#include "email-utilities.h"
-#include "email-core-tasks.h"
-#include "email-core-task-manager.h"
-#include "email-core-signal.h"
-#include "email-core-global.h"
-#include "email-core-utils.h"
-#include "email-debug-log.h"
-
-/* TODO : implement a function for removing a task from task pool */
-/* TODO : after fetching a task from DB, update status of the task. */
-
-
-#define REGISTER_TASK_BINDER(TASK_NAME) emcore_register_task_handler(TASK_NAME, task_handler_##TASK_NAME, email_encode_task_parameter_##TASK_NAME, email_decode_task_parameter_##TASK_NAME)
-
-/*- variables - begin --------------------------------------------------------*/
-static pthread_cond_t _task_available_signal = PTHREAD_COND_INITIALIZER;
-static pthread_mutex_t _task_available_lock = PTHREAD_MUTEX_INITIALIZER;
-static pthread_mutex_t _task_manager_loop_lock = PTHREAD_MUTEX_INITIALIZER;
-static pthread_mutex_t _active_task_pool_lock = PTHREAD_MUTEX_INITIALIZER;
-
-static email_active_task_t _active_task_pool[MAX_ACTIVE_TASK];
-static thread_t _thread_task_manager_loop;
-static int _task_manager_loop_availability = 1;
-/*- variables - end ----------------------------------------------------------*/
-static int emcore_insert_task_to_active_task_pool(int input_task_slot_index, int input_task_id, email_task_type_t input_task_type, thread_t input_thread_id);
-static int emcore_remove_task_from_active_task_pool(int input_task_id);
-static int emcore_find_available_slot_in_active_task_pool(int *result_index);
-static int emcore_update_task_status_on_task_table(char *multi_user_name, int input_task_id, email_task_status_type_t task_status);
-static int emcore_get_task_handler_reference(email_task_type_t input_task_type, email_task_handler_t **output_task_handler);
-
-/*- task handlers helpers - begin --------------------------------------------*/
-static int emcore_initialize_async_task_handler(email_task_t *input_task)
-{
- EM_DEBUG_FUNC_BEGIN("input_task [%p]", input_task);
- int err = EMAIL_ERROR_NONE;
-
- if(input_task == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- /* insert task to _active_task_pool */
- emcore_insert_task_to_active_task_pool(input_task->active_task_id
- , input_task->task_id
- , input_task->task_type
- , THREAD_SELF());
-
- /* send notification for 'task start */
- if( (err = emcore_send_task_status_signal(input_task->task_type, input_task->task_id, EMAIL_TASK_STATUS_STARTED, EMAIL_ERROR_NONE, 0)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emcore_send_task_status_signal failed [%d]", err);
- goto FINISH_OFF;
- }
-
-FINISH_OFF:
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-static int emcore_finalize_async_task_handler(email_task_t *input_task, int input_error_code)
-{
- EM_DEBUG_FUNC_BEGIN("input_task [%p] input_error_code [%d]",input_task ,input_error_code);
- int err = EMAIL_ERROR_NONE;
- email_task_status_type_t task_status = EMAIL_TASK_STATUS_FINISHED;
-
- if(input_task == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- if(input_error_code != EMAIL_ERROR_NONE) {
- task_status = EMAIL_TASK_STATUS_FAILED;
- }
-
- /* remove task from task table */
- if( (err = emcore_remove_task_from_task_table(NULL, input_task->task_id)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emcore_remove_task_from_active_task_pool failed [%d]", err);
- goto FINISH_OFF;
- }
-
- /* remove task id from active task id array */
- if( (err = emcore_remove_task_from_active_task_pool(input_task->task_id)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emcore_remove_task_from_active_task_pool failed [%d]", err);
- goto FINISH_OFF;
- }
-
- /* send signal for 'task finish or failure */
- if( (err = emcore_send_task_status_signal(input_task->task_type, input_task->task_id, task_status, input_error_code, 0)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emcore_send_task_status_signal failed [%d]", err);
- goto FINISH_OFF;
- }
-
- ENTER_CRITICAL_SECTION(_task_available_lock);
- WAKE_CONDITION_VARIABLE(_task_available_signal);
- LEAVE_CRITICAL_SECTION(_task_available_lock);
-
-FINISH_OFF:
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC void* emcore_default_async_task_handler(void *input_param)
-{
- EM_DEBUG_FUNC_BEGIN("intput_param [%p]", input_param);
- int err = EMAIL_ERROR_NONE;
- email_task_t *task = input_param;
- email_task_handler_t *task_handler = NULL;
- void *decoded_task_parameter = NULL;
-
- if((err = emcore_initialize_async_task_handler(task)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emcore_initialize_async_task_handler failed. [%d]", err);
- goto FINISH_OFF;
- }
-
- /* create a thread to do this task */
- if((err = emcore_get_task_handler_reference(task->task_type, &task_handler)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_LOG("emcore_get_task_handler_reference returns [%d]", err);
- }
- else {
- /* Decode parameter */
- emcore_decode_task_parameter(task->task_type, task->task_parameter, task->task_parameter_length, &decoded_task_parameter);
- task_handler->task_handler_function(decoded_task_parameter);
- }
-
-FINISH_OFF:
- emcore_finalize_async_task_handler(task, err);
-
- EM_SAFE_FREE(decoded_task_parameter);
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return NULL;
-}
-
-INTERNAL_FUNC void* emcore_default_sync_task_handler(void *intput_param)
-{
- EM_DEBUG_FUNC_BEGIN("intput_param [%p]", intput_param);
- int err = EMAIL_ERROR_NONE;
- email_task_t *task = intput_param;
- email_task_handler_t *task_handler = NULL;
- void *decoded_task_parameter = NULL;
-
- /* create a thread to do this task */
- if((err = emcore_get_task_handler_reference(task->task_type, &task_handler)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_LOG("emcore_get_task_handler_reference returns [%d]", err);
- }
- else {
- /* Decode parameter */
- emcore_decode_task_parameter(task->task_type, task->task_parameter, task->task_parameter_length, &decoded_task_parameter);
- err = (int)task_handler->task_handler_function(decoded_task_parameter);
- }
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return (void*)err;
-}
-/*- task handlers helpers - end --------------------------------------------*/
-
-int _task_handler_array_size;
-email_task_handler_t **_task_handler_array;
-
-static int emcore_register_task_handler(email_task_type_t input_task_type, void* (*input_task_handler)(void *), int (*input_task_parameter_encoder)(void*,char**,int*), int (*input_task_parameter_decoder)(char*,int,void**))
-{
- EM_DEBUG_FUNC_BEGIN("input_task_type [%d] input_task_handler [%p] input_task_parameter_encoder [%p] input_task_parameter_decoder [%p]", input_task_type, input_task_handler, input_task_parameter_encoder, input_task_parameter_decoder);
- int err = EMAIL_ERROR_NONE;
- email_task_handler_t *new_task_handler = NULL;
-
- new_task_handler = malloc(sizeof(email_task_handler_t));
-
- if (new_task_handler == NULL) {
- err = EMAIL_ERROR_OUT_OF_MEMORY;
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
- goto FINISH_OFF;
- }
-
- new_task_handler->task_type = input_task_type;
- new_task_handler->task_handler_function = input_task_handler;
- new_task_handler->task_parameter_encoder = input_task_parameter_encoder;
- new_task_handler->task_parameter_decoder = input_task_parameter_decoder;
-
- _task_handler_array_size++;
-
- if (_task_handler_array) {
- _task_handler_array = realloc(_task_handler_array, sizeof(email_task_handler_t*) * _task_handler_array_size);
- }
- else {
- _task_handler_array = malloc(sizeof(email_task_handler_t*) * _task_handler_array_size);
- }
-
- if (_task_handler_array == NULL) {
- err = EMAIL_ERROR_OUT_OF_MEMORY;
- EM_SAFE_FREE(new_task_handler);
- goto FINISH_OFF;
- }
-
- _task_handler_array[_task_handler_array_size - 1] = new_task_handler;
-
-FINISH_OFF:
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC int emcore_init_task_handler_array()
-{
- EM_DEBUG_FUNC_BEGIN();
-
- if (_task_handler_array == NULL) {
- _task_handler_array = NULL;
- _task_handler_array_size = 0;
-
- REGISTER_TASK_BINDER(EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT);
- REGISTER_TASK_BINDER(EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX);
- REGISTER_TASK_BINDER(EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL);
- REGISTER_TASK_BINDER(EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL);
- REGISTER_TASK_BINDER(EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE);
- }
-
- EM_DEBUG_FUNC_END();
- return EMAIL_ERROR_NONE;
-}
-
-INTERNAL_FUNC int emcore_free_task_handler_array()
-{
- EM_DEBUG_FUNC_BEGIN();
-
- int i = 0;
-
- for(i = 0; i < _task_handler_array_size; i++) {
- EM_SAFE_FREE (_task_handler_array[i]);
- }
-
- EM_SAFE_FREE (_task_handler_array);
- _task_handler_array_size = 0;
-
- EM_DEBUG_FUNC_END();
- return EMAIL_ERROR_NONE;
-}
-
-static int emcore_get_task_handler_reference(email_task_type_t input_task_type, email_task_handler_t **output_task_handler)
-{
- EM_DEBUG_FUNC_BEGIN("input_task_type [%d] output_task_handler [%p]", input_task_type, output_task_handler);
- int i = 0;
- int err = EMAIL_ERROR_NONE;
-
- if (output_task_handler == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- *output_task_handler = NULL;
- for (i = 0; i < _task_handler_array_size; i++) {
- if (_task_handler_array[i]->task_type == input_task_type) {
- *output_task_handler = _task_handler_array[i];
- break;
- }
- }
-
- if (*output_task_handler == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_TASK_BINDER_NOT_FOUND");
- err = EMAIL_ERROR_TASK_BINDER_NOT_FOUND;
- goto FINISH_OFF;
- }
-
-FINISH_OFF:
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC int emcore_encode_task_parameter(email_task_type_t input_task_type, void *input_task_parameter_struct, char **output_byte_stream, int *output_stream_size)
-{
- EM_DEBUG_FUNC_BEGIN("input_task_type [%d] input_task_parameter_struct [%p] output_byte_stream [%p] output_stream_size [%p]", input_task_type, input_task_parameter_struct, output_byte_stream, output_stream_size);
- int err = EMAIL_ERROR_NONE;
- email_task_handler_t *task_handler = NULL;
- int (*task_parameter_encoder)(void*, char**, int*);
-
- if (input_task_parameter_struct == NULL || output_byte_stream == NULL || output_stream_size == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- if ((err = emcore_get_task_handler_reference(input_task_type, &task_handler)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emcore_get_task_handler_reference failed [%d]", err);
- goto FINISH_OFF;
- }
-
- task_parameter_encoder = task_handler->task_parameter_encoder;
-
- if ((err = task_parameter_encoder(input_task_parameter_struct, output_byte_stream, output_stream_size)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("task_parameter_encoder failed [%d]", err);
- goto FINISH_OFF;
- }
-
-FINISH_OFF:
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC int emcore_decode_task_parameter(email_task_type_t input_task_type, char *input_byte_stream, int input_stream_size, void **output_task_parameter_struct)
-{
- EM_DEBUG_FUNC_BEGIN("input_task_type [%d] input_byte_stream [%p] input_stream_size [%d] output_task_parameter_struct [%p]", input_task_type, input_byte_stream, input_stream_size, output_task_parameter_struct);
- int err = EMAIL_ERROR_NONE;
- email_task_handler_t *task_handler = NULL;
- int (*task_parameter_decoder)(char*, int, void**);
-
- if (input_byte_stream == NULL || output_task_parameter_struct == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- if ((err = emcore_get_task_handler_reference(input_task_type, &task_handler)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emcore_get_task_handler_reference failed [%d]", err);
- goto FINISH_OFF;
- }
-
- task_parameter_decoder = task_handler->task_parameter_decoder;
-
+/*
+* email-service
+*
+* Copyright (c) 2012 - 2013 Samsung Electronics Co., Ltd. All rights reserved.
+*
+* Contact: Kyuho Jo <kyuho.jo@samsung.com>, Sunghyun Kwon <sh0701.kwon@samsung.com>
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+
+/*
+ * email-core-task-manager.c
+ *
+ * Created on: 2012. 11. 1.
+ * Author: kyuho.jo@samsung.com
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <pthread.h>
+#include <dbus/dbus.h>
+
+#include "email-internal-types.h"
+#include "email-utilities.h"
+#include "email-core-tasks.h"
+#include "email-core-task-manager.h"
+#include "email-core-signal.h"
+#include "email-core-global.h"
+#include "email-core-utils.h"
+#include "email-debug-log.h"
+
+/* TODO : implement a function for removing a task from task pool */
+/* TODO : after fetching a task from DB, update status of the task. */
+
+
+#define REGISTER_TASK_BINDER(TASK_NAME) emcore_register_task_handler(TASK_NAME, task_handler_##TASK_NAME, email_encode_task_parameter_##TASK_NAME, email_decode_task_parameter_##TASK_NAME)
+
+/*- variables - begin --------------------------------------------------------*/
+static pthread_cond_t _task_available_signal = PTHREAD_COND_INITIALIZER;
+static pthread_mutex_t _task_available_lock = PTHREAD_MUTEX_INITIALIZER;
+static pthread_mutex_t _task_manager_loop_lock = PTHREAD_MUTEX_INITIALIZER;
+static pthread_mutex_t _active_task_pool_lock = PTHREAD_MUTEX_INITIALIZER;
+
+static email_active_task_t _active_task_pool[MAX_ACTIVE_TASK];
+static thread_t _thread_task_manager_loop;
+static int _task_manager_loop_availability = 1;
+/*- variables - end ----------------------------------------------------------*/
+static int emcore_insert_task_to_active_task_pool(int input_task_slot_index, int input_task_id, email_task_type_t input_task_type, thread_t input_thread_id);
+static int emcore_remove_task_from_active_task_pool(int input_task_id);
+static int emcore_find_available_slot_in_active_task_pool(int *result_index);
+static int emcore_update_task_status_on_task_table(char *multi_user_name, int input_task_id, email_task_status_type_t task_status);
+static int emcore_get_task_handler_reference(email_task_type_t input_task_type, email_task_handler_t **output_task_handler);
+
+/*- task handlers helpers - begin --------------------------------------------*/
+static int emcore_initialize_async_task_handler(email_task_t *input_task)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task [%p]", input_task);
+ int err = EMAIL_ERROR_NONE;
+
+ if(input_task == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ /* insert task to _active_task_pool */
+ emcore_insert_task_to_active_task_pool(input_task->active_task_id
+ , input_task->task_id
+ , input_task->task_type
+ , THREAD_SELF());
+
+ /* send notification for 'task start */
+ if( (err = emcore_send_task_status_signal(input_task->task_type, input_task->task_id, EMAIL_TASK_STATUS_STARTED, EMAIL_ERROR_NONE, 0)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emcore_send_task_status_signal failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+FINISH_OFF:
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+static int emcore_finalize_async_task_handler(email_task_t *input_task, int input_error_code)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task [%p] input_error_code [%d]",input_task ,input_error_code);
+ int err = EMAIL_ERROR_NONE;
+ email_task_status_type_t task_status = EMAIL_TASK_STATUS_FINISHED;
+
+ if(input_task == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ if(input_error_code != EMAIL_ERROR_NONE) {
+ task_status = EMAIL_TASK_STATUS_FAILED;
+ }
+
+ /* remove task from task table */
+ if( (err = emcore_remove_task_from_task_table(NULL, input_task->task_id)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emcore_remove_task_from_active_task_pool failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+ /* remove task id from active task id array */
+ if( (err = emcore_remove_task_from_active_task_pool(input_task->task_id)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emcore_remove_task_from_active_task_pool failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+ /* send signal for 'task finish or failure */
+ if( (err = emcore_send_task_status_signal(input_task->task_type, input_task->task_id, task_status, input_error_code, 0)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emcore_send_task_status_signal failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+ ENTER_CRITICAL_SECTION(_task_available_lock);
+ WAKE_CONDITION_VARIABLE(_task_available_signal);
+ LEAVE_CRITICAL_SECTION(_task_available_lock);
+
+FINISH_OFF:
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC void* emcore_default_async_task_handler(void *input_param)
+{
+ EM_DEBUG_FUNC_BEGIN("intput_param [%p]", input_param);
+ int err = EMAIL_ERROR_NONE;
+ email_task_t *task = input_param;
+ email_task_handler_t *task_handler = NULL;
+ void *decoded_task_parameter = NULL;
+
+ if((err = emcore_initialize_async_task_handler(task)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emcore_initialize_async_task_handler failed. [%d]", err);
+ goto FINISH_OFF;
+ }
+
+ /* create a thread to do this task */
+ if ((err = emcore_get_task_handler_reference(task->task_type, &task_handler)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_LOG("emcore_get_task_handler_reference returns [%d]", err);
+ }
+ else {
+ /* Decode parameter */
+ emcore_decode_task_parameter(task->task_type,
+ task->task_parameter,
+ task->task_parameter_length,
+ &decoded_task_parameter);
+
+ task_handler->task_handler_function(decoded_task_parameter);
+ }
+
+FINISH_OFF:
+ emcore_finalize_async_task_handler(task, err);
+
+ EM_SAFE_FREE(decoded_task_parameter);
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return NULL;
+}
+
+INTERNAL_FUNC int emcore_default_sync_task_handler(void *intput_param)
+{
+ EM_DEBUG_FUNC_BEGIN("intput_param [%p]", intput_param);
+ int err = EMAIL_ERROR_NONE;
+ int *return_err = NULL;
+ email_task_t *task = intput_param;
+ email_task_handler_t *task_handler = NULL;
+ void *decoded_task_parameter = NULL;
+
+ /* create a thread to do this task */
+ if ((err = emcore_get_task_handler_reference(task->task_type, &task_handler)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_LOG("emcore_get_task_handler_reference returns [%d]", err);
+ } else {
+ /* Decode parameter */
+ emcore_decode_task_parameter(task->task_type,
+ task->task_parameter,
+ task->task_parameter_length,
+ &decoded_task_parameter);
+
+ return_err = (int *)task_handler->task_handler_function(decoded_task_parameter);
+ }
+
+ if (return_err) {
+ err = *return_err;
+ free(return_err);
+ }
+
+ EM_SAFE_FREE(decoded_task_parameter);
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+/*- task handlers helpers - end --------------------------------------------*/
+
+int _task_handler_array_size;
+email_task_handler_t **_task_handler_array;
+
+static int emcore_register_task_handler(email_task_type_t input_task_type,
+ void* (*input_task_handler)(void *),
+ int (*input_task_parameter_encoder)(void*,char**,int*),
+ int (*input_task_parameter_decoder)(char*,int,void**))
+{
+ EM_DEBUG_FUNC_BEGIN("input_task_type [%d] input_task_handler [%p] "
+ "input_task_parameter_encoder [%p] input_task_parameter_decoder [%p]",
+ input_task_type, input_task_handler,
+ input_task_parameter_encoder, input_task_parameter_decoder);
+
+ int err = EMAIL_ERROR_NONE;
+ email_task_handler_t *new_task_handler = NULL;
+
+ new_task_handler = malloc(sizeof(email_task_handler_t));
+
+ if (new_task_handler == NULL) {
+ err = EMAIL_ERROR_OUT_OF_MEMORY;
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
+ goto FINISH_OFF;
+ }
+
+ new_task_handler->task_type = input_task_type;
+ new_task_handler->task_handler_function = input_task_handler;
+ new_task_handler->task_parameter_encoder = input_task_parameter_encoder;
+ new_task_handler->task_parameter_decoder = input_task_parameter_decoder;
+
+ _task_handler_array_size++;
+
+ if (_task_handler_array) {
+ _task_handler_array = realloc(_task_handler_array, sizeof(email_task_handler_t*) * _task_handler_array_size);
+ }
+ else {
+ _task_handler_array = malloc(sizeof(email_task_handler_t*) * _task_handler_array_size);
+ }
+
+ if (_task_handler_array == NULL) {
+ err = EMAIL_ERROR_OUT_OF_MEMORY;
+ EM_SAFE_FREE(new_task_handler);
+ goto FINISH_OFF;
+ }
+
+ _task_handler_array[_task_handler_array_size - 1] = new_task_handler;
+
+FINISH_OFF:
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC int emcore_init_task_handler_array()
+{
+ EM_DEBUG_FUNC_BEGIN();
+
+ if (_task_handler_array == NULL) {
+ _task_handler_array = NULL;
+ _task_handler_array_size = 0;
+
+ REGISTER_TASK_BINDER(EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT);
+ REGISTER_TASK_BINDER(EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX);
+ REGISTER_TASK_BINDER(EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL);
+ REGISTER_TASK_BINDER(EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL);
+ REGISTER_TASK_BINDER(EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE);
+ }
+
+ EM_DEBUG_FUNC_END();
+ return EMAIL_ERROR_NONE;
+}
+
+INTERNAL_FUNC int emcore_free_task_handler_array()
+{
+ EM_DEBUG_FUNC_BEGIN();
+
+ int i = 0;
+
+ for(i = 0; i < _task_handler_array_size; i++) {
+ EM_SAFE_FREE (_task_handler_array[i]);
+ }
+
+ EM_SAFE_FREE (_task_handler_array);
+ _task_handler_array_size = 0;
+
+ EM_DEBUG_FUNC_END();
+ return EMAIL_ERROR_NONE;
+}
+
+static int emcore_get_task_handler_reference(email_task_type_t input_task_type, email_task_handler_t **output_task_handler)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task_type [%d] output_task_handler [%p]", input_task_type, output_task_handler);
+ int i = 0;
+ int err = EMAIL_ERROR_NONE;
+
+ if (output_task_handler == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ *output_task_handler = NULL;
+ for (i = 0; i < _task_handler_array_size; i++) {
+ if (_task_handler_array[i]->task_type == input_task_type) {
+ *output_task_handler = _task_handler_array[i];
+ break;
+ }
+ }
+
+ if (*output_task_handler == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_TASK_BINDER_NOT_FOUND");
+ err = EMAIL_ERROR_TASK_BINDER_NOT_FOUND;
+ goto FINISH_OFF;
+ }
+
+FINISH_OFF:
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC int emcore_encode_task_parameter(email_task_type_t input_task_type, void *input_task_parameter_struct, char **output_byte_stream, int *output_stream_size)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task_type [%d] input_task_parameter_struct [%p] output_byte_stream [%p] output_stream_size [%p]", input_task_type, input_task_parameter_struct, output_byte_stream, output_stream_size);
+ int err = EMAIL_ERROR_NONE;
+ email_task_handler_t *task_handler = NULL;
+ int (*task_parameter_encoder)(void*, char**, int*);
+
+ if (input_task_parameter_struct == NULL || output_byte_stream == NULL || output_stream_size == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ if ((err = emcore_get_task_handler_reference(input_task_type, &task_handler)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emcore_get_task_handler_reference failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+ task_parameter_encoder = task_handler->task_parameter_encoder;
+
+ if ((err = task_parameter_encoder(input_task_parameter_struct, output_byte_stream, output_stream_size)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("task_parameter_encoder failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+FINISH_OFF:
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC int emcore_decode_task_parameter(email_task_type_t input_task_type, char *input_byte_stream, int input_stream_size, void **output_task_parameter_struct)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task_type [%d] input_byte_stream [%p] input_stream_size [%d] output_task_parameter_struct [%p]", input_task_type, input_byte_stream, input_stream_size, output_task_parameter_struct);
+ int err = EMAIL_ERROR_NONE;
+ email_task_handler_t *task_handler = NULL;
+ int (*task_parameter_decoder)(char*, int, void**);
+
+ if (input_byte_stream == NULL || output_task_parameter_struct == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ if ((err = emcore_get_task_handler_reference(input_task_type, &task_handler)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emcore_get_task_handler_reference failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+ task_parameter_decoder = task_handler->task_parameter_decoder;
+
if ((err = task_parameter_decoder(input_byte_stream,
input_stream_size,
output_task_parameter_struct)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("task_parameter_decoder failed [%d]", err);
- goto FINISH_OFF;
- }
-
-FINISH_OFF:
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-int emcore_fetch_task_from_task_pool(email_task_t **output_task)
-{
- EM_DEBUG_FUNC_BEGIN("output_task [%p]", output_task);
- int err = EMAIL_ERROR_NONE;
- int output_task_count;
-
+ EM_DEBUG_EXCEPTION("task_parameter_decoder failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+FINISH_OFF:
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+int emcore_fetch_task_from_task_pool(email_task_t **output_task)
+{
+ EM_DEBUG_FUNC_BEGIN("output_task [%p]", output_task);
+ int err = EMAIL_ERROR_NONE;
+ int output_task_count;
+
if ((err = emstorage_query_task(NULL,
"WHERE task_status == 1",
"ORDER BY date_time ASC, task_priority ASC LIMIT 0, 1",
output_task,
&output_task_count)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emstorage_query_task failed [%d]", err);
- goto FINISH_OFF;
- }
-
-FINISH_OFF:
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-
-/*-Task manager loop - begin -------------------------------------------------------------*/
-
-
-static int emcore_insert_task_to_active_task_pool(int input_task_slot_index, int input_task_id, email_task_type_t input_task_type, thread_t input_thread_id)
-{
- EM_DEBUG_FUNC_BEGIN("input_task_slot_index [%d] input_task_id [%d] input_task_type [%d] input_thread_id [%d]", input_task_slot_index, input_task_id, input_task_type, input_thread_id);
- int err = EMAIL_ERROR_NONE;
-
- ENTER_CRITICAL_SECTION(_active_task_pool_lock);
- _active_task_pool[input_task_slot_index].task_id = input_task_id;
- _active_task_pool[input_task_slot_index].task_type = input_task_type;
- _active_task_pool[input_task_slot_index].thread_id = input_thread_id;
- LEAVE_CRITICAL_SECTION(_active_task_pool_lock);
-
- EM_DEBUG_LOG("_active_task_pool[%d].task_id [%d]", input_task_slot_index, _active_task_pool[input_task_slot_index].task_id);
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-static int emcore_remove_task_from_active_task_pool(int input_task_id)
-{
- EM_DEBUG_FUNC_BEGIN(" input_task_id [%d]", input_task_id);
- int err = EMAIL_ERROR_NONE;
- int i = 0;
-
- ENTER_CRITICAL_SECTION(_active_task_pool_lock);
- for(i = 0; i < MAX_ACTIVE_TASK; i++) {
- if(_active_task_pool[i].task_id == input_task_id) {
- _active_task_pool[i].task_id = 0;
- _active_task_pool[i].task_type = 0;
- _active_task_pool[i].thread_id = 0;
- break;
- }
- }
- LEAVE_CRITICAL_SECTION(_active_task_pool_lock);
-
- if(i >= MAX_ACTIVE_TASK) {
- EM_DEBUG_LOG("couldn't find proper task in active task pool [%d]", input_task_id);
- err = EMAIL_ERROR_TASK_NOT_FOUND;
- }
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC int emcore_get_active_task_by_thread_id(thread_t input_thread_id, email_active_task_t **output_active_task)
-{
- EM_DEBUG_FUNC_BEGIN(" input_thread_id [%d] output_active_task [%p]", input_thread_id, output_active_task);
- int err = EMAIL_ERROR_NONE;
- int i = 0;
-
- if (output_active_task == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- for(i = 0; i < MAX_ACTIVE_TASK; i++) {
- if(_active_task_pool[i].thread_id == input_thread_id) {
- *output_active_task = _active_task_pool + i;
- break;
- }
- }
-
- if(i >= MAX_ACTIVE_TASK) {
- EM_DEBUG_LOG("couldn't find proper task in active task pool [%d]", input_thread_id);
- err = EMAIL_ERROR_TASK_NOT_FOUND;
- }
-
-FINISH_OFF:
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-
-static int emcore_find_available_slot_in_active_task_pool(int *result_index)
-{
- EM_DEBUG_FUNC_BEGIN("result_index [%p]", result_index);
- int i = 0;
- int err = EMAIL_ERROR_NONE;
-
- if (result_index == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- ENTER_CRITICAL_SECTION(_active_task_pool_lock);
- for(i = 0; i < MAX_ACTIVE_TASK; i++) {
- if(_active_task_pool[i].task_id == 0) {
- break;
- }
- }
-
- if(i >= MAX_ACTIVE_TASK) {
- EM_DEBUG_EXCEPTION("There is no available task slot");
- err = EMAIL_NO_AVAILABLE_TASK_SLOT;
- }
- else {
- _active_task_pool[i].task_id = -1;
- *result_index = i;
- }
- LEAVE_CRITICAL_SECTION(_active_task_pool_lock);
-
-FINISH_OFF :
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-void* thread_func_task_manager_loop(void *arg)
-{
- EM_DEBUG_FUNC_BEGIN();
- int err = EMAIL_ERROR_NONE;
- int thread_error;
- int available_slot_index = 0;
- email_task_t *new_task = NULL;
-
- /* while loop */
- while (_task_manager_loop_availability) {
- /* fetch task from DB */
- if( ((err = emcore_fetch_task_from_task_pool(&new_task)) == EMAIL_ERROR_NONE) &&
- ((err = emcore_find_available_slot_in_active_task_pool(&available_slot_index)) == EMAIL_ERROR_NONE) ) {
-
- /* update task status as STARTED */
- if((err = emcore_update_task_status_on_task_table(NULL, new_task->task_id, EMAIL_TASK_STATUS_STARTED)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emcore_update_task_status_on_task_table failed [%d]", err);
- }
- new_task->active_task_id = available_slot_index;
-
- /* create a thread to do this task */
- THREAD_CREATE(new_task->thread_id, emcore_default_async_task_handler, new_task, thread_error);
- EM_DEBUG_LOG("pthread_create returns [%d]", thread_error);
-
- /* new_task and task_parameter will be free in task handler. */
+ EM_DEBUG_EXCEPTION("emstorage_query_task failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+FINISH_OFF:
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+
+/*-Task manager loop - begin -------------------------------------------------------------*/
+
+
+static int emcore_insert_task_to_active_task_pool(int input_task_slot_index, int input_task_id, email_task_type_t input_task_type, thread_t input_thread_id)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task_slot_index [%d] input_task_id [%d] input_task_type [%d] input_thread_id [%d]", input_task_slot_index, input_task_id, input_task_type, input_thread_id);
+ int err = EMAIL_ERROR_NONE;
+
+ ENTER_CRITICAL_SECTION(_active_task_pool_lock);
+ _active_task_pool[input_task_slot_index].task_id = input_task_id;
+ _active_task_pool[input_task_slot_index].task_type = input_task_type;
+ _active_task_pool[input_task_slot_index].thread_id = input_thread_id;
+ LEAVE_CRITICAL_SECTION(_active_task_pool_lock);
+
+ EM_DEBUG_LOG("_active_task_pool[%d].task_id [%d]", input_task_slot_index, _active_task_pool[input_task_slot_index].task_id);
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+static int emcore_remove_task_from_active_task_pool(int input_task_id)
+{
+ EM_DEBUG_FUNC_BEGIN(" input_task_id [%d]", input_task_id);
+ int err = EMAIL_ERROR_NONE;
+ int i = 0;
+
+ ENTER_CRITICAL_SECTION(_active_task_pool_lock);
+ for(i = 0; i < MAX_ACTIVE_TASK; i++) {
+ if(_active_task_pool[i].task_id == input_task_id) {
+ _active_task_pool[i].task_id = 0;
+ _active_task_pool[i].task_type = 0;
+ _active_task_pool[i].thread_id = 0;
+ break;
+ }
+ }
+ LEAVE_CRITICAL_SECTION(_active_task_pool_lock);
+
+ if(i >= MAX_ACTIVE_TASK) {
+ EM_DEBUG_LOG("couldn't find proper task in active task pool [%d]", input_task_id);
+ err = EMAIL_ERROR_TASK_NOT_FOUND;
+ }
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC int emcore_get_active_task_by_thread_id(thread_t input_thread_id, email_active_task_t **output_active_task)
+{
+ EM_DEBUG_FUNC_BEGIN(" input_thread_id [%d] output_active_task [%p]", input_thread_id, output_active_task);
+ int err = EMAIL_ERROR_NONE;
+ int i = 0;
+
+ if (output_active_task == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ for(i = 0; i < MAX_ACTIVE_TASK; i++) {
+ if(_active_task_pool[i].thread_id == input_thread_id) {
+ *output_active_task = _active_task_pool + i;
+ break;
+ }
+ }
+
+ if(i >= MAX_ACTIVE_TASK) {
+ EM_DEBUG_LOG("couldn't find proper task in active task pool [%d]", input_thread_id);
+ err = EMAIL_ERROR_TASK_NOT_FOUND;
+ }
+
+FINISH_OFF:
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+
+static int emcore_find_available_slot_in_active_task_pool(int *result_index)
+{
+ EM_DEBUG_FUNC_BEGIN("result_index [%p]", result_index);
+ int i = 0;
+ int err = EMAIL_ERROR_NONE;
+
+ if (result_index == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ ENTER_CRITICAL_SECTION(_active_task_pool_lock);
+ for(i = 0; i < MAX_ACTIVE_TASK; i++) {
+ if(_active_task_pool[i].task_id == 0) {
+ break;
+ }
+ }
+
+ if(i >= MAX_ACTIVE_TASK) {
+ EM_DEBUG_EXCEPTION("There is no available task slot");
+ err = EMAIL_NO_AVAILABLE_TASK_SLOT;
+ }
+ else {
+ _active_task_pool[i].task_id = -1;
+ *result_index = i;
+ }
+ LEAVE_CRITICAL_SECTION(_active_task_pool_lock);
+
+FINISH_OFF :
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+void* thread_func_task_manager_loop(void *arg)
+{
+ EM_DEBUG_FUNC_BEGIN();
+ int err = EMAIL_ERROR_NONE;
+ int thread_error;
+ int available_slot_index = 0;
+ email_task_t *new_task = NULL;
+
+ /* while loop */
+ while (_task_manager_loop_availability) {
+ /* fetch task from DB */
+ if( ((err = emcore_fetch_task_from_task_pool(&new_task)) == EMAIL_ERROR_NONE) &&
+ ((err = emcore_find_available_slot_in_active_task_pool(&available_slot_index)) == EMAIL_ERROR_NONE) ) {
+
+ /* update task status as STARTED */
+ if((err = emcore_update_task_status_on_task_table(NULL, new_task->task_id, EMAIL_TASK_STATUS_STARTED)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emcore_update_task_status_on_task_table failed [%d]", err);
+ }
+ new_task->active_task_id = available_slot_index;
+
+ /* create a thread to do this task */
+ THREAD_CREATE(new_task->thread_id, emcore_default_async_task_handler, new_task, thread_error);
+ EM_DEBUG_LOG("pthread_create returns [%d]", thread_error);
+
+ /* new_task and task_parameter will be free in task handler. */
EM_SAFE_FREE(new_task->task_parameter);
EM_SAFE_FREE(new_task);
- }
- else {
- /* If there is no task or no available slot, sleep until someone wake you up. */
- /* Wake up case 1 : by emcore_add_task_to_task_table */
- /* Wake up case 2 : when some task terminated */
- ENTER_CRITICAL_SECTION(_task_available_lock);
- SLEEP_CONDITION_VARIABLE(_task_available_signal, _task_available_lock);
- LEAVE_CRITICAL_SECTION(_task_available_lock);
- EM_DEBUG_LOG("thread_func_task_manager_loop wake up!");
- }
- }
-
- EM_DEBUG_FUNC_END();
- return NULL;
-}
-
-INTERNAL_FUNC int emcore_start_task_manager_loop()
-{
- EM_DEBUG_FUNC_BEGIN();
- int thread_error;
- int err = EMAIL_ERROR_NONE;
-
- memset(&_active_task_pool, 0, sizeof(email_active_task_t) * MAX_ACTIVE_TASK);
-
- if (_thread_task_manager_loop) {
- EM_DEBUG_EXCEPTION("service thread is already running...");
- err = EMAIL_ERROR_ALREADY_INITIALIZED;
- goto FINISH_OFF;
- }
-
- _task_manager_loop_availability = 10;
-
- /* create thread */
- THREAD_CREATE(_thread_task_manager_loop, thread_func_task_manager_loop, NULL, thread_error);
-
- if (thread_error != 0) {
- EM_DEBUG_EXCEPTION("cannot create thread [%d]", thread_error);
- err = EMAIL_ERROR_SYSTEM_FAILURE;
- goto FINISH_OFF;
- }
-
-FINISH_OFF :
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC int emcore_stop_task_manager_loop()
-{
- EM_DEBUG_FUNC_BEGIN();
-
- int err = EMAIL_ERROR_NONE;
-
- if (!_thread_task_manager_loop) {
- EM_DEBUG_LOG("_thread_task_manager_loop is NULL ");
- err = EMAIL_ERROR_UNKNOWN;
- return err;
- }
-
- /* TODO : cancel tasks */
-
- /* stop event_data loop */
- _task_manager_loop_availability = 0;
-
- ENTER_CRITICAL_SECTION(_task_manager_loop_lock);
- WAKE_CONDITION_VARIABLE(_task_available_signal);
- LEAVE_CRITICAL_SECTION(_task_manager_loop_lock);
-
- /* wait for thread finished */
- THREAD_JOIN(_thread_task_manager_loop);
-
- _thread_task_manager_loop = 0;
-
- DELETE_CRITICAL_SECTION(_task_manager_loop_lock);
- DELETE_CONDITION_VARIABLE(_task_available_signal);
-
- /* Free _active_task_pool */
-
- //FINISH_OFF :
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC int emcore_add_task_to_task_table(char *multi_user_name, email_task_type_t input_task_type, email_task_priority_t input_task_priority, char *input_task_parameter, int input_task_parameter_length, int *output_task_id)
-{
- EM_DEBUG_FUNC_BEGIN("input_task_type [%d] input_task_priority [%d] input_task_parameter [%p] input_task_parameter_length [%d] output_task_id [%p]", input_task_type, input_task_priority, input_task_parameter, input_task_parameter_length, output_task_id);
- int err = EMAIL_ERROR_NONE;
-
- if((err = emstorage_add_task(multi_user_name, input_task_type, input_task_priority, input_task_parameter, input_task_parameter_length, false, output_task_id)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emstorage_add_task failed [%d]", err);
- goto FINISH_OFF;
- }
-
- ENTER_CRITICAL_SECTION(_task_available_lock);
- WAKE_CONDITION_VARIABLE(_task_available_signal);
- LEAVE_CRITICAL_SECTION(_task_available_lock);
-
-FINISH_OFF:
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC int emcore_remove_task_from_task_table(char *multi_user_name, int input_task_id)
-{
- EM_DEBUG_FUNC_BEGIN("input_task_id [%d]", input_task_id);
- int err = EMAIL_ERROR_NONE;
-
- if((err = emstorage_delete_task(multi_user_name, input_task_id, true)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emstorage_delete_task failed [%d]", err);
- goto FINISH_OFF;
- }
-
-FINISH_OFF:
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-static int emcore_update_task_status_on_task_table(char *multi_user_name, int input_task_id, email_task_status_type_t task_status)
-{
- EM_DEBUG_FUNC_BEGIN("input_task_id [%d] task_status [%d]", input_task_id, task_status);
- int err = EMAIL_ERROR_NONE;
-
- if((err = emstorage_update_task_status(multi_user_name, input_task_id, task_status, true)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emstorage_update_task_status failed [%d]", err);
- goto FINISH_OFF;
- }
-
-FINISH_OFF:
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-/*-Task manager loop - end-------------------------------------------------------------*/
+ }
+ else {
+ /* If there is no task or no available slot, sleep until someone wake you up. */
+ /* Wake up case 1 : by emcore_add_task_to_task_table */
+ /* Wake up case 2 : when some task terminated */
+ ENTER_CRITICAL_SECTION(_task_available_lock);
+ SLEEP_CONDITION_VARIABLE(_task_available_signal, _task_available_lock);
+ LEAVE_CRITICAL_SECTION(_task_available_lock);
+ EM_DEBUG_LOG("thread_func_task_manager_loop wake up!");
+ }
+ }
+
+ EM_DEBUG_FUNC_END();
+ return NULL;
+}
+
+INTERNAL_FUNC int emcore_start_task_manager_loop()
+{
+ EM_DEBUG_FUNC_BEGIN();
+ int thread_error;
+ int err = EMAIL_ERROR_NONE;
+
+ memset(&_active_task_pool, 0, sizeof(email_active_task_t) * MAX_ACTIVE_TASK);
+
+ if (_thread_task_manager_loop) {
+ EM_DEBUG_EXCEPTION("service thread is already running...");
+ err = EMAIL_ERROR_ALREADY_INITIALIZED;
+ goto FINISH_OFF;
+ }
+
+ _task_manager_loop_availability = 10;
+
+ /* create thread */
+ THREAD_CREATE(_thread_task_manager_loop, thread_func_task_manager_loop, NULL, thread_error);
+
+ if (thread_error != 0) {
+ EM_DEBUG_EXCEPTION("cannot create thread [%d]", thread_error);
+ err = EMAIL_ERROR_SYSTEM_FAILURE;
+ goto FINISH_OFF;
+ }
+
+FINISH_OFF :
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC int emcore_stop_task_manager_loop()
+{
+ EM_DEBUG_FUNC_BEGIN();
+
+ int err = EMAIL_ERROR_NONE;
+
+ if (!_thread_task_manager_loop) {
+ EM_DEBUG_LOG("_thread_task_manager_loop is NULL ");
+ err = EMAIL_ERROR_UNKNOWN;
+ return err;
+ }
+
+ /* TODO : cancel tasks */
+
+ /* stop event_data loop */
+ _task_manager_loop_availability = 0;
+
+ ENTER_CRITICAL_SECTION(_task_manager_loop_lock);
+ WAKE_CONDITION_VARIABLE(_task_available_signal);
+ LEAVE_CRITICAL_SECTION(_task_manager_loop_lock);
+
+ /* wait for thread finished */
+ THREAD_JOIN(_thread_task_manager_loop);
+
+ _thread_task_manager_loop = 0;
+
+ DELETE_CRITICAL_SECTION(_task_manager_loop_lock);
+ DELETE_CONDITION_VARIABLE(_task_available_signal);
+
+ /* Free _active_task_pool */
+
+ //FINISH_OFF :
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC int emcore_add_task_to_task_table(char *multi_user_name, email_task_type_t input_task_type, email_task_priority_t input_task_priority, char *input_task_parameter, int input_task_parameter_length, int *output_task_id)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task_type [%d] input_task_priority [%d] input_task_parameter [%p] input_task_parameter_length [%d] output_task_id [%p]", input_task_type, input_task_priority, input_task_parameter, input_task_parameter_length, output_task_id);
+ int err = EMAIL_ERROR_NONE;
+
+ if((err = emstorage_add_task(multi_user_name, input_task_type, input_task_priority, input_task_parameter, input_task_parameter_length, false, output_task_id)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emstorage_add_task failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+ ENTER_CRITICAL_SECTION(_task_available_lock);
+ WAKE_CONDITION_VARIABLE(_task_available_signal);
+ LEAVE_CRITICAL_SECTION(_task_available_lock);
+
+FINISH_OFF:
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC int emcore_remove_task_from_task_table(char *multi_user_name, int input_task_id)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task_id [%d]", input_task_id);
+ int err = EMAIL_ERROR_NONE;
+
+ if((err = emstorage_delete_task(multi_user_name, input_task_id, true)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emstorage_delete_task failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+FINISH_OFF:
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+static int emcore_update_task_status_on_task_table(char *multi_user_name, int input_task_id, email_task_status_type_t task_status)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task_id [%d] task_status [%d]", input_task_id, task_status);
+ int err = EMAIL_ERROR_NONE;
+
+ if((err = emstorage_update_task_status(multi_user_name, input_task_id, task_status, true)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emstorage_update_task_status failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+FINISH_OFF:
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+/*-Task manager loop - end-------------------------------------------------------------*/
diff --git a/email-core/email-core-tasks.c b/email-core/email-core-tasks.c
index 2f6f209..065154d 100755
--- a/email-core/email-core-tasks.c
+++ b/email-core/email-core-tasks.c
@@ -1,119 +1,119 @@
-/*
-* email-service
-*
-* Copyright (c) 2012 - 2013 Samsung Electronics Co., Ltd. All rights reserved.
-*
-* Contact: Kyuho Jo <kyuho.jo@samsung.com>, Sunghyun Kwon <sh0701.kwon@samsung.com>
-*
-* Licensed under the Apache License, Version 2.0 (the "License");
-* you may not use this file except in compliance with the License.
-* You may obtain a copy of the License at
-*
-* http://www.apache.org/licenses/LICENSE-2.0
-*
-* Unless required by applicable law or agreed to in writing, software
-* distributed under the License is distributed on an "AS IS" BASIS,
-* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-* See the License for the specific language governing permissions and
-* limitations under the License.
-*
-*/
-/*
- * email-tasks.c
- *
- * Created on: 2012. 11. 5.
- * Author: kyuho.jo@samsung.com
- */
-#include <stdlib.h>
-#include <stdio.h>
-#include <string.h>
-
-
-#include "email-debug-log.h"
-#include "email-utilities.h"
-#include "email-internal-types.h"
-#include "email-core-tasks.h"
-#include "email-core-task-manager.h"
-#include "email-core-mail.h"
-#include "email-core-smtp.h"
-#include "email-core-mailbox-sync.h"
-#include "email-core-signal.h"
-#include "email-core-utils.h"
-#include "tpl.h"
-
-/*-------------------------------------------------------------------------------------------*/
-/* to handle EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT */
-#define task_parameter_format_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT "iiiB"
-
-INTERNAL_FUNC int email_encode_task_parameter_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT(void *input_task_parameter_struct, char **output_byte_stream, int *output_stream_size)
-{
- EM_DEBUG_FUNC_BEGIN("input_task_parameter_struct [%p] output_byte_stream [%p] output_stream_size [%p]", input_task_parameter_struct, output_byte_stream, output_stream_size);
-
- int err = EMAIL_ERROR_NONE;
- task_parameter_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT *task_parameter = input_task_parameter_struct;
- tpl_bin tb;
- tpl_node *tn = NULL;
- void *result_data = NULL;
- size_t result_data_length = 0;
-
- if (task_parameter == NULL || output_byte_stream == NULL || output_stream_size == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- tn = tpl_map(task_parameter_format_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT
- , &task_parameter->source_mailbox_id
- , &task_parameter->target_mailbox_id
- , &task_parameter->mail_id_count
- , &tb);
+/*
+* email-service
+*
+* Copyright (c) 2012 - 2013 Samsung Electronics Co., Ltd. All rights reserved.
+*
+* Contact: Kyuho Jo <kyuho.jo@samsung.com>, Sunghyun Kwon <sh0701.kwon@samsung.com>
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+*/
+/*
+ * email-tasks.c
+ *
+ * Created on: 2012. 11. 5.
+ * Author: kyuho.jo@samsung.com
+ */
+#include <stdlib.h>
+#include <stdio.h>
+#include <string.h>
+
+
+#include "email-debug-log.h"
+#include "email-utilities.h"
+#include "email-internal-types.h"
+#include "email-core-tasks.h"
+#include "email-core-task-manager.h"
+#include "email-core-mail.h"
+#include "email-core-smtp.h"
+#include "email-core-mailbox-sync.h"
+#include "email-core-signal.h"
+#include "email-core-utils.h"
+#include "tpl.h"
+
+/*-------------------------------------------------------------------------------------------*/
+/* to handle EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT */
+#define task_parameter_format_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT "iiiB"
+
+INTERNAL_FUNC int email_encode_task_parameter_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT(void *input_task_parameter_struct, char **output_byte_stream, int *output_stream_size)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task_parameter_struct [%p] output_byte_stream [%p] output_stream_size [%p]", input_task_parameter_struct, output_byte_stream, output_stream_size);
+
+ int err = EMAIL_ERROR_NONE;
+ task_parameter_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT *task_parameter = input_task_parameter_struct;
+ tpl_bin tb;
+ tpl_node *tn = NULL;
+ void *result_data = NULL;
+ size_t result_data_length = 0;
+
+ if (task_parameter == NULL || output_byte_stream == NULL || output_stream_size == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ tn = tpl_map(task_parameter_format_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT
+ , &task_parameter->source_mailbox_id
+ , &task_parameter->target_mailbox_id
+ , &task_parameter->mail_id_count
+ , &tb);
if (tn == NULL) {
EM_DEBUG_EXCEPTION("tpl_map failed");
err = EMAIL_ERROR_SYSTEM_FAILURE;
goto FINISH_OFF;
}
- tb.sz = sizeof(int) * task_parameter->mail_id_count;
- tb.addr = task_parameter->mail_id_array;
- tpl_pack(tn, 0);
- tpl_dump(tn, TPL_MEM, &result_data, &result_data_length);
- tpl_free(tn);
-
- *output_byte_stream = result_data;
- *output_stream_size = result_data_length;
-
-FINISH_OFF:
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC int email_decode_task_parameter_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT(char *input_byte_stream, int input_stream_size, void **output_task_parameter_struct)
-{
- EM_DEBUG_FUNC_BEGIN("input_byte_stream [%p] input_stream_size [%d] output_task_parameter_struct [%p]", input_byte_stream, input_stream_size, output_task_parameter_struct);
- int err = EMAIL_ERROR_NONE;
- tpl_bin tb;
- tpl_node *tn = NULL;
- task_parameter_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT *task_parameter = NULL;
-
- if (input_byte_stream == NULL || input_stream_size == 0 || output_task_parameter_struct == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- task_parameter = em_malloc(sizeof(task_parameter_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT));
+ tb.sz = sizeof(int) * task_parameter->mail_id_count;
+ tb.addr = task_parameter->mail_id_array;
+ tpl_pack(tn, 0);
+ tpl_dump(tn, TPL_MEM, &result_data, &result_data_length);
+ tpl_free(tn);
+
+ *output_byte_stream = result_data;
+ *output_stream_size = result_data_length;
+
+FINISH_OFF:
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC int email_decode_task_parameter_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT(char *input_byte_stream, int input_stream_size, void **output_task_parameter_struct)
+{
+ EM_DEBUG_FUNC_BEGIN("input_byte_stream [%p] input_stream_size [%d] output_task_parameter_struct [%p]", input_byte_stream, input_stream_size, output_task_parameter_struct);
+ int err = EMAIL_ERROR_NONE;
+ tpl_bin tb;
+ tpl_node *tn = NULL;
+ task_parameter_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT *task_parameter = NULL;
+
+ if (input_byte_stream == NULL || input_stream_size == 0 || output_task_parameter_struct == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ task_parameter = em_malloc(sizeof(task_parameter_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT));
if (task_parameter == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
- err = EMAIL_ERROR_OUT_OF_MEMORY;
- goto FINISH_OFF;
- }
-
- tn = tpl_map(task_parameter_format_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT
- , &task_parameter->source_mailbox_id
- , &task_parameter->target_mailbox_id
- , &task_parameter->mail_id_count
- , &tb);
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
+ err = EMAIL_ERROR_OUT_OF_MEMORY;
+ goto FINISH_OFF;
+ }
+
+ tn = tpl_map(task_parameter_format_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT
+ , &task_parameter->source_mailbox_id
+ , &task_parameter->target_mailbox_id
+ , &task_parameter->mail_id_count
+ , &tb);
if (tn == NULL) {
EM_DEBUG_EXCEPTION("tpl_map failed");
EM_SAFE_FREE(task_parameter);
@@ -121,127 +121,127 @@ INTERNAL_FUNC int email_decode_task_parameter_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAI
goto FINISH_OFF;
}
- tpl_load(tn, TPL_MEM, input_byte_stream, input_stream_size);
- tpl_unpack(tn, 0);
- if(task_parameter->mail_id_count <= 0 || tb.addr == NULL) {
- EM_DEBUG_LOG("No mail id list. mail_id_count[%d] addr[%p]", task_parameter->mail_id_count, tb.addr);
- }
- else {
- task_parameter->mail_id_array = tb.addr;
- }
-
- *output_task_parameter_struct = task_parameter;
-
-FINISH_OFF:
-
- if(tn)
- tpl_free(tn);
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC void* task_handler_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT(void *input_param)
-{
- EM_DEBUG_FUNC_BEGIN("input_param [%p]", input_param);
- int err = EMAIL_ERROR_NONE;
- int err_for_signal = EMAIL_ERROR_NONE;
- int i = 0;
- int task_id = THREAD_SELF();
- task_parameter_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT *task_param = input_param;
-
- for(i = 0; i < task_param->mail_id_count; i++) {
- if((err = emcore_move_mail_to_another_account(task_param->multi_user_name, task_param->mail_id_array[i], task_param->source_mailbox_id, task_param->target_mailbox_id, task_id)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emcore_move_mail_to_another_account failed [%d]", err);
- goto FINISH_OFF;
- }
-
- /* Send progress signal */
- if((err_for_signal = emcore_send_task_status_signal(EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT, task_id, EMAIL_TASK_STATUS_IN_PROGRESS, i, task_param->mail_id_count)) != EMAIL_ERROR_NONE)
- EM_DEBUG_LOG("emcore_send_task_status_signal failed [%d]", err_for_signal);
- }
-
-FINISH_OFF:
- /* Free task parameter */
- EM_SAFE_FREE(task_param->mail_id_array);
- EM_SAFE_FREE(task_param);
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return NULL;
-}
-/*-------------------------------------------------------------------------------------------*/
-/* to handle EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX */
-#define task_parameter_format_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX "iiBi"
-
-INTERNAL_FUNC int email_encode_task_parameter_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX(void *input_task_parameter_struct, char **output_byte_stream, int *output_stream_size)
-{
- EM_DEBUG_FUNC_BEGIN("input_task_parameter_struct [%p] output_byte_stream [%p] output_stream_size [%p]", input_task_parameter_struct, output_byte_stream, output_stream_size);
-
- int err = EMAIL_ERROR_NONE;
- task_parameter_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX *task_parameter = input_task_parameter_struct;
- tpl_bin tb;
- tpl_node *tn = NULL;
- void *result_data = NULL;
- size_t result_data_length = 0;
-
- if (task_parameter == NULL || output_byte_stream == NULL || output_stream_size == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- tn = tpl_map(task_parameter_format_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX
- , &task_parameter->account_id
- , &task_parameter->mailbox_id_count
- , &tb
- , &task_parameter->on_server);
+ tpl_load(tn, TPL_MEM, input_byte_stream, input_stream_size);
+ tpl_unpack(tn, 0);
+ if(task_parameter->mail_id_count <= 0 || tb.addr == NULL) {
+ EM_DEBUG_LOG("No mail id list. mail_id_count[%d] addr[%p]", task_parameter->mail_id_count, tb.addr);
+ }
+ else {
+ task_parameter->mail_id_array = tb.addr;
+ }
+
+ *output_task_parameter_struct = task_parameter;
+
+FINISH_OFF:
+
+ if(tn)
+ tpl_free(tn);
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC void* task_handler_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT(void *input_param)
+{
+ EM_DEBUG_FUNC_BEGIN("input_param [%p]", input_param);
+ int err = EMAIL_ERROR_NONE;
+ int err_for_signal = EMAIL_ERROR_NONE;
+ int i = 0;
+ int task_id = THREAD_SELF();
+ task_parameter_EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT *task_param = input_param;
+
+ for(i = 0; i < task_param->mail_id_count; i++) {
+ if((err = emcore_move_mail_to_another_account(task_param->multi_user_name, task_param->mail_id_array[i], task_param->source_mailbox_id, task_param->target_mailbox_id, task_id)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emcore_move_mail_to_another_account failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+ /* Send progress signal */
+ if((err_for_signal = emcore_send_task_status_signal(EMAIL_ASYNC_TASK_MOVE_MAILS_TO_MAILBOX_OF_ANOTHER_ACCOUNT, task_id, EMAIL_TASK_STATUS_IN_PROGRESS, i, task_param->mail_id_count)) != EMAIL_ERROR_NONE)
+ EM_DEBUG_LOG("emcore_send_task_status_signal failed [%d]", err_for_signal);
+ }
+
+FINISH_OFF:
+ /* Free task parameter */
+ EM_SAFE_FREE(task_param->mail_id_array);
+ EM_SAFE_FREE(task_param);
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return NULL;
+}
+/*-------------------------------------------------------------------------------------------*/
+/* to handle EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX */
+#define task_parameter_format_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX "iiBi"
+
+INTERNAL_FUNC int email_encode_task_parameter_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX(void *input_task_parameter_struct, char **output_byte_stream, int *output_stream_size)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task_parameter_struct [%p] output_byte_stream [%p] output_stream_size [%p]", input_task_parameter_struct, output_byte_stream, output_stream_size);
+
+ int err = EMAIL_ERROR_NONE;
+ task_parameter_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX *task_parameter = input_task_parameter_struct;
+ tpl_bin tb;
+ tpl_node *tn = NULL;
+ void *result_data = NULL;
+ size_t result_data_length = 0;
+
+ if (task_parameter == NULL || output_byte_stream == NULL || output_stream_size == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ tn = tpl_map(task_parameter_format_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX
+ , &task_parameter->account_id
+ , &task_parameter->mailbox_id_count
+ , &tb
+ , &task_parameter->on_server);
if (tn == NULL) {
EM_DEBUG_EXCEPTION("tpl_map failed");
err = EMAIL_ERROR_SYSTEM_FAILURE;
goto FINISH_OFF;
}
- tb.sz = sizeof(int) * task_parameter->mailbox_id_count;
- tb.addr = task_parameter->mailbox_id_array;
- tpl_pack(tn, 0);
- tpl_dump(tn, TPL_MEM, &result_data, &result_data_length);
- tpl_free(tn);
-
- *output_byte_stream = result_data;
- *output_stream_size = result_data_length;
-
-FINISH_OFF:
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC int email_decode_task_parameter_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX(char *input_byte_stream, int input_stream_size, void **output_task_parameter_struct)
-{
- EM_DEBUG_FUNC_BEGIN("input_byte_stream [%p] input_stream_size [%d] output_task_parameter_struct [%p]", input_byte_stream, input_stream_size, output_task_parameter_struct);
- int err = EMAIL_ERROR_NONE;
- tpl_bin tb;
- tpl_node *tn = NULL;
- task_parameter_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX *task_parameter = NULL;
-
- if (input_byte_stream == NULL || input_stream_size == 0 || output_task_parameter_struct == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- task_parameter = em_malloc(sizeof(task_parameter_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX));
- if(task_parameter == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
- err = EMAIL_ERROR_OUT_OF_MEMORY;
- goto FINISH_OFF;
- }
-
- tn = tpl_map(task_parameter_format_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX
- , &task_parameter->account_id
- , &task_parameter->mailbox_id_count
- , &tb
- , &task_parameter->on_server);
+ tb.sz = sizeof(int) * task_parameter->mailbox_id_count;
+ tb.addr = task_parameter->mailbox_id_array;
+ tpl_pack(tn, 0);
+ tpl_dump(tn, TPL_MEM, &result_data, &result_data_length);
+ tpl_free(tn);
+
+ *output_byte_stream = result_data;
+ *output_stream_size = result_data_length;
+
+FINISH_OFF:
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC int email_decode_task_parameter_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX(char *input_byte_stream, int input_stream_size, void **output_task_parameter_struct)
+{
+ EM_DEBUG_FUNC_BEGIN("input_byte_stream [%p] input_stream_size [%d] output_task_parameter_struct [%p]", input_byte_stream, input_stream_size, output_task_parameter_struct);
+ int err = EMAIL_ERROR_NONE;
+ tpl_bin tb;
+ tpl_node *tn = NULL;
+ task_parameter_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX *task_parameter = NULL;
+
+ if (input_byte_stream == NULL || input_stream_size == 0 || output_task_parameter_struct == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ task_parameter = em_malloc(sizeof(task_parameter_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX));
+ if(task_parameter == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
+ err = EMAIL_ERROR_OUT_OF_MEMORY;
+ goto FINISH_OFF;
+ }
+
+ tn = tpl_map(task_parameter_format_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX
+ , &task_parameter->account_id
+ , &task_parameter->mailbox_id_count
+ , &tb
+ , &task_parameter->on_server);
if (tn == NULL) {
EM_DEBUG_EXCEPTION("tpl_map failed");
EM_SAFE_FREE(task_parameter);
@@ -249,93 +249,93 @@ INTERNAL_FUNC int email_decode_task_parameter_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX
goto FINISH_OFF;
}
- tpl_load(tn, TPL_MEM, input_byte_stream, input_stream_size);
- tpl_unpack(tn, 0);
- if(task_parameter->mailbox_id_count <= 0 || tb.addr == NULL) {
- EM_DEBUG_LOG("No mail id list. mail_id_count[%d] addr[%p]", task_parameter->mailbox_id_count, tb.addr);
- }
- else {
- task_parameter->mailbox_id_array = tb.addr;
- }
-
- *output_task_parameter_struct = task_parameter;
-
-FINISH_OFF:
-
- if(tn)
- tpl_free(tn);
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC void* task_handler_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX(void *input_param)
-{
- return NULL;
-}
-/*-------------------------------------------------------------------------------------------*/
-/* to handle EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL */
-#define task_parameter_format_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL "i"
-
-INTERNAL_FUNC int email_encode_task_parameter_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL(void *input_task_parameter_struct, char **output_byte_stream, int *output_stream_size)
-{
- EM_DEBUG_FUNC_BEGIN("input_task_parameter_struct [%p] output_byte_stream [%p] output_stream_size [%p]", input_task_parameter_struct, output_byte_stream, output_stream_size);
-
- int err = EMAIL_ERROR_NONE;
- task_parameter_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL *task_parameter = input_task_parameter_struct;
- tpl_node *tn = NULL;
- void *result_data = NULL;
- size_t result_data_length = 0;
-
- if (task_parameter == NULL || output_byte_stream == NULL || output_stream_size == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- tn = tpl_map(task_parameter_format_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL
- , &task_parameter->mail_id);
+ tpl_load(tn, TPL_MEM, input_byte_stream, input_stream_size);
+ tpl_unpack(tn, 0);
+ if(task_parameter->mailbox_id_count <= 0 || tb.addr == NULL) {
+ EM_DEBUG_LOG("No mail id list. mail_id_count[%d] addr[%p]", task_parameter->mailbox_id_count, tb.addr);
+ }
+ else {
+ task_parameter->mailbox_id_array = tb.addr;
+ }
+
+ *output_task_parameter_struct = task_parameter;
+
+FINISH_OFF:
+
+ if(tn)
+ tpl_free(tn);
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC void* task_handler_EMAIL_ASYNC_TASK_DELETE_MAILBOX_EX(void *input_param)
+{
+ return NULL;
+}
+/*-------------------------------------------------------------------------------------------*/
+/* to handle EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL */
+#define task_parameter_format_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL "i"
+
+INTERNAL_FUNC int email_encode_task_parameter_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL(void *input_task_parameter_struct, char **output_byte_stream, int *output_stream_size)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task_parameter_struct [%p] output_byte_stream [%p] output_stream_size [%p]", input_task_parameter_struct, output_byte_stream, output_stream_size);
+
+ int err = EMAIL_ERROR_NONE;
+ task_parameter_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL *task_parameter = input_task_parameter_struct;
+ tpl_node *tn = NULL;
+ void *result_data = NULL;
+ size_t result_data_length = 0;
+
+ if (task_parameter == NULL || output_byte_stream == NULL || output_stream_size == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ tn = tpl_map(task_parameter_format_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL
+ , &task_parameter->mail_id);
if (tn == NULL) {
EM_DEBUG_EXCEPTION("tpl_map failed");
err = EMAIL_ERROR_SYSTEM_FAILURE;
goto FINISH_OFF;
}
- tpl_pack(tn, 0);
- tpl_dump(tn, TPL_MEM, &result_data, &result_data_length);
- tpl_free(tn);
-
- *output_byte_stream = result_data;
- *output_stream_size = result_data_length;
-
-FINISH_OFF:
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC int email_decode_task_parameter_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL(char *input_byte_stream, int input_stream_size, void **output_task_parameter_struct)
-{
- EM_DEBUG_FUNC_BEGIN("input_byte_stream [%p] input_stream_size [%d] output_task_parameter_struct [%p]", input_byte_stream, input_stream_size, output_task_parameter_struct);
- int err = EMAIL_ERROR_NONE;
- tpl_node *tn = NULL;
- task_parameter_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL *task_parameter = NULL;
-
- if (input_byte_stream == NULL || input_stream_size == 0 || output_task_parameter_struct == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- task_parameter = em_malloc(sizeof(task_parameter_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL));
+ tpl_pack(tn, 0);
+ tpl_dump(tn, TPL_MEM, &result_data, &result_data_length);
+ tpl_free(tn);
+
+ *output_byte_stream = result_data;
+ *output_stream_size = result_data_length;
+
+FINISH_OFF:
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC int email_decode_task_parameter_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL(char *input_byte_stream, int input_stream_size, void **output_task_parameter_struct)
+{
+ EM_DEBUG_FUNC_BEGIN("input_byte_stream [%p] input_stream_size [%d] output_task_parameter_struct [%p]", input_byte_stream, input_stream_size, output_task_parameter_struct);
+ int err = EMAIL_ERROR_NONE;
+ tpl_node *tn = NULL;
+ task_parameter_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL *task_parameter = NULL;
+
+ if (input_byte_stream == NULL || input_stream_size == 0 || output_task_parameter_struct == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ task_parameter = em_malloc(sizeof(task_parameter_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL));
if (task_parameter == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
- err = EMAIL_ERROR_OUT_OF_MEMORY;
- goto FINISH_OFF;
- }
-
- tn = tpl_map(task_parameter_format_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL
- , &task_parameter->mail_id);
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
+ err = EMAIL_ERROR_OUT_OF_MEMORY;
+ goto FINISH_OFF;
+ }
+
+ tn = tpl_map(task_parameter_format_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL
+ , &task_parameter->mail_id);
if (tn == NULL) {
EM_DEBUG_EXCEPTION("tpl_map failed");
EM_SAFE_FREE(task_parameter);
@@ -343,87 +343,87 @@ INTERNAL_FUNC int email_decode_task_parameter_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DO
goto FINISH_OFF;
}
- tpl_load(tn, TPL_MEM, input_byte_stream, input_stream_size);
- tpl_unpack(tn, 0);
-
- *output_task_parameter_struct = task_parameter;
-
-FINISH_OFF:
-
- if(tn)
- tpl_free(tn);
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC void* task_handler_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL(void *input_param)
-{
- return NULL;
-}
-/*-------------------------------------------------------------------------------------------*/
-/* to handle EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL */
-#define task_parameter_format_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL "ii"
-
-INTERNAL_FUNC int email_encode_task_parameter_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL(void *input_task_parameter_struct, char **output_byte_stream, int *output_stream_size)
-{
- EM_DEBUG_FUNC_BEGIN("input_task_parameter_struct [%p] output_byte_stream [%p] output_stream_size [%p]", input_task_parameter_struct, output_byte_stream, output_stream_size);
-
- int err = EMAIL_ERROR_NONE;
- task_parameter_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL *task_parameter = input_task_parameter_struct;
- tpl_node *tn = NULL;
- void *result_data = NULL;
- size_t result_data_length = 0;
-
- if (task_parameter == NULL || output_byte_stream == NULL || output_stream_size == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- tn = tpl_map(task_parameter_format_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL
- , &task_parameter->mail_id, &task_parameter->scheduled_time);
+ tpl_load(tn, TPL_MEM, input_byte_stream, input_stream_size);
+ tpl_unpack(tn, 0);
+
+ *output_task_parameter_struct = task_parameter;
+
+FINISH_OFF:
+
+ if(tn)
+ tpl_free(tn);
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC void* task_handler_EMAIL_ASYNC_TASK_SEND_MAIL_WITH_DOWNLOADING_ATTACHMENT_OF_ORIGINAL_MAIL(void *input_param)
+{
+ return NULL;
+}
+/*-------------------------------------------------------------------------------------------*/
+/* to handle EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL */
+#define task_parameter_format_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL "ii"
+
+INTERNAL_FUNC int email_encode_task_parameter_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL(void *input_task_parameter_struct, char **output_byte_stream, int *output_stream_size)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task_parameter_struct [%p] output_byte_stream [%p] output_stream_size [%p]", input_task_parameter_struct, output_byte_stream, output_stream_size);
+
+ int err = EMAIL_ERROR_NONE;
+ task_parameter_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL *task_parameter = input_task_parameter_struct;
+ tpl_node *tn = NULL;
+ void *result_data = NULL;
+ size_t result_data_length = 0;
+
+ if (task_parameter == NULL || output_byte_stream == NULL || output_stream_size == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ tn = tpl_map(task_parameter_format_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL
+ , &task_parameter->mail_id, &task_parameter->scheduled_time);
if (tn == NULL) {
EM_DEBUG_EXCEPTION("tpl_map failed");
err = EMAIL_ERROR_SYSTEM_FAILURE;
goto FINISH_OFF;
}
- tpl_pack(tn, 0);
- tpl_dump(tn, TPL_MEM, &result_data, &result_data_length);
- tpl_free(tn);
-
- *output_byte_stream = result_data;
- *output_stream_size = result_data_length;
-
-FINISH_OFF:
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC int email_decode_task_parameter_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL(char *input_byte_stream, int input_stream_size, void **output_task_parameter_struct)
-{
- EM_DEBUG_FUNC_BEGIN("input_byte_stream [%p] input_stream_size [%d] output_task_parameter_struct [%p]", input_byte_stream, input_stream_size, output_task_parameter_struct);
- int err = EMAIL_ERROR_NONE;
- tpl_node *tn = NULL;
- task_parameter_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL *task_parameter = NULL;
-
- if (input_byte_stream == NULL || input_stream_size == 0 || output_task_parameter_struct == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- task_parameter = em_malloc(sizeof(task_parameter_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL));
- if(task_parameter == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
- err = EMAIL_ERROR_OUT_OF_MEMORY;
- goto FINISH_OFF;
- }
-
- tn = tpl_map(task_parameter_format_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL
- , &task_parameter->mail_id, &task_parameter->scheduled_time);
+ tpl_pack(tn, 0);
+ tpl_dump(tn, TPL_MEM, &result_data, &result_data_length);
+ tpl_free(tn);
+
+ *output_byte_stream = result_data;
+ *output_stream_size = result_data_length;
+
+FINISH_OFF:
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC int email_decode_task_parameter_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL(char *input_byte_stream, int input_stream_size, void **output_task_parameter_struct)
+{
+ EM_DEBUG_FUNC_BEGIN("input_byte_stream [%p] input_stream_size [%d] output_task_parameter_struct [%p]", input_byte_stream, input_stream_size, output_task_parameter_struct);
+ int err = EMAIL_ERROR_NONE;
+ tpl_node *tn = NULL;
+ task_parameter_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL *task_parameter = NULL;
+
+ if (input_byte_stream == NULL || input_stream_size == 0 || output_task_parameter_struct == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ task_parameter = em_malloc(sizeof(task_parameter_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL));
+ if(task_parameter == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
+ err = EMAIL_ERROR_OUT_OF_MEMORY;
+ goto FINISH_OFF;
+ }
+
+ tn = tpl_map(task_parameter_format_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL
+ , &task_parameter->mail_id, &task_parameter->scheduled_time);
if (tn == NULL) {
EM_DEBUG_EXCEPTION("tpl_map failed");
EM_SAFE_FREE(task_parameter);
@@ -431,268 +431,308 @@ INTERNAL_FUNC int email_decode_task_parameter_EMAIL_SYNC_TASK_SCHEDULE_SENDING_M
goto FINISH_OFF;
}
- tpl_load(tn, TPL_MEM, input_byte_stream, input_stream_size);
- tpl_unpack(tn, 0);
-
- *output_task_parameter_struct = task_parameter;
-
-FINISH_OFF:
-
- if(tn)
- tpl_free(tn);
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return err;
-}
-
-INTERNAL_FUNC void* task_handler_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL(void *input_param)
-{
- EM_DEBUG_FUNC_BEGIN("input_param [%p]", input_param);
- int err = EMAIL_ERROR_NONE;
- task_parameter_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL *task_param = input_param;
-
- if((err = emcore_schedule_sending_mail(task_param->multi_user_name, task_param->mail_id, task_param->scheduled_time)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emcore_schedule_sending_mail [%d]", err);
- err = EMAIL_ERROR_OUT_OF_MEMORY;
- goto FINISH_OFF;
- }
-
-FINISH_OFF:
-
+ tpl_load(tn, TPL_MEM, input_byte_stream, input_stream_size);
+ tpl_unpack(tn, 0);
+
+ *output_task_parameter_struct = task_parameter;
+
+FINISH_OFF:
+
+ if(tn)
+ tpl_free(tn);
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return err;
+}
+
+INTERNAL_FUNC void* task_handler_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL(void *input_param)
+{
+ EM_DEBUG_FUNC_BEGIN("input_param [%p]", input_param);
+
+ int err = EMAIL_ERROR_NONE;
+ int *return_err = NULL;
+ task_parameter_EMAIL_SYNC_TASK_SCHEDULE_SENDING_MAIL *task_param = input_param;
+
+ if ((err = emcore_schedule_sending_mail(task_param->multi_user_name,
+ task_param->mail_id,
+ task_param->scheduled_time)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emcore_schedule_sending_mail [%d]", err);
+ err = EMAIL_ERROR_OUT_OF_MEMORY;
+ goto FINISH_OFF;
+ }
+
+ return_err = em_malloc(sizeof(int));
+ if (return_err == NULL) {
+ EM_DEBUG_EXCEPTION("em_malloc failed");
+ err = EMAIL_ERROR_OUT_OF_MEMORY;
+ goto FINISH_OFF;
+ }
+
+ *return_err = err;
+
+FINISH_OFF:
+
EM_SAFE_FREE(task_param);
- emcore_close_smtp_stream_list ();
- EM_DEBUG_FUNC_END("err [%d]", err);
- return (void*)err;
-}
-/*-------------------------------------------------------------------------------------------*/
-/* to handle EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE */
-#define task_parameter_format_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE "iiBiiB"
-
-INTERNAL_FUNC int email_encode_task_parameter_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE(void *input_task_parameter_struct, char **output_byte_stream, int *output_stream_size)
-{
- EM_DEBUG_FUNC_BEGIN("input_task_parameter_struct [%p] output_byte_stream [%p] output_stream_size [%p]", input_task_parameter_struct, output_byte_stream, output_stream_size);
-
- int err = EMAIL_ERROR_NONE;
- task_parameter_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE *task_parameter = input_task_parameter_struct;
- email_mail_attribute_value_type attribute_value_type = EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE;
- tpl_bin tb_mail_id_array;
- tpl_bin tb_value;
- tpl_node *tn = NULL;
- void *result_data = NULL;
- size_t result_data_length = 0;
-
- if (task_parameter == NULL || output_byte_stream == NULL || output_stream_size == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- if ((err = emcore_get_mail_attribute_value_type(task_parameter->attribute_type, &attribute_value_type)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emcore_get_mail_attribute_value_type failed [%d]", err);
- goto FINISH_OFF;
- }
-
- tn = tpl_map(task_parameter_format_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE
- , &task_parameter->account_id
- , &task_parameter->mail_id_count
- , &tb_mail_id_array
- , &task_parameter->attribute_type
- , &task_parameter->value_length
- , &tb_value);
+ emcore_close_smtp_stream_list();
+ EM_DEBUG_FUNC_END("err [%d]", err);
+
+ return (void *)return_err;
+}
+/*-------------------------------------------------------------------------------------------*/
+/* to handle EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE */
+#define task_parameter_format_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE "iiBiiB"
+
+INTERNAL_FUNC int email_encode_task_parameter_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE(void *input_task_parameter_struct, char **output_byte_stream, int *output_stream_size)
+{
+ EM_DEBUG_FUNC_BEGIN("input_task_parameter_struct [%p] output_byte_stream [%p] output_stream_size [%p]", input_task_parameter_struct, output_byte_stream, output_stream_size);
+
+ int err = EMAIL_ERROR_NONE;
+ task_parameter_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE *task_parameter = input_task_parameter_struct;
+ email_mail_attribute_value_type attribute_value_type = EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE;
+ tpl_bin tb_mail_id_array;
+ tpl_bin tb_value;
+ tpl_node *tn = NULL;
+ void *result_data = NULL;
+ size_t result_data_length = 0;
+
+ if (task_parameter == NULL || output_byte_stream == NULL || output_stream_size == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ if ((err = emcore_get_mail_attribute_value_type(task_parameter->attribute_type, &attribute_value_type)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emcore_get_mail_attribute_value_type failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+ tn = tpl_map(task_parameter_format_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE
+ , &task_parameter->account_id
+ , &task_parameter->mail_id_count
+ , &tb_mail_id_array
+ , &task_parameter->attribute_type
+ , &task_parameter->value_length
+ , &tb_value);
if (tn == NULL) {
EM_DEBUG_EXCEPTION("tpl_map failed");
err = EMAIL_ERROR_SYSTEM_FAILURE;
goto FINISH_OFF;
}
-
- tb_mail_id_array.sz = sizeof(int) * task_parameter->mail_id_count;
- tb_mail_id_array.addr = task_parameter->mail_id_array;
-
- switch(attribute_value_type) {
- case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_INTEGER :
- task_parameter->value_length = 4;
- tb_value.sz = task_parameter->value_length;
- tb_value.addr = &task_parameter->value.integer_type_value;
- break;
- case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_STRING :
- task_parameter->value_length = EM_SAFE_STRLEN(task_parameter->value.string_type_value);
- tb_value.sz = task_parameter->value_length;
- tb_value.addr = task_parameter->value.string_type_value;
- break;
- case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_TIME :
- task_parameter->value_length = 4;
- tb_value.sz = task_parameter->value_length;
- tb_value.addr = &task_parameter->value.datetime_type_value;
- break;
- case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE :
- default :
- EM_DEBUG_EXCEPTION("invalid attribute value type [%d]", attribute_value_type);
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- tpl_pack(tn, 0);
- tpl_dump(tn, TPL_MEM, &result_data, &result_data_length);
-
- *output_byte_stream = result_data;
- *output_stream_size = result_data_length;
-
-FINISH_OFF:
-
- if(tn)
- tpl_free(tn);
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return EMAIL_ERROR_NONE;
-}
-
-INTERNAL_FUNC int email_decode_task_parameter_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE(char *input_byte_stream, int input_stream_size, void **output_task_parameter_struct)
-{
- EM_DEBUG_FUNC_BEGIN("input_byte_stream [%p] input_stream_size [%d] output_task_parameter_struct [%p]", input_byte_stream, input_stream_size, output_task_parameter_struct);
- int err = EMAIL_ERROR_NONE;
- tpl_node *tn = NULL;
- tpl_bin tb_mail_id_array;
- tpl_bin tb_value;
- task_parameter_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE *task_parameter = NULL;
- email_mail_attribute_value_type attribute_value_type = EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE;
-
- if (input_byte_stream == NULL || input_stream_size == 0 || output_task_parameter_struct == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- task_parameter = em_malloc(sizeof(task_parameter_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE));
-
- if(task_parameter == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
- err = EMAIL_ERROR_OUT_OF_MEMORY;
- goto FINISH_OFF;
- }
-
- tn = tpl_map(task_parameter_format_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE
- , &task_parameter->account_id
- , &task_parameter->mail_id_count
- , &tb_mail_id_array
- , &task_parameter->attribute_type
- , &task_parameter->value_length
- , &tb_value);
+
+ tb_mail_id_array.sz = sizeof(int) * task_parameter->mail_id_count;
+ tb_mail_id_array.addr = task_parameter->mail_id_array;
+
+ switch(attribute_value_type) {
+ case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_INTEGER :
+ task_parameter->value_length = 4;
+ tb_value.sz = task_parameter->value_length;
+ tb_value.addr = &task_parameter->value.integer_type_value;
+ break;
+ case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_STRING :
+ task_parameter->value_length = EM_SAFE_STRLEN(task_parameter->value.string_type_value);
+ tb_value.sz = task_parameter->value_length;
+ tb_value.addr = task_parameter->value.string_type_value;
+ break;
+ case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_TIME :
+ task_parameter->value_length = 4;
+ tb_value.sz = task_parameter->value_length;
+ tb_value.addr = &task_parameter->value.datetime_type_value;
+ break;
+ case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE :
+ default :
+ EM_DEBUG_EXCEPTION("invalid attribute value type [%d]", attribute_value_type);
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ tpl_pack(tn, 0);
+ tpl_dump(tn, TPL_MEM, &result_data, &result_data_length);
+
+ *output_byte_stream = result_data;
+ *output_stream_size = result_data_length;
+
+FINISH_OFF:
+
+ if(tn)
+ tpl_free(tn);
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return EMAIL_ERROR_NONE;
+}
+
+INTERNAL_FUNC int email_decode_task_parameter_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE(char *input_byte_stream, int input_stream_size, void **output_task_parameter_struct)
+{
+ EM_DEBUG_FUNC_BEGIN("input_byte_stream [%p] input_stream_size [%d] output_task_parameter_struct [%p]", input_byte_stream, input_stream_size, output_task_parameter_struct);
+ int err = EMAIL_ERROR_NONE;
+ tpl_node *tn = NULL;
+ tpl_bin tb_mail_id_array;
+ tpl_bin tb_value;
+ task_parameter_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE *task_parameter = NULL;
+ email_mail_attribute_value_type attribute_value_type = EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE;
+
+ if (input_byte_stream == NULL || input_stream_size == 0 || output_task_parameter_struct == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ task_parameter = em_malloc(sizeof(task_parameter_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE));
+
+ if(task_parameter == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
+ err = EMAIL_ERROR_OUT_OF_MEMORY;
+ goto FINISH_OFF;
+ }
+
+ tn = tpl_map(task_parameter_format_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE
+ , &task_parameter->account_id
+ , &task_parameter->mail_id_count
+ , &tb_mail_id_array
+ , &task_parameter->attribute_type
+ , &task_parameter->value_length
+ , &tb_value);
if (tn == NULL) {
EM_DEBUG_EXCEPTION("tpl_map failed");
err = EMAIL_ERROR_SYSTEM_FAILURE;
goto FINISH_OFF;
}
-
- tpl_load(tn, TPL_MEM, input_byte_stream, input_stream_size);
- tpl_unpack(tn, 0);
-
- if(task_parameter->mail_id_count <= 0 || tb_mail_id_array.addr == NULL) {
- EM_DEBUG_LOG("No mail id list. mail_id_count[%d] addr[%p]", task_parameter->mail_id_count, tb_mail_id_array.addr);
- }
- else {
- task_parameter->mail_id_array = tb_mail_id_array.addr;
- }
-
- if(tb_value.addr) {
- if ((err = emcore_get_mail_attribute_value_type(task_parameter->attribute_type, &attribute_value_type)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emcore_get_mail_attribute_value_type failed [%d]", err);
- goto FINISH_OFF;
- }
-
- switch(attribute_value_type) {
- case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_INTEGER :
- memcpy(&task_parameter->value.integer_type_value, tb_value.addr, tb_value.sz);
- break;
- case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_STRING :
- task_parameter->value.string_type_value = em_malloc(tb_value.sz + 1);
- if(task_parameter->value.string_type_value == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
- err = EMAIL_ERROR_OUT_OF_MEMORY;
- goto FINISH_OFF;
- }
- memcpy(&task_parameter->value.string_type_value, tb_value.addr, tb_value.sz);
- break;
- case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_TIME :
- memcpy(&task_parameter->value.datetime_type_value, tb_value.addr, tb_value.sz);
- break;
- case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE :
- default :
- EM_DEBUG_EXCEPTION("invalid attribute value type [%d]", attribute_value_type);
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
- }
-
- *output_task_parameter_struct = task_parameter;
-
-FINISH_OFF:
-
- if(tn)
- tpl_free(tn);
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return EMAIL_ERROR_NONE;
-}
-
-INTERNAL_FUNC void* task_handler_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE(void *input_param)
-{
- EM_DEBUG_FUNC_BEGIN("input_param [%p]", input_param);
- if(!input_param) { /*prevent 43681*/
- EM_DEBUG_EXCEPTION("NULL parameter");
- return NULL;
- }
-
- int err = EMAIL_ERROR_NONE;
- char *field_name = NULL;
- task_parameter_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE *task_param = input_param;
- email_mail_attribute_value_type attribute_value_type = EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE; /*prevent 43700*/
-
- if((field_name = emcore_get_mail_field_name_by_attribute_type(task_param->attribute_type)) == NULL) {
- EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
- err = EMAIL_ERROR_INVALID_PARAM;
- goto FINISH_OFF;
- }
-
- if((err = emcore_get_mail_attribute_value_type(task_param->attribute_type, &attribute_value_type)) != EMAIL_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("emcore_get_mail_attribute_value_type failed [%d]", err);
- goto FINISH_OFF;
- }
-
- switch(attribute_value_type) {
- case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_INTEGER :
- if(!emstorage_set_field_of_mails_with_integer_value(task_param->multi_user_name, task_param->account_id, task_param->mail_id_array, task_param->mail_id_count, field_name, task_param->value.integer_type_value, true, &err)) {
- EM_DEBUG_EXCEPTION("emstorage_set_field_of_mails_with_integer_value failed [%d]", err);
- goto FINISH_OFF;
- }
- break;
- case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_STRING :
- err = EMAIL_ERROR_NOT_SUPPORTED;
- EM_DEBUG_LOG("EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_STRING is not supported");
- break;
- case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_TIME :
- if(!emstorage_set_field_of_mails_with_integer_value(task_param->multi_user_name, task_param->account_id, task_param->mail_id_array, task_param->mail_id_count, field_name, task_param->value.datetime_type_value, true, &err)) {
- EM_DEBUG_EXCEPTION("emstorage_set_field_of_mails_with_integer_value failed [%d]", err);
- goto FINISH_OFF;
- }
- break;
- case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE :
- default :
- EM_DEBUG_LOG("EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE or default");
- err = EMAIL_ERROR_INVALID_PARAM;
- break;
- }
-
-FINISH_OFF:
-
- EM_SAFE_FREE(task_param->multi_user_name);
- EM_SAFE_FREE(task_param->mail_id_array);
- if (attribute_value_type == EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_STRING) {
- EM_SAFE_FREE(task_param->value.string_type_value);
- }
-
- EM_SAFE_FREE (task_param);
-
- EM_DEBUG_FUNC_END("err [%d]", err);
- return (void*)err;
-}
-/*-------------------------------------------------------------------------------------------*/
+
+ tpl_load(tn, TPL_MEM, input_byte_stream, input_stream_size);
+ tpl_unpack(tn, 0);
+
+ if(task_parameter->mail_id_count <= 0 || tb_mail_id_array.addr == NULL) {
+ EM_DEBUG_LOG("No mail id list. mail_id_count[%d] addr[%p]", task_parameter->mail_id_count, tb_mail_id_array.addr);
+ }
+ else {
+ task_parameter->mail_id_array = tb_mail_id_array.addr;
+ }
+
+ if(tb_value.addr) {
+ if ((err = emcore_get_mail_attribute_value_type(task_parameter->attribute_type, &attribute_value_type)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emcore_get_mail_attribute_value_type failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+ switch(attribute_value_type) {
+ case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_INTEGER :
+ memcpy(&task_parameter->value.integer_type_value, tb_value.addr, tb_value.sz);
+ break;
+ case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_STRING :
+ task_parameter->value.string_type_value = em_malloc(tb_value.sz + 1);
+ if(task_parameter->value.string_type_value == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_OUT_OF_MEMORY");
+ err = EMAIL_ERROR_OUT_OF_MEMORY;
+ goto FINISH_OFF;
+ }
+ memcpy(&task_parameter->value.string_type_value, tb_value.addr, tb_value.sz);
+ break;
+ case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_TIME :
+ memcpy(&task_parameter->value.datetime_type_value, tb_value.addr, tb_value.sz);
+ break;
+ case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE :
+ default :
+ EM_DEBUG_EXCEPTION("invalid attribute value type [%d]", attribute_value_type);
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+ }
+
+ *output_task_parameter_struct = task_parameter;
+
+FINISH_OFF:
+
+ if(tn)
+ tpl_free(tn);
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+ return EMAIL_ERROR_NONE;
+}
+
+INTERNAL_FUNC void *task_handler_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE(void *input_param)
+{
+ EM_DEBUG_FUNC_BEGIN("input_param [%p]", input_param);
+ if (!input_param) { /*prevent 43681*/
+ EM_DEBUG_EXCEPTION("NULL parameter");
+ return NULL;
+ }
+
+ int err = EMAIL_ERROR_NONE;
+ int *return_err = NULL;
+ char *field_name = NULL;
+ task_parameter_EMAIL_SYNC_TASK_UPDATE_ATTRIBUTE *task_param = input_param;
+ email_mail_attribute_value_type attribute_value_type = EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE; /*prevent 43700*/
+
+ if ((field_name = emcore_get_mail_field_name_by_attribute_type(task_param->attribute_type)) == NULL) {
+ EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ goto FINISH_OFF;
+ }
+
+ if ((err = emcore_get_mail_attribute_value_type(task_param->attribute_type,
+ &attribute_value_type)) != EMAIL_ERROR_NONE) {
+ EM_DEBUG_EXCEPTION("emcore_get_mail_attribute_value_type failed [%d]", err);
+ goto FINISH_OFF;
+ }
+
+ switch(attribute_value_type) {
+ case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_INTEGER :
+ if (!emstorage_set_field_of_mails_with_integer_value(task_param->multi_user_name,
+ task_param->account_id,
+ task_param->mail_id_array,
+ task_param->mail_id_count,
+ field_name,
+ task_param->value.integer_type_value,
+ true,
+ &err)) {
+ EM_DEBUG_EXCEPTION("emstorage_set_field_of_mails_with_integer_value failed [%d]", err);
+ goto FINISH_OFF;
+ }
+ break;
+ case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_STRING :
+ err = EMAIL_ERROR_NOT_SUPPORTED;
+ EM_DEBUG_LOG("EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_STRING is not supported");
+ break;
+ case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_TIME :
+ if (!emstorage_set_field_of_mails_with_integer_value(task_param->multi_user_name,
+ task_param->account_id,
+ task_param->mail_id_array,
+ task_param->mail_id_count,
+ field_name,
+ task_param->value.datetime_type_value,
+ true,
+ &err)) {
+ EM_DEBUG_EXCEPTION("emstorage_set_field_of_mails_with_integer_value failed [%d]", err);
+ goto FINISH_OFF;
+ }
+ break;
+ case EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE :
+ default :
+ EM_DEBUG_LOG("EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_NONE or default");
+ err = EMAIL_ERROR_INVALID_PARAM;
+ break;
+ }
+
+ return_err = em_malloc(sizeof(int));
+ if (return_err == NULL) {
+ EM_DEBUG_EXCEPTION("em_malloc failed");
+ err = EMAIL_ERROR_OUT_OF_MEMORY;
+ goto FINISH_OFF;
+ }
+
+ *return_err = err;
+
+FINISH_OFF:
+
+ EM_SAFE_FREE(task_param->multi_user_name);
+ EM_SAFE_FREE(task_param->mail_id_array);
+ if (attribute_value_type == EMAIL_MAIL_ATTRIBUTE_VALUE_TYPE_STRING) {
+ EM_SAFE_FREE(task_param->value.string_type_value);
+ }
+
+ EM_SAFE_FREE (task_param);
+
+ EM_DEBUG_FUNC_END("err [%d]", err);
+
+ return (void *)return_err;
+}
+/*-------------------------------------------------------------------------------------------*/
diff --git a/email-core/email-core-utils.c b/email-core/email-core-utils.c
index e58f53f..f2573f4 100755
--- a/email-core/email-core-utils.c
+++ b/email-core/email-core-utils.c
@@ -2464,8 +2464,8 @@ int emcore_strip_mail_body_from_file(char *multi_user_name, emstorage_mail_tbl_t
char *prefix_path = NULL;
char real_html_path[255] = {0};
char real_plain_path[255] = {0};
- unsigned int byte_read = 0;
- unsigned int byte_written = 0;
+ gsize byte_read = 0;
+ gsize byte_written = 0;
GError *glib_error = NULL;
FILE *fp_plain = NULL;
struct stat st_buf;
@@ -2581,7 +2581,7 @@ int emcore_strip_mail_body_from_file(char *multi_user_name, emstorage_mail_tbl_t
}
EM_DEBUG_LOG("Extract the preview text, again");
- utf8_encoded_string = (char *)g_convert(buf, byte_read, "UTF-8", encoding_type, &byte_read, &byte_written, &glib_error);
+ utf8_encoded_string = (char *)g_convert(buf, -1, "UTF-8", encoding_type, &byte_read, &byte_written, &glib_error);
if (utf8_encoded_string == NULL) {
EM_SAFE_FREE(*stripped_text);
*stripped_text = EM_SAFE_STRDUP(buf);
@@ -2624,8 +2624,8 @@ int emcore_get_preview_text_from_file(char *multi_user_name, const char *input_p
EM_DEBUG_FUNC_BEGIN("input_plain_path[%p], input_html_path[%p], input_preview_buffer_length [%d], output_preview_buffer[%p]", input_plain_path, input_html_path, input_preview_buffer_length, output_preview_buffer);
int err = EMAIL_ERROR_NONE;
- unsigned int byte_read = 0;
- unsigned int byte_written = 0;
+ gsize byte_read = 0;
+ gsize byte_written = 0;
int local_preview_buffer_length = 0;
char *local_preview_text = NULL;
char *encoding_type = NULL;
@@ -2633,8 +2633,8 @@ int emcore_get_preview_text_from_file(char *multi_user_name, const char *input_p
FILE *fp_plain = NULL;
GError *glib_error = NULL;
struct stat st_buf;
- char *prefix_path = NULL;
- char real_file_path[255] = {0};
+ char *prefix_path = NULL;
+ char real_file_path[255] = {0};
if (!output_preview_buffer) {
EM_DEBUG_EXCEPTION("EMAIL_ERROR_INVALID_PARAM");
@@ -2735,7 +2735,7 @@ int emcore_get_preview_text_from_file(char *multi_user_name, const char *input_p
encoding_type = EM_SAFE_STRDUP("EUC-KR");
}
- utf8_encoded_string = (char*)g_convert (local_preview_text, -1, "UTF-8", encoding_type, &byte_read, &byte_written, &glib_error);
+ utf8_encoded_string = (char *)g_convert(local_preview_text, -1, "UTF-8", encoding_type, &byte_read, &byte_written, &glib_error);
if(utf8_encoded_string == NULL) {
if (!g_error_matches (glib_error, G_CONVERT_ERROR, G_CONVERT_ERROR_ILLEGAL_SEQUENCE)) {
@@ -2743,7 +2743,7 @@ int emcore_get_preview_text_from_file(char *multi_user_name, const char *input_p
}
EM_DEBUG_LOG("Extract the preview text, again");
- utf8_encoded_string = (char *)g_convert(local_preview_text, byte_read, "UTF-8", encoding_type, &byte_read, &byte_written, &glib_error);
+ utf8_encoded_string = (char *)g_convert(local_preview_text, -1, "UTF-8", encoding_type, &byte_read, &byte_written, &glib_error);
if (utf8_encoded_string == NULL) {
EM_DEBUG_LOG("g_convert fail, again");
goto FINISH_OFF;
@@ -5225,33 +5225,6 @@ FINISH_OFF:
return mime_entity_path;
}
-/* Feedback LED api */
-INTERNAL_FUNC void emcore_set_flash_noti()
-{
- EM_DEBUG_FUNC_BEGIN();
- int flash_error = FEEDBACK_ERROR_NONE;
-
- flash_error = feedback_initialize();
- if (flash_error != FEEDBACK_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("feedback_initialize failed : [%d]", flash_error);
- return;
- }
-
-#ifdef __FEATURE_FEEDBACK_TYPE_LED_ENABLE__
- flash_error = feedback_play_type(FEEDBACK_TYPE_LED, FEEDBACK_PATTERN_EMAIL);
- if (flash_error != FEEDBACK_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("feedback_play_type failed : [%d]", flash_error);
- }
-#endif /* __FEATURE_FEEDBACK_TYPE_LED_ENABLE__ */
-
- flash_error = feedback_deinitialize();
- if (flash_error != FEEDBACK_ERROR_NONE) {
- EM_DEBUG_EXCEPTION("feedback_play_type failed : [%d]", flash_error);
- }
-
- EM_DEBUG_FUNC_END();
-}
-
INTERNAL_FUNC int emcore_get_content_from_file(char *filename, char **contents, int *length)
{
EM_DEBUG_FUNC_BEGIN("filename[%s], contents[%p], length[%p]", filename, contents, length);
diff --git a/email-core/email-storage/email-storage.c b/email-core/email-storage/email-storage.c
index c2ce544..b2060c6 100755
--- a/email-core/email-storage/email-storage.c
+++ b/email-core/email-storage/email-storage.c
@@ -65,10 +65,7 @@
#include "email-core-container.h"
#include "email-core-key-manager.h"
-#define DB_STMT sqlite3_stmt *
-
#define SETTING_MEMORY_TEMP_FILE_PATH "/tmp/email_tmp_file"
-
#define CONTENT_DATA "<head><meta http-equiv=\"Content-Type\" content=\"text/html; charset="
#define CONTENT_TYPE_DATA "<meta http-equiv=\"Content-Type\" content=\"text/html; charset="
@@ -8325,9 +8322,20 @@ FINISH_OFF:
}
#endif
-INTERNAL_FUNC int emstorage_mail_search_start(char *multi_user_name, emstorage_search_filter_t *search, int account_id, int mailbox_id, int sorting, int *search_handle, int *searched, int transaction, int *err_code)
-{
- EM_DEBUG_FUNC_BEGIN("search[%p], account_id[%d], mailbox_id[%d], sorting[%d], search_handle[%p], searched[%p], transaction[%d], err_code[%p]", search, account_id, mailbox_id, sorting, search_handle, searched, transaction, err_code);
+INTERNAL_FUNC int emstorage_mail_search_start(char *multi_user_name,
+ emstorage_search_filter_t *search,
+ int account_id,
+ int mailbox_id,
+ int sorting,
+ DB_STMT *search_handle,
+ int *searched,
+ int transaction,
+ int *err_code)
+{
+ EM_DEBUG_FUNC_BEGIN("search[%p], account_id[%d], mailbox_id[%d], sorting[%d], "
+ "search_handle[%p], searched[%p], transaction[%d], err_code[%p]",
+ search, account_id, mailbox_id, sorting, search_handle,
+ searched, transaction, err_code);
if (!search_handle || !searched) {
if (err_code != NULL)
@@ -8409,7 +8417,7 @@ INTERNAL_FUNC int emstorage_mail_search_start(char *multi_user_name, emstorage_s
FINISH_OFF:
if (ret == true) {
- *search_handle = (int)hStmt;
+ *search_handle = hStmt;
*searched = mail_count;
EM_DEBUG_LOG("mail_count [%d]", mail_count);
}
@@ -8432,7 +8440,7 @@ FINISH_OFF:
return ret;
}
-INTERNAL_FUNC int emstorage_mail_search_result(int search_handle, emstorage_mail_field_type_t type, void** data, int transaction, int *err_code)
+INTERNAL_FUNC int emstorage_mail_search_result(DB_STMT search_handle, emstorage_mail_field_type_t type, void** data, int transaction, int *err_code)
{
EM_DEBUG_FUNC_BEGIN("search_handle[%d], type[%d], data[%p], transaction[%d], err_code[%p]", search_handle, type, data, transaction, err_code);
@@ -8445,7 +8453,7 @@ INTERNAL_FUNC int emstorage_mail_search_result(int search_handle, emstorage_mail
}
emstorage_mail_tbl_t* p_data_tbl = NULL;
- DB_STMT hStmt = (DB_STMT)search_handle;
+ DB_STMT hStmt = search_handle;
int rc, ret = false;
int error = EMAIL_ERROR_NONE;
@@ -8581,7 +8589,7 @@ FINISH_OFF:
return ret;
}
-INTERNAL_FUNC int emstorage_mail_search_end(int search_handle, int transaction, int *err_code)
+INTERNAL_FUNC int emstorage_mail_search_end(DB_STMT search_handle, int transaction, int *err_code)
{
EM_DEBUG_FUNC_BEGIN("search_handle[%d], transaction[%d], err_code[%p]", search_handle, transaction, err_code);
@@ -8594,8 +8602,7 @@ INTERNAL_FUNC int emstorage_mail_search_end(int search_handle, int transaction,
goto FINISH_OFF;
}
- DB_STMT hStmt = (DB_STMT)search_handle;
-
+ DB_STMT hStmt = search_handle;
rc = sqlite3_finalize(hStmt);
if (rc != SQLITE_OK) {
diff --git a/email-core/email-storage/include/email-storage.h b/email-core/email-storage/include/email-storage.h
index 1708379..63c36bc 100755
--- a/email-core/email-storage/include/email-storage.h
+++ b/email-core/email-storage/include/email-storage.h
@@ -56,6 +56,8 @@ extern "C"
#define MAX_INTEGER_LENGTH 5 /* 32767 -> 5 bytes */
#define FILE_MAX_BUFFER_SIZE 16 * 1024 /* 16 Kbyte */
+#define DB_STMT sqlite3_stmt *
+
typedef struct
{
int mail_id;
@@ -1023,7 +1025,15 @@ INTERNAL_FUNC int emstorage_update_save_status(char *multi_user_name, int accoun
* @remarks N/A
* @return This function returns 0 on success or error code on failure.
*/
-INTERNAL_FUNC int emstorage_mail_search_start(char *multi_user_name, emstorage_search_filter_t *search, int account_id, int mailbox_id, int sorting, int *search_handle, int *searched, int transaction, int *err_code);
+INTERNAL_FUNC int emstorage_mail_search_start(char *multi_user_name,
+ emstorage_search_filter_t *search,
+ int account_id,
+ int mailbox_id,
+ int sorting,
+ DB_STMT *search_handle,
+ int *searched,
+ int transaction,
+ int *err_code);
/*
* emstorage_mail_search_result
@@ -1034,7 +1044,11 @@ INTERNAL_FUNC int emstorage_mail_search_start(char *multi_user_name, emstorage_s
* mail : double pointer to hold mail
* return :
*/
-INTERNAL_FUNC int emstorage_mail_search_result(int search_handle, emstorage_mail_field_type_t type, void **data, int transaction, int *err_code);
+INTERNAL_FUNC int emstorage_mail_search_result(DB_STMT search_handle,
+ emstorage_mail_field_type_t type,
+ void **data,
+ int transaction,
+ int *err_code);
/*
* emstorage_mail_search_end
@@ -1044,7 +1058,7 @@ INTERNAL_FUNC int emstorage_mail_search_result(int search_handle, emstorage_mail
* search_handle : handle to be finished
* return :
*/
-INTERNAL_FUNC int emstorage_mail_search_end(int search_handle, int transaction, int *err_code);
+INTERNAL_FUNC int emstorage_mail_search_end(DB_STMT search_handle, int transaction, int *err_code);
/*
* emstorage_set_field_of_mails_with_integer_value
diff --git a/email-core/include/email-core-mail.h b/email-core/include/email-core-mail.h
index 52b41d1..73c1b69 100755
--- a/email-core/include/email-core-mail.h
+++ b/email-core/include/email-core-mail.h
@@ -340,6 +340,7 @@ INTERNAL_FUNC int emcore_sync_flag_with_server(char *multi_user_name, int mail
INTERNAL_FUNC int emcore_sync_seen_flag_with_server(char *multi_user_name, int mail_ids[], int num, int event_handle, int *err_code);
INTERNAL_FUNC int emcore_set_flags_field(char *multi_user_name, int account_id, int mail_ids[], int num, email_flags_field_type field_type, int value, int *err_code);
+INTERNAL_FUNC char* emcore_convert_mutf7_to_utf8(char *mailbox_name);
INTERNAL_FUNC int emcore_convert_string_to_structure(const char *encoded_string, void **struct_var, email_convert_struct_type_e type);
INTERNAL_FUNC int emcore_save_mail_file(char *multi_user_name, int account_id, int mail_id, int attachment_id, char *src_file_path, char *file_name, char *full_path, char *virtual_path, int *err_code);
diff --git a/email-core/include/email-core-task-manager.h b/email-core/include/email-core-task-manager.h
index 4f7279f..c792ef2 100755
--- a/email-core/include/email-core-task-manager.h
+++ b/email-core/include/email-core-task-manager.h
@@ -43,7 +43,7 @@ INTERNAL_FUNC int emcore_remove_task_from_task_table(char *multi_user_name, int
INTERNAL_FUNC int emcore_get_active_task_by_thread_id(thread_t input_thread_id, email_active_task_t **output_active_task);
INTERNAL_FUNC void* emcore_default_async_task_handler(void *intput_param);
-INTERNAL_FUNC void* emcore_default_sync_task_handler(void *intput_param);
+INTERNAL_FUNC int emcore_default_sync_task_handler(void *intput_param);
INTERNAL_FUNC int emcore_start_task_manager_loop();
INTERNAL_FUNC int emcore_stop_task_manager_loop();
diff --git a/email-core/include/email-core-utils.h b/email-core/include/email-core-utils.h
index 3a6573f..b9c5cb8 100755
--- a/email-core/include/email-core-utils.h
+++ b/email-core/include/email-core-utils.h
@@ -111,8 +111,6 @@ INTERNAL_FUNC int emcore_add_notification_for_send(char *multi_user_name, int ac
INTERNAL_FUNC void emcore_update_notification_for_send(int account_id, int mail_id, double progress);
INTERNAL_FUNC int emcore_delete_notification_for_read_mail(int mail_id);
INTERNAL_FUNC int emcore_delete_notification_by_account(char *multi_user_name, int account_id, int with_noti_tray);
-INTERNAL_FUNC void emcore_set_flash_noti();
-
INTERNAL_FUNC int emcore_show_user_message(char *multi_user_name, int id, email_action_t action, int error);
diff --git a/email-daemon/email-daemon-etc.c b/email-daemon/email-daemon-etc.c
index a3861a0..e4a98fc 100755
--- a/email-daemon/email-daemon-etc.c
+++ b/email-daemon/email-daemon-etc.c
@@ -463,8 +463,6 @@ INTERNAL_FUNC int emdaemon_finalize_sync(char *multi_user_name, int account_id,
EM_DEBUG_LOG("The email app is topmost");
} else {
- /* LED feature */
-// emcore_set_flash_noti();
if ((err = emcore_add_notification(multi_user_name, account_id, 0, unread_mail_count, vip_unread_mail_count, 1, EMAIL_ERROR_NONE, NOTIFICATION_DISPLAY_APP_ALL)) != EMAIL_ERROR_NONE)
EM_DEBUG_EXCEPTION("emcore_add_notification failed : [%d]", err);
diff --git a/email-daemon/email-daemon-mail.c b/email-daemon/email-daemon-mail.c
index aa2d318..cc7ef17 100755
--- a/email-daemon/email-daemon-mail.c
+++ b/email-daemon/email-daemon-mail.c
@@ -587,7 +587,7 @@ void* thread_func_to_delete_mail(void *thread_argument)
int account_id = 0;
int from_server = 0;
int noti_param_2 = 0;
- int handle = 0;
+ int handle = 0;
char *multi_user_name = NULL;
email_event_t *event_data = (email_event_t*)thread_argument;
@@ -597,15 +597,17 @@ void* thread_func_to_delete_mail(void *thread_argument)
from_server = event_data->event_param_data_5;
multi_user_name = event_data->multi_user_name;
- if (!emcore_delete_mail(multi_user_name, account_id, mail_id_list, mail_id_count, EMAIL_DELETE_LOCALLY, EMAIL_DELETED_BY_COMMAND, noti_param_2, &err)) {
- EM_DEBUG_EXCEPTION(" emcore_delete_mail failed [%d]", err);
+ if (!emcore_delete_mail(multi_user_name, account_id, mail_id_list,
+ mail_id_count, EMAIL_DELETE_LOCALLY,
+ EMAIL_DELETED_BY_COMMAND, noti_param_2, &err)) {
+ EM_DEBUG_EXCEPTION("emcore_delete_mail failed [%d]", err);
emcore_free_event(event_data); /* prevent 17922 */
EM_SAFE_FREE(event_data);
goto FINISH_OFF;
}
if (from_server == EMAIL_DELETE_LOCAL_AND_SERVER || from_server == EMAIL_DELETE_FROM_SERVER) {
- if (!emcore_insert_event(event_data, (int*)handle, &err)) {
+ if (!emcore_insert_event(event_data, &handle, &err)) {
EM_DEBUG_EXCEPTION("emcore_insert_event failed [%d]", err);
/* if (from_server != EMAIL_DELETE_LOCAL_AND_SERVER && from_server != EMAIL_DELETE_FROM_SERVER) {
EM_SAFE_FREE(event_data->event_param_data_3);
@@ -756,7 +758,8 @@ int emdaemon_delete_mail_all(char *multi_user_name, int input_mailbox_id, int in
}
#ifdef __FEATURE_LOCAL_ACTIVITY__
- int i, total = 0 , search_handle = 0;
+ int i, total = 0;
+ DB_STMT search_handle = 0;
int *mail_ids = NULL;
emstorage_activity_tbl_t new_activity;
int activityid = 0;
diff --git a/email-daemon/main.c b/email-daemon/main.c
index 783d05a..035f495 100755
--- a/email-daemon/main.c
+++ b/email-daemon/main.c
@@ -3368,7 +3368,12 @@ void stb_handle_task(int task_type, HIPC_API a_hAPI)
if(is_async_task) {
/* add async task */
- if((err = emcore_add_task_to_task_table(NULL, task_type, EMAIL_TASK_PRIORITY_MID, task_parameter, task_parameter_length, &task_id)) != EMAIL_ERROR_NONE) {
+ if((err = emcore_add_task_to_task_table(NULL,
+ task_type,
+ EMAIL_TASK_PRIORITY_MID,
+ task_parameter,
+ task_parameter_length,
+ &task_id)) != EMAIL_ERROR_NONE) {
EM_DEBUG_EXCEPTION("emcore_add_task_to_task_pool failed [%d]", err);
goto FINISH_OFF;
}
@@ -3383,7 +3388,7 @@ void stb_handle_task(int task_type, HIPC_API a_hAPI)
sync_task.task_parameter = task_parameter;
sync_task.task_parameter_length = task_parameter_length;
- if((err = (int)emcore_default_sync_task_handler(&sync_task)) != EMAIL_ERROR_NONE) {
+ if((err = emcore_default_sync_task_handler(&sync_task)) != EMAIL_ERROR_NONE) {
EM_DEBUG_EXCEPTION("emcore_default_sync_task_handler failed [%d]", err);
goto FINISH_OFF;
}
diff --git a/email-ipc/include/email-ipc.h b/email-ipc/include/email-ipc.h
index 3fb55aa..0a574b9 100755
--- a/email-ipc/include/email-ipc.h
+++ b/email-ipc/include/email-ipc.h
@@ -73,6 +73,7 @@ EXPORT_API void emipc_destroy_email_api(HIPC_API input_api_handle);
EXPORT_API long emipc_get_api_id(HIPC_API input_api_handle);
EXPORT_API long emipc_get_app_id(HIPC_API input_api_handle);
+EXPORT_API long emipc_get_response_id(HIPC_API input_api_handle);
EXPORT_API bool emipc_add_parameter(HIPC_API api, EPARAMETER_DIRECTION direction, void *data, int data_length);
EXPORT_API bool emipc_add_dynamic_parameter(HIPC_API api, EPARAMETER_DIRECTION direction, void *data, int data_length);
diff --git a/utilities/test-application/testapp-mail.c b/utilities/test-application/testapp-mail.c
index af15c2a..32219c3 100755
--- a/utilities/test-application/testapp-mail.c
+++ b/utilities/test-application/testapp-mail.c
@@ -45,8 +45,8 @@
#include "email-core-utils.h"
#include "email-core-mime.h"
-#define MAIL_TEMP_BODY "/tmp/utf-8"
-#define HTML_TEMP_BODY "/tmp/utf-8.htm"
+#define MAIL_TEMP_BODY "/tmp/utf8"
+#define HTML_TEMP_BODY "/tmp/utf8.htm"
/*
static void testapp_test_print_sorting_menu()