else {
AbstractFilterPtrVector::const_iterator it = src_filters.begin();
AbstractFilterPtrVector::const_iterator end_it = src_filters.end();
- for(;it != end_it; it++) {
+ for(;it != end_it; ++it) {
const bool last_result = (*it)->isMatching(filtered_object);
if(INTERSECTION == m_type) {
{
LoggerD("Entered");
email_mail_data_t* mail_data = NULL;
- int err = EMAIL_ERROR_NONE;
- err = email_get_mail_data(msg_id, &mail_data);
+ int err = email_get_mail_data(msg_id, &mail_data);
if (EMAIL_ERROR_NONE != err) {
LoggerE("email_get_mail_data failed. [%d]", err);
} else {
m_proxy_load_body->addCallback(callback);
const int mailId = callback->getMessage()->getId();
- int err = EMAIL_ERROR_NONE;
int op_handle = -1;
- err = email_download_body(mailId, 0, &op_handle);
+ int err = email_download_body(mailId, 0, &op_handle);
if(EMAIL_ERROR_NONE != err){
LoggerE("Email download body failed, %d", err);
m_proxy_load_body->removeCallback(callback);
return;
}
- int err = EMAIL_ERROR_NONE;
-
email_mailbox_t* mailbox = NULL;
const std::string folder_id_str = callback->getMessageFolder()->getId();
int folder_id = 0;
std::istringstream(folder_id_str) >> folder_id;
- err = email_get_mailbox_by_mailbox_id(folder_id, &mailbox);
+ int err = email_get_mailbox_by_mailbox_id(folder_id, &mailbox);
if (EMAIL_ERROR_NONE != err || NULL == mailbox) {
LoggerE("Couldn't get mailbox, error code: %d", err);
return;
}
- int err = EMAIL_ERROR_NONE;
- err = email_cancel_job(callback->getAccountId(),
+ int err = email_cancel_job(callback->getAccountId(),
callback->getOperationHandle(),
EMAIL_CANCELED_BY_USER);
}
if (fprintf(file, "%s", data.c_str()) < 0) {
LoggerE("Failed to write data into file");
+ fclose(file);
+ remove(tmp_name.c_str());
return PlatformResult(ErrorCode::UNKNOWN_ERR, "Failed to write data into file");
}
fflush(file);
return PlatformResult(ErrorCode::NO_ERROR);
}
-PlatformResult Message::addMMSBodyAndAttachmentsToStruct(const AttachmentPtrVector attach,
+PlatformResult Message::addMMSBodyAndAttachmentsToStruct(const AttachmentPtrVector &attach,
msg_struct_t &mms_struct, Message* message)
{
LoggerD("Entered with %d attachments", attach.size());
// function for filling Message attributes
static common::PlatformResult convertPlatformShortMessageToObject(msg_struct_t msg, Message** message);
static common::PlatformResult findShortMessageById(const int id, MessagePtr* message);
- static common::PlatformResult addMMSBodyAndAttachmentsToStruct(const AttachmentPtrVector attach,
+ static common::PlatformResult addMMSBodyAndAttachmentsToStruct(const AttachmentPtrVector &attach,
msg_struct_t &mms_struct,
Message* message);
static common::PlatformResult setMMSBodyAndAttachmentsFromStruct(Message *message,
msg_list_handle_t addr_list = NULL;
msg_struct_t addr_info = NULL;
- msg_error_t err = MSG_SUCCESS;
-
int tempInt;
bool tempBool;
int nToCnt;
std::unique_ptr<std::remove_pointer<msg_struct_t*>::type, int(*)(msg_struct_t*)>
msg_thread_ptr(&msg_thread, &msg_release_struct);
// automatically release the memory
- err = msg_get_thread(handle, conversation->m_conversation_id, msg_thread);
+ msg_error_t err = msg_get_thread(handle, conversation->m_conversation_id, msg_thread);
if (err != MSG_SUCCESS)
{
LoggerE("Failed to retrieve thread.");
msg_error_t MessagingDatabaseManager::connect()
{
LoggerD("Entered");
- int err = 0;
if (NULL == sqlHandle) {
char strDBName[64];
memset(strDBName, 0x00, sizeof(strDBName));
snprintf(strDBName, sizeof(strDBName), "%s", MSG_DB_NAME);
- err = db_util_open(strDBName, &sqlHandle, DB_UTIL_REGISTER_HOOK_METHOD);
+ int err = db_util_open(strDBName, &sqlHandle, DB_UTIL_REGISTER_HOOK_METHOD);
if (SQLITE_OK != err) {
LoggerE("DB connecting fail [%d]", err);
auto callback = new MessagesCallbackUserData(queue_);
- std::vector<std::shared_ptr<Message>> messages;
std::for_each(pico_array.begin(), pico_array.end(), [&callback](picojson::value& v)->void {
std::shared_ptr<Message> message;
PlatformResult ret = MessagingUtil::jsonToMessage(v, &message);
LoggerD("Entered");
std::string str = input;
std::string::iterator i;
- for (i = str.begin(); i != str.end(); i++) {
+ for (i = str.begin(); i != str.end(); ++i) {
if (!isspace(*i)) {
break;
}
EmailManager::getInstance().RemoveCallbacksByQueue(*this);
}
-void PostQueue::addAndResolve(const long cid, PostPriority priority, const std::string json)
+void PostQueue::addAndResolve(const long cid, PostPriority priority, const std::string &json)
{
LoggerD("Entered");
return;
}
-void PostQueue::resolve(const long cid, const std::string json)
+void PostQueue::resolve(const long cid, const std::string &json)
{
LoggerD("Entered: [%p]", this);
LoggerD("Entered");
}
-void PostQueue::PostTask::attach(const std::string j)
+void PostQueue::PostTask::attach(const std::string &j)
{
LoggerD("Entered");
if (TaskState::DONE == state_) {
explicit PostQueue(MessagingInstance& instance);
~PostQueue();
- void addAndResolve(const long cid, PostPriority priority, const std::string json);
+ void addAndResolve(const long cid, PostPriority priority, const std::string &json);
void add(const long cid, PostPriority priority = PostPriority::LAST);
- void resolve(const long cid, const std::string json);
+ void resolve(const long cid, const std::string &json);
enum TaskState {
NEW = 0,
PostTask();
PostTask(PostPriority p);
~PostTask();
- void attach(const std::string j);
+ void attach(const std::string &j);
PostPriority priority();
TaskState state();
std::string json();
ConversationPtrVector updated_conv;
for(ConversationPtrVector::iterator it = eventConv->items.begin();
- it != eventConv->items.end(); it++) {
+ it != eventConv->items.end(); ++it) {
ConversationPtr cur_conv = *it;
const bool new_conv = (cur_conv->getMessageCount() <= 1);
if(new_conv) {
return;
}
- int error;
std::vector<std::shared_ptr<Message>> messages;
{
break;
}
- error = msg_delete_message(m_msg_handle, id);
+ int error = msg_delete_message(m_msg_handle, id);
if (MSG_SUCCESS != error) {
LoggerE("Error while deleting message");
callback->SetError(PlatformResult(ErrorCode::UNKNOWN_ERR, "Error while deleting message"));