1
This commit is contained in:
parent
45cd22c75b
commit
25596b9653
41
app.go
Normal file
41
app.go
Normal file
@ -0,0 +1,41 @@
|
||||
package f5
|
||||
|
||||
import "q5"
|
||||
|
||||
type App_ struct {
|
||||
nodeId int32
|
||||
instanceId int32
|
||||
terminated bool
|
||||
flags map[int32]int32
|
||||
servicing bool
|
||||
contextHash map[int32]q5.XParams
|
||||
}
|
||||
|
||||
func (this *App_) Init() {
|
||||
_Timer = &q5.Timer{}
|
||||
_Timer.Init(
|
||||
q5.GetTickCount,
|
||||
nil,
|
||||
1000 * 60,
|
||||
5000)
|
||||
}
|
||||
|
||||
func (this *App_) UnInit() {
|
||||
_Timer.UnInit()
|
||||
_Timer = nil
|
||||
}
|
||||
|
||||
func (this *App_) Run() {
|
||||
for !this.terminated {
|
||||
_Timer.Update()
|
||||
}
|
||||
}
|
||||
|
||||
func (this *App_) NewUuid() int64 {
|
||||
return 0
|
||||
}
|
||||
|
||||
func (this *App_) HasFlag(flag int32) bool {
|
||||
_, ok := this.flags[flag]
|
||||
return ok
|
||||
}
|
10
global.go
Normal file
10
global.go
Normal file
@ -0,0 +1,10 @@
|
||||
package f5
|
||||
|
||||
import "q5"
|
||||
|
||||
var App *App_
|
||||
var _Timer *q5.Timer
|
||||
|
||||
func Timer() *q5.Timer {
|
||||
return _Timer
|
||||
}
|
41
metautils.go
41
metautils.go
@ -1,41 +0,0 @@
|
||||
package f5
|
||||
|
||||
import (
|
||||
"os"
|
||||
"bufio"
|
||||
"reflect"
|
||||
"fmt"
|
||||
|
||||
"github.com/golang/protobuf/proto"
|
||||
"github.com/golang/protobuf/jsonpb"
|
||||
"google.golang.org/protobuf/reflect/protoregistry"
|
||||
)
|
||||
|
||||
func ReadJsonMetaFile(fileName string, list interface{}) {
|
||||
msgType := reflect.TypeOf(list).Elem().Elem().Elem()
|
||||
msg := reflect.New(msgType)
|
||||
msgPb := msg.Interface().(proto.Message)
|
||||
msgReflect := proto.MessageReflect(msgPb)
|
||||
msgDesc := msgReflect.Descriptor()
|
||||
|
||||
meta, _ := protoregistry.GlobalTypes.FindMessageByName(msgDesc.FullName() + "Metas")
|
||||
metaList := meta.New()
|
||||
f, _ := os.Open(fileName)
|
||||
data, _ := bufio.NewReader(f).ReadString(0)
|
||||
data = "{\"values\":" + data
|
||||
data += "}"
|
||||
err := jsonpb.UnmarshalString(data, proto.MessageV1(metaList))
|
||||
if err == nil {
|
||||
fmt.Println("json decode ok", data)
|
||||
}
|
||||
fmt.Println(err)
|
||||
|
||||
/* msgReflect = proto.MessageReflect(proto.MessageV1(metaList))
|
||||
msgDesc = msgReflect.Descriptor()
|
||||
valuesField := msgDesc.Fields().ByName("values")
|
||||
values := msgReflect.Get(valuesField)
|
||||
reflect.ValueOf(list).Elem().Set(reflect.ValueOf(values.List()))
|
||||
_ = valuesField
|
||||
fmt.Println(valuesField, values)*/
|
||||
}
|
||||
|
15
syslog.go
Normal file
15
syslog.go
Normal file
@ -0,0 +1,15 @@
|
||||
package f5
|
||||
|
||||
type SysLog_ struct {
|
||||
|
||||
}
|
||||
|
||||
var SysLog *SysLog_
|
||||
|
||||
func (this *SysLog_) Init() {
|
||||
|
||||
}
|
||||
|
||||
func (this *SysLog_) UnInit() {
|
||||
|
||||
}
|
Loading…
x
Reference in New Issue
Block a user