From 92318a47bd59659e2dbfde174b14893ee2fe4afa Mon Sep 17 00:00:00 2001
From: JoelKatz <DavidJoelSchwartz@GMail.com>
Date: Sun, 10 Mar 2013 19:15:28 -0700
Subject: [PATCH] Log when we would disconnected, but don't actually disconnect
 for now.

---
 src/cpp/ripple/LoadManager.cpp |  6 ++++++
 src/cpp/ripple/LoadManager.h   | 10 ++++++++--
 src/cpp/ripple/WSConnection.h  |  2 ++
 3 files changed, 16 insertions(+), 2 deletions(-)

diff --git a/src/cpp/ripple/LoadManager.cpp b/src/cpp/ripple/LoadManager.cpp
index 5384df4bd..41d15ac94 100644
--- a/src/cpp/ripple/LoadManager.cpp
+++ b/src/cpp/ripple/LoadManager.cpp
@@ -124,7 +124,10 @@ void LoadManager::canonicalize(LoadSource& source, int now) const
 		{
 			source.mBalance += mCreditRate * (now - source.mLastUpdate);
 			if (source.mBalance > mCreditLimit)
+			{
 				source.mBalance = mCreditLimit;
+				source.mLogged = false;
+			}
 		}
 		source.mLastUpdate = now;
 	}
@@ -154,6 +157,9 @@ bool LoadManager::shouldCutoff(LoadSource& source) const
 		canonicalize(source, now);
 		if (source.isPrivileged() || (source.mBalance > mDebitLimit))
 			return false;
+		if (source.mLogged)
+			return true;
+		source.mLogged = true;
 	}
 	logDisconnect(source.getName());
 	return true;
diff --git a/src/cpp/ripple/LoadManager.h b/src/cpp/ripple/LoadManager.h
index 070384d70..25b8aa585 100644
--- a/src/cpp/ripple/LoadManager.h
+++ b/src/cpp/ripple/LoadManager.h
@@ -66,11 +66,14 @@ protected:
 	int			mFlags;
 	int			mLastUpdate;
 	int			mLastWarning;
+	bool		mLogged;
 
 public:
-	LoadSource(bool admin) : mBalance(0), mFlags(admin ? lsfPrivileged : 0), mLastUpdate(upTime()), mLastWarning(0)
+	LoadSource(bool admin) :
+		mBalance(0), mFlags(admin ? lsfPrivileged : 0), mLastUpdate(upTime()), mLastWarning(0), mLogged(false)
 	{ ; }
-	LoadSource(const std::string& name) : mName(name), mBalance(0), mFlags(0), mLastUpdate(upTime()), mLastWarning(0)
+	LoadSource(const std::string& name) :
+		mName(name), mBalance(0), mFlags(0), mLastUpdate(upTime()), mLastWarning(0), mLogged(false)
 	{ ; }
 
 	void rename(const std::string& name)	{ mName = name; }
@@ -80,6 +83,9 @@ public:
 	void	setPrivileged()			{ mFlags |= lsfPrivileged; }
 	int		getBalance() const		{ return mBalance; }
 
+	bool isLogged() const			{ return mLogged; }
+	void clearLogged()				{ mLogged = false; }
+
 	void	setOutbound()			{ mFlags |= lsfOutbound; }
 	bool	isOutbound() const		{ return (mFlags & lsfOutbound) != 0; }
 };
diff --git a/src/cpp/ripple/WSConnection.h b/src/cpp/ripple/WSConnection.h
index bc928d713..6f3aa2cd2 100644
--- a/src/cpp/ripple/WSConnection.h
+++ b/src/cpp/ripple/WSConnection.h
@@ -90,10 +90,12 @@ public:
 	{
 		if (theApp->getLoadManager().shouldCutoff(mLoadSource))
 		{
+#if SHOULD_DISCONNECT
 			connection_ptr ptr = mConnection.lock();
 			if (ptr)
 				ptr->close(websocketpp::close::status::PROTOCOL_ERROR, "overload");
 			return rpcError(rpcSLOW_DOWN);
+#endif
 		}
 
 		if (!jvRequest.isMember("command"))