How to use Close method of vm Package

Best Syzkaller code snippet using vm.Close

vm_server.go

Source:vm_server.go

...32// VMServer is a VM that is managed over RPC.33type VMServer struct {34	vm     block.ChainVM35	broker *plugin.GRPCBroker36	serverCloser grpcutils.ServerCloser37	conns        []*grpc.ClientConn38	ctx      *snow.Context39	toEngine chan common.Message40}41// NewServer returns a vm instance connected to a remote vm instance42func NewServer(vm block.ChainVM, broker *plugin.GRPCBroker) *VMServer {43	return &VMServer{44		vm:     vm,45		broker: broker,46	}47}48// Initialize ...49func (vm *VMServer) Initialize(_ context.Context, req *vmproto.InitializeRequest) (*vmproto.InitializeResponse, error) {50	subnetID, err := ids.ToID(req.SubnetID)51	if err != nil {52		return nil, err53	}54	chainID, err := ids.ToID(req.ChainID)55	if err != nil {56		return nil, err57	}58	nodeID, err := ids.ToShortID(req.NodeID)59	if err != nil {60		return nil, err61	}62	xChainID, err := ids.ToID(req.XChainID)63	if err != nil {64		return nil, err65	}66	avaxAssetID, err := ids.ToID(req.AvaxAssetID)67	if err != nil {68		return nil, err69	}70	dbConn, err := vm.broker.Dial(req.DbServer)71	if err != nil {72		return nil, err73	}74	msgConn, err := vm.broker.Dial(req.EngineServer)75	if err != nil {76		// Ignore DB closing error to return the original error77		_ = dbConn.Close()78		return nil, err79	}80	keystoreConn, err := vm.broker.Dial(req.KeystoreServer)81	if err != nil {82		// Ignore closing error to return the original error83		_ = dbConn.Close()84		_ = msgConn.Close()85		return nil, err86	}87	sharedMemoryConn, err := vm.broker.Dial(req.SharedMemoryServer)88	if err != nil {89		// Ignore closing error to return the original error90		_ = dbConn.Close()91		_ = msgConn.Close()92		_ = keystoreConn.Close()93		return nil, err94	}95	bcLookupConn, err := vm.broker.Dial(req.BcLookupServer)96	if err != nil {97		// Ignore closing error to return the original error98		_ = dbConn.Close()99		_ = msgConn.Close()100		_ = keystoreConn.Close()101		_ = sharedMemoryConn.Close()102		return nil, err103	}104	snLookupConn, err := vm.broker.Dial(req.SnLookupServer)105	if err != nil {106		// Ignore closing error to return the original error107		_ = dbConn.Close()108		_ = msgConn.Close()109		_ = keystoreConn.Close()110		_ = sharedMemoryConn.Close()111		_ = bcLookupConn.Close()112		return nil, err113	}114	dbClient := rpcdb.NewClient(rpcdbproto.NewDatabaseClient(dbConn))115	msgClient := messenger.NewClient(messengerproto.NewMessengerClient(msgConn))116	keystoreClient := gkeystore.NewClient(gkeystoreproto.NewKeystoreClient(keystoreConn), vm.broker)117	sharedMemoryClient := gsharedmemory.NewClient(gsharedmemoryproto.NewSharedMemoryClient(sharedMemoryConn))118	bcLookupClient := galiaslookup.NewClient(galiaslookupproto.NewAliasLookupClient(bcLookupConn))119	snLookupClient := gsubnetlookup.NewClient(gsubnetlookupproto.NewSubnetLookupClient(snLookupConn))120	toEngine := make(chan common.Message, 1)121	go func() {122		for msg := range toEngine {123			// Nothing to do with the error within the goroutine124			_ = msgClient.Notify(msg)125		}126	}()127	vm.ctx = &snow.Context{128		NetworkID:           req.NetworkID,129		SubnetID:            subnetID,130		ChainID:             chainID,131		NodeID:              nodeID,132		XChainID:            xChainID,133		AVAXAssetID:         avaxAssetID,134		Log:                 logging.NoLog{},135		DecisionDispatcher:  nil,136		ConsensusDispatcher: nil,137		Keystore:            keystoreClient,138		SharedMemory:        sharedMemoryClient,139		BCLookup:            bcLookupClient,140		SNLookup:            snLookupClient,141	}142	if err := vm.vm.Initialize(vm.ctx, dbClient, req.GenesisBytes, toEngine, nil); err != nil {143		// Ignore errors closing resources to return the original error144		_ = dbConn.Close()145		_ = msgConn.Close()146		_ = keystoreConn.Close()147		_ = sharedMemoryConn.Close()148		_ = bcLookupConn.Close()149		_ = snLookupConn.Close()150		close(toEngine)151		return nil, err152	}153	vm.conns = append(vm.conns, dbConn)154	vm.conns = append(vm.conns, msgConn)155	vm.toEngine = toEngine156	lastAccepted := vm.vm.LastAccepted()157	return &vmproto.InitializeResponse{158		LastAcceptedID: lastAccepted[:],159	}, nil160}161// Bootstrapping ...162func (vm *VMServer) Bootstrapping(context.Context, *vmproto.BootstrappingRequest) (*vmproto.BootstrappingResponse, error) {163	return &vmproto.BootstrappingResponse{}, vm.vm.Bootstrapping()164}165// Bootstrapped ...166func (vm *VMServer) Bootstrapped(context.Context, *vmproto.BootstrappedRequest) (*vmproto.BootstrappedResponse, error) {167	vm.ctx.Bootstrapped()168	return &vmproto.BootstrappedResponse{}, vm.vm.Bootstrapped()169}170// Shutdown ...171func (vm *VMServer) Shutdown(context.Context, *vmproto.ShutdownRequest) (*vmproto.ShutdownResponse, error) {172	if vm.toEngine == nil {173		return &vmproto.ShutdownResponse{}, nil174	}175	errs := wrappers.Errs{}176	errs.Add(vm.vm.Shutdown())177	close(vm.toEngine)178	vm.serverCloser.Stop()179	for _, conn := range vm.conns {180		errs.Add(conn.Close())181	}182	return &vmproto.ShutdownResponse{}, errs.Err183}184// CreateHandlers ...185func (vm *VMServer) CreateHandlers(_ context.Context, req *vmproto.CreateHandlersRequest) (*vmproto.CreateHandlersResponse, error) {186	handlers := vm.vm.CreateHandlers()187	resp := &vmproto.CreateHandlersResponse{}188	for prefix, h := range handlers {189		handler := h190		// start the messenger server191		serverID := vm.broker.NextId()192		go vm.broker.AcceptAndServe(serverID, func(opts []grpc.ServerOption) *grpc.Server {193			server := grpc.NewServer(opts...)194			vm.serverCloser.Add(server)195			ghttpproto.RegisterHTTPServer(server, ghttp.NewServer(handler.Handler, vm.broker))196			return server197		})198		resp.Handlers = append(resp.Handlers, &vmproto.Handler{199			Prefix:      prefix,200			LockOptions: uint32(handler.LockOptions),201			Server:      serverID,202		})203	}204	return resp, nil205}206// BuildBlock ...207func (vm *VMServer) BuildBlock(_ context.Context, _ *vmproto.BuildBlockRequest) (*vmproto.BuildBlockResponse, error) {208	blk, err := vm.vm.BuildBlock()...

