short chanrpc calls

Author: name5566

chanrpc/chanrpc.go

@@ -149,6 +149,27 @@ func (s *Server) Go(id interface{}, args ...interface{}) {
 	}
 }
 
+// goroutine safe
+func (s *Server) Call0(id interface{}, args ...interface{}) error {
+	c := NewClient(0)
+	c.Attach(s)
+	return c.Call0(id, args...)
+}
+
+// goroutine safe
+func (s *Server) Call1(id interface{}, args ...interface{}) (interface{}, error) {
+	c := NewClient(0)
+	c.Attach(s)
+	return c.Call1(id, args...)
+}
+
+// goroutine safe
+func (s *Server) CallN(id interface{}, args ...interface{}) ([]interface{}, error) {
+	c := NewClient(0)
+	c.Attach(s)
+	return c.CallN(id, args...)
+}
+
 func (s *Server) Close() {
 	close(s.ChanCall)
 
@@ -159,13 +180,6 @@ func (s *Server) Close() {
 	}
 }
 
-// goroutine safe
-func (s *Server) Open(l int) *Client {
-	c := NewClient(l)
-	c.Attach(s)
-	return c
-}
-
 func NewClient(l int) *Client {
 	c := new(Client)
 	c.chanSyncRet = make(chan *RetInfo, 1)

console/command.go

@@ -46,7 +46,7 @@ func (c *ExternalCommand) run(_args []string) string {
 		args[i] = v
 	}
 
-	ret, err := c.server.Open(0).Call1(c._name, args...)
+	ret, err := c.server.Call1(c._name, args...)
 	if err != nil {
 		return err.Error()
 	}

gate/gate.go

@@ -109,7 +109,7 @@ func (a *agent) Run() {
 
 func (a *agent) OnClose() {
 	if a.gate.AgentChanRPC != nil {
-		err := a.gate.AgentChanRPC.Open(0).Call0("CloseAgent", a)
+		err := a.gate.AgentChanRPC.Call0("CloseAgent", a)
 		if err != nil {
 			log.Error("chanrpc error: %v", err)
 		}