TestMu Conference is Back! Future of Testing + AI LambdaTest G2 Announcement

How to use Forward method of qemu Package

Best Syzkaller code snippet using qemu.Forward

runner.go

Source:runner.go

...20		SilenceUsage: true,21		RunE: func(cmd *cobra.Command, args []string) error {22			var err error23			rcnf.Logger = logrus.New()24			rcnf.ForwardedPorts, err = parsePorts(ports)25			if err != nil {26				return fmt.Errorf("Port flags: %w", err)27			}28			t0 := time.Now()29			err = StartQemu(rcnf)30			dur := time.Since(t0).Round(time.Millisecond)31			fmt.Printf("Execution took %v\n", dur)32			if err != nil {33				return fmt.Errorf("Qemu exited with an error: %w", err)34			}35			return nil36		},37	}38	cmd.Flags().StringVar(&rcnf.Image, "image", "", "VM image file path")39	cmd.MarkFlagRequired("image")40	cmd.Flags().StringVar(&rcnf.KernelFname, "kernel", "", "kernel filename to boot with. (if empty no -kernel option will be passed to qemu)")41	cmd.Flags().BoolVar(&rcnf.QemuPrint, "qemu-cmd-print", false, "Do not run the qemu command, just print it")42	cmd.Flags().BoolVar(&rcnf.DisableKVM, "qemu-disable-kvm", false, "Do not use KVM acceleration, even if /dev/kvm exists")43	cmd.Flags().BoolVar(&rcnf.Daemonize, "daemonize", false, "daemonize QEMU after initializing")44	cmd.Flags().StringVar(&rcnf.HostMount, "host-mount", "", "Mount the specified host directory in the VM using a 'host_mount' tag")45	cmd.Flags().StringArrayVarP(&ports, "port", "p", nil, "Forward a port (hostport[:vmport[:tcp|udp]])")46	cmd.Flags().IntVar(&rcnf.SerialPort, "serial-port", 0, "Port for serial console")47	return cmd48}49func parsePorts(flags []string) ([]PortForward, error) {50	var forwards []PortForward51	for _, flag := range flags {52		hostPortStr, vmPortAndProto, found := strings.Cut(flag, ":")53		if !found {54			hostPort, err := strconv.Atoi(flag)55			if err != nil {56				return nil, fmt.Errorf("'%s' is not a valid port number", flag)57			}58			forwards = append(forwards, PortForward{59				HostPort: hostPort,60				VMPort:   hostPort,61				Protocol: "tcp",62			})63			continue64		}65		hostPort, err := strconv.Atoi(hostPortStr)66		if err != nil {67			return nil, fmt.Errorf("'%s' is not a valid port number", hostPortStr)68		}69		vmPortStr, proto, found := strings.Cut(vmPortAndProto, ":")70		if !found {71			vmPort, err := strconv.Atoi(vmPortAndProto)72			if err != nil {73				return nil, fmt.Errorf("'%s' is not a valid port number", vmPortAndProto)74			}75			forwards = append(forwards, PortForward{76				HostPort: hostPort,77				VMPort:   vmPort,78				Protocol: "tcp",79			})80			continue81		}82		vmPort, err := strconv.Atoi(vmPortStr)83		if err != nil {84			return nil, fmt.Errorf("'%s' is not a valid port number", vmPortStr)85		}86		proto = strings.ToLower(proto)87		if proto != "tcp" && proto != "udp" {88			return nil, fmt.Errorf("port forward protocol must be tcp or udp")89		}90		forwards = append(forwards, PortForward{91			HostPort: hostPort,92			VMPort:   vmPort,93			Protocol: proto,94		})95	}96	return forwards, nil97}98const qemuBin = "qemu-system-x86_64"99func StartQemu(rcnf RunConf) error {100	qemuArgs, err := BuildQemuArgs(rcnf.Logger, &rcnf)101	if err != nil {102		return err103	}104	if rcnf.QemuPrint {...

qemu.go

Source:qemu.go

...13	CDRoms         []string14	CPU            int15	Disks          []string16	Memory         int17	SSHPortForward int18}19type NewOptions struct {20	ExecutableName string21}22type QEMU struct {23	accelerator    string24	bios           string25	cpu            string26	executableName string27	machine        string28}29func (q *QEMU) lookExecutable() bool {30	path, err := exec.LookPath(q.executableName)31	if err != nil {32		return false33	}34	if path == "" {35		return false36	}37	return true38}39func (q *QEMU) Command(opts *CommandOptions) (*exec.Cmd, error) {40	cmdArgs := []string{41		"-accel", q.accelerator, // enable acceleration42		"-cpu", q.cpu, // sets the emulated cpu43		"-m", fmt.Sprint(opts.Memory), // sets the memory available44		"-machine", q.machine, // sets the emulated machine with highmem=off45		"-nographic",             // use stdio for the serial input and output46		"-rtc", "base=localtime", // sync RTC clock with host time47		"-smp", fmt.Sprint(opts.CPU), // sets the number of CPUs48		"-device", "qemu-xhci", // adds a bus for USB devices49	}50	if q.bios != "" {51		// sets the bios52		cmdArgs = append(cmdArgs, "-bios", q.bios)53	}54	for i, disk := range opts.Disks {55		diskArgs := []string{56			"-device", fmt.Sprintf("virtio-blk,drive=drive%d", i), // create a virtio PCI block device57			"-drive", fmt.Sprintf("if=none,media=disk,id=drive%d,file=%s,cache=writethrough", i, disk), // sets the media as disk and load the file58		}59		cmdArgs = append(cmdArgs, diskArgs...)60	}61	for i, cdrom := range opts.CDRoms {62		cdromArgs := []string{63			"-device", fmt.Sprintf("usb-storage,drive=cdrom%d,removable=true", i), // create a removable USB storage64			"-drive", fmt.Sprintf("if=none,media=cdrom,id=cdrom%d,file=%s,cache=writethrough", i, cdrom), // sets the media as cdrom and load the ISO file65		}66		cmdArgs = append(cmdArgs, cdromArgs...)67	}68	if opts.SSHPortForward != 0 {69		networkArgs := []string{70			"-device", "virtio-net-pci,netdev=netdev0", // create a virtio PCI network device71			"-netdev", fmt.Sprintf("user,id=netdev0,hostfwd=tcp::%d-:22", opts.SSHPortForward), // configure port forwarding72		}73		cmdArgs = append(cmdArgs, networkArgs...)74	}75	return exec.Command(76		q.executableName,77		cmdArgs...,78	), nil79}80func New(opts *NewOptions) (*QEMU, error) {81	qemu := &QEMU{82		executableName: opts.ExecutableName,83	}84	if !qemu.lookExecutable() {85		return nil, ErrExecutableNotFound...

Forward

Using AI Code Generation

1import (2func main() {3    c, err := qmp.NewSocketConnection(socketPath)4    if err != nil {5        panic(err)6    }7    defer c.Close()8    q, err := qmp.NewQMP(c)9    if err != nil {10        panic(err)11    }12    defer q.Shutdown()13    ch, err := q.Events()14    if err != nil {15        panic(err)16    }17    go q.Loop()18    if err := q.ExecuteCommand(commands.BlockdevAddWithFile{"file", "file1", "myfile"}); err != nil {19        panic(err)20    }21    fmt.Printf("%+v", e)22}23{Event:"BLOCK_JOB_COMPLETED",Timestamp:{Seconds:0,Nanoseconds:0},Data:{Device:"file1",Type:"commit",Speed:0,Len:0,Offset:0,End:0,Ret:0,Error:""}}

Forward

Using AI Code Generation

1import (2func main() {3    q, err := qemu.NewQemu("qemu-system-x86_64", qemu.VNC, &qemu.Options{4    })5    if err != nil {6        panic(err)7    }8    defer q.Disconnect()9    if err := q.Connect(); err != nil {10        panic(err)11    }12    if err := q.Start(); err != nil {13        panic(err)14    }15    if err := q.Forward("

Forward

Using AI Code Generation

1import (2func main() {3	q, err := qemu.NewQemu("/usr/bin/qemu-system-x86_64", "qemu-system-x86_64")4	if err != nil {5		panic(err)6	}7	q.SetArgs([]string{8	})9	if err := q.Start(); err != nil {10		panic(err)11	}12	if err := q.Wait(context.Background(), 5*time.Second); err != nil {13		panic(err)14	}15	if err := q.Forward([]byte("E")); err != nil {16		panic(err)17	}18	if err := q.Forward([]byte("C")); err != nil {19		panic(err)20	}21	if err := q.Wait(context.Background(), 0); err != nil {22		panic(err)23	}24	fmt.Printf("QEMU exit status: %d25", q.ExitStatus())26}27import (28func main() {29	q, err := qemu.NewQemu("/usr/bin/qemu-system-x86_64", "qemu-system-x86_64")30	if err != nil {31		panic(err)32	}33	q.SetArgs([]string{

Forward

Using AI Code Generation

1import (2func main() {3	if len(os.Args) > 1 {4	} else {5	}6	handle, err = pcap.OpenLive(device, 65536, true, 0)7	if err != nil {8		panic(err)9	}10	defer handle.Close()11	err = handle.Compile(&bpfprog, filter, 1, 0)12	if err != nil {13		panic(err)14	}15	err = handle.SetFilter(&bpfprog)16	if err != nil {17		panic(err)18	}19	for {20		packet, err = handle.NextEx()21		if err != nil {22			panic(err)23		}24		if packet == nil {25		}

Forward

Using AI Code Generation

1import (2func main() {3	q := qemu.NewQemu("/usr/bin/qemu-system-x86_64", "qemu-system-x86_64")4	q.AddArgs("-m", "512")5	q.AddArgs("-nographic")6	q.AddArgs("-kernel", "/home/srikanth/Downloads/linux-4.14.13/arch/x86_64/boot/bzImage")7	q.AddArgs("-append", "console=ttyS0")8	q.AddArgs("-drive", "file=/home/srikanth/Downloads/ubuntu-17.04-server-amd64.iso,format=raw")9	q.Start()10	q.Wait()11	exitCode := q.ExitStatus()12	fmt.Println("Exit code was", exitCode)13}14import (15func main() {16	q := qemu.NewQemu("/usr/bin/qemu-system-x86_64", "qemu-system-x86_64")17	q.AddArgs("-m", "512")18	q.AddArgs("-nographic")19	q.AddArgs("-kernel", "/home/srikanth/Downloads/linux-4.14.13/arch/x86_64/boot/bzImage")20	q.AddArgs("-append", "console=ttyS0")21	q.AddArgs("-drive", "file=/home/srikanth/Downloads/ubuntu-17.04-server-amd64.iso,format=raw")22	q.Start()23	q.Wait()24	exitCode := q.ExitStatus()25	fmt.Println("Exit code was", exitCode)26}27import (28func main() {29	q := qemu.NewQemu("/usr/bin/qemu-system-x86_64", "qemu-system-x86_64")

Forward

Using AI Code Generation

1import (2func main() {3    fmt.Println("Hello, playground")4    q.Forward()5}6import (7func main() {8    fmt.Println("Hello, playground")9    q.Forward()10}

Forward

Using AI Code Generation

1import (2func main() {3    qemu := qemu.NewQemu("/usr/bin/qemu-system-x86_64")4    qemu.AddDrive("/home/paras/Downloads/iso/ubuntu-14.04.4-server-amd64.iso")5    qemu.AddDrive("/home/paras/Downloads/iso/ubuntu-14.04.4-server-amd64.iso")6    qemu.AddNetwork("user")7    qemu.AddNetwork("user")8    qemu.AddNetwork("user")9    qemu.SetMachine("pc")10    qemu.SetCpu("qemu64")11    qemu.SetSmp(1, 1)12    qemu.SetMemory(1024)13    qemu.SetVnc("

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.