table

Documentation

Index

• type Fib
  • func NewFib(config *config.Config, nfdc *nfdc.NfdMgmtThread) *Fib
  • func (fib *Fib) MarkH(name uint64)
  • func (fib *Fib) RemoveUnmarked()
  • func (fib *Fib) UnmarkAll()
  • func (fib *Fib) Update(name enc.Name, newEntries []FibEntry) bool
  • func (fib *Fib) UpdateH(nameH uint64, name enc.Name, newEntries []FibEntry) bool
• type FibEntry
• type NeighborState
  • func (ns *NeighborState) IsDead() bool
  • func (ns *NeighborState) RecvPing(faceId uint64) error
• type NeighborTable
  • func NewNeighborTable(config *config.Config, nfdc *nfdc.NfdMgmtThread) *NeighborTable
  • func (nt *NeighborTable) Add(name enc.Name) *NeighborState
  • func (nt *NeighborTable) Get(name enc.Name) *NeighborState
  • func (nt *NeighborTable) GetAll() []*NeighborState
  • func (nt *NeighborTable) GetH(nameHash uint64) *NeighborState
  • func (nt *NeighborTable) Remove(name enc.Name)
• type PrefixEntry
• type PrefixTable
  • func NewPrefixTable(config *config.Config, engine ndn.Engine, svs *ndn_sync.SvSync) *PrefixTable
  • func (pt *PrefixTable) Announce(name enc.Name)
  • func (pt *PrefixTable) Apply(ops *tlv.PrefixOpList) (dirty bool)
  • func (pt *PrefixTable) GetRouter(name enc.Name) *PrefixTableRouter
  • func (pt *PrefixTable) OnDataInterest(args ndn.InterestHandlerArgs)
  • func (pt *PrefixTable) Withdraw(name enc.Name)
• type PrefixTableRouter
• type Rib
  • func NewRib(config *config.Config) *Rib
  • func (r *Rib) Advert() *tlv.Advertisement
  • func (r *Rib) DirtyResetNextHop(nextHop enc.Name)
  • func (r *Rib) Entries() []*RibEntry
  • func (rib *Rib) GetFibEntries(nt *NeighborTable, router uint64) []FibEntry
  • func (r *Rib) Has(destName enc.Name) bool
  • func (r *Rib) Print()
  • func (r *Rib) Prune() bool
  • func (r *Rib) RemoveNextHop(nextHop enc.Name) bool
  • func (r *Rib) Set(destName enc.Name, nextHop enc.Name, cost uint64) bool
• type RibEntry
  • func (e *RibEntry) Name() enc.Name
  • func (e *RibEntry) Set(nextHop uint64, cost uint64) bool

Types

type Fib

type Fib struct {
	// contains filtered or unexported fields
}

func NewFib

func NewFib(config *config.Config, nfdc *nfdc.NfdMgmtThread) *Fib

func (*Fib) MarkH

func (fib *Fib) MarkH(name uint64)

func (*Fib) RemoveUnmarked

func (fib *Fib) RemoveUnmarked()

func (*Fib) UnmarkAll

func (fib *Fib) UnmarkAll()

func (*Fib) Update

func (fib *Fib) Update(name enc.Name, newEntries []FibEntry) bool

func (*Fib) UpdateH

func (fib *Fib) UpdateH(nameH uint64, name enc.Name, newEntries []FibEntry) bool

type FibEntry

type FibEntry struct {
	// next hop face Id
	FaceId uint64
	// cost in this entry
	Cost uint64
	// contains filtered or unexported fields
}

type NeighborState

type NeighborState struct {

	// neighbor name
	Name enc.Name
	// advertisement sequence number for neighbor
	AdvertSeq uint64
	// most recent advertisement
	Advert *tlv.Advertisement
	// contains filtered or unexported fields
}

func (*NeighborState) IsDead

func (ns *NeighborState) IsDead() bool

func (*NeighborState) RecvPing

func (ns *NeighborState) RecvPing(faceId uint64) error

