Function setupServers

rpc/xxx_test.go:172–198

(nodes []*proto.Node, f AcceptConn)

}

func setupServers(nodes []*proto.Node, f AcceptConn) (stop func(), err error) {
	servers := make([]*Server, len(nodes))
	for i, v := range nodes {
		if servers[i], err = setupServer(v); err != nil {
			return
		}
	}

	wg := &sync.WaitGroup{}
	for _, v := range servers {
		wg.Add(1)
		go func(server *Server) {
			defer wg.Done()
			server.WithAcceptConnFunc(f).Serve()
		}(v)
	}

	return func() {
		for _, v := range nodes {
			defaultResolver.deleteNode(*(v.ID.ToRawNodeID()))
		}
		for _, v := range servers {
			v.Stop()
		}
		wg.Wait()
	}, nil
}

func setupEnvironment(n int, f AcceptConn) ([]*proto.Node, func(), error) {
	nodes, err := createLocalNodes(10, n)