aboutsummaryrefslogtreecommitdiffstats
path: root/rpc/types.go
diff options
context:
space:
mode:
authorEgon Elbre <egonelbre@gmail.com>2017-08-08 17:08:37 +0800
committerFelix Lange <fjl@users.noreply.github.com>2017-08-08 17:08:37 +0800
commite063d538b80d2edfc3c2b374aaee4e38e2145170 (patch)
treefd27b3a044dc674b9c6d3415a1dfca465d846fa5 /rpc/types.go
parent43437806fb49d4ca0b5f6e7599c9871663960b15 (diff)
downloaddexon-e063d538b80d2edfc3c2b374aaee4e38e2145170.tar.gz
dexon-e063d538b80d2edfc3c2b374aaee4e38e2145170.tar.zst
dexon-e063d538b80d2edfc3c2b374aaee4e38e2145170.zip
rpc: fix megacheck warnings
Diffstat (limited to 'rpc/types.go')
-rw-r--r--rpc/types.go13
1 files changed, 4 insertions, 9 deletions
diff --git a/rpc/types.go b/rpc/types.go
index a7b8c9788..f2375604e 100644
--- a/rpc/types.go
+++ b/rpc/types.go
@@ -48,7 +48,6 @@ type callback struct {
// service represents a registered object
type service struct {
name string // name for service
- rcvr reflect.Value // receiver of methods for the service
typ reflect.Type // receiver type
callbacks callbacks // registered handlers
subscriptions subscriptions // available subscriptions/notifications
@@ -58,23 +57,19 @@ type service struct {
type serverRequest struct {
id interface{}
svcname string
- rcvr reflect.Value
callb *callback
args []reflect.Value
isUnsubscribe bool
err Error
}
-type serviceRegistry map[string]*service // collection of services
-type callbacks map[string]*callback // collection of RPC callbacks
-type subscriptions map[string]*callback // collection of subscription callbacks
-type subscriptionRegistry map[string]*callback // collection of subscription callbacks
+type serviceRegistry map[string]*service // collection of services
+type callbacks map[string]*callback // collection of RPC callbacks
+type subscriptions map[string]*callback // collection of subscription callbacks
// Server represents a RPC server
type Server struct {
- services serviceRegistry
- muSubcriptions sync.Mutex // protects subscriptions
- subscriptions subscriptionRegistry
+ services serviceRegistry
run int32
codecsMu sync.Mutex