| 212 | |
| 213 | protected: |
| 214 | void uninit(int flag) { |
| 215 | pwrn("uninit, pipe:[%d,%d], m_fd:%d, queue:%d, flag:%d", m_pipefd[0], m_pipefd[1], m_fd, m_sendQueue.size(), flag); |
| 216 | if (m_pipefd[0]) { |
| 217 | close(m_pipefd[0]); |
| 218 | m_pipefd[0] = 0; |
| 219 | } |
| 220 | if (m_pipefd[1]) { |
| 221 | close(m_pipefd[1]); |
| 222 | m_pipefd[1] = 0; |
| 223 | } |
| 224 | if (m_fd) { |
| 225 | close(m_fd); |
| 226 | m_fd = 0; |
| 227 | } |
| 228 | while (m_sendQueue.size()) { |
| 229 | SendPack *s = m_sendQueue.pop(); |
| 230 | delete[] s->data; |
| 231 | delete s; |
| 232 | } |
| 233 | } |
| 234 | |
| 235 | public: |
| 236 | LocalSocket() { |