#include "pollmgr.h"
PollMgr *PollMgr::instance = NULL;
-static std::once_flag pollmgr_is_initialized;
+static once_flag pollmgr_is_initialized;
static void
PollMgrInit()
PollMgr *
PollMgr::Instance()
{
- std::call_once(pollmgr_is_initialized, PollMgrInit);
+ call_once(pollmgr_is_initialized, PollMgrInit);
return instance;
}
aio_ = new SelectAIO();
//aio_ = new EPollAIO();
- th_ = std::thread(&PollMgr::wait_loop, this);
+ th_ = thread(&PollMgr::wait_loop, this);
}
PollMgr::~PollMgr() [[noreturn]]
PollMgr::wait_loop() [[noreturn]]
{
- std::vector<int> readable;
- std::vector<int> writable;
+ vector<int> readable;
+ vector<int> writable;
while (1) {
{
}
void
-SelectAIO::wait_ready(std::vector<int> *readable, std::vector<int> *writable)
+SelectAIO::wait_ready(vector<int> *readable, vector<int> *writable)
{
fd_set trfds, twfds;
int high;
return;
} else {
perror("select:");
- IF_LEVEL(0) LOG("PollMgr::select_loop failure errno " << errno);
+ IF_LEVEL(0) LOG("select_loop failure errno " << errno);
VERIFY(0);
}
}
}
void
-EPollAIO::wait_ready(std::vector<int> *readable, std::vector<int> *writable)
+EPollAIO::wait_ready(vector<int> *readable, vector<int> *writable)
{
int nfds = epoll_wait(pollfd_, ready_, MAX_POLL_FDS, -1);
for (int i = 0; i < nfds; i++) {