From ec22bcd3ad1a6c49c673da27fc4248df7ff8f22e Mon Sep 17 00:00:00 2001 From: Liang Ding Date: Fri, 20 Mar 2015 16:49:58 +0800 Subject: [PATCH] channel err logging --- output/build.go | 2 +- output/get.go | 4 ++-- output/install.go | 2 +- output/run.go | 12 ++++++------ output/test.go | 4 ++-- output/vet.go | 4 ++-- playground/run.go | 10 +++++----- scm/git/clone.go | 4 ++-- 8 files changed, 21 insertions(+), 21 deletions(-) diff --git a/output/build.go b/output/build.go index 79913b0..f541a2d 100644 --- a/output/build.go +++ b/output/build.go @@ -245,7 +245,7 @@ func BuildHandler(w http.ResponseWriter, r *http.Request) { wsChannel := session.OutputWS[sid] err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) } wsChannel.Refresh() diff --git a/output/get.go b/output/get.go index 51106b8..52fabe8 100644 --- a/output/get.go +++ b/output/get.go @@ -94,7 +94,7 @@ func GoGetHandler(w http.ResponseWriter, r *http.Request) { err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) return } @@ -137,7 +137,7 @@ func GoGetHandler(w http.ResponseWriter, r *http.Request) { err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) } wsChannel.Refresh() diff --git a/output/install.go b/output/install.go index e88afaf..b485f59 100644 --- a/output/install.go +++ b/output/install.go @@ -188,7 +188,7 @@ func GoInstallHandler(w http.ResponseWriter, r *http.Request) { wsChannel := session.OutputWS[sid] err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) } wsChannel.Refresh() diff --git a/output/run.go b/output/run.go index 19400eb..9cdab5a 100644 --- a/output/run.go +++ b/output/run.go @@ -98,7 +98,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) { err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) return } @@ -125,7 +125,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) { channelRet["output"] = "" err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) return } @@ -146,7 +146,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) { r, _, err := outReader.ReadRune() 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) 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 err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) break } @@ -184,7 +184,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) { err = wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) break } @@ -222,7 +222,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) { err = wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) break } diff --git a/output/test.go b/output/test.go index da5f9f4..d70ea4a 100644 --- a/output/test.go +++ b/output/test.go @@ -95,7 +95,7 @@ func GoTestHandler(w http.ResponseWriter, r *http.Request) { err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) return } @@ -140,7 +140,7 @@ func GoTestHandler(w http.ResponseWriter, r *http.Request) { err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) } wsChannel.Refresh() diff --git a/output/vet.go b/output/vet.go index dba29c7..978cf89 100644 --- a/output/vet.go +++ b/output/vet.go @@ -95,7 +95,7 @@ func GoVetHandler(w http.ResponseWriter, r *http.Request) { err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) return } @@ -140,7 +140,7 @@ func GoVetHandler(w http.ResponseWriter, r *http.Request) { err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) } wsChannel.Refresh() diff --git a/playground/run.go b/playground/run.go index 92c8b6d..21e8d59 100644 --- a/playground/run.go +++ b/playground/run.go @@ -96,7 +96,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) { err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) return } @@ -123,7 +123,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) { channelRet["output"] = "" err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) return } @@ -153,7 +153,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) { channelRet["output"] = buf.content err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) break } @@ -182,7 +182,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) { err = wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) break } @@ -220,7 +220,7 @@ func RunHandler(w http.ResponseWriter, r *http.Request) { err = wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) break } diff --git a/scm/git/clone.go b/scm/git/clone.go index 0decc02..30a76ff 100644 --- a/scm/git/clone.go +++ b/scm/git/clone.go @@ -95,7 +95,7 @@ func CloneHandler(w http.ResponseWriter, r *http.Request) { err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) return } @@ -132,7 +132,7 @@ func CloneHandler(w http.ResponseWriter, r *http.Request) { err := wsChannel.WriteJSON(&channelRet) if nil != err { - logger.Error(err) + logger.Warn(err) } wsChannel.Refresh()