(m *stream.Message)
| 141 | } |
| 142 | |
| 143 | func (s *TunnelSession) WriteToLocalConnection(m *stream.Message) { |
| 144 | if con, ok := s.GetLocalConnection(m.ConnectID); ok { |
| 145 | con.CacheTunnelMessage(m) |
| 146 | } |
| 147 | } |
| 148 | |
| 149 | func (s *TunnelSession) startPing(ctx context.Context) { |
| 150 | t := time.NewTicker(time.Second * 5) |
no test coverage detected