ouch/inspircd
2
0
Fork 0
mirror of https://github.com/inspircd/inspircd.git synced 2025-03-12 03:59:03 -04:00
Code Issues Packages Projects Releases Wiki Activity

Fix to trigger the write notification on successful writes, too

Browse Source 
git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@7662 e03df62e-2008-0410-955e-edbf42e46eb7
This commit is contained in:
brain 2007-08-05 14:40:16 +00:00
parent 1e2e45fdc3
commit 82ce717cd2
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/modules/extra/m_ssl_openssl.cpp
View File

@ -589,12 +589,13 @@ class ModuleSSLOpenSSL : public Module
}
else if (ret < 0)
{
MakePollWrite(session);
int err = SSL_get_error(session->sess, ret);
if (err == SSL_ERROR_WANT_WRITE)
{
session->wstat = ISSL_WRITE;
MakePollWrite(session);
return -1;
}
else if (err == SSL_ERROR_WANT_READ)
@ -611,6 +612,7 @@ class ModuleSSLOpenSSL : public Module
else
{
session->outbuf = session->outbuf.substr(ret);
MakePollWrite(session);
return ret;
}
}
@ -798,14 +800,14 @@ class ModuleSSLOpenSSL : public Module
ServerInstance->SE->WantWrite(eh);
}
virtual void OnBufferFlushed(userrec* user)
{
if (user->GetExt("ssl"))
virtual void OnBufferFlushed(userrec* user)
{
ServerInstance->Log(DEBUG,"OnBufferFlushed for ssl user");
issl_session* session = &sessions[user->GetFd()];
if (session && session->outbuf.size())
OnRawSocketWrite(user->GetFd(), NULL, 0);
if (user->GetExt("ssl"))
{
ServerInstance->Log(DEBUG,"OnBufferFlushed for ssl user");
issl_session* session = &sessions[user->GetFd()];
if (session && session->outbuf.size())
OnRawSocketWrite(user->GetFd(), NULL, 0);
}
}