(ts uint64)
| 218 | } |
| 219 | |
| 220 | func (o *oracle) RegisterStartTs(ts uint64) *Txn { |
| 221 | o.Lock() |
| 222 | defer o.Unlock() |
| 223 | txn, ok := o.pendingTxns[ts] |
| 224 | if ok { |
| 225 | txn.lastUpdate = time.Now() |
| 226 | } else { |
| 227 | txn = NewTxn(ts) |
| 228 | o.pendingTxns[ts] = txn |
| 229 | } |
| 230 | return txn |
| 231 | } |
| 232 | |
| 233 | func (o *oracle) CacheAt(ts uint64) *LocalCache { |
| 234 | o.RLock() |