scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-10-08 11:57:51 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

refactor same node URI check in SendSync

Browse source
This commit is contained in:
Michael Baird 2017-11-30 22:03:24 -06:00 • committed by Travis Turner
parent 04790f70f2
commit 21072a665f
No known key found for this signature in database
GPG key ID: 7F08008DFD9314C9
1 changed files with 8 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
server.go
View file

@ -345,13 +345,15 @@ func (s *Server) SendSync(pb proto.Message) error {
return err
}
// Don't forward the message to ourselves
if *s.URI != *uri {
ctx := context.WithValue(context.Background(), "uri", uri)
eg.Go(func() error {
return s.defaultClient.ClusterMessage(ctx, pb)
})
// Don't forward the message to ourselves.
if *s.URI == *uri {
continue
}
ctx := context.WithValue(context.Background(), "uri", uri)
eg.Go(func() error {
return s.defaultClient.ClusterMessage(ctx, pb)
})
}
return eg.Wait()