Method OnLargeRollback

data/shared_state_variable.go:477–481

(cb func(currentVal, newVal int64))

}

func (c *counterInt64) OnLargeRollback(cb func(currentVal, newVal int64)) {
	c.callbackMu.Lock()
	defer c.callbackMu.Unlock()
	c.largeRollbackCallbacks = append(c.largeRollbackCallbacks, cb)
}

func (c *counterInt64) markFreshAttempt() {
	c.allocateUpdatedAtMs()