unistack-org/micro
4
0
Fork 3
Code Issues 20 Pull Requests 1 Actions Packages Projects Releases 281 Wiki Activity

changes to minimize allocations and provide useful info

Browse Source 
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
Василий Толстов 2019-07-17 00:19:59 +03:00
parent 8c7e35c3c6
commit a3bddf5839
2 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
client/rpc_client.go
View File

@ -280,16 +280,16 @@ func (r *rpcClient) next(request Request, opts CallOptions) (selector.Next, erro
// return remote address // return remote address
if len(opts.Address) > 0 { if len(opts.Address) > 0 {
var nodes []*registry.Node nodes := make([]*registry.Node, len(opts.Address))
for _, address := range opts.Address { for i, address := range opts.Address {
nodes = append(nodes, &registry.Node{ nodes[i] = &registry.Node{
Address: address, Address: address,
// Set the protocol // Set the protocol
Metadata: map[string]string{ Metadata: map[string]string{
"protocol": "mucp", "protocol": "mucp",
}, },
}) }
} }
// crude return method // crude return method

3
server/rpc_server.go
View File

@ -405,6 +405,7 @@ func (s *rpcServer) Register() error {
if err != nil { if err != nil {
return err return err
} }
log.Logf("Subscribing %s to topic: %s", node.Id, sub.Topic())
s.subscribers[sb] = []broker.Subscriber{sub} s.subscribers[sb] = []broker.Subscriber{sub}
} }
@ -465,7 +466,7 @@ func (s *rpcServer) Deregister() error {
for sb, subs := range s.subscribers { for sb, subs := range s.subscribers {
for _, sub := range subs { for _, sub := range subs {
log.Logf("Unsubscribing from topic: %s", sub.Topic()) log.Logf("Unsubscribing %s from topic: %s", node.Id, sub.Topic())
sub.Unsubscribe() sub.Unsubscribe()
} }
s.subscribers[sb] = nil s.subscribers[sb] = nil