Function rpc_StartServer

tests/rpc_test.go:23–46

()

)

func rpc_StartServer() {
	queue := cellnet.NewEventQueue()

	rpc_Acceptor = peer.NewGenericPeer("tcp.Acceptor", "server", syncRPC_Address, queue)

	proc.BindProcessorHandler(rpc_Acceptor, "tcp.ltv", func(ev cellnet.Event) {
		switch msg := ev.Message().(type) {
		case *TestEchoACK:
			log.Debugln("server recv rpc ", *msg)

			ev.(interface {
				Reply(interface{})
			}).Reply(&TestEchoACK{
				Msg:   msg.Msg,
				Value: msg.Value,
			})

		}

	})
	rpc_Acceptor.Start()

	queue.StartLoop()
}
func syncRPC_OnClientEvent(ev cellnet.Event) {

	switch ev.Message().(type) {