(replicas []codersdk.Replica)
| 512 | } |
| 513 | |
| 514 | func (s *Server) pingSiblingReplicas(replicas []codersdk.Replica) { |
| 515 | ctx, cancel := context.WithTimeout(s.ctx, 10*time.Second) |
| 516 | defer cancel() |
| 517 | |
| 518 | errStr := pingSiblingReplicas(ctx, s.Logger, &s.replicaPingSingleflight, s.derpMeshTLSConfig, replicas) |
| 519 | s.replicaErrMut.Lock() |
| 520 | s.replicaErr = errStr |
| 521 | defer s.replicaErrMut.Unlock() |
| 522 | if s.Options.ReplicaErrCallback != nil { |
| 523 | s.Options.ReplicaErrCallback(replicas, s.replicaErr) |
| 524 | } |
| 525 | } |
| 526 | |
| 527 | func pingSiblingReplicas(ctx context.Context, logger slog.Logger, sf *singleflight.Group, derpMeshTLSConfig *tls.Config, replicas []codersdk.Replica) string { |
| 528 | if len(replicas) == 0 { |
no test coverage detected