← Back to branch summary

~ubuntu-branches/ubuntu/raring/qtwebkit-source/raring-proposed

« back to all changes in this revision

Viewing changes to Source/WebCore/storage/wince/DatabaseThreadWinCE.cpp

  • Committer: Package Import Robot
  • Author(s): Jonathan Riddell
  • Date: 2013-02-18 14:24:18 UTC
  • Revision ID: package-import@ubuntu.com-20130218142418-eon0jmjg3nj438uy
Tags: upstream-2.3
Import upstream version 2.3

Show diffs side-by-side

added added

removed removed

Lines of Context:
Source/WebCore/storage/wince/DatabaseThreadWinCE.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 "DatabaseThread.h"
 
26
 
 
27
#include "Database.h"
 
28
#include "DatabaseTask.h"
 
29
 
 
30
namespace WebCore {
 
31
 
 
32
DatabaseThread::DatabaseThread()
 
33
: m_timer(this, &DatabaseThread::timerFired)
 
34
{
 
35
}
 
36
 
 
37
DatabaseThread::~DatabaseThread()
 
38
{
 
39
}
 
40
 
 
41
void DatabaseThread::requestTermination()
 
42
{
 
43
    m_queue.clear();
 
44
}
 
45
 
 
46
bool DatabaseThread::terminationRequested() const
 
47
{
 
48
    return m_queue.isEmpty();
 
49
}
 
50
 
 
51
void DatabaseThread::timerFired(Timer<DatabaseThread>*)
 
52
{
 
53
    if (!m_queue.isEmpty()) {
 
54
        RefPtr<DatabaseTask> task = m_queue.first();
 
55
        task->performTask();
 
56
        m_queue.removeFirst();
 
57
        if (!m_queue.isEmpty())
 
58
            m_timer.startOneShot(0);
 
59
    }
 
60
}
 
61
 
 
62
void DatabaseThread::scheduleTask(PassRefPtr<DatabaseTask> task)
 
63
{
 
64
    m_queue.append(task);
 
65
    if (!m_timer.isActive())
 
66
        m_timer.startOneShot(0);
 
67
}
 
68
 
 
69
void DatabaseThread::scheduleImmediateTask(PassRefPtr<DatabaseTask> task)
 
70
{
 
71
    task->performTask();
 
72
}
 
73
 
 
74
void DatabaseThread::unscheduleDatabaseTasks(Database* database)
 
75
{
 
76
    Deque<RefPtr<DatabaseTask> > reservedTasks;
 
77
    for (Deque<RefPtr<DatabaseTask> >::const_iterator i = m_queue.begin(); i != m_queue.end(); ++i) {
 
78
        if ((*i)->database() != database)
 
79
            reservedTasks.append(*i);
 
80
    }
 
81
 
 
82
    m_queue.swap(reservedTasks);
 
83
}
 
84
 
 
85
void DatabaseThread::recordDatabaseOpen(Database* database)
 
86
{
 
87
    notImplemented();
 
88
}
 
89
 
 
90
void DatabaseThread::recordDatabaseClosed(Database* database)
 
91
{
 
92
    notImplemented();
 
93
}
 
94
 
 
95
} // namespace WebCore