143   reactor_object_t* object =  in reactor_register()  local
146   object->reactor = reactor;  in reactor_register()
147   object->fd = fd;  in reactor_register()
148   object->context = context;  in reactor_register()
149   object->read_ready = read_ready;  in reactor_register()
150   object->write_ready = write_ready;  in reactor_register()
151   object->mutex = new std::mutex;  in reactor_register()
157   event.data.ptr = object;  in reactor_register()
162     delete object->mutex;  in reactor_register()
163     osi_free(object);  in reactor_register()
167   return object;  in reactor_register()
170 bool reactor_change_registration(reactor_object_t* object,  in reactor_change_registration()  argument
173   CHECK(object != NULL);  in reactor_change_registration()
179   event.data.ptr = object;  in reactor_change_registration()
181   if (epoll_ctl(object->reactor->epoll_fd, EPOLL_CTL_MOD, object->fd, &event) ==  in reactor_change_registration()
184               object->fd, strerror(errno));  in reactor_change_registration()
188   std::lock_guard<std::mutex> lock(*object->mutex);  in reactor_change_registration()
189   object->read_ready = read_ready;  in reactor_change_registration()
190   object->write_ready = write_ready;  in reactor_change_registration()
264       reactor_object_t* object = (reactor_object_t*)events[j].data.ptr;  in run_reactor()  local
267       if (list_contains(reactor->invalidation_list, object)) {  in run_reactor()
273         std::lock_guard<std::mutex> obj_lock(*object->mutex);  in run_reactor()
278             object->read_ready)  in run_reactor()
279           object->read_ready(object->context);  in run_reactor()
281             object->write_ready)  in run_reactor()
282           object->write_ready(object->context);  in run_reactor()
286         delete object->mutex;  in run_reactor()
287         osi_free(object);  in run_reactor()