(datagram *packet.Session)
| 180 | } |
| 181 | |
| 182 | func (m *manager) sendToSession(datagram *packet.Session) { |
| 183 | session, ok := m.sessions[datagram.ID] |
| 184 | if !ok { |
| 185 | m.log.Error().Str(LogFieldSessionID, FormatSessionID(datagram.ID)).Msg("session not found") |
| 186 | return |
| 187 | } |
| 188 | // session writes to destination over a connected UDP socket, which should not be blocking, so this call doesn't |
| 189 | // need to run in another go routine |
| 190 | session.transportToDst(datagram.Payload) |
| 191 | } |
no test coverage detected