darlinghq/darling-libkqueue
1
0
Fork 0
mirror of https://github.com/darlinghq/darling-libkqueue.git synced 2024-11-23 03:39:51 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add internal kqueue_dup()

Browse Source
This commit is contained in:
Lubos Dolezel 2020-04-27 11:27:13 +02:00
parent 2c2d5cfd06
commit 0bed997345
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/common/kqueue.c
View File

@ -172,6 +172,24 @@ kqueue_close(int kqfd)
pthread_mutex_unlock(&kq_mtx);
}
void VISIBLE
kqueue_dup(int oldfd, int newfd)
{
if (kqmap == NULL)
return;
pthread_mutex_lock(&kq_mtx);
struct kqueue* kq = kqueue_lookup(oldfd);
if (kq != NULL)
{
kqueue_addref(kq);
map_insert(kqmap, newfd, kq);
}
pthread_mutex_unlock(&kq_mtx);
}
static void _kqueue_close_atfork_cb(int kqfd, void* kqptr, void* private)
{
struct kqueue* kq = (struct kqueue*) kqptr;
@ -179,7 +197,7 @@ static void _kqueue_close_atfork_cb(int kqfd, void* kqptr, void* private)
// Mutexes are not valid after a fork, reset it to unlocked state
pthread_mutex_init(&kq->kq_mtx, NULL);
kqueue_free(kq);
kqueue_delref(kq);
__close_for_kqueue(kqfd);
}