ayo/houston
8
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

로거 되돌림

Browse Source
This commit is contained in:
mountain
2023-06-14 00:13:51 +09:00
parent 20b2df1fc5
commit 3add5d9355
10 changed files with 60 additions and 87 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
client/client.go
View File

@ -20,6 +20,7 @@ import (
"time"
"unsafe"
"repositories.action2quare.com/ayo/gocommon/logger"
"repositories.action2quare.com/ayo/houston/shared"
"repositories.action2quare.com/ayo/houston/shared/protos"
@ -196,7 +197,7 @@ func NewClient() (HoustonClient, error) {
var client *grpc.ClientConn
for {
shared.Logger().Println("grpc.DialContext :", clientConfig.GrpcAddress)
logger.Println("grpc.DialContext :", clientConfig.GrpcAddress)
dialContext, cancelDial := context.WithTimeout(context.Background(), 15*time.Second)
client, err = grpc.DialContext(dialContext, clientConfig.GrpcAddress, grpc.WithBlock(), grpc.WithTransportCredentials(insecure.NewCredentials()))
if err == nil {
@ -205,11 +206,11 @@ func NewClient() (HoustonClient, error) {
}
cancelDial()
shared.Logger().Println("grpc.DialContext failed :", err)
logger.Println("grpc.DialContext failed :", err)
time.Sleep(5 * time.Second)
}
shared.Logger().Println("grpc.DialContext succeeded")
logger.Println("grpc.DialContext succeeded")
exefile, err := os.Executable()
if err != nil {
return nil, err
@ -292,12 +293,12 @@ func NewClient() (HoustonClient, error) {
args = append(args, os.Args[1:]...)
cmd := exec.Command(replacer, args...)
if err := cmd.Start(); err != nil {
shared.Logger().Println(err)
logger.Println(err)
} else {
hc.shutdownFunc()
}
} else {
shared.Logger().Println(err)
logger.Println(err)
}
} else {
if err := hc.deploy(&dr); err == nil {
@ -305,7 +306,7 @@ func NewClient() (HoustonClient, error) {
hc.deploys[dr.Name] = prog
op.Refresh(ctx, hc.makeOperationQueryRequest())
} else {
shared.Logger().Println(err)
logger.Println(err)
}
}
@ -322,35 +323,35 @@ func NewClient() (HoustonClient, error) {
}
op.Refresh(ctx, hc.makeOperationQueryRequest())
} else {
shared.Logger().Println(err)
logger.Println(err)
}
case shared.Start:
var sr shared.StartProcessRequest
unmarshal(&sr, resp.Args)
if err := hc.startChildProcess(&sr); err != nil {
shared.Logger().Println(err)
logger.Println(err)
}
case shared.Stop:
var sr shared.StopProcessRequest
unmarshal(&sr, resp.Args)
if err := hc.stopChildProcess(&sr); err != nil {
shared.Logger().Println(err)
logger.Println(err)
}
case shared.Restart:
var rr shared.RestartProcessRequest
unmarshal(&rr, resp.Args)
if err := hc.restartChildProcess(&rr); err != nil {
shared.Logger().Println(err)
logger.Println(err)
}
case shared.Upload:
var ur shared.UploadRequest
unmarshal(&ur, resp.Args)
if err := hc.uploadFiles(&ur); err != nil {
shared.Logger().Println(err)
logger.Println(err)
}
}
}
@ -387,7 +388,7 @@ func (hc *houstonClient) Start() {
go func() {
c := <-interrupt
shared.Logger().Println("interrupt!!!!!!!! :", c.String())
logger.Println("interrupt!!!!!!!! :", c.String())
hc.shutdownFunc()
}()
@ -399,7 +400,7 @@ func (hc *houstonClient) Start() {
default:
err := hc.checkOperation()
if err != nil {
shared.Logger().Println("hc.checkUpdate failed :", err)
logger.Println("hc.checkUpdate failed :", err)
}
}
}
@ -413,7 +414,7 @@ func (hc *houstonClient) checkOperation() error {
defer func() {
r := recover()
if r != nil {
shared.Logger().Println(r)
logger.Println(r)
}
}()