| 148 | } |
| 149 | |
| 150 | bool KqueueProxy::KqueueDel(KqObjList& obj_list) |
| 151 | { |
| 152 | bool ret = true; |
| 153 | |
| 154 | KqueuerObj *kqobj = NULL; |
| 155 | TAILQ_FOREACH(kqobj, &obj_list, _entry) |
| 156 | { |
| 157 | if (!KqueueDelObj(kqobj)) // failed also need continue, be sure ref count ok |
| 158 | { |
| 159 | MTLOG_ERROR("epobj del failed, fd: %d", kqobj->GetOsfd()); |
| 160 | kqueue_assert(0); |
| 161 | ret = false; |
| 162 | } |
| 163 | } |
| 164 | |
| 165 | return ret; |
| 166 | } |
| 167 | |
| 168 | bool KqueueProxy::KqueueCtrlAdd(int fd, int events) |
| 169 | { |