(ctx context.Context, origin gomatrixserverlib.ServerName)
| 576 | } |
| 577 | |
| 578 | func (f *FederationWakeups) Wakeup(ctx context.Context, origin gomatrixserverlib.ServerName) { |
| 579 | key, keyok := f.origins.Load(origin) |
| 580 | if keyok { |
| 581 | lastTime, ok := key.(time.Time) |
| 582 | if ok && time.Since(lastTime) < time.Minute { |
| 583 | return |
| 584 | } |
| 585 | } |
| 586 | f.FsAPI.MarkServersAlive([]gomatrixserverlib.ServerName{origin}) |
| 587 | f.origins.Store(origin, time.Now()) |
| 588 | } |
no test coverage detected