move own ips to tcp stream factory

tap/passive_tapper.go

@@ -91,7 +91,6 @@ type TapOpts struct {
 }
 
 //lint:ignore U1000 will be used in the future
-var ownIps []string                               // global
 var hostMode bool                                 // global
 var extensions []*api.Extension                   // global
 var filteringOptions *api.TrafficFilteringOptions // global
@@ -202,17 +201,9 @@ func startPassiveTapper(outputItems chan *api.OutputChannelItem) {
 
 	tapErrors = NewErrorsMap(outputLevel)
 
-	if localhostIPs, err := getLocalhostIPs(); err != nil {
-		// TODO: think this over
-		rlog.Info("Failed to get self IP addresses")
-		rlog.Errorf("Getting-Self-Address", "Error getting self ip address: %s (%v,%+v)", err, err, err)
-		ownIps = make([]string, 0)
-	} else {
-		ownIps = localhostIPs
-	}
-
 	var handle *pcap.Handle
 	var err error
+
 	if *fname != "" {
 		if handle, err = pcap.OpenOffline(*fname); err != nil {
 			log.Fatalf("PCAP OpenOffline error: %v", err)

tap/tcp_stream_factory.go

@@ -23,6 +23,7 @@ type tcpStreamFactory struct {
 	outboundLinkWriter *OutboundLinkWriter
 	Emitter            api.Emitter
 	streamsMap         *tcpStreamMap
+	ownIps             []string
 }
 
 type tcpStreamWrapper struct {
@@ -31,9 +32,21 @@ type tcpStreamWrapper struct {
 }
 
 func NewTcpStreamFactory(emitter api.Emitter, streamsMap *tcpStreamMap) *tcpStreamFactory {
+	var ownIps []string
+
+	if localhostIPs, err := getLocalhostIPs(); err != nil {
+		// TODO: think this over
+		rlog.Info("Failed to get self IP addresses")
+		rlog.Errorf("Getting-Self-Address", "Error getting self ip address: %s (%v,%+v)", err, err, err)
+		ownIps = make([]string, 0)
+	} else {
+		ownIps = localhostIPs
+	}
+
 	return &tcpStreamFactory{
 		Emitter:    emitter,
 		streamsMap: streamsMap,
+		ownIps:     ownIps,
 	}
 }
 
@@ -150,7 +163,7 @@ func (factory *tcpStreamFactory) getStreamProps(srcIP string, srcPort string, ds
 //lint:ignore U1000 will be used in the future
 func (factory *tcpStreamFactory) shouldNotifyOnOutboundLink(dstIP string, dstPort int) bool {
 	if inArrayInt(remoteOnlyOutboundPorts, dstPort) {
-		isDirectedHere := inArrayString(ownIps, dstIP)
+		isDirectedHere := inArrayString(factory.ownIps, dstIP)
 		return !isDirectedHere && !isPrivateIP(dstIP)
 	}
 	return true