#include "portab.h"
-static char UNUSED id[] = "$Id: io.c,v 1.4 2005/07/14 09:20:39 alex Exp $";
+static char UNUSED id[] = "$Id: io.c,v 1.6 2005/08/27 20:25:54 fw Exp $";
#include <assert.h>
#include <stdlib.h>
#endif
#endif
+static bool library_initialized;
#ifdef IO_USE_EPOLL
#include <sys/epoll.h>
bool
io_library_init(unsigned int eventsize)
{
+ bool ret;
#ifdef IO_USE_EPOLL
int ecreate_hint = (int)eventsize;
if (ecreate_hint <= 0)
ecreate_hint = 128;
#endif
+ if (library_initialized)
+ return true;
+
#ifdef IO_USE_SELECT
#ifdef FD_SETSIZE
if (eventsize >= FD_SETSIZE)
Log(LOG_INFO,
"IO subsystem: epoll (hint size %d, initial maxfd %u, masterfd %d).",
ecreate_hint, eventsize, io_masterfd);
- return io_masterfd >= 0;
+ ret = io_masterfd >= 0;
+ if (ret) library_initialized = true;
+
+ return ret;
#endif
#ifdef IO_USE_SELECT
Log(LOG_INFO, "IO subsystem: select (initial maxfd %u).",
#else
Log(LOG_WARNING,
"FD_SETSIZE undefined, don't know how many descriptors select() can handle on your platform ...");
-#endif
+#endif /* FD_SETSIZE */
+ library_initialized = true;
return true;
-#endif
+#endif /* SELECT */
#ifdef IO_USE_KQUEUE
io_masterfd = kqueue();
Log(LOG_INFO,
"IO subsystem: kqueue (initial maxfd %u, masterfd %d)",
eventsize, io_masterfd);
- return io_masterfd >= 0;
+ ret = io_masterfd >= 0;
+ if (ret) library_initialized = true;
+
+ return ret;
#endif
}
#ifdef IO_USE_KQUEUE
array_free(&io_evcache);
#endif
+ library_initialized = false;
}
struct kevent kev;
short filter = 0;
unsigned int len = array_length(&io_evcache, sizeof kev);
- bool ret;
if (what & IO_WANTREAD)
filter = EVFILT_READ;
filter |= EVFILT_WRITE;
if (len >= 100) {
- ret = io_event_kqueue_commit_cache();
- if (ret)
- array_trunc(&io_evcache);
+ (void)array_trunc(&io_evcache);
}
EV_SET(&kev, fd, filter, EV_ADD | EV_ENABLE, 0, 0, NULL);
{
int i, total = 0, ret;
struct kevent kev[100];
- struct kevents *newevents;
+ struct kevent *newevents;
struct timespec ts;
int newevents_len;
short type;