for (int i = 0; i < descriptor->handler->sockcount; i++) {
if (descriptor->handler->pollfds[i].fd == descriptor->fd) {
if (pause_read) {
- descriptor->handler->pollfds[i].events &= POLLIN;
- descriptor->handler->pollfds[i].events |= POLLOUT;
+ descriptor->handler->pollfds[i].events = POLLOUT;
} else {
- descriptor->handler->pollfds[i].events |= POLLIN;
+ descriptor->handler->pollfds[i].events = POLLIN;
}
break;
}
const struct Descriptor *descriptor = (const struct Descriptor*)desc;
return (uint64_t)descriptor->fd;
}
-static void* sock_clone(const void* desc) {
- const struct Descriptor *descriptor = (const struct Descriptor*)desc;
+static void sock_cloned(LDKSocketDescriptor *NONNULL_PTR ldk_desc) {
+ const struct Descriptor *descriptor = (const struct Descriptor*)ldk_desc->this_arg;
struct Descriptor *new_desc = malloc(sizeof(struct Descriptor));
new_desc->handler = descriptor->handler;
new_desc->fd = descriptor->fd;
- return new_desc;
+ ldk_desc->this_arg = (void*) new_desc;
}
static void sock_free(void* desc) {
free(desc);
.disconnect_socket = sock_disconnect,
.eq = sock_eq,
.hash = sock_hash,
- .clone = sock_clone,
+ .cloned = sock_cloned,
.free = sock_free,
};
return ret;
lockres = pthread_mutex_lock(&handler->sockets_mutex);
assert(lockres == 0);
assert(handler->pollfds[i - 1].fd == pollfds[i].fd); // Only we change fd order!
- handler->pollfds[i - 1].events &= POLLIN;
- handler->pollfds[i - 1].events |= POLLOUT;
+ handler->pollfds[i - 1].events = POLLOUT;
lockres = pthread_mutex_unlock(&handler->sockets_mutex);
assert(lockres == 0);
}