overflow_cloud/container-go
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2018-04-19 16:01:08 +09:00
parent 9a68cbc02b
commit f93dcf388a
1 changed files with 28 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
server/server-handler.go
View File

@ -5,11 +5,13 @@ import (
"io/ioutil" "io/ioutil"
"net" "net"
"os" "os"
"reflect"
"strconv" "strconv"
logging "git.loafle.net/commons/logging-go" logging "git.loafle.net/commons/logging-go"
"git.loafle.net/commons/server-go" "git.loafle.net/commons/server-go"
cssn "git.loafle.net/commons/server-go/socket/net" cssn "git.loafle.net/commons/server-go/socket/net"
occi "git.loafle.net/overflow/commons-go/core/interfaces"
) )
type ServerHandler interface { type ServerHandler interface {
@ -19,7 +21,9 @@ type ServerHandler interface {
type ServerHandlers struct { type ServerHandlers struct {
cssn.ServerHandlers cssn.ServerHandlers
PIDFilePath string PIDFilePath string
Services []interface{}
OrderedServices []reflect.Type
port int port int
} }
@ -29,6 +33,10 @@ func (sh *ServerHandlers) Init(serverCtx server.ServerCtx) error {
return err return err
} }
if err := occi.ExecServices(sh.Services, occi.ServiceMethodInit, sh.OrderedServices, false); nil != err {
return err
}
return nil return nil
} }
@ -37,6 +45,10 @@ func (sh *ServerHandlers) OnStart(serverCtx server.ServerCtx) error {
return err return err
} }
if err := occi.ExecServices(sh.Services, occi.ServiceMethodStart, sh.OrderedServices, false); nil != err {
return err
}
if _, err := os.Stat(sh.PIDFilePath); os.IsExist(err) { if _, err := os.Stat(sh.PIDFilePath); os.IsExist(err) {
if err := os.Remove(sh.PIDFilePath); nil != err { if err := os.Remove(sh.PIDFilePath); nil != err {
logging.Logger().Errorf("Container[%s]: Removing pid file has been failed [%v]", sh.Name, err) logging.Logger().Errorf("Container[%s]: Removing pid file has been failed [%v]", sh.Name, err)
@ -52,6 +64,10 @@ func (sh *ServerHandlers) OnStart(serverCtx server.ServerCtx) error {
} }
func (sh *ServerHandlers) OnStop(serverCtx server.ServerCtx) { func (sh *ServerHandlers) OnStop(serverCtx server.ServerCtx) {
if err := occi.ExecServices(sh.Services, occi.ServiceMethodStop, sh.OrderedServices, true); nil != err {
logging.Logger().Errorf("Container[%s]: Service stop err %v", sh.Name, err)
}
if _, err := os.Stat(sh.PIDFilePath); os.IsExist(err) { if _, err := os.Stat(sh.PIDFilePath); os.IsExist(err) {
if err := os.Remove(sh.PIDFilePath); nil != err { if err := os.Remove(sh.PIDFilePath); nil != err {
logging.Logger().Errorf("Container: Removing pid file has been failed [%v]", err) logging.Logger().Errorf("Container: Removing pid file has been failed [%v]", err)
@ -62,6 +78,9 @@ func (sh *ServerHandlers) OnStop(serverCtx server.ServerCtx) {
} }
func (sh *ServerHandlers) Destroy(serverCtx server.ServerCtx) { func (sh *ServerHandlers) Destroy(serverCtx server.ServerCtx) {
if err := occi.ExecServices(sh.Services, occi.ServiceMethodDestroy, sh.OrderedServices, true); nil != err {
logging.Logger().Errorf("Container[%s]: Service destroy err %v", sh.Name, err)
}
sh.ServerHandlers.Destroy(serverCtx) sh.ServerHandlers.Destroy(serverCtx)
} }
@ -88,5 +107,13 @@ func (sh *ServerHandlers) Validate() error {
return fmt.Errorf("Container[%s]: The path of pid file must be specified", sh.Name) return fmt.Errorf("Container[%s]: The path of pid file must be specified", sh.Name)
} }
if nil == sh.Services {
return fmt.Errorf("Container[%s]: Services must be specified", sh.Name)
}
if nil == sh.OrderedServices {
return fmt.Errorf("Container[%s]: OrderedServices must be specified", sh.Name)
}
return nil return nil
} }