func()

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
}