GoLua.go

Source:GoLua.go

...50}51func (this *GoLua) GetName() string {52	return this.name53}54func (this *GoLua) Close() {55	if !atomic.CompareAndSwapUint32(&this.closed, 0, 1) {56		return57	}58	func() {59		for {60			select {61			case vm := <-this.vmpool:62				vm.Destroy()63			default:64				return65			}66		}67	}()68	close(this.vmpool)69	this.serviceMutex.Lock()70	tmp := this.services71	this.services = make(map[string]interface{})72	this.serviceMutex.Unlock()73	for k, o := range tmp {74		closed := false75		if tc, ok := o.(SupportTryClose); ok {76			closed = tc.TryClose()77		} else {78			closed = doClose(o)79		}80		if closed {81			if logger.EnableDebug(tag) {82				s := k83				idx := strings.Index(s, "!!")84				if idx != -1 {85					s = s[:idx] + "..."86				}87				logger.Debug(tag, "%s shutdown service '%s'", this, s)88			}89		}90	}91}92func (this *GoLua) String() string {93	return fmt.Sprintf("GoLua[%s]", this.name)94}95func (this *GoLua) newVM() (*VM, error) {96	err := this.CheckClose()97	if err != nil {98		return nil, err99	}100	atomic.AddUint32(&this.vmid, 1)101	vm := newVM(this, this.vmid)102	if this.cfg != nil {103		vm.Setup(this.cfg)104	}105	return vm, nil106}107func (this *GoLua) CreateVM() (*VM, error) {108	vm, err := this.newVM()109	if err != nil {110		return nil, err111	}112	vm.name = fmt.Sprintf("%s:%d", this.name, vm.id)113	st := newVMStack(nil)114	st.chunkName = fmt.Sprintf("VM<%s>", vm.name)115	vm.initStack(st)116	logger.Debug(tag, "createVM -> %s", vm)117	return vm, nil118}119func (this *GoLua) GetVM() (*VM, error) {120	err := this.CheckClose()121	if err != nil {122		return nil, err123	}124	vm, err1 := func() (*VM, error) {125		select {126		case vm := <-this.vmpool:127			if vm != nil {128				logger.Debug(tag, "%s leave pool", vm)129				vm.ResetExecutionTime()130				return vm, nil131			}132		default:133		}134		return this.CreateVM()135	}()136	if err1 != nil {137		return nil, err1138	}139	if this.DevMode {140		this.dgMutex.RLock()141		l := len(this.breakpoints)142		this.dgMutex.RUnlock()143		if l > 0 {144			vm.DebugSet(3)145		}146	}147	return vm, nil148}149func (this *GoLua) ReturnVM(vm *VM) {150	defer func() {151		x := recover()152		if x != nil {153			vm.Destroy()154		}155	}()156	if !this.IsClose() {157		select {158		case this.vmpool <- vm:159			logger.Debug(tag, "%s return pool", vm)160			return161		default:162		}163	}164	vm.Destroy()165}166func (this *GoLua) CheckClose() error {167	if atomic.LoadUint32(&this.closed) == 1 {168		return fmt.Errorf("%s closed", this)169	}170	return nil171}172func (this *GoLua) IsClose() bool {173	return atomic.LoadUint32(&this.closed) == 1174}...

