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

Copied to Clipboard!

How to use State method of wait Package

Best Testcontainers-go code snippet using wait.State

miner_test.go

Source:miner_test.go

...46func (m *mockBackend) TxPool() *core.TxPool {47	return m.txPool48}49type testBlockChain struct {50	statedb       *state.StateDB51	gasLimit      uint6452	chainHeadFeed *event.Feed53}54func (bc *testBlockChain) CurrentBlock() *types.Block {55	return types.NewBlock(&types.Header{56		GasLimit: bc.gasLimit,57	}, nil, nil, nil, trie.NewStackTrie(nil))58}59func (bc *testBlockChain) GetBlock(hash common.Hash, number uint64) *types.Block {60	return bc.CurrentBlock()61}62func (bc *testBlockChain) StateAt(common.Hash) (*state.StateDB, error) {63	return bc.statedb, nil64}65func (bc *testBlockChain) SubscribeChainHeadEvent(ch chan<- core.ChainHeadEvent) event.Subscription {66	return bc.chainHeadFeed.Subscribe(ch)67}68func TestMiner(t *testing.T) {69	miner, mux := createMiner(t)70	miner.Start(common.HexToAddress("0x12345"))71	waitForMiningState(t, miner, true)72	// Start the downloader73	mux.Post(downloader.StartEvent{})74	waitForMiningState(t, miner, false)75	// Stop the downloader and wait for the update loop to run76	mux.Post(downloader.DoneEvent{})77	waitForMiningState(t, miner, true)78	// Subsequent downloader events after a successful DoneEvent should not cause the79	// miner to start or stop. This prevents a security vulnerability80	// that would allow entities to present fake high blocks that would81	// stop mining operations by causing a downloader sync82	// until it was discovered they were invalid, whereon mining would resume.83	mux.Post(downloader.StartEvent{})84	waitForMiningState(t, miner, true)85	mux.Post(downloader.FailedEvent{})86	waitForMiningState(t, miner, true)87}88// TestMinerDownloaderFirstFails tests that mining is only89// permitted to run indefinitely once the downloader sees a DoneEvent (success).90// An initial FailedEvent should allow mining to stop on a subsequent91// downloader StartEvent.92func TestMinerDownloaderFirstFails(t *testing.T) {93	miner, mux := createMiner(t)94	miner.Start(common.HexToAddress("0x12345"))95	waitForMiningState(t, miner, true)96	// Start the downloader97	mux.Post(downloader.StartEvent{})98	waitForMiningState(t, miner, false)99	// Stop the downloader and wait for the update loop to run100	mux.Post(downloader.FailedEvent{})101	waitForMiningState(t, miner, true)102	// Since the downloader hasn't yet emitted a successful DoneEvent,103	// we expect the miner to stop on next StartEvent.104	mux.Post(downloader.StartEvent{})105	waitForMiningState(t, miner, false)106	// Downloader finally succeeds.107	mux.Post(downloader.DoneEvent{})108	waitForMiningState(t, miner, true)109	// Downloader starts again.110	// Since it has achieved a DoneEvent once, we expect miner111	// state to be unchanged.112	mux.Post(downloader.StartEvent{})113	waitForMiningState(t, miner, true)114	mux.Post(downloader.FailedEvent{})115	waitForMiningState(t, miner, true)116}117func TestMinerStartStopAfterDownloaderEvents(t *testing.T) {118	miner, mux := createMiner(t)119	miner.Start(common.HexToAddress("0x12345"))120	waitForMiningState(t, miner, true)121	// Start the downloader122	mux.Post(downloader.StartEvent{})123	waitForMiningState(t, miner, false)124	// Downloader finally succeeds.125	mux.Post(downloader.DoneEvent{})126	waitForMiningState(t, miner, true)127	miner.Stop()128	waitForMiningState(t, miner, false)129	miner.Start(common.HexToAddress("0x678910"))130	waitForMiningState(t, miner, true)131	miner.Stop()132	waitForMiningState(t, miner, false)133}134func TestStartWhileDownload(t *testing.T) {135	miner, mux := createMiner(t)136	waitForMiningState(t, miner, false)137	miner.Start(common.HexToAddress("0x12345"))138	waitForMiningState(t, miner, true)139	// Stop the downloader and wait for the update loop to run140	mux.Post(downloader.StartEvent{})141	waitForMiningState(t, miner, false)142	// Starting the miner after the downloader should not work143	miner.Start(common.HexToAddress("0x12345"))144	waitForMiningState(t, miner, false)145}146func TestStartStopMiner(t *testing.T) {147	miner, _ := createMiner(t)148	waitForMiningState(t, miner, false)149	miner.Start(common.HexToAddress("0x12345"))150	waitForMiningState(t, miner, true)151	miner.Stop()152	waitForMiningState(t, miner, false)153}154func TestCloseMiner(t *testing.T) {155	miner, _ := createMiner(t)156	waitForMiningState(t, miner, false)157	miner.Start(common.HexToAddress("0x12345"))158	waitForMiningState(t, miner, true)159	// Terminate the miner and wait for the update loop to run160	miner.Close()161	waitForMiningState(t, miner, false)162}163// TestMinerSetEtherbase checks that etherbase becomes set even if mining isn't164// possible at the moment165func TestMinerSetEtherbase(t *testing.T) {166	miner, mux := createMiner(t)167	// Start with a 'bad' mining address168	miner.Start(common.HexToAddress("0xdead"))169	waitForMiningState(t, miner, true)170	// Start the downloader171	mux.Post(downloader.StartEvent{})172	waitForMiningState(t, miner, false)173	// Now user tries to configure proper mining address174	miner.Start(common.HexToAddress("0x1337"))175	// Stop the downloader and wait for the update loop to run176	mux.Post(downloader.DoneEvent{})177	waitForMiningState(t, miner, true)178	// The miner should now be using the good address179	if got, exp := miner.coinbase, common.HexToAddress("0x1337"); got != exp {180		t.Fatalf("Wrong coinbase, got %x expected %x", got, exp)181	}182}183// waitForMiningState waits until either184// * the desired mining state was reached185// * a timeout was reached which fails the test186func waitForMiningState(t *testing.T, m *Miner, mining bool) {187	t.Helper()188	var state bool189	for i := 0; i < 100; i++ {190		time.Sleep(10 * time.Millisecond)191		if state = m.Mining(); state == mining {192			return193		}194	}195	t.Fatalf("Mining() == %t, want %t", state, mining)196}197func createMiner(t *testing.T) (*Miner, *event.TypeMux) {198	// Create Ethash config199	config := Config{200		Etherbase: common.HexToAddress("123456789"),...

state.go

Source:state.go

...18)19// type _dtype int20//21// var _d _dtype22// State stores all the common state data used in pod23type State struct {24	sync.Mutex25	WaitGroup sync.WaitGroup26	KillAll   qu.C27	// Config is the pod all-in-one server config28	Config *config.Config29	// ConfigMap30	ConfigMap map[string]opt.Option31	// StateCfg is a reference to the main node state configuration struct32	StateCfg *active.Config33	// ActiveNet is the active net parameters34	ActiveNet *chaincfg.Params35	// Language libraries36	Language *lang.Lexicon37	// Node is the run state of the node38	Node atomic.Bool39	// NodeReady is closed when it is ready then always returns40	NodeReady qu.C41	// NodeKill is the killswitch for the Node42	NodeKill qu.C43	// Wallet is the run state of the wallet44	Wallet atomic.Bool45	// WalletKill is the killswitch for the Wallet46	WalletKill qu.C47	// RPCServer is needed to directly query data48	RPCServer *chainrpc.Server49	// NodeChan relays the chain RPC server to the main50	NodeChan chan *chainrpc.Server51	// // WalletServer is needed to query the wallet52	// WalletServer *wallet.Wallet53	// ChainClientReady signals when the chain client is ready54	ChainClientReady qu.C55	// ChainClient is the wallet's chain RPC client56	ChainClient *chainclient.RPCClient57	// RealNode is the main node58	RealNode *chainrpc.Node59	// Hashrate is the current total hashrate from kopach workers taking work from this node60	Hashrate atomic.Uint6461	// Controller is the state of the controller62	Controller *ctrl.State63	// OtherNodesCounter is the count of nodes connected automatically on the LAN64	OtherNodesCounter atomic.Int3265	waitChangers []string66	waitCounter  int67	Syncing           *atomic.Bool68	IsGUI             bool69}70func (cx *State) WaitAdd() {71	cx.WaitGroup.Add(1)72	_, file, line, _ := runtime.Caller(1)73	record := fmt.Sprintf("+ %s:%d", file, line)74	cx.waitChangers = append(cx.waitChangers, record)75	cx.waitCounter++76	D.Ln("added to waitgroup", record, cx.waitCounter)77	D.Ln(cx.PrintWaitChangers())78}79func (cx *State) WaitDone() {80	_, file, line, _ := runtime.Caller(1)81	record := fmt.Sprintf("- %s:%d", file, line)82	cx.waitChangers = append(cx.waitChangers, record)83	cx.waitCounter--84	D.Ln("removed from waitgroup", record, cx.waitCounter)85	D.Ln(cx.PrintWaitChangers())86	qu.PrintChanState()87	cx.WaitGroup.Done()88}89func (cx *State) WaitWait() {90	D.Ln(cx.PrintWaitChangers())91	cx.WaitGroup.Wait()92}93func (cx *State) PrintWaitChangers() string {94	o := "Calls that change context waitgroup values:\n"95	for i := range cx.waitChangers {96		o += strings.Repeat(" ", 48)97		o += cx.waitChangers[i] + "\n"98	}99	o += strings.Repeat(" ", 48)100	o += "current total:"101	o += fmt.Sprint(cx.waitCounter)102	return o103}104func GetContext(cx *State) *chainrpc.Context {105	return &chainrpc.Context{106		Config: cx.Config, StateCfg: cx.StateCfg, ActiveNet: cx.ActiveNet,107		Hashrate: cx.Hashrate,108	}109}110// func (cx *State) IsCurrent() (is bool) {111// 	rn := cx.RealNode112// 	cc := rn.ConnectedCount()113// 	othernodes := cx.OtherNodesCounter.Load()114// 	if !cx.Config.LAN.True() {115// 		cc -= othernodes116// 	}117// 	D.Ln(cc, "nodes connected")118// 	connected := cc > 0119// 	is = rn.Chain.IsCurrent() &&120// 		rn.SyncManager.IsCurrent() &&121// 		connected &&122// 		rn.Chain.BestChain.Height() >= rn.HighestKnown.Load() || cx.Config.Solo.True()123// 	D.Ln(124// 		"is current:", is, "-", rn.Chain.IsCurrent(), rn.SyncManager.IsCurrent(),...

