OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2010 Google Inc. All rights reserved. | 2 * Copyright (C) 2010 Google Inc. All rights reserved. |
3 * | 3 * |
4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
5 * modification, are permitted provided that the following conditions | 5 * modification, are permitted provided that the following conditions |
6 * are met: | 6 * are met: |
7 * | 7 * |
8 * 1. Redistributions of source code must retain the above copyright | 8 * 1. Redistributions of source code must retain the above copyright |
9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
10 * 2. Redistributions in binary form must reproduce the above copyright | 10 * 2. Redistributions in binary form must reproduce the above copyright |
(...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
102 | 102 |
103 void IDBCursor::trace(Visitor* visitor) | 103 void IDBCursor::trace(Visitor* visitor) |
104 { | 104 { |
105 visitor->trace(m_request); | 105 visitor->trace(m_request); |
106 visitor->trace(m_source); | 106 visitor->trace(m_source); |
107 visitor->trace(m_transaction); | 107 visitor->trace(m_transaction); |
108 visitor->trace(m_key); | 108 visitor->trace(m_key); |
109 visitor->trace(m_primaryKey); | 109 visitor->trace(m_primaryKey); |
110 } | 110 } |
111 | 111 |
112 IDBRequest* IDBCursor::update(ExecutionContext* executionContext, ScriptValue& v
alue, ExceptionState& exceptionState) | 112 IDBRequest* IDBCursor::update(ScriptState* scriptState, ScriptValue& value, Exce
ptionState& exceptionState) |
113 { | 113 { |
114 IDB_TRACE("IDBCursor::update"); | 114 IDB_TRACE("IDBCursor::update"); |
115 | 115 |
116 if (!m_gotValue) { | 116 if (!m_gotValue) { |
117 exceptionState.throwDOMException(InvalidStateError, IDBDatabase::noValue
ErrorMessage); | 117 exceptionState.throwDOMException(InvalidStateError, IDBDatabase::noValue
ErrorMessage); |
118 return 0; | 118 return 0; |
119 } | 119 } |
120 if (isKeyCursor()) { | 120 if (isKeyCursor()) { |
121 exceptionState.throwDOMException(InvalidStateError, IDBDatabase::isKeyCu
rsorErrorMessage); | 121 exceptionState.throwDOMException(InvalidStateError, IDBDatabase::isKeyCu
rsorErrorMessage); |
122 return 0; | 122 return 0; |
(...skipping 12 matching lines...) Expand all Loading... |
135 } | 135 } |
136 if (m_transaction->isReadOnly()) { | 136 if (m_transaction->isReadOnly()) { |
137 exceptionState.throwDOMException(ReadOnlyError, "The record may not be u
pdated inside a read-only transaction."); | 137 exceptionState.throwDOMException(ReadOnlyError, "The record may not be u
pdated inside a read-only transaction."); |
138 return 0; | 138 return 0; |
139 } | 139 } |
140 | 140 |
141 IDBObjectStore* objectStore = effectiveObjectStore(); | 141 IDBObjectStore* objectStore = effectiveObjectStore(); |
142 const IDBKeyPath& keyPath = objectStore->metadata().keyPath; | 142 const IDBKeyPath& keyPath = objectStore->metadata().keyPath; |
143 const bool usesInLineKeys = !keyPath.isNull(); | 143 const bool usesInLineKeys = !keyPath.isNull(); |
144 if (usesInLineKeys) { | 144 if (usesInLineKeys) { |
145 IDBKey* keyPathKey = createIDBKeyFromScriptValueAndKeyPath(toIsolate(exe
cutionContext), value, keyPath); | 145 IDBKey* keyPathKey = createIDBKeyFromScriptValueAndKeyPath(scriptState->
isolate(), value, keyPath); |
146 if (!keyPathKey || !keyPathKey->isEqual(m_primaryKey.get())) { | 146 if (!keyPathKey || !keyPathKey->isEqual(m_primaryKey.get())) { |
147 exceptionState.throwDOMException(DataError, "The effective object st
ore of this cursor uses in-line keys and evaluating the key path of the value pa
rameter results in a different value than the cursor's effective key."); | 147 exceptionState.throwDOMException(DataError, "The effective object st
ore of this cursor uses in-line keys and evaluating the key path of the value pa
rameter results in a different value than the cursor's effective key."); |
148 return 0; | 148 return 0; |
149 } | 149 } |
150 } | 150 } |
151 | 151 |
152 return objectStore->put(executionContext, WebIDBDatabase::CursorUpdate, IDBA
ny::create(this), value, m_primaryKey, exceptionState); | 152 return objectStore->put(scriptState, WebIDBDatabase::CursorUpdate, IDBAny::c
reate(this), value, m_primaryKey, exceptionState); |
153 } | 153 } |
154 | 154 |
155 void IDBCursor::advance(unsigned long count, ExceptionState& exceptionState) | 155 void IDBCursor::advance(unsigned long count, ExceptionState& exceptionState) |
156 { | 156 { |
157 IDB_TRACE("IDBCursor::advance"); | 157 IDB_TRACE("IDBCursor::advance"); |
158 if (!count) { | 158 if (!count) { |
159 exceptionState.throwTypeError("A count argument with value 0 (zero) was
supplied, must be greater than 0."); | 159 exceptionState.throwTypeError("A count argument with value 0 (zero) was
supplied, must be greater than 0."); |
160 return; | 160 return; |
161 } | 161 } |
162 if (!m_gotValue) { | 162 if (!m_gotValue) { |
(...skipping 12 matching lines...) Expand all Loading... |
175 if (!m_transaction->isActive()) { | 175 if (!m_transaction->isActive()) { |
176 exceptionState.throwDOMException(TransactionInactiveError, IDBDatabase::
transactionInactiveErrorMessage); | 176 exceptionState.throwDOMException(TransactionInactiveError, IDBDatabase::
transactionInactiveErrorMessage); |
177 return; | 177 return; |
178 } | 178 } |
179 | 179 |
180 m_request->setPendingCursor(this); | 180 m_request->setPendingCursor(this); |
181 m_gotValue = false; | 181 m_gotValue = false; |
182 m_backend->advance(count, WebIDBCallbacksImpl::create(m_request).leakPtr()); | 182 m_backend->advance(count, WebIDBCallbacksImpl::create(m_request).leakPtr()); |
183 } | 183 } |
184 | 184 |
185 void IDBCursor::continueFunction(ExecutionContext* context, const ScriptValue& k
eyValue, ExceptionState& exceptionState) | 185 void IDBCursor::continueFunction(ScriptState* scriptState, const ScriptValue& ke
yValue, ExceptionState& exceptionState) |
186 { | 186 { |
187 IDB_TRACE("IDBCursor::continue"); | 187 IDB_TRACE("IDBCursor::continue"); |
188 IDBKey* key = keyValue.isUndefined() || keyValue.isNull() ? 0 : scriptValueT
oIDBKey(toIsolate(context), keyValue); | 188 IDBKey* key = keyValue.isUndefined() || keyValue.isNull() ? nullptr : script
ValueToIDBKey(scriptState->isolate(), keyValue); |
189 if (key && !key->isValid()) { | 189 if (key && !key->isValid()) { |
190 exceptionState.throwDOMException(DataError, IDBDatabase::notValidKeyErro
rMessage); | 190 exceptionState.throwDOMException(DataError, IDBDatabase::notValidKeyErro
rMessage); |
191 return; | 191 return; |
192 } | 192 } |
193 continueFunction(key, 0, exceptionState); | 193 continueFunction(key, 0, exceptionState); |
194 } | 194 } |
195 | 195 |
196 void IDBCursor::continuePrimaryKey(ExecutionContext* context, const ScriptValue&
keyValue, const ScriptValue& primaryKeyValue, ExceptionState& exceptionState) | 196 void IDBCursor::continuePrimaryKey(ScriptState* scriptState, const ScriptValue&
keyValue, const ScriptValue& primaryKeyValue, ExceptionState& exceptionState) |
197 { | 197 { |
198 IDB_TRACE("IDBCursor::continuePrimaryKey"); | 198 IDB_TRACE("IDBCursor::continuePrimaryKey"); |
199 IDBKey* key = scriptValueToIDBKey(toIsolate(context), keyValue); | 199 IDBKey* key = scriptValueToIDBKey(scriptState->isolate(), keyValue); |
200 IDBKey* primaryKey = scriptValueToIDBKey(toIsolate(context), primaryKeyValue
); | 200 IDBKey* primaryKey = scriptValueToIDBKey(scriptState->isolate(), primaryKeyV
alue); |
201 if (!key->isValid() || !primaryKey->isValid()) { | 201 if (!key->isValid() || !primaryKey->isValid()) { |
202 exceptionState.throwDOMException(DataError, IDBDatabase::notValidKeyErro
rMessage); | 202 exceptionState.throwDOMException(DataError, IDBDatabase::notValidKeyErro
rMessage); |
203 return; | 203 return; |
204 } | 204 } |
205 continueFunction(key, primaryKey, exceptionState); | 205 continueFunction(key, primaryKey, exceptionState); |
206 } | 206 } |
207 | 207 |
208 void IDBCursor::continueFunction(IDBKey* key, IDBKey* primaryKey, ExceptionState
& exceptionState) | 208 void IDBCursor::continueFunction(IDBKey* key, IDBKey* primaryKey, ExceptionState
& exceptionState) |
209 { | 209 { |
210 ASSERT(!primaryKey || (key && primaryKey)); | 210 ASSERT(!primaryKey || (key && primaryKey)); |
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
248 } | 248 } |
249 } | 249 } |
250 | 250 |
251 // FIXME: We're not using the context from when continue was called, which m
eans the callback | 251 // FIXME: We're not using the context from when continue was called, which m
eans the callback |
252 // will be on the original context openCursor was called on. Is this
right? | 252 // will be on the original context openCursor was called on. Is this
right? |
253 m_request->setPendingCursor(this); | 253 m_request->setPendingCursor(this); |
254 m_gotValue = false; | 254 m_gotValue = false; |
255 m_backend->continueFunction(key, primaryKey, WebIDBCallbacksImpl::create(m_r
equest).leakPtr()); | 255 m_backend->continueFunction(key, primaryKey, WebIDBCallbacksImpl::create(m_r
equest).leakPtr()); |
256 } | 256 } |
257 | 257 |
258 IDBRequest* IDBCursor::deleteFunction(ExecutionContext* context, ExceptionState&
exceptionState) | 258 IDBRequest* IDBCursor::deleteFunction(ScriptState* scriptState, ExceptionState&
exceptionState) |
259 { | 259 { |
260 IDB_TRACE("IDBCursor::delete"); | 260 IDB_TRACE("IDBCursor::delete"); |
261 if (m_transaction->isFinished() || m_transaction->isFinishing()) { | 261 if (m_transaction->isFinished() || m_transaction->isFinishing()) { |
262 exceptionState.throwDOMException(TransactionInactiveError, IDBDatabase::
transactionFinishedErrorMessage); | 262 exceptionState.throwDOMException(TransactionInactiveError, IDBDatabase::
transactionFinishedErrorMessage); |
263 return 0; | 263 return 0; |
264 } | 264 } |
265 if (!m_transaction->isActive()) { | 265 if (!m_transaction->isActive()) { |
266 exceptionState.throwDOMException(TransactionInactiveError, IDBDatabase::
transactionInactiveErrorMessage); | 266 exceptionState.throwDOMException(TransactionInactiveError, IDBDatabase::
transactionInactiveErrorMessage); |
267 return 0; | 267 return 0; |
268 } | 268 } |
(...skipping 15 matching lines...) Expand all Loading... |
284 return 0; | 284 return 0; |
285 } | 285 } |
286 if (!m_transaction->backendDB()) { | 286 if (!m_transaction->backendDB()) { |
287 exceptionState.throwDOMException(InvalidStateError, IDBDatabase::databas
eClosedErrorMessage); | 287 exceptionState.throwDOMException(InvalidStateError, IDBDatabase::databas
eClosedErrorMessage); |
288 return 0; | 288 return 0; |
289 } | 289 } |
290 | 290 |
291 IDBKeyRange* keyRange = IDBKeyRange::only(m_primaryKey, exceptionState); | 291 IDBKeyRange* keyRange = IDBKeyRange::only(m_primaryKey, exceptionState); |
292 ASSERT(!exceptionState.hadException()); | 292 ASSERT(!exceptionState.hadException()); |
293 | 293 |
294 IDBRequest* request = IDBRequest::create(context, IDBAny::create(this), m_tr
ansaction.get()); | 294 IDBRequest* request = IDBRequest::create(scriptState, IDBAny::create(this),
m_transaction.get()); |
295 m_transaction->backendDB()->deleteRange(m_transaction->id(), effectiveObject
Store()->id(), keyRange, WebIDBCallbacksImpl::create(request).leakPtr()); | 295 m_transaction->backendDB()->deleteRange(m_transaction->id(), effectiveObject
Store()->id(), keyRange, WebIDBCallbacksImpl::create(request).leakPtr()); |
296 return request; | 296 return request; |
297 } | 297 } |
298 | 298 |
299 void IDBCursor::postSuccessHandlerCallback() | 299 void IDBCursor::postSuccessHandlerCallback() |
300 { | 300 { |
301 if (m_backend) | 301 if (m_backend) |
302 m_backend->postSuccessHandlerCallback(); | 302 m_backend->postSuccessHandlerCallback(); |
303 } | 303 } |
304 | 304 |
(...skipping 115 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
420 case WebIDBCursor::PrevNoDuplicate: | 420 case WebIDBCursor::PrevNoDuplicate: |
421 return IDBCursor::directionPrevUnique(); | 421 return IDBCursor::directionPrevUnique(); |
422 | 422 |
423 default: | 423 default: |
424 ASSERT_NOT_REACHED(); | 424 ASSERT_NOT_REACHED(); |
425 return IDBCursor::directionNext(); | 425 return IDBCursor::directionNext(); |
426 } | 426 } |
427 } | 427 } |
428 | 428 |
429 } // namespace WebCore | 429 } // namespace WebCore |
OLD | NEW |