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 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
62 void reportTransactionFailed(ExecuteSQLCallback* requestCallback, SQLError* erro
r) | 62 void reportTransactionFailed(ExecuteSQLCallback* requestCallback, SQLError* erro
r) |
63 { | 63 { |
64 RefPtr<TypeBuilder::Database::Error> errorObject = TypeBuilder::Database::Er
ror::create() | 64 RefPtr<TypeBuilder::Database::Error> errorObject = TypeBuilder::Database::Er
ror::create() |
65 .setMessage(error->message()) | 65 .setMessage(error->message()) |
66 .setCode(error->code()); | 66 .setCode(error->code()); |
67 requestCallback->sendSuccess(nullptr, nullptr, errorObject.release()); | 67 requestCallback->sendSuccess(nullptr, nullptr, errorObject.release()); |
68 } | 68 } |
69 | 69 |
70 class StatementCallback FINAL : public SQLStatementCallback { | 70 class StatementCallback FINAL : public SQLStatementCallback { |
71 public: | 71 public: |
72 static PassOwnPtrWillBeRawPtr<StatementCallback> create(PassRefPtrWillBeRawP
tr<ExecuteSQLCallback> requestCallback) | 72 static StatementCallback* create(PassRefPtrWillBeRawPtr<ExecuteSQLCallback>
requestCallback) |
73 { | 73 { |
74 return adoptPtrWillBeNoop(new StatementCallback(requestCallback)); | 74 return new StatementCallback(requestCallback); |
75 } | 75 } |
76 | 76 |
77 virtual ~StatementCallback() { } | 77 virtual ~StatementCallback() { } |
78 | 78 |
79 virtual void trace(Visitor* visitor) | 79 virtual void trace(Visitor* visitor) |
80 { | 80 { |
81 visitor->trace(m_requestCallback); | 81 visitor->trace(m_requestCallback); |
82 SQLStatementCallback::trace(visitor); | 82 SQLStatementCallback::trace(visitor); |
83 } | 83 } |
84 | 84 |
(...skipping 21 matching lines...) Expand all Loading... |
106 } | 106 } |
107 | 107 |
108 private: | 108 private: |
109 StatementCallback(PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestCallback
) | 109 StatementCallback(PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestCallback
) |
110 : m_requestCallback(requestCallback) { } | 110 : m_requestCallback(requestCallback) { } |
111 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; | 111 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; |
112 }; | 112 }; |
113 | 113 |
114 class StatementErrorCallback FINAL : public SQLStatementErrorCallback { | 114 class StatementErrorCallback FINAL : public SQLStatementErrorCallback { |
115 public: | 115 public: |
116 static PassOwnPtrWillBeRawPtr<StatementErrorCallback> create(PassRefPtrWillB
eRawPtr<ExecuteSQLCallback> requestCallback) | 116 static StatementErrorCallback* create(PassRefPtrWillBeRawPtr<ExecuteSQLCallb
ack> requestCallback) |
117 { | 117 { |
118 return adoptPtrWillBeNoop(new StatementErrorCallback(requestCallback)); | 118 return new StatementErrorCallback(requestCallback); |
119 } | 119 } |
120 | 120 |
121 virtual ~StatementErrorCallback() { } | 121 virtual ~StatementErrorCallback() { } |
122 | 122 |
123 virtual void trace(Visitor* visitor) OVERRIDE | 123 virtual void trace(Visitor* visitor) OVERRIDE |
124 { | 124 { |
125 visitor->trace(m_requestCallback); | 125 visitor->trace(m_requestCallback); |
126 SQLStatementErrorCallback::trace(visitor); | 126 SQLStatementErrorCallback::trace(visitor); |
127 } | 127 } |
128 | 128 |
129 virtual bool handleEvent(SQLTransaction*, SQLError* error) OVERRIDE | 129 virtual bool handleEvent(SQLTransaction*, SQLError* error) OVERRIDE |
130 { | 130 { |
131 reportTransactionFailed(m_requestCallback.get(), error); | 131 reportTransactionFailed(m_requestCallback.get(), error); |
132 return true; | 132 return true; |
133 } | 133 } |
134 | 134 |
135 private: | 135 private: |
136 StatementErrorCallback(PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestCal
lback) | 136 StatementErrorCallback(PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestCal
lback) |
137 : m_requestCallback(requestCallback) { } | 137 : m_requestCallback(requestCallback) { } |
138 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; | 138 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; |
139 }; | 139 }; |
140 | 140 |
141 class TransactionCallback FINAL : public SQLTransactionCallback { | 141 class TransactionCallback FINAL : public SQLTransactionCallback { |
142 public: | 142 public: |
143 static PassOwnPtrWillBeRawPtr<TransactionCallback> create(const String& sqlS
tatement, PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestCallback) | 143 static TransactionCallback* create(const String& sqlStatement, PassRefPtrWil
lBeRawPtr<ExecuteSQLCallback> requestCallback) |
144 { | 144 { |
145 return adoptPtrWillBeNoop(new TransactionCallback(sqlStatement, requestC
allback)); | 145 return new TransactionCallback(sqlStatement, requestCallback); |
146 } | 146 } |
147 | 147 |
148 virtual ~TransactionCallback() { } | 148 virtual ~TransactionCallback() { } |
149 | 149 |
150 virtual void trace(Visitor* visitor) OVERRIDE | 150 virtual void trace(Visitor* visitor) OVERRIDE |
151 { | 151 { |
152 visitor->trace(m_requestCallback); | 152 visitor->trace(m_requestCallback); |
153 SQLTransactionCallback::trace(visitor); | 153 SQLTransactionCallback::trace(visitor); |
154 } | 154 } |
155 | 155 |
156 virtual bool handleEvent(SQLTransaction* transaction) OVERRIDE | 156 virtual bool handleEvent(SQLTransaction* transaction) OVERRIDE |
157 { | 157 { |
158 if (!m_requestCallback->isActive()) | 158 if (!m_requestCallback->isActive()) |
159 return true; | 159 return true; |
160 | 160 |
161 Vector<SQLValue> sqlValues; | 161 Vector<SQLValue> sqlValues; |
162 OwnPtrWillBeRawPtr<SQLStatementCallback> callback(StatementCallback::cre
ate(m_requestCallback.get())); | 162 SQLStatementCallback* callback = StatementCallback::create(m_requestCall
back.get()); |
163 OwnPtrWillBeRawPtr<SQLStatementErrorCallback> errorCallback(StatementErr
orCallback::create(m_requestCallback.get())); | 163 SQLStatementErrorCallback* errorCallback = StatementErrorCallback::creat
e(m_requestCallback.get()); |
164 transaction->executeSQL(m_sqlStatement, sqlValues, callback.release(), e
rrorCallback.release(), IGNORE_EXCEPTION); | 164 transaction->executeSQL(m_sqlStatement, sqlValues, callback, errorCallba
ck, IGNORE_EXCEPTION); |
165 return true; | 165 return true; |
166 } | 166 } |
167 private: | 167 private: |
168 TransactionCallback(const String& sqlStatement, PassRefPtrWillBeRawPtr<Execu
teSQLCallback> requestCallback) | 168 TransactionCallback(const String& sqlStatement, PassRefPtrWillBeRawPtr<Execu
teSQLCallback> requestCallback) |
169 : m_sqlStatement(sqlStatement) | 169 : m_sqlStatement(sqlStatement) |
170 , m_requestCallback(requestCallback) { } | 170 , m_requestCallback(requestCallback) { } |
171 String m_sqlStatement; | 171 String m_sqlStatement; |
172 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; | 172 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; |
173 }; | 173 }; |
174 | 174 |
175 class TransactionErrorCallback FINAL : public SQLTransactionErrorCallback { | 175 class TransactionErrorCallback FINAL : public SQLTransactionErrorCallback { |
176 public: | 176 public: |
177 static PassOwnPtrWillBeRawPtr<TransactionErrorCallback> create(PassRefPtrWil
lBeRawPtr<ExecuteSQLCallback> requestCallback) | 177 static TransactionErrorCallback* create(PassRefPtrWillBeRawPtr<ExecuteSQLCal
lback> requestCallback) |
178 { | 178 { |
179 return adoptPtrWillBeNoop(new TransactionErrorCallback(requestCallback))
; | 179 return new TransactionErrorCallback(requestCallback); |
180 } | 180 } |
181 | 181 |
182 virtual ~TransactionErrorCallback() { } | 182 virtual ~TransactionErrorCallback() { } |
183 | 183 |
184 virtual void trace(Visitor* visitor) OVERRIDE | 184 virtual void trace(Visitor* visitor) OVERRIDE |
185 { | 185 { |
186 visitor->trace(m_requestCallback); | 186 visitor->trace(m_requestCallback); |
187 SQLTransactionErrorCallback::trace(visitor); | 187 SQLTransactionErrorCallback::trace(visitor); |
188 } | 188 } |
189 | 189 |
190 virtual bool handleEvent(SQLError* error) OVERRIDE | 190 virtual bool handleEvent(SQLError* error) OVERRIDE |
191 { | 191 { |
192 reportTransactionFailed(m_requestCallback.get(), error); | 192 reportTransactionFailed(m_requestCallback.get(), error); |
193 return true; | 193 return true; |
194 } | 194 } |
195 private: | 195 private: |
196 TransactionErrorCallback(PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestC
allback) | 196 TransactionErrorCallback(PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestC
allback) |
197 : m_requestCallback(requestCallback) { } | 197 : m_requestCallback(requestCallback) { } |
198 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; | 198 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; |
199 }; | 199 }; |
200 | 200 |
201 class TransactionSuccessCallback FINAL : public VoidCallback { | 201 class TransactionSuccessCallback FINAL : public VoidCallback { |
202 public: | 202 public: |
203 static PassOwnPtrWillBeRawPtr<TransactionSuccessCallback> create() | 203 static TransactionSuccessCallback* create() |
204 { | 204 { |
205 return adoptPtrWillBeNoop(new TransactionSuccessCallback()); | 205 return new TransactionSuccessCallback(); |
206 } | 206 } |
207 | 207 |
208 virtual ~TransactionSuccessCallback() { } | 208 virtual ~TransactionSuccessCallback() { } |
209 | 209 |
210 virtual void handleEvent() OVERRIDE { } | 210 virtual void handleEvent() OVERRIDE { } |
211 | 211 |
212 private: | 212 private: |
213 TransactionSuccessCallback() { } | 213 TransactionSuccessCallback() { } |
214 }; | 214 }; |
215 | 215 |
(...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
307 requestCallback->sendFailure("Database agent is not enabled"); | 307 requestCallback->sendFailure("Database agent is not enabled"); |
308 return; | 308 return; |
309 } | 309 } |
310 | 310 |
311 Database* database = databaseForId(databaseId); | 311 Database* database = databaseForId(databaseId); |
312 if (!database) { | 312 if (!database) { |
313 requestCallback->sendFailure("Database not found"); | 313 requestCallback->sendFailure("Database not found"); |
314 return; | 314 return; |
315 } | 315 } |
316 | 316 |
317 OwnPtrWillBeRawPtr<SQLTransactionCallback> callback(TransactionCallback::cre
ate(query, requestCallback.get())); | 317 SQLTransactionCallback* callback = TransactionCallback::create(query, reques
tCallback.get()); |
318 OwnPtrWillBeRawPtr<SQLTransactionErrorCallback> errorCallback(TransactionErr
orCallback::create(requestCallback.get())); | 318 SQLTransactionErrorCallback* errorCallback = TransactionErrorCallback::creat
e(requestCallback.get()); |
319 OwnPtrWillBeRawPtr<VoidCallback> successCallback(TransactionSuccessCallback:
:create()); | 319 VoidCallback* successCallback = TransactionSuccessCallback::create(); |
320 database->transaction(callback.release(), errorCallback.release(), successCa
llback.release()); | 320 database->transaction(callback, errorCallback, successCallback); |
321 } | 321 } |
322 | 322 |
323 InspectorDatabaseResource* InspectorDatabaseAgent::findByFileName(const String&
fileName) | 323 InspectorDatabaseResource* InspectorDatabaseAgent::findByFileName(const String&
fileName) |
324 { | 324 { |
325 for (DatabaseResourcesHeapMap::iterator it = m_resources.begin(); it != m_re
sources.end(); ++it) { | 325 for (DatabaseResourcesHeapMap::iterator it = m_resources.begin(); it != m_re
sources.end(); ++it) { |
326 if (it->value->database()->fileName() == fileName) | 326 if (it->value->database()->fileName() == fileName) |
327 return it->value.get(); | 327 return it->value.get(); |
328 } | 328 } |
329 return 0; | 329 return 0; |
330 } | 330 } |
331 | 331 |
332 Database* InspectorDatabaseAgent::databaseForId(const String& databaseId) | 332 Database* InspectorDatabaseAgent::databaseForId(const String& databaseId) |
333 { | 333 { |
334 DatabaseResourcesHeapMap::iterator it = m_resources.find(databaseId); | 334 DatabaseResourcesHeapMap::iterator it = m_resources.find(databaseId); |
335 if (it == m_resources.end()) | 335 if (it == m_resources.end()) |
336 return 0; | 336 return 0; |
337 return it->value->database(); | 337 return it->value->database(); |
338 } | 338 } |
339 | 339 |
340 void InspectorDatabaseAgent::trace(Visitor* visitor) | 340 void InspectorDatabaseAgent::trace(Visitor* visitor) |
341 { | 341 { |
342 #if ENABLE(OILPAN) | 342 #if ENABLE(OILPAN) |
343 visitor->trace(m_resources); | 343 visitor->trace(m_resources); |
344 #endif | 344 #endif |
345 InspectorBaseAgent::trace(visitor); | 345 InspectorBaseAgent::trace(visitor); |
346 } | 346 } |
347 | 347 |
348 } // namespace blink | 348 } // namespace blink |
OLD | NEW |