diff options
Diffstat (limited to 'rhimport/session.go')
| -rw-r--r-- | rhimport/session.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/rhimport/session.go b/rhimport/session.go index 1c3439d..a119285 100644 --- a/rhimport/session.go +++ b/rhimport/session.go @@ -155,7 +155,7 @@ func (self *Session) run(timeout time.Duration) { go sessionRun(self.ctx, self.doneIntChan) self.state = SESSION_RUNNING if timeout > 3*time.Hour { - rhl.Printf("requested session timeout (%v) is to high - lowering to 3h", timeout) + self.ctx.stdlog.Printf("requested session timeout (%v) is to high - lowering to 3h", timeout) timeout = 3 * time.Hour } self.timer.Reset(timeout) @@ -163,7 +163,7 @@ func (self *Session) run(timeout time.Duration) { } func (self *Session) cancel() { - rhdl.Println("Session: canceling running import") + self.ctx.dbglog.Println("Session: canceling running import") select { case self.cancelIntChan <- true: default: // session got canceled already?? @@ -380,7 +380,7 @@ func (self *Session) getInterface() *SessionChan { func (self *Session) cleanup() { self.quit <- true - rhdl.Printf("Session: waiting for session to close") + self.ctx.dbglog.Printf("Session: waiting for session to close") <-self.done close(self.quit) close(self.done) @@ -395,7 +395,7 @@ func (self *Session) cleanup() { // close(self.addProgressChan) // close(self.addDoneChan) // close(self.attachUploader) - rhdl.Printf("Session: cleanup is now done") + self.ctx.dbglog.Printf("Session: cleanup is now done") } func newSession(ctx *Context, removeFunc func()) (session *Session) { |