pegasus/anope
1
0
Fork 0
mirror of https://github.com/anope/anope.git synced 2026-07-09 01:23:13 +02:00
Code Activity

Temporary fix for /os restart with m_async_commands loaded, is fixed properly in 1.9.5

Browse Source
This commit is contained in:
Adam
2011-04-29 18:03:04 -04:00
parent 7da33344d1
commit 036b3c9053
3 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
modules/extra/m_async_commands.cpp
+2
View File
@@ -150,6 +150,8 @@ class ModuleAsynchCommands : public Module, public Pipe, public AsynchCommandsSe
}
else if (current_command)
return EVENT_CONTINUE;
else if (command->name == "RESTART")
return EVENT_CONTINUE;
CommandSource source_copy = source;
AsynchCommandMutex *cm = new AsynchCommandMutex(source_copy, command, params);
modules/extra/m_ssl.cpp
+2 -2
View File
@@ -202,14 +202,14 @@ SSLSocketIO::SSLSocketIO()
int SSLSocketIO::Recv(Socket *s, char *buf, size_t sz) const
{
size_t i = SSL_read(this->sslsock, buf, sz);
int i = SSL_read(this->sslsock, buf, sz);
TotalRead += i;
return i;
}
int SSLSocketIO::Send(Socket *s, const Anope::string &buf) const
{
size_t i = SSL_write(this->sslsock, buf.c_str(), buf.length());
int i = SSL_write(this->sslsock, buf.c_str(), buf.length());
TotalWritten += i;
return i;
}
src/sockets.cpp
+1 -1
View File
@@ -522,7 +522,7 @@ bool BufferedSocket::ProcessWrite()
if (this->WriteBuffer.empty())
return true;
int count = this->IO->Send(this, this->WriteBuffer);
if (count == -1)
if (count <= -1)
return false;
this->WriteBuffer = this->WriteBuffer.substr(count);
if (this->WriteBuffer.empty())