fix map race condition in grpc server
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
		
							
								
								
									
										8
									
								
								grpc.go
									
									
									
									
									
								
							
							
						
						
									
										8
									
								
								grpc.go
									
									
									
									
									
								
							| @@ -562,11 +562,17 @@ func (g *grpcServer) Register() error { | ||||
| 		return err | ||||
| 	} | ||||
|  | ||||
| 	// make copy of metadata | ||||
| 	md := make(meta.Metadata) | ||||
| 	for k, v := range config.Metadata { | ||||
| 		md[k] = v | ||||
| 	} | ||||
|  | ||||
| 	// register service | ||||
| 	node := ®istry.Node{ | ||||
| 		Id:       config.Name + "-" + config.Id, | ||||
| 		Address:  mnet.HostPort(addr, port), | ||||
| 		Metadata: config.Metadata, | ||||
| 		Metadata: md, | ||||
| 	} | ||||
|  | ||||
| 	node.Metadata["broker"] = config.Broker.String() | ||||
|   | ||||
		Reference in New Issue
	
	Block a user