Call this when a ping is received from a face. This will automatically register the face route with the neighbor and update the last seen time for the neighbor.

type NeighborTable

type NeighborTable struct {
	// contains filtered or unexported fields
}

func NewNeighborTable

func NewNeighborTable(config *config.Config, nfdc *nfdc.NfdMgmtThread) *NeighborTable

func (*NeighborTable) Add

func (nt *NeighborTable) Add(name enc.Name) *NeighborState

func (*NeighborTable) Get

func (nt *NeighborTable) Get(name enc.Name) *NeighborState

func (*NeighborTable) GetAll

func (nt *NeighborTable) GetAll() []*NeighborState

func (*NeighborTable) GetH

func (nt *NeighborTable) GetH(nameHash uint64) *NeighborState

func (*NeighborTable) Remove

func (nt *NeighborTable) Remove(name enc.Name)

type PrefixEntry

type PrefixEntry struct {
	Name enc.Name
}

type PrefixTable

type PrefixTable struct {
	// contains filtered or unexported fields
}

func NewPrefixTable

func NewPrefixTable(
	config *config.Config,
	engine ndn.Engine,
	svs *ndn_sync.SvSync,
) *PrefixTable

func (*PrefixTable) Announce

func (pt *PrefixTable) Announce(name enc.Name)

func (*PrefixTable) Apply

func (pt *PrefixTable) Apply(ops *tlv.PrefixOpList) (dirty bool)

Applies ops from a list. Returns if dirty.

func (*PrefixTable) GetRouter

func (pt *PrefixTable) GetRouter(name enc.Name) *PrefixTableRouter

func (*PrefixTable) OnDataInterest

func (pt *PrefixTable) OnDataInterest(args ndn.InterestHandlerArgs)

Received prefix data Interest

func (*PrefixTable) Withdraw

func (pt *PrefixTable) Withdraw(name enc.Name)

type PrefixTableRouter

type PrefixTableRouter struct {
	Name     enc.Name
	Fetching bool
	Known    uint64
	Latest   uint64
	Prefixes map[uint64]*PrefixEntry
}

type Rib

type Rib struct {
	// contains filtered or unexported fields
}

Routing Information Base (RIB)

func NewRib

func NewRib(config *config.Config) *Rib

func (*Rib) Advert

func (r *Rib) Advert() *tlv.Advertisement

Get all advertisement entries in the RIB.

func (*Rib) DirtyResetNextHop

func (r *Rib) DirtyResetNextHop(nextHop enc.Name)

Resets all entries for a given next hop to infinity without refreshing any entry. This is specifically intended for the RIB update algorithm to avoid unnecessary changes.

func (*Rib) Entries

func (r *Rib) Entries() []*RibEntry

Get all destinations reachable in the RIB.

func (*Rib) GetFibEntries

func (rib *Rib) GetFibEntries(nt *NeighborTable, router uint64) []FibEntry

Get the FIB entry for a name prefix. router should be hash of the router name.

func (*Rib) Has

func (r *Rib) Has(destName enc.Name) bool

Check if a destination is reachable in the RIB.

func (*Rib) Print

func (r *Rib) Print()

Print the RIB to the console (for debugging).

func (*Rib) Prune

func (r *Rib) Prune() bool

Whenever the RIB is changed, this must be called manually to remove unreachable destinations. Returns true if the Advertisement might change.

func (*Rib) RemoveNextHop

func (r *Rib) RemoveNextHop(nextHop enc.Name) bool

Remove all entries with a given next hop. Returns true if the Advertisement might change.

func (*Rib) Set

func (r *Rib) Set(destName enc.Name, nextHop enc.Name, cost uint64) bool

Set a destination in the RIB. Returns true if the Advertisement might change.

type RibEntry

type RibEntry struct {
	// contains filtered or unexported fields
}

func (*RibEntry) Name

func (e *RibEntry) Name() enc.Name

func (*RibEntry) Set

func (e *RibEntry) Set(nextHop uint64, cost uint64) bool