diff --git a/server/hallserver/app/app.go b/server/hallserver/app/app.go index 98df0c4f..59a16ddd 100644 --- a/server/hallserver/app/app.go +++ b/server/hallserver/app/app.go @@ -1,19 +1,19 @@ package app import ( - "f5" - "q5" - "mt" "cs" - "ss" + "f5" "main/constant" . "main/global" + "mt" + "q5" + "ss" ) type app struct { netMsgQueue q5.Queue - initCb func() - unInitCb func() + initCb func() + unInitCb func() } func (this *app) GetPkgName() string { @@ -82,3 +82,7 @@ func (this *app) AddNetMsg(hdr *f5.MsgHdr) { func (this *app) registerDataSources() { } + +func (this *app) GetHttpListenPort() int32 { + return mt.Table.HallCluster.GetHttpListenPort() +} diff --git a/server/hallserver/listener/httplistener.go b/server/hallserver/listener/httplistener.go index 28bd86ed..6849506a 100644 --- a/server/hallserver/listener/httplistener.go +++ b/server/hallserver/listener/httplistener.go @@ -10,8 +10,8 @@ type httpListener struct { } func (this *httpListener) Init() { - this.httpServer = new (f5.HttpServer) - this.httpServer.Init("imserver.httplistener", 1000 * 10) + this.httpServer = new(f5.HttpServer) + this.httpServer.Init("hallserver.httplistener", 1000*10) this.httpServer.Start(mt.Table.HallCluster.GetHttpListenPort()) }