145   reactor_object_t* object =  in reactor_register()  local
148   object->reactor = reactor;  in reactor_register()
149   object->fd = fd;  in reactor_register()
150   object->context = context;  in reactor_register()
151   object->read_ready = read_ready;  in reactor_register()
152   object->write_ready = write_ready;  in reactor_register()
153   object->mutex = new std::mutex;  in reactor_register()
159   event.data.ptr = object;  in reactor_register()
164     delete object->mutex;  in reactor_register()
165     osi_free(object);  in reactor_register()
169   return object;  in reactor_register()
172 bool reactor_change_registration(reactor_object_t* object,  in reactor_change_registration()  argument
175   CHECK(object != NULL);  in reactor_change_registration()
181   event.data.ptr = object;  in reactor_change_registration()
183   if (epoll_ctl(object->reactor->epoll_fd, EPOLL_CTL_MOD, object->fd, &event) ==  in reactor_change_registration()
186               __func__, object->fd, strerror(errno));  in reactor_change_registration()
190   std::lock_guard<std::mutex> lock(*object->mutex);  in reactor_change_registration()
191   object->read_ready = read_ready;  in reactor_change_registration()
192   object->write_ready = write_ready;  in reactor_change_registration()
267       reactor_object_t* object = (reactor_object_t*)events[j].data.ptr;  in run_reactor()  local
270       if (list_contains(reactor->invalidation_list, object)) {  in run_reactor()
276         std::lock_guard<std::mutex> obj_lock(*object->mutex);  in run_reactor()
281             object->read_ready)  in run_reactor()
282           object->read_ready(object->context);  in run_reactor()
284             object->write_ready)  in run_reactor()
285           object->write_ready(object->context);  in run_reactor()
289         delete object->mutex;  in run_reactor()
290         osi_free(object);  in run_reactor()