()
| 1956 | } |
| 1957 | |
| 1958 | func (a *agent) setCoordDisconnected() chan struct{} { |
| 1959 | a.closeMutex.Lock() |
| 1960 | defer a.closeMutex.Unlock() |
| 1961 | if a.closing { |
| 1962 | return nil |
| 1963 | } |
| 1964 | disconnected := make(chan struct{}) |
| 1965 | a.coordDisconnected = disconnected |
| 1966 | return disconnected |
| 1967 | } |
| 1968 | |
| 1969 | // runDERPMapSubscriber runs a coordinator and returns if a reconnect should occur. |
| 1970 | func (a *agent) runDERPMapSubscriber(ctx context.Context, tClient tailnetproto.DRPCTailnetClient24, network *tailnet.Conn) (retErr error) { |
no test coverage detected