| OLD | NEW | 
|    1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |    1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 
|    2 // Use of this source code is governed by a BSD-style license that can be |    2 // Use of this source code is governed by a BSD-style license that can be | 
|    3 // found in the LICENSE file. |    3 // found in the LICENSE file. | 
|    4  |    4  | 
|    5 #include "base/message_loop.h" |    5 #include "base/message_loop.h" | 
|    6 #include "base/task.h" |    6 #include "base/task.h" | 
|    7 #include "base/threading/thread.h" |    7 #include "base/threading/thread.h" | 
|    8 #include "base/utf_string_conversions.h" |    8 #include "base/utf_string_conversions.h" | 
|    9 #include "testing/gtest/include/gtest/gtest.h" |    9 #include "testing/gtest/include/gtest/gtest.h" | 
|   10 #include "webkit/database/database_connections.h" |   10 #include "webkit/database/database_connections.h" | 
| (...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|   74   another.AddConnection(kOriginId, kName2); |   74   another.AddConnection(kOriginId, kName2); | 
|   75  |   75  | 
|   76   std::vector<std::pair<string16, string16> > closed_dbs; |   76   std::vector<std::pair<string16, string16> > closed_dbs; | 
|   77   connections.RemoveConnections(another, &closed_dbs); |   77   connections.RemoveConnections(another, &closed_dbs); | 
|   78   EXPECT_EQ(1u, closed_dbs.size()); |   78   EXPECT_EQ(1u, closed_dbs.size()); | 
|   79   EXPECT_EQ(kOriginId, closed_dbs[0].first); |   79   EXPECT_EQ(kOriginId, closed_dbs[0].first); | 
|   80   EXPECT_EQ(kName2, closed_dbs[0].second); |   80   EXPECT_EQ(kName2, closed_dbs[0].second); | 
|   81   EXPECT_FALSE(connections.IsDatabaseOpened(kOriginId, kName2)); |   81   EXPECT_FALSE(connections.IsDatabaseOpened(kOriginId, kName2)); | 
|   82   EXPECT_TRUE(connections.IsDatabaseOpened(kOriginId, kName)); |   82   EXPECT_TRUE(connections.IsDatabaseOpened(kOriginId, kName)); | 
|   83   EXPECT_EQ(kSize, connections.GetOpenDatabaseSize(kOriginId, kName)); |   83   EXPECT_EQ(kSize, connections.GetOpenDatabaseSize(kOriginId, kName)); | 
|   84  |   84   another.RemoveAllConnections(); | 
|   85   connections.RemoveAllConnections(); |   85   connections.RemoveAllConnections(); | 
|   86   EXPECT_TRUE(connections.IsEmpty()); |   86   EXPECT_TRUE(connections.IsEmpty()); | 
|   87  |   87  | 
|   88   another.RemoveAllConnections(); |   88   // Ensure the return value properly indicates the initial | 
 |   89   // addition and final removal. | 
 |   90   EXPECT_TRUE(connections.AddConnection(kOriginId, kName)); | 
 |   91   EXPECT_FALSE(connections.AddConnection(kOriginId, kName)); | 
 |   92   EXPECT_FALSE(connections.AddConnection(kOriginId, kName)); | 
 |   93   EXPECT_FALSE(connections.RemoveConnection(kOriginId, kName)); | 
 |   94   EXPECT_FALSE(connections.RemoveConnection(kOriginId, kName)); | 
 |   95   EXPECT_TRUE(connections.RemoveConnection(kOriginId, kName)); | 
|   89 } |   96 } | 
|   90  |   97  | 
|   91 TEST(DatabaseConnectionsTest, DatabaseConnectionsWrapperTest) { |   98 TEST(DatabaseConnectionsTest, DatabaseConnectionsWrapperTest) { | 
|   92   const string16 kOriginId(ASCIIToUTF16("origin_id")); |   99   const string16 kOriginId(ASCIIToUTF16("origin_id")); | 
|   93   const string16 kName(ASCIIToUTF16("database_name")); |  100   const string16 kName(ASCIIToUTF16("database_name")); | 
|   94  |  101  | 
|   95   scoped_refptr<DatabaseConnectionsWrapper> obj( |  102   scoped_refptr<DatabaseConnectionsWrapper> obj( | 
|   96       new DatabaseConnectionsWrapper); |  103       new DatabaseConnectionsWrapper); | 
|   97   EXPECT_FALSE(obj->HasOpenConnections()); |  104   EXPECT_FALSE(obj->HasOpenConnections()); | 
|   98   obj->AddOpenConnection(kOriginId, kName); |  105   obj->AddOpenConnection(kOriginId, kName); | 
| (...skipping 26 matching lines...) Expand all  Loading... | 
|  125   MessageLoop::current()->PostTask(FROM_HERE, |  132   MessageLoop::current()->PostTask(FROM_HERE, | 
|  126       NewRunnableFunction(ScheduleRemoveConnectionTask, |  133       NewRunnableFunction(ScheduleRemoveConnectionTask, | 
|  127                           &thread, kOriginId, kName, |  134                           &thread, kOriginId, kName, | 
|  128                           obj, &did_task_execute)); |  135                           obj, &did_task_execute)); | 
|  129   obj->WaitForAllDatabasesToClose();  // should return after the task executes |  136   obj->WaitForAllDatabasesToClose();  // should return after the task executes | 
|  130   EXPECT_TRUE(did_task_execute); |  137   EXPECT_TRUE(did_task_execute); | 
|  131   EXPECT_FALSE(obj->HasOpenConnections()); |  138   EXPECT_FALSE(obj->HasOpenConnections()); | 
|  132 } |  139 } | 
|  133  |  140  | 
|  134 }  // namespace webkit_database |  141 }  // namespace webkit_database | 
| OLD | NEW |