-
Notifications
You must be signed in to change notification settings - Fork 0
/
imeta.go
84 lines (68 loc) · 1.62 KB
/
imeta.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
// Code generated by metactl. DO NOT EDIT.
// source: metactl
package meta
import (
"errors"
"fmt"
"reflect"
"runtime"
"github.com/jageros/metactl/example/game/protos/meta/sess"
pb "github.com/jageros/metactl/example/game/protos/pb"
)
var metaData = make(map[pb.MsgID]iMeta)
var NotRegistryMetaErr = errors.New("NotRegistryMetaErr")
type iMeta interface {
getMsgID() pb.MsgID
encodeArg(interface{}) ([]byte, error)
decodeArg([]byte) (interface{}, error)
encodeReply(interface{}) ([]byte, error)
decodeReply([]byte) (interface{}, error)
handle(session sess.ISession, arg interface{}) (interface{}, error)
}
func registerMeta(meta iMeta) {
metaData[meta.getMsgID()] = meta
}
func getMeta(msgId pb.MsgID) (iMeta, error) {
if m, ok := metaData[msgId]; ok {
return m, nil
} else {
return nil, NotRegistryMetaErr
}
}
func AllRegisteredMsgid() []int32 {
var msgids []int32
for id := range metaData {
msgids = append(msgids, int32(id))
}
return msgids
}
func Call(session sess.ISession, msgid pb.MsgID, data []byte) ([]byte, error) {
im, err := getMeta(msgid)
if err != nil {
return nil, err
}
arg, err := im.decodeArg(data)
if err != nil {
return nil, err
}
var resp interface{}
err = catchPanic(func() error {
resp, err = im.handle(session, arg)
return err
})
if err != nil {
return nil, err
}
return im.encodeReply(resp)
}
func catchPanic(f func() error) (err error) {
defer func() {
err1 := recover()
if err1 != nil {
fn := runtime.FuncForPC(reflect.ValueOf(f).Pointer()).Name()
err = errors.New(fmt.Sprintf("%!s(MISSING) call err: %!v(MISSING)", fn, err1))
}
}()
err = f()
return
}