Method allocateUpdatedAtMs

data/shared_state_variable.go:51–62

allocateUpdatedAtMs allocates a strictly-increasing UpdatedAt timestamp (unix ms) for a local update. It also stores the allocated value into updatedAtUnixMs, ensuring uniqueness even under concurrency.

()

// allocateUpdatedAtMs allocates a strictly-increasing UpdatedAt timestamp (unix ms) for a local update.
// It also stores the allocated value into updatedAtUnixMs, ensuring uniqueness even under concurrency.
func (v *baseSharedVariable) allocateUpdatedAtMs() int64 {
	for {
		current := v.updatedAtUnixMs.Load()
		next := time.Now().UnixMilli()
		if next <= current {
			next = current + 1
		}
		if v.updatedAtUnixMs.CompareAndSwap(current, next) {
			return next
		}
	}
}

// updateUpdatedAtMs atomically advances updatedAtUnixMs if newUpdatedAt is newer.
// Returns true if updatedAtUnixMs was advanced.