(name string, args ...interface{})
| 115 | } |
| 116 | |
| 117 | func (this *module) RpcCall(name string, args ...interface{}) { |
| 118 | rpc_msg := this.rpc_msg_pool.Get().(*RpcEventMsg) |
| 119 | rpc_msg.MsgType = event.EVENT_MODULE_RPC |
| 120 | rpc_msg.Sender = this |
| 121 | rpc_msg.Data = args |
| 122 | rpc_msg.RpcName = name |
| 123 | this.ev_queue.Push(rpc_msg) |
| 124 | } |
| 125 | |
| 126 | func (this *module) RouterMsg(agent Agent, msg_id ProtoTypeID, msg interface{}) { |
| 127 | this.PostData(event.EVENT_TCP_READ_MSG, msg_id, agent, msg) |