(index uint64, src *api.TxnContext)
| 262 | } |
| 263 | |
| 264 | func (o *Oracle) updateCommitStatus(index uint64, src *api.TxnContext) { |
| 265 | // TODO: We should check if the tablet is in read-only status here. |
| 266 | if o.updateCommitStatusHelper(index, src) { |
| 267 | delta := new(pb.OracleDelta) |
| 268 | delta.Txns = append(delta.Txns, &pb.TxnStatus{ |
| 269 | StartTs: src.StartTs, |
| 270 | CommitTs: o.commitTs(src.StartTs), |
| 271 | }) |
| 272 | o.updates <- delta |
| 273 | } |
| 274 | } |
| 275 | |
| 276 | func (o *Oracle) commitTs(startTs uint64) uint64 { |
| 277 | o.RLock() |
no test coverage detected