vmimpl

package
v0.0.0-...-af24b05 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 18, 2024 License: Apache-2.0 Imports: 18 Imported by: 148

Documentation

Overview

Package vmimpl provides an abstract test machine (VM, physical machine, etc) interface for the rest of the system. For convenience test machines are subsequently collectively called VMs. The package also provides various utility functions for VM implementations.

Index

Constants

View Source
const PprofPort = 6060

On VMs, pprof will be listening to this port.

Variables

View Source
var (
	// Close to interrupt all pending operations in all VMs.
	Shutdown   = make(chan struct{})
	ErrTimeout = errors.New("timeout")

	Types = make(map[string]Type)
)

Functions

func DiagnoseFreeBSD

func DiagnoseFreeBSD(w io.Writer) ([]byte, bool)

DiagnoseFreeBSD sends the debug commands to the given writer which is expected to be connected to a panicked FreeBSD kernel. If kernel just hanged, we've lost connection or detected some non-panic error, console still shows normal login prompt.

func DiagnoseLinux

func DiagnoseLinux(rep *report.Report, ssh func(args ...string) ([]byte, error)) (output []byte, wait, handled bool)

DiagnoseLinux diagnoses some Linux kernel bugs over the provided ssh callback.

func DiagnoseOpenBSD

func DiagnoseOpenBSD(w io.Writer) ([]byte, bool)

DiagnoseOpenBSD sends the debug commands to the given writer which is expected to be connected to a paniced openbsd kernel. If kernel just hanged, we've lost connection or detected some non-panic error, console still shows normal login prompt.

func EscapeDoubleQuotes

func EscapeDoubleQuotes(inp string) string

Escapes double quotes(and nested double quote escapes). Ignores any other escapes. Reference: https://www.gnu.org/software/bash/manual/html_node/Double-Quotes.html

func MakeBootError

func MakeBootError(err error, output []byte) error

func Multiplex

func Multiplex(cmd *exec.Cmd, merger *OutputMerger, console io.Closer, timeout time.Duration,
	stop, closed <-chan bool, debug bool) (<-chan []byte, <-chan error, error)

func OpenAdbConsole

func OpenAdbConsole(bin, dev string) (rc io.ReadCloser, err error)

OpenAdbConsole provides fallback console output using 'adb shell dmesg -w'.

func OpenConsole

func OpenConsole(con string) (rc io.ReadCloser, err error)

Tested on Suzy-Q and BeagleBone.

func OpenRemoteConsole

func OpenRemoteConsole(bin string, args ...string) (rc io.ReadCloser, err error)

Open dmesg remotely.

func OpenRemoteKernelLog

func OpenRemoteKernelLog(ip, console string) (rc io.ReadCloser, err error)

OpenRemoteKernelLog accesses to the host where Android VM runs on, not Android VM itself. The host stores all kernel outputs of Android VM so in case of crashes nothing will be lost.

func RandomPort

func RandomPort() int

func Register

func Register(typ string, ctor ctorFunc, allowsOvercommit, netCompression bool)

Register registers a new VM type within the package.

func SCPArgs

func SCPArgs(debug bool, sshKey string, port int, systemSSHCfg bool) []string

func SSHArgs

func SSHArgs(debug bool, sshKey string, port int, systemSSHCfg bool) []string

func SSHArgsForward

func SSHArgsForward(debug bool, sshKey string, port, forwardPort int, systemSSHCfg bool) []string

func SleepInterruptible

func SleepInterruptible(d time.Duration) bool

Sleep for d. If shutdown is in progress, return false prematurely.

func UnusedTCPPort

func UnusedTCPPort() int

func WaitForSSH

func WaitForSSH(debug bool, timeout time.Duration, addr, sshKey, sshUser, OS string, port int, stop chan error,
	systemSSHCfg bool) error

Types

type BootError

type BootError struct {
	Title  string
	Output []byte
}

BootError is returned by Pool.Create when VM does not boot. It should not be used for VMM intfrastructure errors, i.e. for problems not related to the tested kernel itself.

func (BootError) BootError

func (err BootError) BootError() (string, []byte)

func (BootError) Error

func (err BootError) Error() string

type Env

type Env struct {
	// Unique name
	// Can be used for VM name collision resolution if several pools share global name space.
	Name      string
	OS        string // target OS
	Arch      string // target arch
	Workdir   string
	Image     string
	SSHKey    string
	SSHUser   string
	Timeouts  targets.Timeouts
	Debug     bool
	Config    []byte // json-serialized VM-type-specific config
	KernelSrc string
}

Env contains global constant parameters for a pool of VMs.

type Infoer

type Infoer interface {
	// MachineInfo returns additional info about the VM, e.g. VMM version/arguments.
	Info() ([]byte, error)
}

Infoer is an optional interface that can be implemented by Instance.

type InfraError

type InfraError struct {
	Title  string
	Output []byte
}

By default, all Pool.Create() errors are related to infrastructure problems. InfraError is to be used when we want to also attach output to the title.

func (InfraError) Error

func (err InfraError) Error() string

func (InfraError) InfraError

func (err InfraError) InfraError() (string, []byte)

type Instance

type Instance interface {
	// Copy copies a hostSrc file into VM and returns file name in VM.
	Copy(hostSrc string) (string, error)

	// Forward sets up forwarding from within VM to the given tcp
	// port on the host and returns the address to use in VM.
	Forward(port int) (string, error)

	// Run runs cmd inside of the VM (think of ssh cmd).
	// outc receives combined cmd and kernel console output.
	// errc receives either command Wait return error or vmimpl.ErrTimeout.
	// Command is terminated after timeout. Send on the stop chan can be used to terminate it earlier.
	Run(timeout time.Duration, stop <-chan bool, command string) (outc <-chan []byte, errc <-chan error, err error)

	// Diagnose retrieves additional debugging info from the VM
	// (e.g. by sending some sys-rq's or SIGABORT'ing a Go program).
	//
	// Optionally returns (some or all) of the info directly. If wait == true,
	// the caller must wait for the VM to output info directly to its log.
	//
	// rep describes the reason why Diagnose was called.
	Diagnose(rep *report.Report) (diagnosis []byte, wait bool)

	// Close stops and destroys the VM.
	Close()
}

Instance represents a single VM.

type MergerError

type MergerError struct {
	Name string
	R    io.ReadCloser
	Err  error
}

func (MergerError) Error

func (err MergerError) Error() string

type OutputMerger

type OutputMerger struct {
	Output chan []byte
	Err    chan error
	// contains filtered or unexported fields
}

func NewOutputMerger

func NewOutputMerger(tee io.Writer) *OutputMerger

func (*OutputMerger) Add

func (merger *OutputMerger) Add(name string, r io.ReadCloser)

func (*OutputMerger) AddDecoder

func (merger *OutputMerger) AddDecoder(name string, r io.ReadCloser,
	decoder func(data []byte) (start, size int, decoded []byte))

func (*OutputMerger) Wait

func (merger *OutputMerger) Wait()

type Pool

type Pool interface {
	// Count returns total number of VMs in the pool.
	Count() int

	// Create creates and boots a new VM instance.
	Create(workdir string, index int) (Instance, error)
}

Pool represents a set of test machines (VMs, physical devices, etc) of particular type.

type PprofPortProvider

type PprofPortProvider interface {
	PprofPort() int
}

PprofPortProvider is used when the instance wants to define a custom pprof port.

type Type

type Type struct {
	Ctor           ctorFunc
	Overcommit     bool
	NetCompression bool
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL