poller

Documentation

Overview

Package poller contains the main xtcp go routine that fires off the actual kernel polling

This routine is responsible for starting up the netlinkers + inetdiagers

Index

• func Poller(af uint8, hostname *string, cliFlags cliflags.CliFlags, wg *sync.WaitGroup, ...)

Functions

func Poller

func Poller(af uint8, hostname *string, cliFlags cliflags.CliFlags, wg *sync.WaitGroup, pollerStaterCh chan<- pollerstater.PollerStats, netlinkerStaterCh chan<- netlinkerstater.NetlinkerStatsWrapper, inetdiagerStaterCh chan<- inetdiagerstater.InetdiagerStatsWrapper)

Poller is instanciated once per address family, and is responsible for: 1. Setting up channels and workers 2. Sending netlink diag dump requests to the kernel 3. Waiting for a done message from the kernel 4. Waiting for the netlinkers to complete 5. Block waiting for tick Left out stats related stuffs