* Update the Database withdrawn prefixes * * \details This method will update the database for the supplied advertised prefixes * * \param wdrawn

* Updates for either advertised or withdrawn Evpn NLRI's * * \param [in] remove True if the records should be deleted, false if they are to

* Update the Database for bgp-ls * * \details This method will update the database for the BGP-LS information * * \note MUST BE called after ad

* Constructor for class * * \details Handles bgp update messages * * \param [in] logPtr Pointer to existing Logger for app logging

* Accept new/pending connections * * Will accept new connections and wait if one is not currently ready. * Supports IPv4 and IPv6 sockets * * \pa

* back * Thread safe method that returns a copy of the back object * in the arg passed as value. * * ARGS: * value

* Connects to Kafka broker */

Decodes input (unsigned char) into output (UINT4). Assumes len is a multiple of 4.

* Decode label from NLRI data * * \details * Decodes the labels from the NLRI data into labels string * * \param [in] data

/ * Decode Protocol ID * * \details will decode and return string representation of protocol (matches DB enum) * * \param [in] p

* Decode EVPN subtypes * * \details * Converts to human readable form. * * \param [in] ec_hdr Reference to th

* Decode Generic subtypes * * \details * Converts to human readable form. * * \param [in] ec_hdr Reference to

* Decode IPv6 Specific Type/Subtypes * * \details * Decodes the IPv6 specific and 2-octet, 4-octet. This is pretty much the as co

* Decode Opaque subtypes * * \details * Converts to human readable form. * * \param [in] ec_hdr Reference to

* Decode common Type/Subtypes * * \details * Decodes the common 2-octet, 4-octet, and IPv4 specific common subtypes. * C

/ * Disables debug logging ***********************************************************************/

* Disconnect from Kafka */

* disconnect/close bmp stream * * Closes the BMP stream and disconnects router as needed * * \param [in] client Client information pointer

* Enable/disable debugs */

* Enable/Disable debug */

* Enable/Disable debug */

Encodes input (UINT4) into output (unsigned char). Assumes len is a multiple of 4.

* Free allocated topic map pointers */

/ * Hash node descriptor info * * \details will produce a hash for the node descriptor. Info hash_bin will be updated. * * \param

* get current BMP message type */

* \brief Time in seconds to printed string format * * \param[in] time_secs Time since epoch in seconds * \param[in] time_

* Get the topic map key name * * \param [in] topic_var MSGBUS_TOPIC_VAR_<name> * \param [in] router_group Router group - empty/NULL mean

* Generate BMP router HASH * * \param [in,out] client Reference to client info used to generate the hash. * * \return client.hash_id will be upd

* \brief binary hash to printed string format * * \details Converts a hash unsigned char bytes to HEX string for *

