pangolin_mirror/olm
1
0
Fork 0
mirror of https://github.com/fosrl/olm.git synced 2026-03-07 03:06:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Clear status

Browse Source
This commit is contained in:
Owen
2025-11-30 18:04:13 -05:00
parent 4a471713e7
commit 13c12f1a73
2 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
api/api.go
View File

@@ -214,6 +214,13 @@ func (s *API) SetTerminated(terminated bool) {
s.isTerminated = terminated s.isTerminated = terminated
} }
// ClearPeerStatuses clears all peer statuses
func (s *API) ClearPeerStatuses() {
s.statusMu.Lock()
defer s.statusMu.Unlock()
s.peerStatuses = make(map[int]*PeerStatus)
}
// SetVersion sets the olm version // SetVersion sets the olm version
func (s *API) SetVersion(version string) { func (s *API) SetVersion(version string) {
s.statusMu.Lock() s.statusMu.Lock()

3
olm/olm.go
View File

@@ -748,6 +748,8 @@ func StartTunnel(config TunnelConfig) {
olm.RegisterHandler("olm/terminate", func(msg websocket.WSMessage) { olm.RegisterHandler("olm/terminate", func(msg websocket.WSMessage) {
logger.Info("Received terminate message") logger.Info("Received terminate message")
apiServer.SetTerminated(true) apiServer.SetTerminated(true)
apiServer.SetConnectionStatus(false)
apiServer.SetRegistered(false)
Close() Close()
if globalConfig.OnTerminated != nil { if globalConfig.OnTerminated != nil {
@@ -909,6 +911,7 @@ func StopTunnel() error {
apiServer.SetRegistered(false) apiServer.SetRegistered(false)
network.ClearNetworkSettings() network.ClearNetworkSettings()
apiServer.ClearPeerStatuses()
logger.Info("Tunnel process stopped") logger.Info("Tunnel process stopped")