()
| 148 | } |
| 149 | |
| 150 | func (this *LogWriter) Recover() { |
| 151 | if r := recover(); r != nil { |
| 152 | LogError("log_manager", "log worker recover[%v]", r) |
| 153 | debug.PrintStack() |
| 154 | go this.Run(false) |
| 155 | } |
| 156 | } |
| 157 | |
| 158 | func (this *LogWriter) syncLog() { |
| 159 | for _, filter := range this.filter { |