diff --git a/service/ProbeService.go b/service/ProbeService.go index 831d4e8..d873da3 100644 --- a/service/ProbeService.go +++ b/service/ProbeService.go @@ -2,7 +2,6 @@ package service import ( "reflect" - "sync" cda "git.loafle.net/commons_go/di/annotation" cdr "git.loafle.net/commons_go/di/registry" @@ -17,12 +16,8 @@ type ProbeService struct { cda.TypeAnnotation `annotation:"@overFlow:Service()"` RPCServlet cr.Servlet - sendMtx sync.RWMutex } func (ps *ProbeService) Send(method string, params ...interface{}) error { - ps.sendMtx.RLock() - defer ps.sendMtx.RUnlock() - return ps.RPCServlet.Send(method, params...) }