From 11c0438e8553ba7f8b555c8837bebe3a49556ea2 Mon Sep 17 00:00:00 2001 From: skotlex Date: Mon, 10 Dec 2007 19:13:12 +0000 Subject: [PATCH] - The interserver outgoing buffer now gets flushed when it reaches 512KB of data stored on it. git-svn-id: https://svn.code.sf.net/p/rathena/svn/trunk@11886 54d463be-8e91-2dee-dedb-b68131a5f0ec --- src/common/socket.c | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/src/common/socket.c b/src/common/socket.c index 9907845eb7..966e27626b 100644 --- a/src/common/socket.c +++ b/src/common/socket.c @@ -210,9 +210,9 @@ int send_from_fifo(int fd) return 0; } - // some data could not be transferred? if( len > 0 ) { + // some data could not be transferred? // shift unsent data to the beginning of the queue if( (size_t)len < session[fd]->wdata_size ) memmove(session[fd]->wdata, session[fd]->wdata + len, session[fd]->wdata_size - len); @@ -507,6 +507,11 @@ int WFIFOSET(int fd, size_t len) } s->wdata_size += len; + //If the interserver has 200% of its normal size full, flush the data. + if(s->max_wdata >= FIFOSIZE_SERVERLINK && + s->wdata_size >= 2*FIFOSIZE_SERVERLINK) + flush_fifo(fd); + // always keep a WFIFO_SIZE reserve in the buffer // For inter-server connections, let the reserve be 1/4th of the link size. newreserve = s->wdata_size + (s->max_wdata >= FIFOSIZE_SERVERLINK ? FIFOSIZE_SERVERLINK / 4 : WFIFO_SIZE);