This function is used to write to the bip_buffer using the supplied writer. # Arguments `writer` - The bipBufferWriter used to write to the bip_buffer

This function is used to start the UdpSender on a seperate thread. The joinhandle to this thread is returned. # Arguments `rec_addr` - The address of

returns a clone of the data struct

This function fetches data from the socket. This data is then copied to the supplied buffer.

This function is used to change the state depending MessageType of the incoming packet.

This function is used to write the packet header to a given buffer. This buffer should contain at least HEADER_SIZE_BYTES of empty space in front of t

Returns the byte value of a given MessageType.

This function is used to read from the bip_buffer using the supplied reader. # Arguments `reader` - The bipBufferReader used to read from the bip_buff

Setting syslog with a specific log level and processname. The logging is sent with UDP

Wait for the given amount of bytes to be available for reading in the bip_buffer. # Arguments `reader` - The bipBufferReader used to read from the bip

Function used to get the element length field from the bip_buffer. The element length is consumed from the buffer by calling this function. # Argument

Stops the SocketReader. Calls Shutdown::Both on the underlying stream.

Convert a handler from a TOML file to a handler struct. `type` and `open_udp_port` are specials cases and needed in the configuration in osdd. All oth

This function is used to handle a message that has the DataFirst MessageType.

This function is used to log the complete configuration of the UdpReceiver.

This function is used to read the information contained in the packet header of a received UDP packet. All packet information is placed inside a Packe

This function is used to send the data contained in `buffer` using `socket`. When the packet is succesfully sent, the sequence number is incremented b

asserts if the given buffer equals the buffer read from the bip_buffer.

Packetloss is checked using the sequence number of the incoming packet. This sequence number should match the expected sequence number. If it doesn't

This function is used to combine all packets that belong to one set of data. The combined messages are written to the BipBuffer.

Create Docker command from a handler

Creates docker commands of the given handlers

returns a vector of multiple Vec<u8>

Give a u8 array, deserialize and send it to kafka # Arguments `bip_reader` - The BipBufferReader used to get data from the bip_buffer.

This filter checks for the first bytes of the incoming data. If it matches the configured "word_to_filter" then it drops the data. If the data is corr

Check for the first bytes of a kafka message. If it matches the word_to_filter then it drops the data. Else it is written to the bipbuffer.

Reads data from the bipbuffer and send it to kafka # Arguments `bip_reader` - The BipBufferReader used to get data from the bip_buffer.

Get data from the kafka server and send it to bipbuffer Calculcates message behind after every poll # Arguments `bip_writer` - The BipBufferWriter use

This function is used to handle a message that has the Data MessageType.

This function is used to handle a message that has the Heartbeat MessageType.

Starts processes from the given commands

This function is used to handle a message that has the ShutDown MessageType.

This function is used to handle a message that has the StartUp MessageType.

This function is used to initialize the socket. It sets the BroadCast flag.

This handler is for udp packets in the ingress network it receive the udp packets and send it to the transport via a unix domain socket. in the egress

This function starts the open source data diode. It loads the configuration from a TOML file. It starts a UDP multiplexer for statitics. It create and

Poll the kafka server and send it to bipbuffer Calculcates message behind after every poll # Arguments `bip_writer` - The BipBufferWriter used to send

Convert TOML file to settings, chains and handlers. println errors because logging is not initialized yet.

This function is used to receive a UDP packet on the given socket. The received data is placed in the supplied buffer. # Arguments `socket` - The UdpS

Replace the topic as it is given in command args # Arguments `topic` - input topic. # Return 'String' - Topic name, if was in give input list it is re

Receives all the stats form the handlers and send it to multiple addresses

This function is used to send packets with MessageType::ShutDown to the UdpReceiver.

This function is used to send packets with MessageType::StartUp to the UdpReceiver.

Read data from the bipbuffer, serialize_packet and send it to another bipbuffer # Arguments `bip_reader` - The BipBufferWriter used to get data from t

Setup a kafka consumer # Arguments `topic` - Topic name `host` - Host of the kafka server `port` - Server port of the kafka server # Returns `Consumer

This function is used to split the data read from a bip_buffer. The data is split into packets that can be sent over UDP(payload < 65507 bytes)

The program will start multiple threads: receiver_thread - The thread used by the UdpReceiver struct. statistics_thread - The thread used by the Stati

The program will start multiple threads: sender_thread - The thread used by the UdpSender struct. statistics_thread - The thread used by the Statistic

This function will update the in_bytes and in_packets counter of the statistics struct.

This function is used to send packets with MessageType::HeartBeat to the UdpReceiver.

Returns the MessageType for a given byte value. When no MessageType exists for the given byte value, MessageType::DataFirst is returned. # Arguments `

This function is used to log the complete configuration of the UdpSender.