main.go

Source:main.go

1package main2import (3	"fmt"4	"sync"5	"sync/atomic"6	"unsafe"7)8type noCopy struct{}9// Lock is a no-op used by -copylocks checker from `go vet`.10func (*noCopy) Lock()   {}11func (*noCopy) Unlock() {}12type User struct {13	//noCopy noCopy14	Name string15	Info *Info16}17type Info struct {18	Age int19	Number int20}21func main() {22	wg := sync.WaitGroup{}23	wg.Add(100)24	for i := 0; i < 100; i++ {25		go func() {26			defer wg.Done()27			fmt.Println(i)28		}()29	}30	wg.Wait()31}32func f(i int, wg sync.WaitGroup) {33	fmt.Println(i)34	wg.Done()35}36//func main()  {37//	wg := sync.WaitGroup{}38//	wg.Add(1)39//	doDeadLock(wg)40//	wg.Wait()41//	//u := User{42//	//	Name: "asong",43//	//	Info: &Info{44//	//		Age: 10,45//	//		Number: 24,46//	//	},47//	//}48//	//u1 := u49//	//u1.Name = "Golangæ¢¦å·¥å"50//	//u1.Info.Age = 3051//	//fmt.Println(u.Info.Age,u.Name)52//	//fmt.Println(u1.Info.Age,u1.Name)53//}54func exampleToNoCopy()  {55}56type httpPkg struct{}57func (httpPkg) Get(url string) {}58var http httpPkg59func exampleDemo()  {60	var wg sync.WaitGroup61	var urls = []string{62		"http://www.golang.org/",63		"http://www.google.com/",64		"http://www.somestupidname.com/",65	}66	for _, url := range urls {67		// Increment the WaitGroup counter.68		wg.Add(1)69		// Launch a goroutine to fetch the URL.70		go func(url string) {71			// Decrement the counter when the goroutine completes.72			defer wg.Done()73			// Fetch the URL.74			http.Get(url)75		}(url)76	}77	// Wait for all HTTP fetches to complete.78	wg.Wait()79}80func exampleImplWaitGroup()  {81	done := make(chan struct{}) // æ¶10ä»½ä¿æ¤è´¹82	count := 10 // 10ä¸ªé©¬ä»83	for i:=0;i < count;i++{84		go func(i int) {85			defer func() {86				done <- struct {}{}87			}()88			fmt.Printf("é©¬ä»%då·æ¶ä¿æ¤è´¹\n",i)89		}(i)90	}91	for i:=0;i< count;i++{92		<- done93		fmt.Printf("é©¬ä»%då·å·²ç»æ¶å®ä¿æ¤è´¹\n",i)94	}95	fmt.Println("ææé©¬ä»å·²ç»å¹²å®æ´»äºï¼å¼å§éå§æ¶è´¹ï½")96}97func doDeadLock(wg sync.WaitGroup)  {98	defer wg.Done()99	fmt.Println("do something")100}101type MyWaitGroup struct {102	state1 [3]uint32103}104// state returns pointers to the state and sema fields stored within wg.state1.105func (wg *MyWaitGroup) state() (statep *uint64, semap *uint32) {106	if uintptr(unsafe.Pointer(&wg.state1))%8 == 0 {107		return (*uint64)(unsafe.Pointer(&wg.state1)), &wg.state1[2]108	} else {109		return (*uint64)(unsafe.Pointer(&wg.state1[1])), &wg.state1[0]110	}111}112func (wg *MyWaitGroup) Add(delta int) {113	statep, _ := wg.state()114	state := atomic.AddUint64(statep, uint64(delta)<<32)115	v := int32(state >> 32)116	w := uint32(state)117	fmt.Println(v,w)118}119// Done decrements the WaitGroup counter by one.120func (wg *MyWaitGroup) Done() {121	wg.Add(-1)122}123// Wait blocks until the WaitGroup counter is zero.124func (wg *MyWaitGroup) Wait() {125	statep, _ := wg.state()126	for {127		state := atomic.LoadUint64(statep)128		v := int32(state >> 32)129		w := uint32(state)130		fmt.Println(v,w)131		if v == 0 {132			return133		}134		// Increment waiters count.135		if atomic.CompareAndSwapUint64(statep, state, state+1) {136			v = int32(state >> 32)137			w = uint32(state)138			fmt.Println(state,v,w)139			if *statep != 0 {140				panic("sync: WaitGroup is reused before previous Wait has returned")141			}142			return143		}144	}145}...

