How to use runStop method of proxyapp Package

Best Syzkaller code snippet using proxyapp.runStop

proxyappclient_test.go

Source:proxyappclient_test.go

1// Copyright 2022 syzkaller project authors. All rights reserved.2// Use of this source code is governed by Apache 2 LICENSE that can be found in the LICENSE file.3package proxyapp4import (5	"bytes"6	"fmt"7	"io"8	"net/rpc"9	"net/rpc/jsonrpc"10	"strings"11	"testing"12	"time"13	"github.com/google/syzkaller/pkg/report"14	"github.com/google/syzkaller/vm/proxyapp/mocks"15	"github.com/google/syzkaller/vm/proxyapp/proxyrpc"16	"github.com/google/syzkaller/vm/vmimpl"17	"github.com/stretchr/testify/assert"18	"github.com/stretchr/testify/mock"19)20var testEnv = &vmimpl.Env{21	Config: []byte(`22{23    "cmd": "/path/to/proxyapp_binary",24    "config": {25			"internal_values": 12326    }27  }28`)}29func makeTestParams() *proxyAppParams {30	return &proxyAppParams{31		CommandRunner:  osutilCommandContext,32		InitRetryDelay: 0,33	}34}35func makeMockProxyAppProcess(t *testing.T) (36	*mock.Mock, io.WriteCloser, io.ReadCloser, io.ReadCloser) {37	rStdin, wStdin := io.Pipe()38	rStdout, wStdout := io.Pipe()39	rStderr, wStderr := io.Pipe()40	wStderr.Close()41	server := rpc.NewServer()42	handler := mocks.NewProxyAppInterface(t)43	server.RegisterName("ProxyVM", struct{ proxyrpc.ProxyAppInterface }{handler})44	go server.ServeCodec(jsonrpc.NewServerCodec(stdInOutCloser{45		rStdin,46		wStdout,47	}))48	return &handler.Mock, wStdin, rStdout, rStderr49}50type nopWriteCloser struct {51	io.Writer52}53func (nopWriteCloser) Close() error {54	return nil55}56func TestCtor_Ok(t *testing.T) {57	_, mCmdRunner, params := proxyAppServerFixture(t)58	p, err := ctor(params, testEnv)59	assert.Nil(t, err)60	assert.Equal(t, 2, p.Count())61	<-mCmdRunner.onWaitCalled62}63func TestCtor_ReadBadConfig(t *testing.T) {64	pool, err := ctor(makeTestParams(), &vmimpl.Env{65		Config: []byte(`{"wrong_key": 1}`),66	})67	assert.NotNil(t, err)68	assert.Nil(t, pool)69}70func TestCtor_FailedPipes(t *testing.T) {71	mCmdRunner, params := makeMockCommandRunner(t)72	mCmdRunner.73		On("StdinPipe").74		Return(nil, fmt.Errorf("stdinpipe error")).75		Once().76		On("StdinPipe").77		Return(nopWriteCloser{&bytes.Buffer{}}, nil).78		On("StdoutPipe").79		Return(nil, fmt.Errorf("stdoutpipe error")).80		Once().81		On("StdoutPipe").82		Return(io.NopCloser(strings.NewReader("")), nil).83		On("StderrPipe").84		Return(nil, fmt.Errorf("stderrpipe error"))85	for i := 0; i < 3; i++ {86		p, err := ctor(params, testEnv)87		assert.NotNil(t, err)88		assert.Nil(t, p)89	}90}91func TestClose_waitDone(t *testing.T) {92	_, mCmdRunner, params := proxyAppServerFixture(t)93	mCmdRunner.94		On("waitDone").95		Return(nil)96	p, _ := ctor(params, testEnv)97	p.(io.Closer).Close()98}99func TestCtor_FailedStartProxyApp(t *testing.T) {100	mCmdRunner, params := makeMockCommandRunner(t)101	mCmdRunner.102		On("StdinPipe").103		Return(nopWriteCloser{&bytes.Buffer{}}, nil).104		On("StdoutPipe").105		Return(io.NopCloser(strings.NewReader("")), nil).106		On("StderrPipe").107		Return(io.NopCloser(strings.NewReader("")), nil).108		On("Start").109		Return(fmt.Errorf("failed to start program"))110	p, err := ctor(params, testEnv)111	assert.NotNil(t, err)112	assert.Nil(t, p)113}114// TODO: reuse proxyAppServerFixture() code: func could be called here once Mock.Unset() error115//  fixed https://github.com/stretchr/testify/issues/1236116//  nolint: dupl117func TestCtor_FailedConstructPool(t *testing.T) {118	mProxyAppServer, stdin, stdout, stderr :=119		makeMockProxyAppProcess(t)120	mProxyAppServer.121		On("CreatePool", mock.Anything, mock.Anything).122		Return(fmt.Errorf("failed to construct pool"))123	mCmdRunner, params := makeMockCommandRunner(t)124	mCmdRunner.125		On("StdinPipe").126		Return(stdin, nil).127		On("StdoutPipe").128		Return(stdout, nil).129		On("StderrPipe").130		Return(stderr, nil).131		On("Start").132		Return(nil).133		On("Wait").134		Run(func(args mock.Arguments) {135			<-mCmdRunner.ctx.Done()136		}).137		Return(nil)138	p, err := ctor(params, testEnv)139	assert.NotNil(t, err)140	assert.Nil(t, p)141}142// TODO: to remove duplicate see TestCtor_FailedConstructPool() comment143//  nolint: dupl144func proxyAppServerFixture(t *testing.T) (*mock.Mock, *mockCommandRunner, *proxyAppParams) {145	mProxyAppServer, stdin, stdout, stderr :=146		makeMockProxyAppProcess(t)147	mProxyAppServer.148		On("CreatePool", mock.Anything, mock.Anything).149		Run(func(args mock.Arguments) {150			out := args.Get(1).(*proxyrpc.CreatePoolResult)151			out.Count = 2152		}).153		Return(nil)154	mCmdRunner, params := makeMockCommandRunner(t)155	mCmdRunner.156		On("StdinPipe").157		Return(stdin, nil).158		On("StdoutPipe").159		Return(stdout, nil).160		On("StderrPipe").161		Return(stderr, nil).162		On("Start").163		Return(nil).164		On("Wait").165		Run(func(args mock.Arguments) {166			<-mCmdRunner.ctx.Done()167			mCmdRunner.MethodCalled("waitDone")168		}).169		Return(nil).170		Maybe()171	return mProxyAppServer, mCmdRunner, params172}173func poolFixture(t *testing.T) (*mock.Mock, *mockCommandRunner, vmimpl.Pool) {174	mProxyAppServer, mCmdRunner, params := proxyAppServerFixture(t)175	p, _ := ctor(params, testEnv)176	return mProxyAppServer, mCmdRunner, p177}178func TestPool_Create_Ok(t *testing.T) {179	mockServer, _, p := poolFixture(t)180	mockServer.181		On("CreateInstance", mock.Anything, mock.Anything).182		Return(nil)183	inst, err := p.Create("workdir", 0)184	assert.NotNil(t, inst)185	assert.Nil(t, err)186}187func TestPool_Create_ProxyNilError(t *testing.T) {188	_, mCmdRunner, p := poolFixture(t)189	mCmdRunner.190		On("waitDone").191		Return(nil)192	p.(io.Closer).Close()193	inst, err := p.Create("workdir", 0)194	assert.Nil(t, inst)195	assert.NotNil(t, err)196}197func TestPool_Create_OutOfPoolError(t *testing.T) {198	mockServer, _, p := poolFixture(t)199	mockServer.200		On("CreateInstance", mock.Anything, mock.Anything).201		Run(func(args mock.Arguments) {202			in := args.Get(0).(proxyrpc.CreateInstanceParams)203			assert.Equal(t, p.Count(), in.Index)204		}).205		Return(fmt.Errorf("out of pool size"))206	inst, err := p.Create("workdir", p.Count())207	assert.Nil(t, inst)208	assert.NotNil(t, err)209}210func TestPool_Create_ProxyFailure(t *testing.T) {211	mockServer, _, p := poolFixture(t)212	mockServer.213		On("CreateInstance", mock.Anything, mock.Anything).214		Return(fmt.Errorf("create instance failure"))215	inst, err := p.Create("workdir", 0)216	assert.Nil(t, inst)217	assert.NotNil(t, err)218}219// nolint: dupl220func createInstanceFixture(t *testing.T) (*mock.Mock, vmimpl.Instance) {221	mockServer, _, p := poolFixture(t)222	mockServer.223		On("CreateInstance", mock.Anything, mock.Anything).224		Run(func(args mock.Arguments) {225			in := args.Get(0).(proxyrpc.CreateInstanceParams)226			out := args.Get(1).(*proxyrpc.CreateInstanceResult)227			out.ID = fmt.Sprintf("instance_id_%v", in.Index)228		}).229		Return(nil)230	inst, err := p.Create("workdir", 0)231	assert.Nil(t, err)232	assert.NotNil(t, inst)233	return mockServer, inst234}235func TestInstance_Close(t *testing.T) {236	mockInstance, inst := createInstanceFixture(t)237	mockInstance.238		On("Close", mock.Anything, mock.Anything).239		Return(fmt.Errorf("mock error"))240	inst.Close()241}242func TestInstance_Diagnose_Ok(t *testing.T) {243	mockInstance, inst := createInstanceFixture(t)244	mockInstance.245		On("Diagnose", mock.Anything, mock.Anything).246		Run(func(args mock.Arguments) {247			out := args.Get(1).(*proxyrpc.DiagnoseReply)248			out.Diagnosis = "diagnostic result"249		}).250		Return(nil)251	diagnosis, wait := inst.Diagnose(nil)252	assert.NotNil(t, diagnosis)253	assert.Equal(t, wait, false)254	diagnosis, wait = inst.Diagnose(&report.Report{})255	assert.NotNil(t, diagnosis)256	assert.Equal(t, wait, false)257}258func TestInstance_Diagnose_Failure(t *testing.T) {259	mockInstance, inst := createInstanceFixture(t)260	mockInstance.261		On("Diagnose", mock.Anything, mock.Anything).262		Return(fmt.Errorf("diagnose failed"))263	diagnosis, wait := inst.Diagnose(&report.Report{})264	assert.Nil(t, diagnosis)265	assert.Equal(t, wait, false)266}267func TestInstance_Copy_OK(t *testing.T) {268	mockInstance, inst := createInstanceFixture(t)269	mockInstance.270		On("Copy", mock.Anything, mock.Anything).271		Run(func(args mock.Arguments) {272			out := args.Get(1).(*proxyrpc.CopyResult)273			out.VMFileName = "remote_file_path"274		}).275		Return(nil)276	remotePath, err := inst.Copy("host/path")277	assert.Nil(t, err)278	assert.NotEmpty(t, remotePath)279}280// nolint: dupl281func TestInstance_Copy_Failure(t *testing.T) {282	mockInstance, inst := createInstanceFixture(t)283	mockInstance.284		On("Copy", mock.Anything, mock.Anything).285		Return(fmt.Errorf("copy failure"))286	remotePath, err := inst.Copy("host/path")287	assert.NotNil(t, err)288	assert.Empty(t, remotePath)289}290// nolint: dupl291func TestInstance_Forward_OK(t *testing.T) {292	mockInstance, inst := createInstanceFixture(t)293	mockInstance.294		On("Forward", mock.Anything, mock.Anything).295		Run(func(args mock.Arguments) {296			in := args.Get(0).(proxyrpc.ForwardParams)297			out := args.Get(1).(*proxyrpc.ForwardResult)298			out.ManagerAddress = fmt.Sprintf("manager_address:%v", in.Port)299		}).300		Return(nil)301	remoteAddressToUse, err := inst.Forward(12345)302	assert.Nil(t, err)303	assert.Equal(t, "manager_address:12345", remoteAddressToUse)304}305// nolint: dupl306func TestInstance_Forward_Failure(t *testing.T) {307	mockInstance, inst := createInstanceFixture(t)308	mockInstance.309		On("Forward", mock.Anything, mock.Anything).310		Return(fmt.Errorf("forward failure"))311	remoteAddressToUse, err := inst.Forward(12345)312	assert.NotNil(t, err)313	assert.Empty(t, remoteAddressToUse)314}315func TestInstance_Run_SimpleOk(t *testing.T) {316	mockInstance, inst := createInstanceFixture(t)317	mockInstance.318		On("RunStart", mock.Anything, mock.Anything).319		Return(nil).320		On("RunReadProgress", mock.Anything, mock.Anything).321		Return(nil).322		Maybe()323	outc, errc, err := inst.Run(10*time.Second, make(chan bool), "command")324	assert.NotNil(t, outc)325	assert.NotNil(t, errc)326	assert.Nil(t, err)327}328func TestInstance_Run_Failure(t *testing.T) {329	mockInstance, inst := createInstanceFixture(t)330	mockInstance.331		On("RunStart", mock.Anything, mock.Anything).332		Return(fmt.Errorf("run start error"))333	outc, errc, err := inst.Run(10*time.Second, make(chan bool), "command")334	assert.Nil(t, outc)335	assert.Nil(t, errc)336	assert.NotEmpty(t, err)337}338func TestInstance_Run_OnTimeout(t *testing.T) {339	mockInstance, inst := createInstanceFixture(t)340	mockInstance.341		On("RunStart", mock.Anything, mock.Anything).342		Return(nil).343		On("RunReadProgress", mock.Anything, mock.Anything).344		Return(nil).Maybe().345		On("RunStop", mock.Anything, mock.Anything).346		Return(nil)347	_, errc, _ := inst.Run(time.Second, make(chan bool), "command")348	err := <-errc349	assert.Equal(t, err, vmimpl.ErrTimeout)350}351func TestInstance_Run_OnStop(t *testing.T) {352	mockInstance, inst := createInstanceFixture(t)353	mockInstance.354		On("RunStart", mock.Anything, mock.Anything).355		Return(nil).356		On("RunReadProgress", mock.Anything, mock.Anything).357		Return(nil).358		Maybe().359		On("RunStop", mock.Anything, mock.Anything).360		Return(nil)361	stop := make(chan bool)362	_, errc, _ := inst.Run(10*time.Second, stop, "command")363	stop <- true364	err := <-errc365	assert.Equal(t, err, vmimpl.ErrTimeout)366}367func TestInstance_RunReadProgress_OnErrorReceived(t *testing.T) {368	mockInstance, inst := createInstanceFixture(t)369	mockInstance.370		On("RunStart", mock.Anything, mock.Anything).371		Return(nil).372		On("RunReadProgress", mock.Anything, mock.Anything).373		Return(nil).374		Times(100).375		On("RunReadProgress", mock.Anything, mock.Anything).376		Run(func(args mock.Arguments) {377			out := args.Get(1).(*proxyrpc.RunReadProgressReply)378			out.Error = "mock error"379		}).380		Return(nil).381		Once()382	outc, _, _ := inst.Run(10*time.Second, make(chan bool), "command")383	output := string(<-outc)384	assert.Equal(t, "mock error\nSYZFAIL: proxy app plugin error\n", output)385}386// nolint: dupl387func TestInstance_RunReadProgress_OnFinished(t *testing.T) {388	mockInstance, inst := createInstanceFixture(t)389	mockInstance.390		On("RunStart", mock.Anything, mock.Anything).391		Return(nil).392		On("RunReadProgress", mock.Anything, mock.Anything).393		Return(nil).Times(100).394		On("RunReadProgress", mock.Anything, mock.Anything).395		Run(func(args mock.Arguments) {396			out := args.Get(1).(*proxyrpc.RunReadProgressReply)397			out.Finished = true398		}).399		Return(nil).400		Once()401	_, errc, _ := inst.Run(10*time.Second, make(chan bool), "command")402	err := <-errc403	assert.Equal(t, err, nil)404}405func TestInstance_RunReadProgress_Failed(t *testing.T) {406	mockInstance, inst := createInstanceFixture(t)407	mockInstance.408		On("RunStart", mock.Anything, mock.Anything).409		Run(func(args mock.Arguments) {410			out := args.Get(1).(*proxyrpc.RunStartReply)411			out.RunID = "test_run_id"412		}).413		Return(nil).414		On("RunReadProgress", mock.Anything, mock.Anything).415		Return(fmt.Errorf("runreadprogresserror")).416		Once()417	outc, _, _ := inst.Run(10*time.Second, make(chan bool), "command")418	output := string(<-outc)419	assert.Equal(t,420		"error reading progress from instance_id_0:test_run_id: runreadprogresserror\nSYZFAIL: proxy app plugin error\n",421		output,422	)423}424// TODO: test for periodical proxyapp subprocess crashes handling.425//  [option] check pool size was changed426// TODO: test pool.Close() calls plugin API and return error....

