wib_packet_receiver Namespace Reference

Functions
	cli (port)

Variables
	console = Console()
	CONTEXT_SETTINGS = dict(help_option_names=['-h', '--help'])
	show_default
	True
	standalone_mode

Function Documentation

cli()

wib_packet_receiver.cli

(

port

)

Definition at line 15 of file wib_packet_receiver.py.

def cli(port):
    console.log(f"Preparing to receive WIB packets on port {port}.")
    sock = socket.socket(socket.AF_INET, # Internet
                     socket.SOCK_DGRAM) # UDP
    sock.bind(("0.0.0.0", port))
 
    rcv_bytes = 0
    rcv_pkts_tot  = 0
    rcv_pkts  = 0
    rcv_bytes = 0
    start_time = time.time();
    while True:
        try:
            data, addr = sock.recvfrom(8192)
            rcv_bytes += len(data)
            wf = fddetdataformats.WIBEthFrame(data)
            rcv_pkts +=1
            if rcv_pkts_tot % 100000 == 0:
                stop_time = time.time()
                interval = stop_time - start_time
                console.log(f"Received {rcv_pkts} packets: throughput is {rcv_bytes*8/(interval*1000000000.):.2f} Gb/s")
                rcv_pkts = 0
                rcv_bytes = 0
                start_time = stop_time
        except KeyboardInterrupt:
            break
        except:
            continue
    console.log(f"Received {rcv_pkts_tot} messages; ending now.")
 

Variable Documentation

console

wib_packet_receiver.console = Console()

Definition at line 8 of file wib_packet_receiver.py.

CONTEXT_SETTINGS

wib_packet_receiver.CONTEXT_SETTINGS = dict(help_option_names=['-h', '--help'])

Definition at line 10 of file wib_packet_receiver.py.

show_default

wib_packet_receiver.show_default

Definition at line 47 of file wib_packet_receiver.py.

standalone_mode

wib_packet_receiver.standalone_mode

Definition at line 47 of file wib_packet_receiver.py.

True

wib_packet_receiver.True

Definition at line 47 of file wib_packet_receiver.py.