diff options
| author | brain <brain@e03df62e-2008-0410-955e-edbf42e46eb7> | 2006-03-11 19:58:10 +0000 |
|---|---|---|
| committer | brain <brain@e03df62e-2008-0410-955e-edbf42e46eb7> | 2006-03-11 19:58:10 +0000 |
| commit | 4c03c456e65cb9d8143b25cc11b9b269798ece60 (patch) | |
| tree | b8a22e61a2c7ccc076ad66a645e594fa25dd165a /src/socket.cpp | |
| parent | 59cdf913f1a7fde4e4fbb4af4e13046b9bd20b0a (diff) | |
Temporarily removed output buffering as an experiment
git-svn-id: http://svn.inspircd.org/repository/trunk/inspircd@3683 e03df62e-2008-0410-955e-edbf42e46eb7
Diffstat (limited to 'src/socket.cpp')
| -rw-r--r-- | src/socket.cpp | 16 |
1 files changed, 10 insertions, 6 deletions
diff --git a/src/socket.cpp b/src/socket.cpp index 2ab7d7a57..06e01f54c 100644 --- a/src/socket.cpp +++ b/src/socket.cpp @@ -256,10 +256,14 @@ int InspSocket::Write(const std::string &data) { if (this->ClosePending) return false; + + write(this->fd,data.c_str(),data.length()); + 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() @@ -267,7 +271,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()) { @@ -278,9 +282,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(); } @@ -300,7 +304,7 @@ bool InspSocket::FlushWriteBuffer() return true; } } - } + }*/ return false; } |