()
| 394 | } |
| 395 | |
| 396 | func (s *kunLogStatStore) Close() (string, error) { |
| 397 | if s.flags.Has(flagClosed) { |
| 398 | return "", errReceiverClosed |
| 399 | } |
| 400 | s.mutex.Lock() |
| 401 | if !s.flags.Has(flagClosed) { |
| 402 | s.setFlagLocked(flagClosed) |
| 403 | s.setFlagLocked(flagErrdone) |
| 404 | s.setFlagLocked(flagOutdone) |
| 405 | } |
| 406 | data := s.LogData() |
| 407 | s.mutex.Unlock() |
| 408 | if s.logfile != nil { |
| 409 | s.logfile.Close() |
| 410 | s.logfile = nil |
| 411 | } |
| 412 | |
| 413 | return data, nil |
| 414 | } |
| 415 | |
| 416 | func (s *kunLogStatStore) Wait() { |
| 417 | s.waitg.Wait() |
nothing calls this directly
no test coverage detected