in collector/collector.go [89:102]
func (ms messageStore) existsRcvd(target string, QosDSCPIndex uint8, srcPort layers.TCPPort) (tcp.Message, bool) {
if _, exists := ms[target]; !exists {
return tcp.Message{}, false
}
if ms[target][QosDSCPIndex].rcvd == nil {
return tcp.Message{}, false
}
matchedMsg, existsMatch := ms[target][QosDSCPIndex].rcvd[srcPort]
if !existsMatch {
return tcp.Message{}, false
}
return matchedMsg, true
}