errno = save;
}
-bool StreamSocket::cull()
+CullResult StreamSocket::cull()
{
Close();
- return true;
+ return EventHandler::cull();
}
bool StreamSocket::GetNextLine(std::string& line, char delim)
else if (rv > 0)
{
// Partial write. Clean out strings from the sendq
+ if (rv < rv_max)
+ {
+ // it's going to block now
+ eventChange = FD_WANT_FAST_WRITE | FD_WRITE_WILL_BLOCK;
+ }
sendq_len -= rv;
while (rv > 0 && !sendq.empty())
{
rv = 0;
}
}
- if (rv < rv_max)
- {
- // it's going to block now
- eventChange = FD_WANT_FAST_WRITE | FD_WRITE_WILL_BLOCK;
- }
}
else if (rv == 0)
{