pegasus/anope
1
0
Fork 0
mirror of https://github.com/anope/anope.git synced 2026-06-28 23:26:39 +02:00
Code Activity

Fix some compile errors

Browse Source
This commit is contained in:
Adam
2013-01-22 21:20:05 -05:00
parent f656e3195f
commit a634c7be65
3 changed files with 24 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/socketengines/socketengine_poll.cpp
+11 -14
View File
@@ -48,17 +48,14 @@ void SocketEngine::Shutdown()
void SocketEngine::Change(Socket *s, bool set, SocketFlag flag)
{
if (set == s->HasFlag(flag))
if (set == s->flags[flag])
return;
bool before_registered = s->HasFlag(SF_READABLE) || s->HasFlag(SF_WRITABLE);
bool before_registered = s->flags[SF_READABLE] || s->flags[SF_WRITABLE];
if (set)
s->SetFlag(flag);
else
s->UnsetFlag(flag);
bool now_registered = s->HasFlag(SF_READABLE) || s->HasFlag(SF_WRITABLE);
s->flags[flag] = set;
bool now_registered = s->flags[SF_READABLE] || s->flags[SF_WRITABLE];
if (!before_registered && now_registered)
{
@@ -69,7 +66,7 @@ void SocketEngine::Change(Socket *s, bool set, SocketFlag flag)
memset(&ev, 0, sizeof(ev));
ev.fd = s->GetFD();
ev.events = (s->HasFlag(SF_READABLE) ? POLLIN : 0) | (s->HasFlag(SF_WRITABLE) ? POLLOUT : 0);
ev.events = (s->flags[SF_READABLE] ? POLLIN : 0) | (s->flags[SF_WRITABLE] ? POLLOUT : 0);
socket_positions[ev.fd] = SocketCount;
++SocketCount;
@@ -100,7 +97,7 @@ void SocketEngine::Change(Socket *s, bool set, SocketFlag flag)
throw SocketException("Unable to modify fd " + stringify(s->GetFD()) + " in poll, it does not exist?");
pollfd &ev = events[pos->second];
ev.events = (s->HasFlag(SF_READABLE) ? POLLIN : 0) | (s->HasFlag(SF_WRITABLE) ? POLLOUT : 0);
ev.events = (s->flags[SF_READABLE] ? POLLIN : 0) | (s->flags[SF_WRITABLE] ? POLLOUT : 0);
}
}
@@ -141,18 +138,18 @@ void SocketEngine::Process()
if (!s->Process())
{
if (s->HasFlag(SF_DEAD))
if (s->flags[SF_DEAD])
delete s;
continue;
}
if ((ev->revents & POLLIN) && !s->ProcessRead())
s->SetFlag(SF_DEAD);
s->flags[SF_DEAD] = true;
if ((ev->revents & POLLOUT) && !s->ProcessWrite())
s->SetFlag(SF_DEAD);
s->flags[SF_DEAD] = true;
if (s->HasFlag(SF_DEAD))
if (s->flags[SF_DEAD])
delete s;
}
}