spidr4.stream

spidr4.stream Module

class spidr4.stream.PacketReaderThread(tpxStub, queue, chipIndex=0, top=True, bottom=True, forward_empty=True, tag=None)

stop()

class spidr4.stream.UDPReaderThread(addr, port, q, tag=None, rx_buffer_size=33554432)

stop()

spidr4.stream.frame8b_generator(q, top_tag='top', bottom_tag='bot', frame_factory=<function <lambda>>)

Generator for complete frames.

Parameters:

• q – A tagged queue for bottom and top. 0

• top_tag

• bottom_tag

• frame_factory

Returns:

spidr4.stream.framefilter(pkt_gen)

spidr4.stream.framefilter_with_tag(pkt_gen)

spidr4.stream.packet_read_thread(tpxStub, queue, chipIndex=0, top=True, bottom=True, forward_empty=True, tag=None)

Start read thread starts a thread retrieving pixel data from the ScDaq using PacketReadout.

This thread will run for the entire duration of the program.

Parameters:

• tpxStub – The gRPC Timepix4 stub

• queue – The queue to place packets in

• chipIndex – the index of the chip (default = 0)

• top – Whether or not to stream the top

• bottom – Whether or not to stream the bottom

• forward_empty – Whether or not to forward empty packets

• tag – The optional tag to put the queue

Returns:

PacketReaderThread

spidr4.stream.queue_generator(q, timeout=0.05)

Generator for retrieving packets from a queue. Data can be placed in the queue from the packet_read_thread.

Parameters:

• q – The queue to read from

• timeout – Optional timeout, default 40 ms

spidr4.stream.udp_read_thread(addr, port, q, tag=None)

spidr4.stream.unwrap_packet_stream(pktstream)

Functions

frame8b_generator(q[, top_tag, bottom_tag, ...])	Generator for complete frames.
framefilter(pkt_gen)
framefilter_with_tag(pkt_gen)
packet_read_thread(tpxStub, queue[, ...])	Start read thread starts a thread retrieving pixel data from the ScDaq using PacketReadout.
queue_generator(q[, timeout])	Generator for retrieving packets from a queue.
udp_read_thread(addr, port, q[, tag])
unwrap_packet_stream(pktstream)

Classes

PacketReaderThread(tpxStub, queue[, ...])
UDPReaderThread(addr, port, q[, tag, ...])
defaultdict	defaultdict(default_factory=None, /, [...]) --> dict with default factory

Class Inheritance Diagram