|
@@ -39,16 +39,16 @@ func (c *Context) AutoCommit() {
|
|
|
//we need to shutdown
|
|
|
log.Infof("sqlite routine shutdown")
|
|
|
if err := c.Flush(); err != nil {
|
|
|
- log.Warningf("error while flushing records: %s", err)
|
|
|
+ log.Errorf("error while flushing records: %s", err)
|
|
|
}
|
|
|
if ret := c.tx.Commit(); ret.Error != nil {
|
|
|
- log.Warningf("failed to commit records : %v", ret.Error)
|
|
|
+ log.Errorf("failed to commit records : %v", ret.Error)
|
|
|
}
|
|
|
if err := c.tx.Close(); err != nil {
|
|
|
- log.Warningf("error while closing tx : %s", err)
|
|
|
+ log.Errorf("error while closing tx : %s", err)
|
|
|
}
|
|
|
if err := c.Db.Close(); err != nil {
|
|
|
- log.Warningf("error while closing db : %s", err)
|
|
|
+ log.Errorf("error while closing db : %s", err)
|
|
|
}
|
|
|
return
|
|
|
case <-ticker.C:
|