State

Using AI Code Generation

1import (2func main() {3    c1 := make(chan string, 1)4    go func() {5        time.Sleep(time.Second * 2)6    }()7    select {8        fmt.Println(res)9    case <-time.After(time.Second * 1):10        fmt.Println("timeout 1")11    }12    c2 := make(chan string, 1)13    go func() {14        time.Sleep(time.Second * 2)15    }()16    select {17        fmt.Println(res)18    case <-time.After(time.Second * 3):19        fmt.Println("timeout 2")20    }21}22import (23func main() {24    ticker := time.NewTicker(time.Millisecond * 500)25    go func() {26        for t := range ticker.C {27            fmt.Println("Tick at", t)28        }29    }()30    time.Sleep(time.Millisecond * 1600)31    ticker.Stop()32    fmt.Println("Ticker stopped")33}34import (35func main() {36    timer1 := time.NewTimer(time

State

Using AI Code Generation

1import (2func main() {3	wg.Add(1)4	go func() {5		count("sheep")6		wg.Done()7	}()8	wg.Wait()9}10func count(thing string) {11	for i := 1; i <= 5; i++ {12		fmt.Println(i, thing)13		time.Sleep(time.Millisecond * 500)14	}15}

State

Using AI Code Generation

1import (2func main() {3	wg.Add(1)4	go func() {5		defer wg.Done()6		fmt.Println("Hello")7	}()8	wg.Add(1)9	go func() {10		defer wg.Done()11		fmt.Println("World")12	}()13	time.Sleep(time.Second)14	state := wg.State()15	fmt.Printf("%+v16	wg.Wait()17}18{Count:2 Waiters:0 NoCopy:sync.noCopy{}}19import (20func main() {21	wg.Add(1)22	go func() {23		defer wg.Done()24		fmt.Println("Hello")25	}()26	wg.Add(1)27	go func() {28		defer wg.Done()29		fmt.Println("World")30	}()31	wg.Wait()32}33import (34func main() {35	wg.Add(1)36	go func() {37		defer wg.Done()38		fmt.Println("Hello")39	}()40	wg.Add(1)41	go func() {42		defer wg.Done()43		fmt.Println("World")44	}()45	done := make(chan bool)46	go func() {47		wg.Wait()48	}()49	select {50		fmt.Println("Waited for long time")51	case <-time.After(500 * time.Millisecond):52		fmt.Println("Waited for short time")53	}54}55import (56func main() {57	wg.Add(1)58	go func() {59		defer wg.Done()60		fmt.Println("Hello")61	}()62	wg.Add(1)63	go func() {64		defer wg.Done()65		fmt.Println("World")66	}()67	wg.Add(-1)68	wg.Wait()69}

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.