Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use UnusedTCPPort method of vmimpl Package

Best Syzkaller code snippet using vmimpl.UnusedTCPPort

qemu.go

Source:qemu.go

...378		inst.mon.Close()379	}380}381func (inst *instance) boot() error {382	inst.port = vmimpl.UnusedTCPPort()383	inst.monport = vmimpl.UnusedTCPPort()384	args := []string{385		"-m", strconv.Itoa(inst.cfg.Mem),386		"-smp", strconv.Itoa(inst.cfg.CPU),387		"-chardev", fmt.Sprintf("socket,id=SOCKSYZ,server=on,nowait,host=localhost,port=%v", inst.monport),388		"-mon", "chardev=SOCKSYZ,mode=control",389		"-display", "none",390		"-serial", "stdio",391		"-no-reboot",392		"-name", fmt.Sprintf("VM-%v", inst.index),393	}394	if inst.archConfig.RngDev != "" {395		args = append(args, "-device", inst.archConfig.RngDev)396	}397	templateDir := filepath.Join(inst.workdir, "template")398	args = append(args, splitArgs(inst.cfg.QemuArgs, templateDir, inst.index)...)399	args = append(args,400		"-device", inst.cfg.NetDev+",netdev=net0",401		"-netdev", fmt.Sprintf("user,id=net0,restrict=on,hostfwd=tcp:127.0.0.1:%v-:22", inst.port))402	if inst.image == "9p" {403		args = append(args,404			"-fsdev", "local,id=fsdev0,path=/,security_model=none,readonly",405			"-device", "virtio-9p-pci,fsdev=fsdev0,mount_tag=/dev/root",406		)407	} else if inst.image != "" {408		if inst.archConfig.UseNewQemuImageOptions {409			args = append(args,410				"-device", "virtio-blk-device,drive=hd0",411				"-drive", fmt.Sprintf("file=%v,if=none,format=raw,id=hd0", inst.image),412			)413		} else {414			// inst.cfg.ImageDevice can contain spaces415			imgline := strings.Split(inst.cfg.ImageDevice, " ")416			imgline[0] = "-" + imgline[0]417			if strings.HasSuffix(imgline[len(imgline)-1], "file=") {418				imgline[len(imgline)-1] = imgline[len(imgline)-1] + inst.image419			} else {420				imgline = append(imgline, inst.image)421			}422			args = append(args, imgline...)423		}424		if inst.cfg.Snapshot {425			args = append(args, "-snapshot")426		}427	}428	if inst.cfg.Initrd != "" {429		args = append(args,430			"-initrd", inst.cfg.Initrd,431		)432	}433	if inst.cfg.Kernel != "" {434		cmdline := append([]string{}, inst.archConfig.CmdLine...)435		if inst.image == "9p" {436			cmdline = append(cmdline,437				"root=/dev/root",438				"rootfstype=9p",439				"rootflags=trans=virtio,version=9p2000.L,cache=loose",440				"init="+filepath.Join(inst.workdir, "init.sh"),441			)442		}443		cmdline = append(cmdline, inst.cfg.Cmdline)444		args = append(args,445			"-kernel", inst.cfg.Kernel,446			"-append", strings.Join(cmdline, " "),447		)448	}449	if inst.cfg.EfiCodeDevice != "" {450		args = append(args,451			"-drive", "if=pflash,format=raw,readonly=on,file="+inst.cfg.EfiCodeDevice,452		)453	}454	if inst.cfg.EfiVarsDevice != "" {455		args = append(args,456			"-drive", "if=pflash,format=raw,readonly=on,file="+inst.cfg.EfiVarsDevice,457		)458	}459	if inst.cfg.AppleSmcOsk != "" {460		args = append(args,461			"-device", "isa-applesmc,osk="+inst.cfg.AppleSmcOsk,462		)463	}464	if inst.debug {465		log.Logf(0, "running command: %v %#v", inst.cfg.Qemu, args)466	}467	inst.args = args468	qemu := osutil.Command(inst.cfg.Qemu, args...)469	qemu.Stdout = inst.wpipe470	qemu.Stderr = inst.wpipe471	if err := qemu.Start(); err != nil {472		return fmt.Errorf("failed to start %v %+v: %v", inst.cfg.Qemu, args, err)473	}474	inst.wpipe.Close()475	inst.wpipe = nil476	inst.qemu = qemu477	// Qemu has started.478	// Start output merger.479	var tee io.Writer480	if inst.debug {481		tee = os.Stdout482	}483	inst.merger = vmimpl.NewOutputMerger(tee)484	inst.merger.Add("qemu", inst.rpipe)485	inst.rpipe = nil486	var bootOutput []byte487	bootOutputStop := make(chan bool)488	go func() {489		for {490			select {491			case out := <-inst.merger.Output:492				bootOutput = append(bootOutput, out...)493			case <-bootOutputStop:494				close(bootOutputStop)495				return496			}497		}498	}()499	if err := vmimpl.WaitForSSH(inst.debug, 10*time.Minute*inst.timeouts.Scale, "localhost",500		inst.sshkey, inst.sshuser, inst.os, inst.port, inst.merger.Err); err != nil {501		bootOutputStop <- true502		<-bootOutputStop503		return vmimpl.MakeBootError(err, bootOutput)504	}505	bootOutputStop <- true506	return nil507}508func splitArgs(str, templateDir string, index int) (args []string) {509	for _, arg := range strings.Split(str, " ") {510		if arg == "" {511			continue512		}513		arg = strings.ReplaceAll(arg, "{{INDEX}}", fmt.Sprint(index))514		arg = strings.ReplaceAll(arg, "{{TEMPLATE}}", templateDir)515		const tcpPort = "{{TCP_PORT}}"516		if strings.Contains(arg, tcpPort) {517			arg = strings.ReplaceAll(arg, tcpPort, fmt.Sprint(vmimpl.UnusedTCPPort()))518		}519		args = append(args, arg)520	}521	return522}523func (inst *instance) Forward(port int) (string, error) {524	if port == 0 {525		return "", fmt.Errorf("vm/qemu: forward port is zero")526	}527	if !inst.target.HostFuzzer {528		if inst.forwardPort != 0 {529			return "", fmt.Errorf("vm/qemu: forward port already set")530		}531		inst.forwardPort = port...

vmimpl.go

Source:vmimpl.go

...137}138func RandomPort() int {139	return rand.Intn(64<<10-1<<10) + 1<<10140}141func UnusedTCPPort() int {142	for {143		port := RandomPort()144		ln, err := net.Listen("tcp", fmt.Sprintf("localhost:%v", port))145		if err == nil {146			ln.Close()147			return port148		}149	}150}...

UnusedTCPPort

Using AI Code Generation

1import (2func main() {3 var (4  ctx = context.Background()5  insecure = flag.Bool("insecure", true, "ignore any vCenter SSL certificate validation errors")6 flag.Parse()7 u1, err := soap.ParseURL(*u)8 if err != nil {9  fmt.Println(err)10 }11 u1.User = url.UserPassword(u1.User.Username(), "password")12 c, err := govmomi.NewClient(ctx, u1, *insecure)13 if err != nil {14  fmt.Println(err)15 }16 defer c.Logout(ctx)17 m := vim25.NewManager(c.Client)18 err = m.Properties(ctx, *c.ServiceContent.RootFolder, []string{"name", "runtime.host"}, &vm)19 if err != nil {20  fmt.Println(err)21 }22 err = m.Properties(ctx, vm.Runtime.Host, []string{"name"}, &host)23 if err != nil {24  fmt.Println(err)25 }26 err = m.Properties(ctx, *c.ServiceContent.VmwareDistributedVirtualSwitchManager, []string{"name"}, &vmm)27 if err != nil {28  fmt.Println(err)29 }30 fmt.Println(vmm.Name)31 fmt.Println(host.Name)32 fmt.Println(vm.Name)

UnusedTCPPort

Using AI Code Generation

1import (2func main() {3    client, _ := vim25.NewClient(ctx, u, true)4    req := types.UnusedTCPPort{5    }6    res, _ := methods.UnusedTCPPort(ctx, client, &req)7    fmt.Println(res.Returnval)8}

UnusedTCPPort

Using AI Code Generation

1import (2func main() {3	vmimpl.UnusedTCPPort()4}5import (6func main() {7	vmimpl.UnusedUDPPort()8}9import (10func main() {11	vmimpl.GetHostIP()12}13import (14func main() {15	vmimpl.GetHostMAC()16}17import (18func main() {19	vmimpl.GetHostOS()20}21import (22func main() {23	vmimpl.GetHostOSArch()24}25import (26func main() {27	vmimpl.GetHostOSKernelVersion()28}29import (30func main() {31	vmimpl.GetHostOSVirtualization()32}33import (34func main() {35	vmimpl.GetHostOSVirtualizationRole()36}37import (38func main() {39	vmimpl.GetHostOSVirtualizationVendor()40}41import (42func main() {43	vmimpl.GetHostOSVirtualizationVersion()44}

UnusedTCPPort

Using AI Code Generation

1func main() {2    port = vmimpl.UnusedTCPPort()3    fmt.Println(port)4}5func main() {6    port = vmimpl.UnusedTCPPort()7    fmt.Println(port)8}

UnusedTCPPort

Using AI Code Generation

1import (2var (3	image = flag.String("image", "", "image under test")4func main() {5	flag.Parse()6	vm, err := utils.GetVM()7	if err != nil {8		log.Fatal(err)9	}10	port, err := vm.UnusedTCPPort()11	if err != nil {12		log.Fatalf("failed to get unused port: %v", err)13	}14	fmt.Printf("unused port: %v", port)15}16import (17var (18	image = flag.String("image", "", "image under test")19func TestMain(m *testing.M) {20	flag.Parse()21	if *image == "" {22		flag.PrintDefaults()23		log.Fatal("please provide -image")24	}25	flag.Parse()26	s := m.Run()27	if s != 0 {28		log.Printf("Tests failed with status %d", s)29	}30}31func TestUnusedTCPPort(t *testing.T) {32	cmd := exec.Command("/2.go")33	port, err := cmd.Output()34	if err != nil {35		t.Fatalf("failed to get unused port: %v", err)36	}37	fmt.Printf("unused port: %v", port)38}39--- FAIL: TestUnusedTCPPort (0.00s)40        c:\go\src\fmt (from $GOROOT)41        C:\Users\shubh\go\src\fmt (from $GOPATH)

UnusedTCPPort

Using AI Code Generation

1func main() {2    vm := vmimpl.NewVM()3    port, err := vm.UnusedTCPPort()4    if err != nil {5    }6    fmt.Println(port)7}8import (9func TestUnusedTCPPort(t *testing.T) {10    vm := vmimpl.NewVM()11    port, err := vm.UnusedTCPPort()12    if err != nil {13        t.Fatal(err)14    }15    if port == 0 {16        t.Fatal("Expected port to be non-zero")17    }18}19func TestMain(m *testing.M) {20    mock := new(mockNet)21    mock.On("Listen", "tcp", mock.Anything).Return(new(fakeListener), nil)22    vmimpl.SetNet(mock)23    os.Exit(m.Run())24}25type mockNet struct {26}27func (m *mockNet) Listen(network, address string) (net.Listener, error) {28    args := m.Called(network, address)29    return args.Get(0).(net.Listener), args.Error(1)30}31type fakeListener struct {32}33func (f *fakeListener) Accept() (net.Conn, error) {34}35func (f *fakeListener) Close() error {36}37func (f *fakeListener) Addr() net.Addr {38}

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.