Method DeleteLocalConnection

edge/pkg/edgestream/tunnel.go:214–224

(id uint64)

}

func (s *TunnelSession) DeleteLocalConnection(id uint64) {
	s.localConsLock.Lock()
	defer s.localConsLock.Unlock()
	con, ok := s.localCons[id]
	if !ok {
		return
	}
	con.CleanChannel()
	con.CloseReadChannel()
	delete(s.localCons, id)
}