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;
}
if (newfd >= 0) {
// Received a new connection, register it!
LDKSocketDescriptor new_descriptor = get_descriptor(handler, newfd);
- LDKCResult_NonePeerHandleErrorZ con_res = PeerManager_new_inbound_connection(&handler->ldk_peer_manager, new_descriptor);
+ LDKCOption_NetAddressZ remote_network_address = {
+ .tag = LDKCOption_NetAddressZ_None,
+ };
+ LDKCResult_NonePeerHandleErrorZ con_res = PeerManager_new_inbound_connection(&handler->ldk_peer_manager, new_descriptor, remote_network_address);
if (con_res.result_ok) {
if (register_socket(handler, newfd, 0))
shutdown(newfd, SHUT_RDWR);
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);
}
if (register_socket(handler, fd, 0)) return -4;
LDKSocketDescriptor descriptor = get_descriptor(handler, fd);
- LDKCResult_CVec_u8ZPeerHandleErrorZ con_res = PeerManager_new_outbound_connection(&handler->ldk_peer_manager, pubkey, descriptor);
+ LDKCOption_NetAddressZ remote_network_address = {
+ .tag = LDKCOption_NetAddressZ_None,
+ };
+ LDKCResult_CVec_u8ZPeerHandleErrorZ con_res = PeerManager_new_outbound_connection(&handler->ldk_peer_manager, pubkey, descriptor, remote_network_address);
if (con_res.result_ok) {
ssize_t write_count = send(fd, con_res.contents.result->data, con_res.contents.result->datalen, MSG_NOSIGNAL);
if (write_count != con_res.contents.result->datalen)