Skip to content

Commit 7f61fee

Browse files
Remove lock options from the info api (#2149)
1 parent c50ea11 commit 7f61fee

File tree

2 files changed

+26
-23
lines changed

2 files changed

+26
-23
lines changed

api/info/service.go

+17-22
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@ import (
1616
"github.com/ava-labs/avalanchego/ids"
1717
"github.com/ava-labs/avalanchego/network"
1818
"github.com/ava-labs/avalanchego/network/peer"
19-
"github.com/ava-labs/avalanchego/snow/engine/common"
2019
"github.com/ava-labs/avalanchego/snow/networking/benchlist"
2120
"github.com/ava-labs/avalanchego/snow/validators"
2221
"github.com/ava-labs/avalanchego/utils/constants"
@@ -59,7 +58,6 @@ type Parameters struct {
5958
VMManager vms.Manager
6059
}
6160

62-
// NewService returns a new admin API service
6361
func NewService(
6462
parameters Parameters,
6563
log logging.Logger,
@@ -69,27 +67,24 @@ func NewService(
6967
network network.Network,
7068
validators validators.Set,
7169
benchlist benchlist.Manager,
72-
) (*common.HTTPHandler, error) {
73-
newServer := rpc.NewServer()
70+
) (http.Handler, error) {
71+
server := rpc.NewServer()
7472
codec := json.NewCodec()
75-
newServer.RegisterCodec(codec, "application/json")
76-
newServer.RegisterCodec(codec, "application/json;charset=UTF-8")
77-
if err := newServer.RegisterService(&Info{
78-
Parameters: parameters,
79-
log: log,
80-
chainManager: chainManager,
81-
vmManager: vmManager,
82-
myIP: myIP,
83-
networking: network,
84-
validators: validators,
85-
benchlist: benchlist,
86-
}, "info"); err != nil {
87-
return nil, err
88-
}
89-
return &common.HTTPHandler{
90-
LockOptions: common.NoLock,
91-
Handler: newServer,
92-
}, nil
73+
server.RegisterCodec(codec, "application/json")
74+
server.RegisterCodec(codec, "application/json;charset=UTF-8")
75+
return server, server.RegisterService(
76+
&Info{
77+
Parameters: parameters,
78+
log: log,
79+
chainManager: chainManager,
80+
vmManager: vmManager,
81+
myIP: myIP,
82+
networking: network,
83+
validators: validators,
84+
benchlist: benchlist,
85+
},
86+
"info",
87+
)
9388
}
9489

9590
// GetNodeVersionReply are the results from calling GetNodeVersion

node/node.go

+9-1
Original file line numberDiff line numberDiff line change
@@ -1112,7 +1112,15 @@ func (n *Node) initInfoAPI() error {
11121112
if err != nil {
11131113
return err
11141114
}
1115-
return n.APIServer.AddRoute(service, &sync.RWMutex{}, "info", "")
1115+
return n.APIServer.AddRoute(
1116+
&common.HTTPHandler{
1117+
LockOptions: common.NoLock,
1118+
Handler: service,
1119+
},
1120+
&sync.RWMutex{},
1121+
"info",
1122+
"",
1123+
)
11161124
}
11171125

11181126
// initHealthAPI initializes the Health API service

0 commit comments

Comments
 (0)