(name string)
| 418 | } |
| 419 | |
| 420 | func (r *mockRepoClock) GetOrCreateClock(name string) (lamport.Clock, error) { |
| 421 | r.mu.Lock() |
| 422 | defer r.mu.Unlock() |
| 423 | |
| 424 | if c, ok := r.clocks[name]; ok { |
| 425 | return c, nil |
| 426 | } |
| 427 | |
| 428 | c := lamport.NewMemClock() |
| 429 | r.clocks[name] = c |
| 430 | return c, nil |
| 431 | } |
| 432 | |
| 433 | func (r *mockRepoClock) Increment(name string) (lamport.Time, error) { |
| 434 | c, err := r.GetOrCreateClock(name) |
no test coverage detected