cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

chainwatch: Collect incoming block tstamps

Browse Source
This commit is contained in:
Łukasz Magiera 2019-12-08 16:49:13 +01:00
parent 8bb6ab02e3
commit 7dcee8c1e3
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
cmd/lotus-chainwatch/storage.go
View File

@ -113,7 +113,8 @@ create table if not exists blocks_synced
constraint blocks_synced_pk
primary key
constraint blocks_synced_blocks_cid_fk
references blocks
references blocks,
add_ts int not null
);
create unique index if not exists blocks_synced_cid_uindex
@ -316,13 +317,15 @@ func (st *storage) storeHeaders(bhs map[cid.Cid]*types.BlockHeader, sync bool) e
}
if sync {
stmt, err := tx.Prepare(`insert into blocks_synced (cid) values (?) on conflict do nothing`)
stmt, err := tx.Prepare(`insert into blocks_synced (cid, add_ts) values (?, ?) on conflict do nothing`)
if err != nil {
return err
}
defer stmt.Close()
now := time.Now().Unix()
for _, bh := range bhs {
if _, err := stmt.Exec(bh.Cid().String()); err != nil {
if _, err := stmt.Exec(bh.Cid().String(), now); err != nil {
return err
}
}