save
This commit is contained in:
parent
b740255bb8
commit
22031c44ef
@ -1,19 +1,19 @@
|
|||||||
package app
|
package app
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"f5"
|
|
||||||
"q5"
|
|
||||||
"mt"
|
|
||||||
"cs"
|
"cs"
|
||||||
"ss"
|
"f5"
|
||||||
"main/constant"
|
"main/constant"
|
||||||
. "main/global"
|
. "main/global"
|
||||||
|
"mt"
|
||||||
|
"q5"
|
||||||
|
"ss"
|
||||||
)
|
)
|
||||||
|
|
||||||
type app struct {
|
type app struct {
|
||||||
netMsgQueue q5.Queue
|
netMsgQueue q5.Queue
|
||||||
initCb func()
|
initCb func()
|
||||||
unInitCb func()
|
unInitCb func()
|
||||||
}
|
}
|
||||||
|
|
||||||
func (this *app) GetPkgName() string {
|
func (this *app) GetPkgName() string {
|
||||||
@ -82,3 +82,7 @@ func (this *app) AddNetMsg(hdr *f5.MsgHdr) {
|
|||||||
|
|
||||||
func (this *app) registerDataSources() {
|
func (this *app) registerDataSources() {
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (this *app) GetHttpListenPort() int32 {
|
||||||
|
return mt.Table.HallCluster.GetHttpListenPort()
|
||||||
|
}
|
||||||
|
@ -10,8 +10,8 @@ type httpListener struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (this *httpListener) Init() {
|
func (this *httpListener) Init() {
|
||||||
this.httpServer = new (f5.HttpServer)
|
this.httpServer = new(f5.HttpServer)
|
||||||
this.httpServer.Init("imserver.httplistener", 1000 * 10)
|
this.httpServer.Init("hallserver.httplistener", 1000*10)
|
||||||
this.httpServer.Start(mt.Table.HallCluster.GetHttpListenPort())
|
this.httpServer.Start(mt.Table.HallCluster.GetHttpListenPort())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user