proxyappclient.go

Source:proxyappclient.go

...284					continue285				}286			case <-timeoutSignal:287				// It is the happy path.288				inst.runStop(runID)289				terminationError <- vmimpl.ErrTimeout290			case <-stop:291				inst.runStop(runID)292				terminationError <- vmimpl.ErrTimeout293			}294			break295		}296	}()297	return outc, terminationError, nil298}299func (inst *instance) runStop(runID string) {300	err := inst.ProxyApp.Call(301		"ProxyVM.RunStop",302		proxyrpc.RunStopParams{303			ID:    inst.ID,304			RunID: runID,305		},306		&proxyrpc.RunStopParams{})307	if err != nil {308		log.Logf(0, "error calling runStop(%v) on %v: %v", runID, inst.ID, err)309	}310}311func (inst *instance) Diagnose(r *report.Report) (diagnosis []byte, wait bool) {312	var title string313	if r != nil {314		title = r.Title315	}316	var reply proxyrpc.DiagnoseReply317	err := inst.ProxyApp.Call(318		"ProxyVM.Diagnose",319		proxyrpc.DiagnoseParams{320			ID:          inst.ID,321			ReasonTitle: title,322		},...

runStop

Using AI Code Generation

1import "fmt"2func main() {3    proxyapp := ProxyApp{}4    proxyapp.runStop()5}6import "fmt"7func main() {8    proxyapp := ProxyApp{}9    proxyapp.runStop()10}11import "fmt"12func main() {13    proxyapp := ProxyApp{}14    proxyapp.runStop()15}16import "fmt"17func main() {18    proxyapp := ProxyApp{}19    proxyapp.runStop()20}21import "fmt"22func main() {23    proxyapp := ProxyApp{}24    proxyapp.runStop()25}26import "fmt"27func main() {28    proxyapp := ProxyApp{}29    proxyapp.runStop()30}31import "fmt"32func main() {33    proxyapp := ProxyApp{}34    proxyapp.runStop()35}36import "fmt"37func main() {38    proxyapp := ProxyApp{}39    proxyapp.runStop()40}41import "fmt"42func main() {43    proxyapp := ProxyApp{}44    proxyapp.runStop()45}46import "fmt"47func main() {48    proxyapp := ProxyApp{}49    proxyapp.runStop()50}51import "fmt"52func main() {53    proxyapp := ProxyApp{}54    proxyapp.runStop()55}56import "fmt"57func main() {

runStop

Using AI Code Generation

1import (2type proxyapp struct {3}4func (p *proxyapp) runStart() {5	fmt.Println("proxyapp runStart called")6}7func (p *proxyapp) runStop() {8	fmt.Println("proxyapp runStop called")9}10type proxyapp2 struct {11}12func (p *proxyapp2) runStart() {13	fmt.Println("proxyapp2 runStart called")14}15func (p *proxyapp2) runStop() {16	fmt.Println("proxyapp2 runStop called")17}18func main() {19	p := &proxyapp2{}20	fmt.Println("proxyapp2")21	fmt.Println("runStart")22	p.runStart()23	fmt.Println("runStop")24	p.runStop()25	fmt.Println("proxyapp")26	fmt.Println("runStart")27	p.proxyapp.runStart()28	fmt.Println("runStop")29	p.proxyapp.runStop()30	fmt.Println("proxyapp2")31	fmt.Println("runStart")32	p.runStart()33	fmt.Println("runStop")34	p.runStop()35	fmt.Println("proxyapp")36	fmt.Println("runStart")37	p.proxyapp.runStart()38	fmt.Println("runStop")39	p.proxyapp.runStop()40	fmt.Println("proxyapp2")41	fmt.Println("runStart")42	p.runStart()43	fmt.Println("runStop")44	p.runStop()45	fmt.Println("proxyapp")46	fmt.Println("runStart")47	p.proxyapp.runStart()48	fmt.Println("runStop")49	p.proxyapp.runStop()50	pv := reflect.ValueOf(p)51	fmt.Println("proxyapp2")52	fmt.Println("runStart")53	pv.MethodByName("runStart").Call(nil)54	fmt.Println("runStop")55	pv.MethodByName("runStop").Call(nil)56	fmt.Println("proxyapp")57	fmt.Println("runStart")58	pv.FieldByName("proxyapp").MethodByName("runStart").Call(nil)59	fmt.Println("runStop")60	pv.FieldByName("proxyapp").MethodByName("runStop").Call(nil)61}

runStop

Using AI Code Generation

1import (2type ProxyApp struct {3}4func (p *ProxyApp) RunStop() error {5	client, err := rpc.DialHTTP("tcp", "localhost:1234")6	if err != nil {7		log.Fatal("dialing:", err)8	}9	err = client.Call("ProxyApp.RunStop", "", &reply)10	if err != nil {11		log.Fatal("arith error:", err)12	}13	fmt.Printf("RunStop: %s14}15func main() {16	p := &ProxyApp{}17	p.RunStop()18}19import (20type ProxyApp struct {21}22func (p *ProxyApp) RunStop() error {23	client, err := rpc.DialHTTP("tcp", "localhost:1234")24	if err != nil {25		log.Fatal("dialing:", err)26	}27	err = client.Call("ProxyApp.RunStop", "", &reply)28	if err != nil {29		log.Fatal("arith error:", err)30	}31	fmt.Printf("RunStop: %s32}33func main() {34	p := &ProxyApp{}35	p.RunStop()36}37import (38type ProxyApp struct {39}40func (p *ProxyApp) RunStop() error {41	client, err := rpc.DialHTTP("tcp", "localhost:1234")42	if err != nil {43		log.Fatal("dialing:", err)44	}45	err = client.Call("ProxyApp.RunStop", "", &reply)46	if err != nil {47		log.Fatal("arith error:", err)48	}49	fmt.Printf("RunStop: %s50}51func main() {52	p := &ProxyApp{}53	p.RunStop()54}

runStop

Using AI Code Generation

1import (2type ProxyApp struct {3}4func (p *ProxyApp) RunStart() {5   err := p.Client.Call("Proxy.RunStart", 0, &reply)6   if err != nil {7      log.Fatal("Proxy.RunStart error:", err)8   }9   fmt.Println(reply)10}11func (p *ProxyApp) RunStop() {12   err := p.Client.Call("Proxy.RunStop", 0, &reply)13   if err != nil {14      log.Fatal("Proxy.RunStop error:", err)15   }16   fmt.Println(reply)17}18func main() {19   client, err := rpc.DialHTTP("tcp", "

runStop

Using AI Code Generation

1import (2func main() {3    p.runStop()4    fmt.Println("main method")5    time.Sleep(10 * time.Second)6}7import (8type proxyApp struct {9}10func (p *proxyApp) runStop() {11    fmt.Println("runStop method")12    time.Sleep(5 * time.Second)13}

runStop

Using AI Code Generation

1import (2func main() {3 proxyapp := new(ProxyApp)4 proxyapp.runStop()5 fmt.Println("Exiting from main")6}

runStop

Using AI Code Generation

1import (2type proxyApp struct {3	runStop func()4}5func main() {6	p := new(proxyApp)7	p.start()8	fmt.Scanln()9	p.stop()10}11func (p *proxyApp) start() {12	go func() {13		p.run()14	}()15}16func (p *proxyApp) run() {17	stop := make(chan struct{})18	done := make(chan struct{})19	go func() {20		p.runStop = p.runApp(stop)21		done <- struct{}{}22	}()23}24func (p *proxyApp) stop() {25	p.runStop()26}27func (p *proxyApp) runApp(stop chan struct{}) func() {28	done := make(chan struct{})29	go func() {30		p.runApp(stop)31		done <- struct{}{}32	}()33	return func() {34		stop <- struct{}{}35	}36}37func (p *proxyApp) runApp(stop chan struct{}) func() {38	done := make(chan struct{})39	go func() {40		p.runApp(stop)

runStop

Using AI Code Generation

1import "fmt"2import "os"3import "os/exec"4import "time"5import "strconv"6func main() {7	pid, _ := strconv.Atoi(os.Args[1])8	proc, _ := os.FindProcess(pid)9	time.Sleep(5000 * time.Millisecond)10	proc.Kill()11}12import "fmt"13import "os"14import "os/exec"15import "time"16import "strconv"17func main() {18	pid, _ := strconv.Atoi(os.Args[1])19	proc, _ := os.FindProcess(pid)20	time.Sleep(5000 * time.Millisecond)21	proc.Kill()22}23import "fmt"24import "os"25import "os/exec"26import "time"27import "strconv"28func main() {29	pid, _ := strconv.Atoi(os.Args[1])30	proc, _ := os.FindProcess(pid)31	time.Sleep(5000 * time.Millisecond)32	proc.Kill()33}

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.