()
| 119 | } |
| 120 | |
| 121 | func (usp *UnixSockPipe) Close() error { |
| 122 | if usp.sender != nil { |
| 123 | if err := usp.sender.Close(); err != nil { |
| 124 | usp.Log.Error("failed to close sender socket", err) |
| 125 | } |
| 126 | } |
| 127 | if usp.listener != nil { |
| 128 | if err := usp.listener.Close(); err != nil { |
| 129 | usp.Log.Error("failed to close listener", err) |
| 130 | } |
| 131 | if err := os.Remove(usp.SockPath); err != nil { |
| 132 | usp.Log.Error("failed to remove socket", err) |
| 133 | } |
| 134 | } |
| 135 | return nil |
| 136 | } |