mirror of
https://github.com/duanhf2012/origin.git
synced 2026-03-13 03:27:36 +08:00
新增接口
This commit is contained in:
@@ -34,6 +34,14 @@ type PBPackInfo struct {
|
|||||||
msg proto.Message
|
msg proto.Message
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (slf *PBPackInfo) GetPackType() uint16 {
|
||||||
|
return slf.typ
|
||||||
|
}
|
||||||
|
|
||||||
|
func (slf *PBPackInfo) GetMsg() proto.Message {
|
||||||
|
return slf.msg
|
||||||
|
}
|
||||||
|
|
||||||
// must goroutine safe
|
// must goroutine safe
|
||||||
func (slf *PBProcessor ) Route(msg interface{},userdata interface{}) error{
|
func (slf *PBProcessor ) Route(msg interface{},userdata interface{}) error{
|
||||||
pPackInfo := msg.(*PBPackInfo)
|
pPackInfo := msg.(*PBPackInfo)
|
||||||
|
|||||||
Reference in New Issue
Block a user