mirror of
https://github.com/Xahau/xahaud.git
synced 2026-02-10 08:52:22 +00:00
Compare commits
3 Commits
fixhookmet
...
patch-conf
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
6a19f94380 | ||
|
|
419fb8f730 | ||
|
|
780378c221 |
@@ -795,17 +795,26 @@
|
|||||||
# [workers]
|
# [workers]
|
||||||
#
|
#
|
||||||
# Configures the number of threads for processing work submitted by peers
|
# Configures the number of threads for processing work submitted by peers
|
||||||
# and clients. If not specified, then the value is automatically set to the
|
# and clients. If not specified, then the value is depends on the node_size
|
||||||
# number of processor threads plus 2 for networked nodes. Nodes running in
|
# and the number of cores: Nodes running in stand alone mode default to 1 worker.
|
||||||
# stand alone mode default to 1 worker.
|
# node_size | cores | threads |
|
||||||
|
# huge | >16 | 14 |
|
||||||
|
# large | >8 | 10 |
|
||||||
|
# medium | any | 6 |
|
||||||
|
# small | any | 6 |
|
||||||
|
# tiny | any | 6 |
|
||||||
|
#
|
||||||
#
|
#
|
||||||
# [io_workers]
|
# [io_workers]
|
||||||
#
|
#
|
||||||
# Configures the number of threads for processing raw inbound and outbound IO.
|
# Configures the number of threads for processing raw inbound and outbound IO.
|
||||||
|
# Default is 1 thread when cores == 1 or node_size is tiny & cores == 2.
|
||||||
|
# Otherwise default is 2.
|
||||||
#
|
#
|
||||||
# [prefetch_workers]
|
# [prefetch_workers]
|
||||||
#
|
#
|
||||||
# Configures the number of threads for performing nodestore prefetching.
|
# Configures the number of threads for performing nodestore prefetching.
|
||||||
|
# Default is 4.
|
||||||
#
|
#
|
||||||
#
|
#
|
||||||
#
|
#
|
||||||
|
|||||||
@@ -1857,7 +1857,8 @@ hook::finalizeHookResult(
|
|||||||
uint16_t exec_index = avi.nextHookExecutionIndex();
|
uint16_t exec_index = avi.nextHookExecutionIndex();
|
||||||
// apply emitted transactions to the ledger (by adding them to the emitted
|
// apply emitted transactions to the ledger (by adding them to the emitted
|
||||||
// directory) if we are allowed to
|
// directory) if we are allowed to
|
||||||
std::map<uint256 /* txnid */, uint256 /* emit nonce */> emission_txnid;
|
std::vector<std::pair<uint256 /* txnid */, uint256 /* emit nonce */>>
|
||||||
|
emission_txnid;
|
||||||
|
|
||||||
if (doEmit)
|
if (doEmit)
|
||||||
{
|
{
|
||||||
@@ -1882,7 +1883,7 @@ hook::finalizeHookResult(
|
|||||||
.getField(sfEmitDetails)
|
.getField(sfEmitDetails)
|
||||||
.downcast<STObject>();
|
.downcast<STObject>();
|
||||||
|
|
||||||
emission_txnid.emplace(
|
emission_txnid.emplace_back(
|
||||||
id, emitDetails.getFieldH256(sfEmitNonce));
|
id, emitDetails.getFieldH256(sfEmitNonce));
|
||||||
sleEmitted = std::make_shared<SLE>(emittedId);
|
sleEmitted = std::make_shared<SLE>(emittedId);
|
||||||
|
|
||||||
|
|||||||
@@ -386,6 +386,17 @@ LedgerHistory::handleMismatch(
|
|||||||
JLOG(j_.error()) << "built\n" << getJson({*builtLedger, {}});
|
JLOG(j_.error()) << "built\n" << getJson({*builtLedger, {}});
|
||||||
JLOG(j_.error()) << "valid\n" << getJson({*validLedger, {}});
|
JLOG(j_.error()) << "valid\n" << getJson({*validLedger, {}});
|
||||||
|
|
||||||
|
{
|
||||||
|
auto b = builtTx.begin();
|
||||||
|
auto v = validTx.begin();
|
||||||
|
while (b != builtTx.end() && v != validTx.end())
|
||||||
|
{
|
||||||
|
log_one(*builtLedger, (*b)->key(), "validInfo", j_);
|
||||||
|
log_one(*validLedger, (*v)->key(), "builtInfo", j_);
|
||||||
|
++b;
|
||||||
|
++v;
|
||||||
|
}
|
||||||
|
}
|
||||||
// Log all differences between built and valid ledgers
|
// Log all differences between built and valid ledgers
|
||||||
auto b = builtTx.begin();
|
auto b = builtTx.begin();
|
||||||
auto v = validTx.begin();
|
auto v = validTx.begin();
|
||||||
|
|||||||
Reference in New Issue
Block a user