(node *proto.Node)
| 155 | } |
| 156 | |
| 157 | func setupServer(node *proto.Node) (server *Server, err error) { |
| 158 | if server, err = NewServerWithService( |
| 159 | ServiceMap{"Count": &CountService{host: node.ID}}, |
| 160 | ); err != nil { |
| 161 | return nil, err |
| 162 | } |
| 163 | if err = server.InitRPCServer(":0", privateKey, []byte{}); err != nil { |
| 164 | return nil, err |
| 165 | } |
| 166 | // register to resolver |
| 167 | node.Addr = server.Listener.Addr().String() |
| 168 | defaultResolver.registerNode(node) |
| 169 | return |
| 170 | } |
| 171 | |
| 172 | func setupServers(nodes []*proto.Node, f AcceptConn) (stop func(), err error) { |
| 173 | servers := make([]*Server, len(nodes)) |
no test coverage detected