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) { |