mbk-lab
/
wide
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

channel err logging

This commit is contained in:
Liang Ding 2015-03-20 16:49:58 +08:00
parent 8c1a705a6a
commit ec22bcd3ad
8 changed files with 21 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
output/build.go
View File

@ -245,7 +245,7 @@ func BuildHandler(w http.ResponseWriter, r *http.Request) {
wsChannel := session.OutputWS[sid] wsChannel := session.OutputWS[sid]
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
} }
wsChannel.Refresh() wsChannel.Refresh()

4
output/get.go
View File

@ -94,7 +94,7 @@ func GoGetHandler(w http.ResponseWriter, r *http.Request) {
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
return return
} }
@ -137,7 +137,7 @@ func GoGetHandler(w http.ResponseWriter, r *http.Request) {
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
} }
wsChannel.Refresh() wsChannel.Refresh()

2
output/install.go
View File

@ -188,7 +188,7 @@ func GoInstallHandler(w http.ResponseWriter, r *http.Request) {
wsChannel := session.OutputWS[sid] wsChannel := session.OutputWS[sid]
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
} }
wsChannel.Refresh() wsChannel.Refresh()

12
output/run.go
View File

@ -98,7 +98,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) {
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
return return
} }
@ -125,7 +125,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) {
channelRet["output"] = "" channelRet["output"] = ""
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
return return
} }
@ -146,7 +146,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) {
r, _, err := outReader.ReadRune() r, _, err := outReader.ReadRune()
if nil != err { if nil != err {
// remove the exited process from user process set // remove the exited process from user's process set
Processes.Remove(wSession, cmd.Process) Processes.Remove(wSession, cmd.Process)
logger.Debugf("User [%s, %s] 's running [id=%d, file=%s] has done [stdout %v], ", wSession.Username, sid, runningId, filePath, err) logger.Debugf("User [%s, %s] 's running [id=%d, file=%s] has done [stdout %v], ", wSession.Username, sid, runningId, filePath, err)
@ -155,7 +155,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) {
channelRet["output"] = buf.content channelRet["output"] = buf.content
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
break break
} }
@ -184,7 +184,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) {
err = wsChannel.WriteJSON(&channelRet) err = wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
break break
} }
@ -222,7 +222,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) {
err = wsChannel.WriteJSON(&channelRet) err = wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
break break
} }

4
output/test.go
View File

@ -95,7 +95,7 @@ func GoTestHandler(w http.ResponseWriter, r *http.Request) {
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
return return
} }
@ -140,7 +140,7 @@ func GoTestHandler(w http.ResponseWriter, r *http.Request) {
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
} }
wsChannel.Refresh() wsChannel.Refresh()

4
output/vet.go
View File

@ -95,7 +95,7 @@ func GoVetHandler(w http.ResponseWriter, r *http.Request) {
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
return return
} }
@ -140,7 +140,7 @@ func GoVetHandler(w http.ResponseWriter, r *http.Request) {
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
} }
wsChannel.Refresh() wsChannel.Refresh()

10
playground/run.go
View File

@ -96,7 +96,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) {
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
return return
} }
@ -123,7 +123,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) {
channelRet["output"] = "" channelRet["output"] = ""
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
return return
} }
@ -153,7 +153,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) {
channelRet["output"] = buf.content channelRet["output"] = buf.content
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
break break
} }
@ -182,7 +182,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) {
err = wsChannel.WriteJSON(&channelRet) err = wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
break break
} }
@ -220,7 +220,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) {
err = wsChannel.WriteJSON(&channelRet) err = wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
break break
} }

4
scm/git/clone.go
View File

@ -95,7 +95,7 @@ func CloneHandler(w http.ResponseWriter, r *http.Request) {
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
return return
} }
@ -132,7 +132,7 @@ func CloneHandler(w http.ResponseWriter, r *http.Request) {
err := wsChannel.WriteJSON(&channelRet) err := wsChannel.WriteJSON(&channelRet)
if nil != err { if nil != err {
logger.Error(err) logger.Warn(err)
} }
wsChannel.Refresh() wsChannel.Refresh()