From 2a12f93949e18946e401534e8b722414c4109bfe Mon Sep 17 00:00:00 2001
From: Andrei Karas <akaras@inbox.ru>
Date: Sun, 19 Aug 2012 15:44:41 +0300
Subject: Increase buffers size and flush send buffer if it too big.

---
 src/net/tmwa/messageout.cpp |  1 +
 src/net/tmwa/network.cpp    | 14 +++++++++++++-
 src/net/tmwa/network.h      |  2 ++
 3 files changed, 16 insertions(+), 1 deletion(-)

diff --git a/src/net/tmwa/messageout.cpp b/src/net/tmwa/messageout.cpp
index b6fcc09a1..c7af9baf6 100644
--- a/src/net/tmwa/messageout.cpp
+++ b/src/net/tmwa/messageout.cpp
@@ -43,6 +43,7 @@ MessageOut::MessageOut(short id):
     Net::MessageOut(id)
 {
     mNetwork = TmwAthena::Network::instance();
+    mNetwork->fixSendBuffer();
     mData = mNetwork->mOutBuffer + mNetwork->mOutSize;
     writeInt16(id);
 }
diff --git a/src/net/tmwa/network.cpp b/src/net/tmwa/network.cpp
index 5beb05c20..783b4b773 100644
--- a/src/net/tmwa/network.cpp
+++ b/src/net/tmwa/network.cpp
@@ -85,7 +85,8 @@ short packet_lengths[] =
    -1,122,  0,  0,  0,  0,  0,  0,  0,  0,  0,  0,  0,  0,  0,  0,
 };
 
-const unsigned int BUFFER_SIZE = 655360;
+const unsigned int BUFFER_SIZE = 1000000;
+const unsigned int BUFFER_LIMIT = 930000;
 
 namespace TmwAthena
 {
@@ -482,4 +483,15 @@ Uint16 Network::readWord(int pos)
 #endif
 }
 
+void Network::fixSendBuffer()
+{
+    if (mOutSize > BUFFER_LIMIT)
+    {
+        if (mState != CONNECTED)
+            mOutSize = 0;
+        else
+            flush();
+    }
+}
+
 } // namespace TmwAthena
diff --git a/src/net/tmwa/network.h b/src/net/tmwa/network.h
index 757358c25..f5e070a72 100644
--- a/src/net/tmwa/network.h
+++ b/src/net/tmwa/network.h
@@ -87,6 +87,8 @@ class Network
 
         void flush();
 
+        void fixSendBuffer();
+
         // ERROR replaced by NET_ERROR because already defined in Windows
         enum
         {
-- 
cgit v1.2.3-60-g2f50