blob: 479876b6c61b1163000adebfb54fce81c5a0623a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
//
// MCPOPOperation.cc
// mailcore2
//
// Created by DINH Viêt Hoà on 1/16/13.
// Copyright (c) 2013 MailCore. All rights reserved.
//
#include "MCPOPOperation.h"
#include <stdlib.h>
#include "MCPOPSession.h"
#include "MCPOPAsyncSession.h"
#include "MCPOPOperationCallback.h"
using namespace mailcore;
POPOperation::POPOperation()
{
mSession = NULL;
mPopCallback = NULL;
mError = ErrorNone;
}
POPOperation::~POPOperation()
{
MC_SAFE_RELEASE(mSession);
}
void POPOperation::setSession(POPAsyncSession * session)
{
MC_SAFE_REPLACE_RETAIN(POPAsyncSession, mSession, session);
#if __APPLE__
dispatch_queue_t queue;
if (session != NULL) {
queue = session->dispatchQueue();
}
else {
queue = dispatch_get_main_queue();
}
setCallbackDispatchQueue(queue);
#endif
}
POPAsyncSession * POPOperation::session()
{
return mSession;
}
void POPOperation::setPopCallback(POPOperationCallback * callback)
{
mPopCallback = callback;
}
POPOperationCallback * POPOperation::popCallback()
{
return mPopCallback;
}
void POPOperation::setError(ErrorCode error)
{
mError = error;
}
ErrorCode POPOperation::error()
{
return mError;
}
void POPOperation::start()
{
mSession->runOperation(this);
}
struct progressContext {
unsigned int current;
unsigned int maximum;
};
void POPOperation::bodyProgress(POPSession * session, unsigned int current, unsigned int maximum)
{
struct progressContext * context = (struct progressContext *) calloc(sizeof(* context), 1);
context->current = current;
context->maximum = maximum;
retain();
performMethodOnCallbackThread((Object::Method) &POPOperation::bodyProgressOnMainThread, context);
}
void POPOperation::bodyProgressOnMainThread(void * ctx)
{
if (isCancelled()) {
release();
return;
}
struct progressContext * context = (struct progressContext *) ctx;
if (mPopCallback != NULL) {
mPopCallback->bodyProgress(this, context->current, context->maximum);
}
free(context);
release();
}
|
