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
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
// Copyright 2013 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "content/browser/indexed_db/indexed_db_transaction.h"
#include "base/bind.h"
#include "base/logging.h"
#include "base/message_loop/message_loop.h"
#include "base/strings/utf_string_conversions.h"
#include "content/browser/indexed_db/indexed_db_fake_backing_store.h"
#include "content/browser/indexed_db/mock_indexed_db_database_callbacks.h"
#include "testing/gtest/include/gtest/gtest.h"
namespace content {
namespace {
class IndexedDBTransactionTest : public testing::Test {
public:
IndexedDBTransactionTest() {
IndexedDBFactory* factory = NULL;
backing_store_ = new IndexedDBFakeBackingStore();
db_ = IndexedDBDatabase::Create(base::ASCIIToUTF16("db"),
backing_store_,
factory,
IndexedDBDatabase::Identifier());
}
void RunPostedTasks() { message_loop_.RunUntilIdle(); }
void DummyOperation(IndexedDBTransaction* transaction) {}
protected:
scoped_refptr<IndexedDBFakeBackingStore> backing_store_;
scoped_refptr<IndexedDBDatabase> db_;
private:
base::MessageLoop message_loop_;
DISALLOW_COPY_AND_ASSIGN(IndexedDBTransactionTest);
};
TEST_F(IndexedDBTransactionTest, Timeout) {
const int64 id = 0;
const std::set<int64> scope;
const bool commit_success = true;
scoped_refptr<IndexedDBTransaction> transaction = new IndexedDBTransaction(
id,
new MockIndexedDBDatabaseCallbacks(),
scope,
indexed_db::TRANSACTION_READ_ONLY,
db_,
new IndexedDBFakeBackingStore::FakeTransaction(commit_success));
db_->TransactionCreated(transaction);
// No conflicting transactions, so coordinator will start it immediately:
EXPECT_EQ(IndexedDBTransaction::STARTED, transaction->state());
EXPECT_FALSE(transaction->IsTimeoutTimerRunning());
// Schedule a task - timer won't be started until it's processed.
transaction->ScheduleTask(base::Bind(
&IndexedDBTransactionTest::DummyOperation, base::Unretained(this)));
EXPECT_FALSE(transaction->IsTimeoutTimerRunning());
RunPostedTasks();
EXPECT_TRUE(transaction->IsTimeoutTimerRunning());
// Abort should cancel the timer.
transaction->Abort();
EXPECT_EQ(IndexedDBTransaction::FINISHED, transaction->state());
EXPECT_FALSE(transaction->IsTimeoutTimerRunning());
// This task will be ignored.
transaction->ScheduleTask(base::Bind(
&IndexedDBTransactionTest::DummyOperation, base::Unretained(this)));
EXPECT_EQ(IndexedDBTransaction::FINISHED, transaction->state());
EXPECT_FALSE(transaction->IsTimeoutTimerRunning());
}
class AbortObserver {
public:
AbortObserver() : abort_task_called_(false) {}
void AbortTask(IndexedDBTransaction* transaction) {
abort_task_called_ = true;
}
bool abort_task_called() const { return abort_task_called_; }
private:
bool abort_task_called_;
DISALLOW_COPY_AND_ASSIGN(AbortObserver);
};
TEST_F(IndexedDBTransactionTest, AbortTasks) {
const int64 id = 0;
const std::set<int64> scope;
const bool commit_failure = false;
scoped_refptr<IndexedDBTransaction> transaction = new IndexedDBTransaction(
id,
new MockIndexedDBDatabaseCallbacks(),
scope,
indexed_db::TRANSACTION_READ_ONLY,
db_,
new IndexedDBFakeBackingStore::FakeTransaction(commit_failure));
db_->TransactionCreated(transaction);
AbortObserver observer;
transaction->ScheduleTask(
base::Bind(&IndexedDBTransactionTest::DummyOperation,
base::Unretained(this)),
base::Bind(&AbortObserver::AbortTask, base::Unretained(&observer)));
// Pump the message loop so that the transaction completes all pending tasks,
// otherwise it will defer the commit.
base::MessageLoop::current()->RunUntilIdle();
EXPECT_FALSE(observer.abort_task_called());
transaction->Commit();
EXPECT_TRUE(observer.abort_task_called());
}
} // namespace
} // namespace content
|
