code.vuplus.com Git - vuplus_webkit/blob - Source/WebCore/storage/wince/LocalStorageThreadWinCE.cpp

   1 /*
   2  * Copyright (C) 2009 Torch Mobile, Inc. All rights reserved.
   3  *
   4  * Redistribution and use in source and binary forms, with or without
   5  * modification, are permitted provided that the following conditions
   6  * are met:
   7  * 1. Redistributions of source code must retain the above copyright
   8  *    notice, this list of conditions and the following disclaimer.
   9  * 2. Redistributions in binary form must reproduce the above copyright
  10  *    notice, this list of conditions and the following disclaimer in the
  11  *    documentation and/or other materials provided with the distribution.
  12  *
  13  *  This library is distributed in the hope that i will be useful,
  14  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  15  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  16  *  Library General Public License for more details.
  17  *
  18  *  You should have received a copy of the GNU Library General Public License
  19  *  along with this library; see the file COPYING.LIB.  If not, write to
  20  *  the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
  21  *  Boston, MA 02110-1301, USA.
  22  */
  23
  24 #include "config.h"
  25 #include "LocalStorageThread.h"
  26
  27 #include "LocalStorageTask.h"
  28 #include "StorageAreaSync.h"
  29
  30 namespace WebCore {
  31
  32 LocalStorageThread::LocalStorageThread()
  33 : m_timer(this, &LocalStorageThread::timerFired)
  34 {
  35 }
  36
  37 LocalStorageThread::~LocalStorageThread()
  38 {
  39 }
  40
  41 bool LocalStorageThread::start()
  42 {
  43     return true;
  44 }
  45
  46 void LocalStorageThread::timerFired(Timer<LocalStorageThread>*)
  47 {
  48     if (!m_queue.isEmpty()) {
  49         RefPtr<LocalStorageTask> task = m_queue.first();
  50         task->performTask();
  51         m_queue.removeFirst();
  52         if (!m_queue.isEmpty())
  53             m_timer.startOneShot(0);
  54     }
  55 }
  56
  57 void LocalStorageThread::scheduleImport(PassRefPtr<StorageAreaSync> area)
  58 {
  59     m_queue.append(LocalStorageTask::createImport(area));
  60     if (!m_timer.isActive())
  61         m_timer.startOneShot(0);
  62 }
  63
  64 void LocalStorageThread::scheduleSync(PassRefPtr<StorageAreaSync> area)
  65 {
  66     m_queue.append(LocalStorageTask::createSync(area));
  67     if (!m_timer.isActive())
  68         m_timer.startOneShot(0);
  69 }
  70
  71 void LocalStorageThread::terminate()
  72 {
  73     m_queue.clear();
  74     m_timer.stop();
  75 }
  76
  77 void LocalStorageThread::performTerminate()
  78 {
  79     m_queue.clear();
  80     m_timer.stop();
  81 }
  82
  83 } // namespace WebCore