MCPcopy Create free account

hub / github.com/SNAS/openbmp / functions

Functions218 in github.com/SNAS/openbmp

⨍ Functions 218◇ Types & classes 125
↓ 132 callersFunctionSWAP_BYTES
Server/src/bgp/bgp_common.h:194
↓ 56 callersMethodupdate
Server/src/md5.cpp:64
↓ 39 callersMethodsize
Server/src/safeQueue.hpp:93
↓ 11 callersMethodfinalize
Server/src/md5.cpp:175
↓ 11 callersMethodraw_digest
Server/src/md5.cpp:242
↓ 6 callersMethodfront
* front * Thread safe method that returns a copy of the front object * in the arg passed as value. * * ARGS: * value =
Server/src/safeQueue.hpp:108
↓ 5 callersFunctioncollector_update_msg
* Collector Update Message * * \param [in] kafka Pointer to kafka instance * \param [in] cfg Reference to configu
Server/src/openbmp.cpp:368
↓ 4 callersMethodenableDebug
* Enable/Disable debug */
Server/src/bmp/BMPReader.cpp:441
↓ 4 callersMethodparse_flags_to_string
/ * Parse flags to string * * \details Will parse flags from binary representation to string. * Bits are read left to righ
Server/src/bgp/linkstate/MPLinkStateAttr.cpp:194
↓ 4 callersMethodupdate_Router
* Abstract method Implementation - See MsgBusInterface.hpp for details */
Server/src/kafka/MsgBusImpl_kafka.cpp:461
↓ 3 callersMethodbufferBMPMessage
* Buffer remaining BMP message * * \details This method will read the remaining amount of BMP data and store it in the instance variable bmp_data.
Server/src/bmp/parseBMP.cpp:561
↓ 3 callersMethodgetAFiSafiKeyString
* Generates unique string from AFI and SAFI combination * * \param [in] afi Afi code from RFC * \param [in] safi Safi code
Server/src/bgp/AddPathDataContainer.cpp:61
↓ 3 callersMethodisAddPathEnabled
* Is add path capability enabled for such AFI and SAFI * * \param [in] afi Afi code from RFC * \param [in] safi Safi code
Server/src/bgp/AddPathDataContainer.cpp:76
↓ 3 callersFunctionparse_mac
/ * Simple function to swap bytes around from network to host or * host to networking. This method will convert any size byte variable, *
Server/src/bgp/bgp_common.h:170
↓ 3 callersMethodupdate_Peer
* Abstract method Implementation - See MsgBusInterface.hpp for details */
Server/src/kafka/MsgBusImpl_kafka.cpp:542
↓ 2 callersFunctionGET_AFI_STRING_BY_CODE
* Function to get string representation of AFI code. * @param code AFI http://www.iana.org/assignments/address-family-numbers/address-family-numb
Server/src/bgp/bgp_common.h:217
↓ 2 callersFunctionGET_SAFI_STRING_BY_CODE
* Function to get string representation of SAFI code. * @param code SAFI http://www.iana.org/assignments/safi-namespace/safi-namespace.xhtml
Server/src/bgp/bgp_common.h:245
↓ 2 callersFunctionUsage
* Usage of the program */
Server/src/openbmp.cpp:53
↓ 2 callersMethodenableDebug
/ * Enables debug logging ***********************************************************************/
Server/src/Logger.cpp:89
↓ 2 callersMethodgetBMPLength
* get current BMP message length * * The length returned does not include the version 3 common header length */
Server/src/bmp/parseBMP.cpp:1031
↓ 2 callersMethodgetTopic
Server/src/kafka/KafkaTopicSelector.cpp:67
↓ 2 callersMethodhandleDownEvent
* handle BGP notify event - updates the down event with parsed data * * \details * The notify message does not directly add to Db, so the calling
Server/src/bgp/parseBGP.cpp:129
↓ 2 callersMethodparseNlriData
TODO: Refactor this method as it's overloaded - each case statement can be its own method * Parse all EVPN nlri's * * * \details *
Server/src/bgp/EVPN.cpp:255
↓ 2 callersMethodparseOpenMsg
* Parses an open message * * \details * Reads the open message from buffer. The parsed data will be * returned via the out params. *
Server/src/bgp/OpenMsg.cpp:58
↓ 2 callersMethodtopicEnabled
/ * Check if a topic is enabled * * \param [in] topic_var MSGBUS_TOPIC_VAR_<name> * * \return bool true if the topic is enabled, false othe
Server/src/kafka/KafkaTopicSelector.cpp:94
↓ 2 callersMethodupdate_LsLink
* Abstract method Implementation - See MsgBusInterface.hpp for details */
Server/src/kafka/MsgBusImpl_kafka.cpp:1238
↓ 2 callersMethodupdate_LsNode
* Abstract method Implementation - See MsgBusInterface.hpp for details */
Server/src/kafka/MsgBusImpl_kafka.cpp:1125
↓ 2 callersMethodupdate_LsPrefix
* Abstract method Implementation - See MsgBusInterface.hpp for details */
Server/src/kafka/MsgBusImpl_kafka.cpp:1407
↓ 2 callersMethodupdate_unicastPrefix
* Abstract method Implementation - See MsgBusInterface.hpp for details */
Server/src/kafka/MsgBusImpl_kafka.cpp:980
↓ 1 callersFunctionReadCmdArgs
* Parse and handle the command line args * * \param [out] cfg Reference to config options - Will be updated based on cli * * \returns true if e
Server/src/openbmp.cpp:187
↓ 1 callersMethodaddAddPath
* Add Add Path data to persistent storage * * \param [in] afi Afi code from RFC * \param [in] safi Safi code form RFC * \
Server/src/bgp/AddPathDataContainer.cpp:29
↓ 1 callersMethodadd_StatReport
* Abstract method Implementation - See MsgBusInterface.hpp for details */
Server/src/kafka/MsgBusImpl_kafka.cpp:1097
↓ 1 callersFunctiondaemonize
* Daemonize the program */
Server/src/openbmp.cpp:94
↓ 1 callersMethodhandleInitMsg
* handle the initiation message and update the router entry * * \param [in] sock Socket to read the init message from * \param [in/out]
Server/src/bmp/parseBMP.cpp:838
↓ 1 callersMethodhandleMessage
* Process the incoming BMP message * * \returns * returns the BMP message type. A type of >= 0 is normal, * < 0 indicates an error * *
Server/src/bmp/parseBMP.cpp:82
↓ 1 callersMethodhandleStatsReport
* Parse and return back the stats report * * \param [in] sock Socket to read the stats message from * \param [out] stats Reference to
Server/src/bmp/parseBMP.cpp:720
↓ 1 callersMethodhandleTermMsg
* handle the termination message, router entry will be updated * * \param [in] sock Socket to read the term message from * \param [in/ou
Server/src/bmp/parseBMP.cpp:928
↓ 1 callersMethodhandleUpEvent
* Handles the up event by parsing the BGP open messages - Up event will be updated * * \details * This method will read the expected sent and rece
Server/src/bgp/parseBGP.cpp:170
↓ 1 callersMethodhandleUpdate
* handle BGP update message and store in DB * * \details Parses the bgp update message and store it in the DB. * * \param [in] data
Server/src/bgp/parseBGP.cpp:87
↓ 1 callersMethodhex_digest
Server/src/md5.cpp:258
↓ 1 callersMethodload
/ * Load configuration from file in YAML format * * \param [in] cfg_filename Yaml configuration filename **************************************
Server/src/Config.cpp:84
↓ 1 callersMethodlookupPeerGroup
/ * Lookup peer group * * \param [in] hostname hostname/fqdn of the peer * \param [in] ip_addr IP address of the peer (printed for
Server/src/kafka/KafkaTopicSelector.cpp:108
↓ 1 callersMethodlookupRouterGroup
/ * Lookup router group * * \param [in] hostname hostname/fqdn of the router * \param [in] ip_addr IP address of the peer (pri
Server/src/kafka/KafkaTopicSelector.cpp:221
↓ 1 callersMethodparseAttrLinkState
* Parse Link State attribute * * \details Will handle parsing the link state attributes * * \param [in] attr_len Length of
Server/src/bgp/linkstate/MPLinkStateAttr.cpp:122
↓ 1 callersMethodparseExtCommunities
* Parse the extended communities path attribute (8 byte as per RFC4360) * * \details * Will parse the EXTENDED COMMUNITIES data pas
Server/src/bgp/ExtCommunity.cpp:51
↓ 1 callersMethodparseNotify
* Parses a notification message stored in a byte parsed_msg.error_textfer * * \details * Reads the notification message from buffer. The pars
Server/src/bgp/NotificationMsg.cpp:45
↓ 1 callersMethodparsePeerDownEventHdr
* Parse the v3 peer down BMP header * * \details This method will update the db peer_down_event struct with BMP header info. * * \param [in] sock
Server/src/bmp/parseBMP.cpp:529
↓ 1 callersMethodparsePeerUpEventHdr
* Parse the v3 peer up BMP header * * \details This method will update the db peer_up_event struct with BMP header info. * * \param [in] sock
Server/src/bmp/parseBMP.cpp:650
↓ 1 callersMethodparsePeerUpInfo
* Parse the peer UP informational data * * \details Updates the peer struct info items * * \param [in] data Data pointer to info, should s
Server/src/bmp/parseBMP.cpp:591
↓ 1 callersMethodparseReachLinkState
* MP Reach Link State NLRI parse * * \details Will handle parsing the link state NLRI * * \param [in] nlri Reference t
Server/src/bgp/linkstate/MPLinkState.cpp:43
↓ 1 callersMethodparseReachNlriAttr
* Parse the MP_REACH NLRI attribute data * * \details * Will parse the MP_REACH_NLRI data passed. Parsed data will be stored * in parse
Server/src/bgp/MPReachAttr.cpp:51
↓ 1 callersMethodparseUnReachLinkState
* MP UnReach Link State NLRI parse * * \details Will handle parsing the unreach link state NLRI * * \param [in] nlri R
Server/src/bgp/linkstate/MPLinkState.cpp:85
↓ 1 callersMethodparseUnReachNlriAttr
* Parse the MP_UNREACH NLRI attribute data * * \details * Will parse the MP_REACH_NLRI data passed. Parsed data will be stored * in par
Server/src/bgp/MPUnReachAttr.cpp:51
↓ 1 callersMethodparseUpdateMsg
* Parses the update message * * \details * Reads the update message from socket and parses it. The parsed output will * be added to the
Server/src/bgp/UpdateMsg.cpp:68
↓ 1 callersMethodparsev6ExtCommunities
* Parse the extended communities path attribute (20 byte as per RFC5701) * * \details * Will parse the EXTENDED COMMUNITIES data pa
Server/src/bgp/ExtCommunity.cpp:581
↓ 1 callersMethodproduce
* produce message to Kafka * * \param [in] topic_var Topic var to use in KafkaTopicSelector::getTopic() MSGBUS_TOPIC_VAR_* * \param [in] msg
Server/src/kafka/MsgBusImpl_kafka.cpp:369
↓ 1 callersFunctionrunServer
* Run Server loop * * \param [in] cfg Reference to the config options */
Server/src/openbmp.cpp:401
↓ 1 callersMethodsend_bmp_raw
* Abstract method Implementation - See MsgBusInterface.hpp for details * * TODO: Consolidate this to single produce method */
Server/src/kafka/MsgBusImpl_kafka.cpp:1551
↓ 1 callersMethodsetWidthFilename
/ * Sets the filename width for printing * * \param[in] width Column width to use for printing ************************************************
Server/src/Logger.cpp:115
↓ 1 callersMethodsetWidthFunction
/ * Sets the function width for printing * * \param[in] width Column width to use for printing ************************************************
Server/src/Logger.cpp:105
↓ 1 callersMethodupdate_Collector
* Abstract method Implementation - See MsgBusInterface.hpp for details */
Server/src/kafka/MsgBusImpl_kafka.cpp:425
↓ 1 callersMethodupdate_L3Vpn
* Abstract method Implementation - See MsgBusInterface.hpp for details */
Server/src/kafka/MsgBusImpl_kafka.cpp:750
↓ 1 callersMethodupdate_baseAttribute
* Abstract method Implementation - See MsgBusInterface.hpp for details */
Server/src/kafka/MsgBusImpl_kafka.cpp:689
↓ 1 callersMethodupdate_eVPN
* Abstract method Implementation - See MsgBusInterface.hpp for details */
Server/src/kafka/MsgBusImpl_kafka.cpp:867
↓ 1 callersMethodwait_and_accept_connection
* Wait and Accept new/pending connections * * Will accept both IPv4 and IPv6 (if configured), but only one will be accepted * per poll/wait period.
Server/src/bmp/BMPListener.cpp:154
MethodAddPathDataContainer
Server/src/bgp/AddPathDataContainer.cpp:15
MethodBMPListener
* Class constructor * * \param [in] logPtr Pointer to existing Logger for app logging * \param [in] config Pointer to the loaded configuration
Server/src/bmp/BMPListener.cpp:37
MethodBMPReader
* Class constructor * * \param [in] logPtr Pointer to existing Logger for app logging * \param [in] config Pointer to the loaded configuration
Server/src/bmp/BMPReader.cpp:39
FunctionClientThread
* Client thread function * * Thread function that is called when starting a new thread. * The DB/mysql is initialized for each thread. * * @param
Server/src/client_thread.cpp:74
FunctionClientThread_cancel
* Client thread cancel * @param arg Pointer to ClientThreadInfo struct */
Server/src/client_thread.cpp:30
MethodConfig
/ * Constructor for class ***********************************************************************/
Server/src/Config.cpp:29
MethodDebugPrint
/ * Prints debug message if debug is enabled * * \param[in] filename the source file that originated the debug message * \param[in] line_num
Server/src/Logger.cpp:130
MethodEVPN
* Constructor for class * * \details Handles bgp Extended Communities * * \param [in] logPtr Pointer to existing Logger
Server/src/bgp/EVPN.cpp:17
MethodExtCommunity
* Constructor for class * * \details Handles bgp Extended Communities * * \param [in] logPtr Pointer to existing Logger
Server/src/bgp/ExtCommunity.cpp:29
MethodF
Server/src/md5.cpp:491
MethodFF
Server/src/md5.cpp:513
MethodG
Server/src/md5.cpp:495
MethodGG
Server/src/md5.cpp:519
MethodH
Server/src/md5.cpp:499
MethodHH
Server/src/md5.cpp:525
MethodI
Server/src/md5.cpp:503
MethodII
Server/src/md5.cpp:531
MethodKafkaEventCallback
Server/src/kafka/KafkaEventCallback.cpp:12
MethodKafkaPeerPartitionerCallback
Server/src/kafka/KafkaPeerPartitionerCallback.cpp:13
MethodKafkaTopicSelector
/ * Constructor for class * * \param [in] logPtr Pointer to Logger instance * \param [in] cfg Pointer to the config instance * \param [in]
Server/src/kafka/KafkaTopicSelector.cpp:23
MethodLogger
/ * Constructor for class * * \param [in] log_filename log file name or NULL to use stdout * \param [in] debug_filename = debug log filename or
Server/src/Logger.cpp:29
MethodMD5
MD5 simple initialization method
Server/src/md5.cpp:54
MethodMPLinkState
* Constructor for class * * \details Handles bgp Extended Communities * * \param [in] logPtr Pointer to existing Logger
Server/src/bgp/linkstate/MPLinkState.cpp:25
MethodMPLinkStateAttr
* Constructor for class * * \details Handles bgp Extended Communities * * \param [in] logPtr Pointer to existing Logger
Server/src/bgp/linkstate/MPLinkStateAttr.cpp:102
MethodMPReachAttr
* Constructor for class * * \details Handles BGP MP Reach NLRI * * \param [in] logPtr Pointer to existing Logger for app log
Server/src/bgp/MPReachAttr.cpp:30
MethodMPUnReachAttr
* Constructor for class * * \details Handles BGP MP UnReach NLRI * * \param [in] logPtr Pointer to existing Logger for app l
Server/src/bgp/MPUnReachAttr.cpp:29
MethodNotificationMsg
* Constructor for class * * \details Handles bgp notification messages * * \param [in] logPtr Pointer to existing Logger for app logging
Server/src/bgp/NotificationMsg.cpp:23
MethodOpenMsg
* Constructor for class * * \details Handles bgp open messages * * \param [in] logPtr Pointer to existing Logger for app logging * \
Server/src/bgp/OpenMsg.cpp:31
MethodPrint
Server/src/Logger.cpp:147
MethodReadIncomingMsg
* Read messages from BMP stream * * BMP routers send BMP/BGP messages, this method reads and parses those. * * \param [in] client Client inf
Server/src/bmp/BMPReader.cpp:98
MethodRecv
* Recv wrapper for recv() to enable packet buffering */
Server/src/bmp/parseBMP.cpp:59
MethodUpdateDB
* Update the Database with the parsed updated data * * \details This method will update the database based on the supplied parsed update data * *
Server/src/bgp/parseBGP.cpp:349
MethodUpdateDBAdvPrefixes
* Update the Database advertised prefixes * * \details This method will update the database for the supplied advertised prefixes * * \param adv_p
Server/src/bgp/parseBGP.cpp:630
MethodUpdateDBAttrs
* Update the Database path attributes * * \details This method will update the database for the supplied path attributes * * \param attrs
Server/src/bgp/parseBGP.cpp:386
MethodUpdateDBL3Vpn
* Update the Database advertised l3vpn * * \details This method will update the database for the supplied advertised prefixes * * \param [in] rem
Server/src/bgp/parseBGP.cpp:468
next →1–100 of 218, ranked by callers