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

Regressed buffering code

Browse Source 
git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@3759 e03df62e-2008-0410-955e-edbf42e46eb7
This commit is contained in:
brain 2006-03-26 14:12:45 +00:00
parent b1cbabb6da
commit 2d04042f17
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/socket.cpp
View File

@ -257,15 +257,15 @@ int InspSocket::Write(const std::string &data)
if (this->ClosePending)
return false;
int result = write(this->fd,data.c_str(),data.length());
/*int result = write(this->fd,data.c_str(),data.length());
if (result < 1)
return false;
return true;
return true;*/
/* Try and append the data to the back of the queue, and send it on its way
*/
//outbuffer.push_back(data);
//return (!this->FlushWriteBuffer());
outbuffer.push_back(data);
return (!this->FlushWriteBuffer());
}
bool InspSocket::FlushWriteBuffer()
@ -273,7 +273,7 @@ bool InspSocket::FlushWriteBuffer()
if (this->ClosePending)
return true;
/*if ((this->fd > -1) && (this->state == I_CONNECTED))
if ((this->fd > -1) && (this->state == I_CONNECTED))
{
if (outbuffer.size())
{
@ -284,9 +284,9 @@ bool InspSocket::FlushWriteBuffer()
log(DEBUG,"Wrote %d to socket",result);
if ((unsigned int)result == outbuffer[0].length())
{
* The whole block was written (usually a line)
/* The whole block was written (usually a line)
* Pop the block off the front of the queue
*
*/
log(DEBUG,"Popping front item, now %d items left",outbuffer.size());
outbuffer.pop_front();
}
@ -306,7 +306,7 @@ bool InspSocket::FlushWriteBuffer()
return true;
}
}
}*/
}
return false;
}