Chromium Code Reviews| Index: components/precache/core/precache_session_table.cc |
| diff --git a/components/precache/core/precache_session_table.cc b/components/precache/core/precache_session_table.cc |
| index 8537b199025d38aaa2a064d59fc60613989f581f..9993c069bbe72ef3de7d9384c6bd79b3d25042b4 100644 |
| --- a/components/precache/core/precache_session_table.cc |
| +++ b/components/precache/core/precache_session_table.cc |
| @@ -4,10 +4,12 @@ |
| #include "components/precache/core/precache_session_table.h" |
| +#include <stdint.h> |
| #include <string> |
| #include "base/logging.h" |
| #include "base/time/time.h" |
| +#include "components/precache/core/proto/timestamp.pb.h" |
| #include "components/precache/core/proto/unfinished_work.pb.h" |
| #include "sql/connection.h" |
| #include "sql/statement.h" |
| @@ -27,6 +29,38 @@ bool PrecacheSessionTable::Init(sql::Connection* db) { |
| return CreateTableIfNonExistent(); |
| } |
| +void PrecacheSessionTable::SetLastPrecacheTimestamp(const base::Time& time) { |
| + DCHECK(!time.is_null()); |
| + Timestamp timestamp; |
| + timestamp.set_seconds((time - base::Time::UnixEpoch()).InSeconds()); |
| + Statement statement(db_->GetCachedStatement( |
| + SQL_FROM_HERE, |
| + "INSERT OR REPLACE INTO precache_session (type, value) VALUES(?,?)")); |
| + statement.BindInt(0, static_cast<int>(LAST_PRECACHE_TIMESTAMP)); |
| + statement.BindString(1, timestamp.SerializeAsString()); |
| + statement.Run(); |
| +} |
| + |
| +base::Time PrecacheSessionTable::GetLastPrecacheTimestamp() { |
| + Statement statement(db_->GetCachedStatement( |
| + SQL_FROM_HERE, "SELECT value from precache_session where type=?")); |
| + statement.BindInt(0, static_cast<int>(LAST_PRECACHE_TIMESTAMP)); |
| + Timestamp timestamp; |
| + if (statement.Step()) |
| + timestamp.ParseFromString(statement.ColumnString(0)); |
| + return timestamp.has_seconds() |
| + ? base::Time::UnixEpoch() + |
| + base::TimeDelta::FromSeconds(timestamp.seconds()) |
| + : base::Time(); |
|
twifkak
2016/07/16 00:47:49
Oops, I missed this edge case in the DoubleT behav
|
| +} |
| + |
| +void PrecacheSessionTable::DeleteLastPrecacheTimestamp() { |
| + Statement statement(db_->GetCachedStatement( |
| + SQL_FROM_HERE, "DELETE FROM precache_session where type=?")); |
| + statement.BindInt(0, static_cast<int>(LAST_PRECACHE_TIMESTAMP)); |
| + statement.Run(); |
| +} |
| + |
| // Store unfinished work. |
| void PrecacheSessionTable::SaveUnfinishedWork( |
| std::unique_ptr<PrecacheUnfinishedWork> unfinished_work) { |