mirror of
https://github.com/stefanocasazza/ULib.git
synced 2025-10-05 19:18:01 +08:00
Update notifier.cpp
This commit is contained in:
parent
6f13627882
commit
2e02d0cc30
|
@ -1374,8 +1374,7 @@ bool UNotifier::waitOnAsynchronousConnects(const UVector<UEventFd *>& waiting, i
|
||||||
struct epoll_event *events;
|
struct epoll_event *events;
|
||||||
struct epoll_event *pevents;
|
struct epoll_event *pevents;
|
||||||
|
|
||||||
size_t maxConnects = waitingOnNConnects + 1;
|
events = pevents = (struct epoll_event*) UMemoryPool::malloc(waiting.size() + 1, sizeof(struct epoll_event), true);
|
||||||
events = pevents = (struct epoll_event*) UMemoryPool::malloc(maxConnects, sizeof(struct epoll_event), true);
|
|
||||||
|
|
||||||
for (UEventFd *waiter : waiting)
|
for (UEventFd *waiter : waiting)
|
||||||
{
|
{
|
||||||
|
@ -1411,7 +1410,7 @@ bool UNotifier::waitOnAsynchronousConnects(const UVector<UEventFd *>& waiting, i
|
||||||
}
|
}
|
||||||
} while (waitingOnNConnects > 0);
|
} while (waitingOnNConnects > 0);
|
||||||
|
|
||||||
UMemoryPool::_free(events, maxConnects, sizeof(struct epoll_event));
|
UMemoryPool::_free(events, waiting.size() + 1, sizeof(struct epoll_event));
|
||||||
(void)U_FF_SYSCALL(close, "%d", epollfd);
|
(void)U_FF_SYSCALL(close, "%d", epollfd);
|
||||||
|
|
||||||
U_RETURN(result);
|
U_RETURN(result);
|
||||||
|
|
Loading…
Reference in New Issue
Block a user