* Initialize topic * Producer must be initialized and connected prior to calling this method. * Topic map will be updated. * * \param [i

* main function */

Note: Replace "for loop" with standard memcpy if possible.

Note: Replace "for loop" with standard memset if possible.

/ * \brief This function will initialize and connect to Kafka. * * \details It is expected that this class will start off with a new connection. *

* Opens server (v4 or 6) listening socket(s) * * \param [in] ipv4 True to open v4 socket * \param [in] ipv6 True to open v6 socket */

* MP UnReach NLRI parse based on AFI * * \details Will parse the nlri data based on AFI. A call to the specific SAFI method will * be per

* MP Reach NLRI parse based on AFI * * \details Will parse the next-hop and nlri data based on AFI. A call to * the specific SAFI method

* MP Reach NLRI parse for BGP_AFI_IPV4 & BGP_AFI_IPV6 * * \details Will handle the SAFI and parsing of AFI IPv4 & IPv6 * * \param [in] isIPv4

* MP Reach NLRI parse for BGP_AFI_IPv4 & BGP_AFI_IPV6 * * \details Will handle parsing the SAFI's for address family ipv6 and IPv4 * * \param [in]

* Parse attribute data based on attribute type * * \details * Parses the attribute data based on the passed attribute type. * Parsed_dat

/ * Parse Link State attribute TLV * * \details Will handle parsing the link state attribute * * \param [in] attr_len Leng

* Parse attribute AGGEGATOR data * * \param [in] attr_len Length of the attribute data * \param [in] data Pointer to the attrib

* Parse attribute AS_PATH data * * \param [in] attr_len Length of the attribute data * \param [in] data Pointer to the attribut

* Parses the BGP attributes in the update * * \details * Parses all attributes. Decoded values are updated in 'parsed_data' * * \param [in]

* Constructor for class - * * \details * This class parses the BGP message and updates DB. The * 'mysql_ptr' must be a pointer reference to

* Constructor for class * * \note * This class will allocate via 'new' the bgp_peers variables * as needed. The calling method/class/func

* Parse v1 and v2 BMP header * * \details * v2 uses the same common header, but adds the Peer Up message type. * * \param [in] sock Socke

* Parse v3 BMP header * * \details * v3 has a different header structure and changes the peer * header format. * * \param [in] sock

* Parse the base configuration * * \param [in] node Reference to the yaml NODE */

* Parses the BGP common header * * \details * This method will parse the bgp common header and will upload the global * c_hdr structure,

* Parses capabilities from buffer * * \details * Reads the capabilities from buffer. The parsed data will be * returned via the out par

* Parse the debug configuration * * \param [in] node Reference to the yaml NODE */

/ * Parse Link Descriptor sub-tlvs * * \details will parse a link descriptor (series of sub-tlv's) * * \param [in] data

/ * Parse a Local or Remote Descriptor sub-tlv's * * \details will parse a local/remote descriptor * * \param [in] data

/ * Parse Prefix Descriptor sub-tlvs * * \details will parse a prefix descriptor (series of sub-tlv's) * * \param [in] data

* Parse Ethernet Segment Identifier * * \details * Will parse the Segment Identifier. Based on https://tools.ietf.org/html/rfc7432

* Parse the kafka configuration * * \param [in] node Reference to the yaml NODE */

/ * Parses Link State NLRI data * * \details Will parse the link state NLRI's from MP_REACH or MP_UNREACH. * * \param [in] data

* Parse the mapping configuration * * \param [in] node Reference to the yaml NODE */

* Parses mp_reach_nlri and mp_unreach_nlri (IPv4/IPv6) * * \details * Will parse the NLRI encoding as defined in RFC4760 Section 5 (NLRI Encod

* Parses NLRI info (IPv4) from the BGP message * * \details * Will get the NLRI and Withdrawn prefix entries from the data buffer. As per RFC

/ * Parse LINK NLRI * * \details will parse the LINK NLRI type. Data starts at local node descriptor. * * \param [in] data

/ * Parse NODE NLRI * * \details will parse the node NLRI type. Data starts at local node descriptor. * * \param [in] data

/ * Parse PREFIX NLRI * * \details will parse the PREFIX NLRI type. Data starts at local node descriptor. * * \param [in] data

* Parse BMP peer header flags by peer type * * This method will update the instance variable "p_entry" * * \param [in] peer_type peer typ

* Parse the v3 peer header * * \param [in] sock Socket to read the message from */

* Parse matching prefix_range list and update the provided map with compiled expressions * * \param [in] node prefix_range list node - should b

* Parse matching regexp list and update the provided map with compiled expressions * * \param [in] node regex list node - should be of type seq

* Parse Route Distinguisher * * \details * Will parse the Route Distinguisher. Based on https://tools.ietf.org/html/rfc4364#sectio

* Parse the kafka topics configuration * * \param [in] node Reference to the yaml NODE */

/ * Parse SID/Label value to string * * \details Parses the SID to index, label, or IPv6 string value * * \param [in] data

* PopFront is a bit different in that the mutex lock handles getting * the object and then pop'ing it afterwards. * * ARGS: *

/ * Prints the message * * * \param[in] sev the logging severity * \param[in] func_name function name of the calling function * \pa

* print warning message for parsing node * * \param [in] msg Warning message * \param [in] node Offending node that caused the warning */

* Read messages from BMP stream in a loop * * \param [in] run Reference to bool to indicate if loop should continue or not * \param [in]

* \brief Method to resolve the IP address to a hostname * * \param [in] name String name (ip address) * \param [out] hostname String refere

* Signal handler * */

* Perform topic name substitutions based on topic variables */

MD5 basic transformation. Transforms state based on block.

* new method to wait for the mutex lock. When the queue is empty the lock is on. * calling this method will cause the caller to block until t