opencode/yao
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Ign session on watch

Browse source
This commit is contained in:
Max 2022-02-14 23:40:21 +08:00
parent 3f7deb9a25
commit b6326c9144
2 changed files with 14 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
service/service.go
View file

@ -45,6 +45,14 @@ func StartWithouttSession() {
Middlewares...)
}
// StopWithouttSession 关闭服务
func StopWithouttSession(onComplete func()) {
shutdown <- true
<-shutdownComplete
gou.KillPlugins()
onComplete()
}
// Stop 关闭服务
func Stop(onComplete func()) {
shutdown <- true

12
service/watch.go
View file

@ -67,7 +67,7 @@ func WatchGlobal(root string) {
fmt.Println(color.RedString("Fatal: %s", err.Error()))
return
}
Stop(func() {
StopWithouttSession(func() {
fmt.Println(color.GreenString("Service Restarted"))
go StartWithouttSession()
})
@ -137,7 +137,7 @@ func WatchAPI(root string, prefix string) {
// 重启服务器
if op == "write" || op == "create" || op == "remove" || op == "rename" {
Stop(func() {
StopWithouttSession(func() {
fmt.Println(color.GreenString("Service Restarted"))
go StartWithouttSession()
})
@ -268,7 +268,7 @@ func WatchTable(root string, prefix string) {
// 重启服务器
if op == "write" || op == "create" || op == "remove" || op == "rename" {
Stop(func() {
StopWithouttSession(func() {
fmt.Println(color.GreenString("Service Restarted"))
go StartWithouttSession()
})
@ -335,7 +335,7 @@ func WatchChart(root string, prefix string) {
// 重启服务器
if op == "write" || op == "create" || op == "remove" || op == "rename" {
Stop(func() {
StopWithouttSession(func() {
fmt.Println(color.GreenString("Service Restarted"))
go StartWithouttSession()
})
@ -402,7 +402,7 @@ func WatchPage(root string, prefix string) {
// 重启服务器
if op == "write" || op == "create" || op == "remove" || op == "rename" {
Stop(func() {
StopWithouttSession(func() {
fmt.Println(color.GreenString("Service Restarted"))
go StartWithouttSession()
})
@ -450,7 +450,7 @@ func WatchWorkFlow(root string, prefix string) {
// 重启服务器
if op == "write" || op == "create" || op == "remove" || op == "rename" {
Stop(func() {
StopWithouttSession(func() {
fmt.Println(color.GreenString("Service Restarted"))
go StartWithouttSession()
})