MCPcopy Create free account

hub / github.com/cloudflare/fgbgp / functions

Functions247 in github.com/cloudflare/fgbgp

↓ 81 callersMethodWrite
(w io.Writer, addpath bool)
messages/messages.go:172
↓ 47 callersMethodWrite
(io.Writer)
mrt/mrt.go:54
↓ 19 callersMethodString
()
messages/messages.go:174
↓ 18 callersMethodString
()
server/server.go:224
↓ 11 callersFunctionAttributeHeaderLen
(size int)
messages/bgp_update.go:332
↓ 10 callersMethodLen
(addpath bool)
messages/messages.go:171
↓ 8 callersFunctionWriteAttributeHeader
(bw io.Writer, size int, attrflag byte, attrcode byte)
messages/bgp_update.go:347
↓ 7 callersMethodBytes
(addpath bool)
messages/messages.go:173
↓ 6 callersMethodDisconnect
()
server/server.go:198
↓ 6 callersFunctionIPtoBytes
(ip net.IP)
messages/bgp_update.go:340
↓ 6 callersMethodUpdateState
(newstate int)
server/server.go:255
↓ 5 callersMethodLen
()
mrt/mrt.go:55
↓ 4 callersFunctionDecodeBGP4TD2RIBSpec
(buf io.Reader, subtype uint16, timestamp time.Time)
mrt/mrt.go:606
↓ 4 callersMethodError
(id int, msg interface{}, err error)
server/workerpool.go:9
↓ 4 callersFunctionGetBGPHeaderLen
()
messages/messages.go:465
↓ 4 callersFunctionParseNLRI
*func (m *BGPMessageUpdate) AddASNToPath(asn uint32) { for i := range(m.PathAttributes) { if v,ok := m.PathAttributes[i].(BGPAttribute_ASP
messages/bgp_update.go:489
↓ 4 callersMethodStart
()
server/server.go:784
↓ 4 callersFunctionWriteBGPHeader
(bgptype byte, size uint16, bw io.Writer)
messages/messages.go:469
↓ 4 callersFunctionWriteCommonHeader
(buf io.Writer, timestamp time.Time, mrttype uint16, subtype uint16, length uint32)
mrt/mrt.go:58
↓ 3 callersMethodEquals
(nlri NLRI)
messages/messages.go:175
↓ 3 callersFunctionInAfiSafi
(afi uint16, safi byte, list []AfiSafi)
messages/messages.go:389
↓ 2 callersMethodClose
()
server/update.go:13
↓ 2 callersMethodContentLen
()
messages/bgp_update.go:397
↓ 2 callersMethodContentLen
()
messages/bgp_update.go:424
↓ 2 callersMethodContentLen
()
messages/bgp_update.go:448
↓ 2 callersFunctionConvertBytesToPrefix
(b []byte, p byte, ipv6 bool)
rib/rib_lc.go:181
↓ 2 callersFunctionConvertNLRIToBytes
(nlri messages.NLRI)
rib/rib_lc.go:237
↓ 2 callersFunctionConvertPrefixToBytes
(prefix net.IPNet)
rib/rib_lc.go:211
↓ 2 callersFunctionDecodeRibEntries
(buf io.Reader)
mrt/mrt.go:589
↓ 2 callersMethodEvolveState
(pkt interface{})
server/server.go:307
↓ 2 callersMethodGetAfi
()
messages/messages.go:169
↓ 2 callersMethodGetNextHopLen
()
messages/bgp_update.go:393
↓ 2 callersMethodGetSplitLen
()
messages/messages.go:221
↓ 2 callersMethodGetSubtype
()
mrt/mrt.go:305
↓ 2 callersMethodIsIPv4
()
mrt/mrt.go:390
↓ 2 callersMethodIsIPv4
()
mrt/mrt.go:435
↓ 2 callersMethodLenContent
()
messages/bgp_open.go:213
↓ 2 callersMethodLenContent
()
messages/bgp_update.go:172
↓ 2 callersMethodLenContent
(enc2bytes bool)
messages/bgp_update.go:295
↓ 2 callersMethodLenContent
()
messages/bgp_update.go:360
↓ 2 callersMethodLenMrt
()
messages/bgp_update.go:376
↓ 2 callersMethodLenParams
()
messages/bgp_open.go:205
↓ 2 callersMethodLenPathAttribute
()
messages/bgp_update.go:164
↓ 2 callersMethodLenSets
()
messages/bgp_update.go:286
↓ 2 callersMethodLenWithdrawn
()
messages/bgp_update.go:156
↓ 2 callersFunctionReadFromSocket
(tcpconn *net.TCPConn, msg []byte)
server/server.go:444
↓ 2 callersMethodRefresh
(afisafi messages.AfiSafi)
server/server.go:159
↓ 2 callersFunctionRemoveFromNLRI
(nlri messages.NLRI, message *messages.BGPMessageUpdate)
rib/rib_lc.go:247
↓ 2 callersMethodUpdateRib
(*messages.BGPMessageUpdate)
rib/rib.go:13
↓ 2 callersMethodWalk
(f Walk, isv6 bool)
rib/rib_lc.go:109
↓ 2 callersMethodaddPrefix
(nlri messages.NLRI, trie *lctrie.Trie, message *messages.BGPMessageUpdate, count *int)
rib/rib_lc.go:274
↓ 2 callersMethoddelPrefix
(nlri messages.NLRI, trie *lctrie.Trie, count *int)
rib/rib_lc.go:292
↓ 1 callersMethodAddEntry
(peerindex uint16, origtime time.Time, attributes []messages.BGPAttributeIf)
mrt/mrt.go:296
↓ 1 callersMethodAddNeighbor
(n *Neighbor)
server/server.go:678
↓ 1 callersMethodApplyUpdateHandlerToNeighbors
()
server/server.go:711
↓ 1 callersFunctionCompareAddPath
(local []messages.AddPath, remote []messages.AddPath)
server/server.go:260
↓ 1 callersMethodConnect
()
server/server.go:183
↓ 1 callersMethodConvertToUpdateIndex
(index int)
mrt/mrt.go:241
↓ 1 callersMethodCraftUpdate
( afisafi messages.AfiSafi, nlri []messages.NLRI, withdraw []messages.NLRI, nextHop net.IP, communities [
server/server.go:241
↓ 1 callersMethodCreateDefaultUpdateHandler
(workers int)
server/update.go:87
↓ 1 callersFunctionCreatePool
(nworkers int, h Handler)
server/workerpool.go:26
↓ 1 callersFunctionCreateWorker
(id int, h Handler, inchan chan chan interface{})
server/workerpool.go:39
↓ 1 callersFunctionDecodeAttributes
(buf io.Reader, attrlen uint16)
mrt/mrt.go:583
↓ 1 callersFunctionDecodeBGP4MP
(buf io.Reader, timestamp time.Time, subtype uint16, length uint32)
mrt/mrt.go:466
↓ 1 callersFunctionDecodeBGP4TD2
(buf io.Reader, timestamp time.Time, subtype uint16, length uint32)
mrt/mrt.go:672
↓ 1 callersFunctionDecodeNLRI
(buf io.Reader, afi uint16, safi byte)
mrt/mrt.go:555
↓ 1 callersMethodDisconnectedNeighbor
(*Neighbor)
server/server.go:33
↓ 1 callersMethodDispatch
(msg interface{})
server/workerpool.go:85
↓ 1 callersMethodEntryToUpdate
()
mrt/mrt.go:234
↓ 1 callersMethodEqualsAfiSafi
(comp AddPath)
messages/messages.go:295
↓ 1 callersMethodGetAfi
()
messages/messages.go:195
↓ 1 callersMethodGetSafi
()
messages/messages.go:170
↓ 1 callersMethodGetSafi
()
messages/messages.go:205
↓ 1 callersMethodLen
()
mrt/mrt.go:147
↓ 1 callersMethodLen
()
mrt/mrt.go:344
↓ 1 callersMethodLen
()
mrt/mrt.go:394
↓ 1 callersMethodLen
()
mrt/mrt.go:439
↓ 1 callersMethodLenContent
()
messages/bgp_update.go:278
↓ 1 callersMethodLookupPrefix
(prefix net.IPNet, exact bool)
rib/rib_lc.go:130
↓ 1 callersMethodNeighborLifeRoutine
()
server/server.go:411
↓ 1 callersMethodNeighborReceiveRoutine
()
server/server.go:463
↓ 1 callersFunctionNewLcRib
()
rib/rib_lc.go:22
↓ 1 callersFunctionNewMrtTableDumpV2_RibGeneric
(seqnum uint32, afi uint16, safi byte, nlri messages.NLRI, ts time.Time)
mrt/mrt.go:217
↓ 1 callersFunctionNewNeighbor
(addr net.IP, port int, identifier net.IP, asn uint32, addpath bool, holdtime int, routerefresh bool)
server/server.go:597
↓ 1 callersMethodNewNeighbor
(*messages.BGPMessageOpen, *Neighbor)
server/server.go:31
↓ 1 callersFunctionNewNeighborFromConn
(tcpconn *net.TCPConn, identifier net.IP, asn uint32, addpath bool, holdtime int, routerefresh bool)
server/server.go:586
↓ 1 callersMethodNewServer
(addr string)
server/server.go:684
↓ 1 callersMethodNotification
KeepAlive(*Neighbor) (bool)
server/server.go:36
↓ 1 callersMethodParseCapability
()
messages/bgp_open.go:233
↓ 1 callersFunctionParseKeepAlive
()
messages/messages.go:417
↓ 1 callersFunctionParseNotification
(b []byte)
messages/messages.go:421
↓ 1 callersFunctionParseOpen
(b []byte)
messages/bgp_open.go:269
↓ 1 callersFunctionParsePathAttribute
(b []byte, addpathlist []AfiSafi, enc2bytes bool)
messages/bgp_update.go:553
↓ 1 callersFunctionParseUpdate
(b []byte, addpathlist []AfiSafi, enc2bytes bool)
messages/bgp_update.go:713
↓ 1 callersMethodProcess
(id int, msg interface{})
server/workerpool.go:8
↓ 1 callersMethodProcessIncomingRequest
(tcpconn *net.TCPConn)
server/server.go:557
↓ 1 callersMethodProcessReceived
(interface{}, *Neighbor)
server/server.go:38
↓ 1 callersMethodProcessUpdate
([]byte, *Neighbor)
server/update.go:12
↓ 1 callersMethodProcessUpdateEvent
(*messages.BGPMessageUpdate, *Neighbor)
server/update.go:17
↓ 1 callersMethodRemoveNeighbor
(n *Neighbor)
server/server.go:661
next →1–100 of 247, ranked by callers