Using AI Code Generation

1import (2func main() {3	vm := otto.New()4	vm.Set("hello", func(call otto.FunctionCall) otto.Value {5		fmt.Println("Hello, World!")6		return otto.Value{}7	})8	vm.Run(`9    hello();10	vm.Close()11	vm.Run(`12    hello();13}14import (15func main() {16	vm := otto.New()17	vm.Set("hello", func(call otto.FunctionCall) otto.Value {18		fmt.Println("Hello, World!")19		return otto.Value{}20	})21	vm.Run(`22    hello();23	vm.Close()24	vm.Run(`25    hello();26}27import (28func main() {29	vm := otto.New()30	vm.Set("hello", func(call otto.FunctionCall) otto.Value {31		fmt.Println("Hello, World!")32		return otto.Value{}33	})34	vm.Run(`35    hello();36	vm.Close()37	vm.Run(`38    hello();39}40import (41func main() {42	vm := otto.New()43	vm.Set("hello",

Using AI Code Generation

1import (2func main() {3    vmConfig := vm.Config{4        Tracer: vm.NewJSONLogger(&vm.LogConfig{}, nil),5    }6    vmEnv := vm.NewEVM(vm.Context{}, nil, params.TestChainConfig, vmConfig)7    vmEnv.Close()8    fmt.Println("vmEnv closed")9}10import (11func main() {12    vmConfig := vm.Config{13        Tracer: vm.NewJSONLogger(&vm.LogConfig{}, nil),14    }15    vmEnv := vm.NewEVM(vm.Context{}, nil, params.TestChainConfig, vmConfig)16    vmEnv.Stop()17    fmt.Println("vmEnv stopped")18}19import (20func main() {21    vmConfig := vm.Config{22        Tracer: vm.NewJSONLogger(&vm.LogConfig{}, nil),23    }24    vmEnv := vm.NewEVM(vm.Context{}, nil, params.TestChainConfig, vmConfig)25    vmEnv.Call(nil, common.HexToAddress("0x0"), nil, 100000, nil, nil)26    fmt.Println("vmEnv called")27}28import (29func main() {30    vmConfig := vm.Config{31        Tracer: vm.NewJSONLogger(&vm.LogConfig{}, nil),32    }33    vmEnv := vm.NewEVM(vm.Context{}, nil, params.TestChainConfig, vmConfig)

Using AI Code Generation

1import (2func main() {3	vm := otto.New()4	file, _ := os.Create("test.txt")5	vm.Set("file", file)6	vm.Run(`7		file.write("Hello World");8		file.close();9}10import (11func main() {12	vm := otto.New()13	file, _ := os.Create("test.txt")14	vm.Set("file", file)15	vm.Run(`16		file.write("Hello World");17		file.close();18}19import (20func main() {21	vm := otto.New()22	file, _ := os.Create("test.txt")23	vm.Set("file", file)24	vm.Run(`25		file.write("Hello World");26		file.close();27}28import (29func main() {30	vm := otto.New()31	file, _ := os.Create("test.txt")32	vm.Set("file", file)33	vm.Run(`34		file.write("Hello World");35		file.close();36}37import (38func main() {39	vm := otto.New()40	file, _ := os.Create("test.txt")41	vm.Set("file", file)42	vm.Run(`43		file.write("Hello World");44		file.close();45}46import (47func main() {48	vm := otto.New()49	file, _ := os.Create("test.txt")50	vm.Set("file", file)51	vm.Run(`52		file.write("Hello World");53		file.close();54}

Using AI Code Generation

1import (2func main() {3	vm := js.Global.Get("vm")4	script := vm.Call("createScript", "var a = 10; var b = 20; a + b", "test.vm")5	result := script.Call("runInThisContext")6	fmt.Println("Result:", result)7	script.Call("close")8	result = script.Call("runInThisContext")9	fmt.Println("Result:", result)10}11import (12func main() {13	vm := js.Global.Get("vm")14	script := vm.Call("createScript", "var a = 10; var b = 20; a + b", "test.vm")15	result := script.Call("runInNewContext")16	fmt.Println("Result:", result)17	script.Call("close")18	result = script.Call("runInNewContext")19	fmt.Println("Result:", result)20}21import (22func main() {23	vm := js.Global.Get("vm")24	context := vm.Call("createContext")25	script := vm.Call("createScript", "var a = 10; var b = 20; a + b", "test.vm")26	result := script.Call("runInContext", context)27	fmt.Println("Result:", result)28	script.Call("close")29	result = script.Call("runInContext", context)30	fmt.Println("Result:", result)31}32import (33func main() {34	vm := js.Global.Get("vm")35	script := vm.Call("createScript", "var a = 10; var b = 20; a + b", "test.vm")36	result := script.Call("runInThisContext")37	fmt.Println("Result:", result)38	script.Call("

Using AI Code Generation

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

Using AI Code Generation

1import (2func main() {3	vm := new(common.VM)4	vm.Close()5	fmt.Println("Close method of vm class")6}7import (8func main() {9	vmrun := new(common.VMRun)10	vmrun.Close()11	fmt.Println("Close method of vmrun class")12}13import (14func main() {15	vmx := new(common.VMX)16	vmx.Close()17	fmt.Println("Close method of vmx class")18}19import (20func main() {21	vmx_data := new(common.VMXData)22	vmx_data.Close()23	fmt.Println("Close method of vmx_data struct")24}25import (26func main() {27	vmx_path := new(common.VMXPath)28	vmx_path.Close()29	fmt.Println("Close method of vmx_path struct")30}31import (

Using AI Code Generation

1import (2func main() {3	vm := otto.New()4	file, err := os.Open("test.txt")5	if err != nil {6		panic(err)7	}8	err = file.Close()9	if err != nil {10		panic(err)11	}12	file, err = os.Open("test.txt")13	if err != nil {14		panic(err)15	}16	err = file.Close()17	if err != nil {18		panic(err)19	}20	file, err = os.Open("test.txt")21	if err != nil {22		panic(err)23	}24	err = file.Close()25	if err != nil {26		panic(err)27	}28	file, err = os.Open("test.txt")29	if err != nil {30		panic(err)31	}32	err = file.Close()33	if err != nil {34		panic(err)35	}36	file, err = os.Open("test.txt")37	if err != nil {38		panic(err)39	}40	err = file.Close()41	if err != nil {42		panic(err)43	}44	file, err = os.Open("test.txt")45	if err != nil {46		panic(err)47	}48	err = file.Close()49	if err != nil {50		panic(err)51	}52	file, err = os.Open("test.txt")53	if err != nil {54		panic(err)55	}56	err = file.Close()57	if err != nil {58		panic(err)59	}60	file, err = os.Open("test.txt")61	if err != nil {62		panic(err)63	}64	err = file.Close()65	if err != nil {66		panic(err)67	}68	file, err = os.Open("test.txt")

Using AI Code Generation

1import (2func main() {3	v := vm.New()4	v.Close()5	v.Close()6}7import (8func main() {9	v := vm.New()10	v.Close()11	v.Close()12}13import (14func main() {15	v := vm.New()16	v.Close()17	v.Close()18}19import (20func main() {21	v := vm.New()22	v.Close()23	v.Close()24}25import (26func main() {27	v := vm.New()28	v.Close()29	v.Close()30}31import (32func main() {33	v := vm.New()34	v.Close()35	v.Close()36}37import (38func main() {39	v := vm.New()

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.