aboutsummaryrefslogtreecommitdiff
path: root/main.cpp
diff options
context:
space:
mode:
authorGavin Andresen <gavinandresen@gmail.com>2010-12-12 16:03:42 -0500
committerGavin Andresen <gavinandresen@gmail.com>2010-12-12 16:03:42 -0500
commit9c17a685bdd69f60c3140f6d502696c880254893 (patch)
tree7d43675cfe4c300eadc024c6a023785a596cc396 /main.cpp
parentd12e53ea090ba49a82ff4f79782af809d21cf280 (diff)
parent986b5e257e2bb9d7aaed5111ca335732f8808b2d (diff)
Merge remote branch 'refs/remotes/svn/trunk' into svn
Diffstat (limited to 'main.cpp')
-rw-r--r--main.cpp46
1 files changed, 36 insertions, 10 deletions
diff --git a/main.cpp b/main.cpp
index 10d482d898..1d9b35b534 100644
--- a/main.cpp
+++ b/main.cpp
@@ -571,10 +571,15 @@ bool CTransaction::AcceptToMemoryPool(CTxDB& txdb, bool fCheckInputs, bool* pfMi
if ((int64)nLockTime > INT_MAX)
return error("AcceptToMemoryPool() : not accepting nLockTime beyond 2038 yet");
- // Rather not work on nonstandard transactions
- if (!IsStandard() || GetSigOpCount() > 2 || ::GetSerializeSize(*this, SER_NETWORK) < 100)
+ // Safety limits
+ unsigned int nSize = ::GetSerializeSize(*this, SER_NETWORK);
+ if (GetSigOpCount() > 2 || nSize < 100)
return error("AcceptToMemoryPool() : nonstandard transaction");
+ // Rather not work on nonstandard transactions
+ if (!IsStandard())
+ return error("AcceptToMemoryPool() : nonstandard transaction type");
+
// Do we already have it?
uint256 hash = GetHash();
CRITICAL_BLOCK(cs_mapTransactions)
@@ -612,14 +617,36 @@ bool CTransaction::AcceptToMemoryPool(CTxDB& txdb, bool fCheckInputs, bool* pfMi
}
}
- // Check against previous transactions
- map<uint256, CTxIndex> mapUnused;
- int64 nFees = 0;
- if (fCheckInputs && !ConnectInputs(txdb, mapUnused, CDiskTxPos(1,1,1), pindexBest, nFees, false, false))
+ if (fCheckInputs)
{
- if (pfMissingInputs)
- *pfMissingInputs = true;
- return error("AcceptToMemoryPool() : ConnectInputs failed %s", hash.ToString().substr(0,10).c_str());
+ // Check against previous transactions
+ map<uint256, CTxIndex> mapUnused;
+ int64 nFees = 0;
+ if (!ConnectInputs(txdb, mapUnused, CDiskTxPos(1,1,1), pindexBest, nFees, false, false))
+ {
+ if (pfMissingInputs)
+ *pfMissingInputs = true;
+ return error("AcceptToMemoryPool() : ConnectInputs failed %s", hash.ToString().substr(0,10).c_str());
+ }
+
+ // Don't accept it if it can't get into a block
+ if (nFees < GetMinFee(1000))
+ return error("AcceptToMemoryPool() : not enough fees");
+
+ // Limit free transactions per 10 minutes
+ if (nFees < CENT && GetBoolArg("-limitfreerelay"))
+ {
+ static int64 nNextReset;
+ static int64 nFreeCount;
+ if (GetTime() > nNextReset)
+ {
+ nNextReset = GetTime() + 10 * 60;
+ nFreeCount = 0;
+ }
+ if (nFreeCount > 150000 && !IsFromMe())
+ return error("AcceptToMemoryPool() : free transaction rejected by rate limiter");
+ nFreeCount += nSize;
+ }
}
// Store transaction in memory
@@ -1926,7 +1953,6 @@ string GetWarnings(string strFor)
{
nPriority = alert.nPriority;
strStatusBar = alert.strStatusBar;
- strRPC = alert.strRPCError;
}
}
}