Function start

service/firewall/interception/module.go:60–92

Start starts the interception.

()

// Start starts the interception.
func start() error {
	if disableInterception {
		log.Warning("interception: packet interception is disabled via flag - this breaks a lot of functionality")
		return nil
	}

	if !isStarted.CompareAndSwap(false, true) {
		return nil // already running
	}

	inputPackets := Packets
	if packetMetricsDestination != "" {
		go metrics.writeMetrics()
		inputPackets = make(chan packet.Packet)
		go func() {
			for p := range inputPackets {
				Packets <- tracePacket(p)
			}
		}()
	}

	err := startInterception(inputPackets)
	if err != nil {
		log.Errorf("interception: failed to start module: %q", err)
		log.Debug("interception: cleaning up after failed start...")
		metrics.stop()
		if e := stopInterception(); e != nil {
			log.Debugf("interception: error cleaning up after failed start: %q", e.Error())
		}
		isStarted.Store(false)
	}
	return err
}

// Stop starts the interception.
func stop() error {