1 files changed, 98 insertions, 0 deletions
diff --git a/src/async/imap/MCIMAPIdleOperation.cpp b/src/async/imap/MCIMAPIdleOperation.cpp
new file mode 100644
index 00000000..7154a9f0
--- /dev/null
+++ b/src/async/imap/MCIMAPIdleOperation.cpp
@@ -0,0 +1,98 @@
+//
+//  IMAPIdleOperation.cc
+//  mailcore2
+//
+//  Created by DINH Viêt Hoà on 1/12/13.
+//  Copyright (c) 2013 MailCore. All rights reserved.
+//
+
+#include "MCIMAPIdleOperation.h"
+
+#include "MCIMAPSession.h"
+#include "MCIMAPAsyncConnection.h"
+
+using namespace mailcore;
+
+IMAPIdleOperation::IMAPIdleOperation()
+{
+    mLastKnownUid = 0;
+    mSetupSuccess = false;
+    mInterrupted = false;
+    pthread_mutex_init(&mLock, NULL);
+}
+
+IMAPIdleOperation::~IMAPIdleOperation()
+{
+    pthread_mutex_destroy(&mLock);
+}
+
+void IMAPIdleOperation::setLastKnownUID(uint32_t uid)
+{
+    mLastKnownUid = uid;
+}
+
+uint32_t IMAPIdleOperation::lastKnownUID()
+{
+    return mLastKnownUid;
+}
+
+void IMAPIdleOperation::prepare(void * data)
+{
+    if (isInterrupted()) {
+        mSetupSuccess = false;
+        return;
+    }
+
+    mSetupSuccess = session()->session()->setupIdle();
+}
+
+void IMAPIdleOperation::unprepare(void * data)
+{
+    if (mSetupSuccess) {
+        session()->session()->unsetupIdle();
+    }
+}
+
+bool IMAPIdleOperation::isInterrupted() {
+    pthread_mutex_lock(&mLock);
+    bool interrupted = mInterrupted;
+    pthread_mutex_unlock(&mLock);
+    
+    return interrupted;
+}
+
+void IMAPIdleOperation::main()
+{
+    if (isInterrupted()) {
+        return;
+    }
+    
+    ErrorCode error;
+    session()->session()->selectIfNeeded(folder(), &error);
+    if (error != ErrorNone) {
+        setError(error);
+        return;
+    }
+    
+    performMethodOnCallbackThread((Object::Method) &IMAPIdleOperation::prepare, NULL, true);
+    
+    if (!mSetupSuccess) {
+        return;
+    }
+    
+    session()->session()->idle(folder(), mLastKnownUid, &error);
+    setError(error);
+    
+    performMethodOnCallbackThread((Object::Method) &IMAPIdleOperation::unprepare, NULL, true);
+}
+
+void IMAPIdleOperation::interruptIdle()
+{
+    pthread_mutex_lock(&mLock);
+    mInterrupted = true;
+    pthread_mutex_unlock(&mLock);
+    if (mSetupSuccess) {
+        session()->session()->interruptIdle();
+    }
+}
+