diff options
author | Egon Elbre <egonelbre@gmail.com> | 2017-08-08 17:08:37 +0800 |
---|---|---|
committer | Felix Lange <fjl@users.noreply.github.com> | 2017-08-08 17:08:37 +0800 |
commit | e063d538b80d2edfc3c2b374aaee4e38e2145170 (patch) | |
tree | fd27b3a044dc674b9c6d3415a1dfca465d846fa5 /rpc/types.go | |
parent | 43437806fb49d4ca0b5f6e7599c9871663960b15 (diff) | |
download | dexon-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.go | 13 |
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 |