loader

Documentation

Overview

Package loader provides accessors to compilation and BPF load routines necessary for creating datapath objects and attaching them to links.

Index

• Variables
• func Compile(ctx context.Context, src string, out string) error
• func ELFSubstitutions(ep datapath.Endpoint) (map[string]uint32, map[string]string)
• func NewObjectCache(c datapath.ConfigWriter, nodeCfg *datapath.LocalNodeConfiguration) *objectCache
• func RestoreTemplates(stateDir string) error
• type Loader
  • func NewLoader(canDisableDwarfRelocations bool) *Loader
  • func (l *Loader) CallsMapPath(id uint16) string
  • func (l *Loader) CompileAndLoad(ctx context.Context, ep datapath.Endpoint, stats *metrics.SpanStat) error
  • func (l *Loader) CompileOrLoad(ctx context.Context, ep datapath.Endpoint, stats *metrics.SpanStat) error
  • func (l *Loader) DeleteDatapath(ctx context.Context, ifName, direction string) error
  • func (l *Loader) EndpointHash(cfg datapath.EndpointConfiguration) (string, error)
  • func (l *Loader) Reinitialize(ctx context.Context, o datapath.BaseProgramOwner, deviceMTU int, ...) error
  • func (l *Loader) ReloadDatapath(ctx context.Context, ep datapath.Endpoint, stats *metrics.SpanStat) (err error)
  • func (l *Loader) Unload(ep datapath.Endpoint)
• type OutputType

Variables

var (
	TemplateSecurityID = identity.ReservedIdentityWorld
	TemplateLxcID      = uint16(65535)
	TemplateMAC        = mac.MAC([]byte{0x02, 0x00, 0x60, 0x0D, 0xF0, 0x0D})
	TemplateIPv4       = []byte{192, 0, 2, 3}
	TemplateIPv6       = []byte{0x20, 0x01, 0xdb, 0x8, 0x0b, 0xad, 0xca, 0xfe, 0x60, 0x0d, 0xbe, 0xe2, 0x0b, 0xad, 0xca, 0xfe}

	CallsMapName = "cilium_calls_"
)

var (
	// DatapathSHA is set during build to the SHA generated from bindata.sh
	// which is hashed across all datapath template code, excluding the
	// node, netdev, lxc and sockops header files (see daemon/Makefile).
	DatapathSHA string
)

var (
	Subsystem = "datapath-loader"
)

Functions

func Compile

func Compile(ctx context.Context, src string, out string) error

Compile compiles a BPF program generating an object file.

func ELFSubstitutions

func ELFSubstitutions(ep datapath.Endpoint) (map[string]uint32, map[string]string)

ELFSubstitutions fetches the set of variable and map substitutions that must be implemented against an ELF template to configure the datapath for the specified endpoint.

func NewObjectCache

func NewObjectCache(c datapath.ConfigWriter, nodeCfg *datapath.LocalNodeConfiguration) *objectCache

NewObjectCache creates a new cache for datapath objects, basing the hash upon the configuration of the datapath and the specified node configuration.

func RestoreTemplates

func RestoreTemplates(stateDir string) error

RestoreTemplates populates the object cache from templates on the filesystem at the specified path.

Types

type Loader

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

Loader is a wrapper structure around operations related to compiling, loading, and reloading datapath programs.

func NewLoader

func NewLoader(canDisableDwarfRelocations bool) *Loader

NewLoader returns a new loader.

func (*Loader) CallsMapPath

func (l *Loader) CallsMapPath(id uint16) string

CallsMapPath gets the BPF Calls Map for the endpoint with the specified ID.

func (*Loader) CompileAndLoad

func (l *Loader) CompileAndLoad(ctx context.Context, ep datapath.Endpoint, stats *metrics.SpanStat) error

CompileAndLoad compiles the BPF datapath programs for the specified endpoint and loads it onto the interface associated with the endpoint.

Expects the caller to have created the directory at the path ep.StateDir().

func (*Loader) CompileOrLoad

func (l *Loader) CompileOrLoad(ctx context.Context, ep datapath.Endpoint, stats *metrics.SpanStat) error

CompileOrLoad loads the BPF datapath programs for the specified endpoint.

In contrast with CompileAndLoad(), it attempts to find a pre-compiled template datapath object to use, to avoid a costly compile operation. Only if there is no existing template that has the same configuration parameters as the specified endpoint, this function will compile a new template for this configuration.

This function will block if the cache does not contain an entry for the same EndpointConfiguration and multiple goroutines attempt to concurrently CompileOrLoad with the same configuration parameters. When the first goroutine completes compilation of the template, all other CompileOrLoad invocations will be released.

func (*Loader) DeleteDatapath

func (l *Loader) DeleteDatapath(ctx context.Context, ifName, direction string) error

DeleteDatapath filter from the given ifName

func (*Loader) EndpointHash

func (l *Loader) EndpointHash(cfg datapath.EndpointConfiguration) (string, error)

EndpointHash hashes the specified endpoint configuration with the current datapath hash cache and returns the hash as string.

func (*Loader) Reinitialize

func (l *Loader) Reinitialize(ctx context.Context, o datapath.BaseProgramOwner, deviceMTU int, iptMgr datapath.IptablesManager, p datapath.Proxy, r datapath.RouteReserver) error

Reinitialize (re-)configures the base datapath configuration including global BPF programs, netfilter rule configuration and reserving routes in IPAM for locally detected prefixes. It may be run upon initial Cilium startup, after restore from a previous Cilium run, or during regular Cilium operation.

func (*Loader) ReloadDatapath

func (l *Loader) ReloadDatapath(ctx context.Context, ep datapath.Endpoint, stats *metrics.SpanStat) (err error)

ReloadDatapath reloads the BPF datapath pgorams for the specified endpoint.

func (*Loader) Unload

func (l *Loader) Unload(ep datapath.Endpoint)

Unload removes the datapath specific program aspects

type OutputType

type OutputType string

OutputType determines the type to be generated by the compilation steps.