Remove braces, fix benchmark and pass callback.
This commit is contained in:
parent
9020ddb85c
commit
b738a5fb84
|
@ -90,7 +90,7 @@ bitcoind.on('ready', function() {
|
||||||
c = 0;
|
c = 0;
|
||||||
}
|
}
|
||||||
var hash = fixtureData.txHashes[c];
|
var hash = fixtureData.txHashes[c];
|
||||||
bitcoind.getTransaction(hash, function(err, tx) {
|
bitcoind.getTransaction(hash, true, function(err, tx) {
|
||||||
if (err) {
|
if (err) {
|
||||||
throw err;
|
throw err;
|
||||||
}
|
}
|
||||||
|
|
|
@ -328,12 +328,7 @@ Bitcoin.prototype.isSpent = function(txid, outputIndex) {
|
||||||
};
|
};
|
||||||
|
|
||||||
Bitcoin.prototype.getTransaction = function(txid, queryMempool, callback) {
|
Bitcoin.prototype.getTransaction = function(txid, queryMempool, callback) {
|
||||||
return bitcoindjs.getTransaction(txid, queryMempool, function(err, tx) {
|
return bitcoindjs.getTransaction(txid, queryMempool, callback);
|
||||||
if (err) {
|
|
||||||
return callback(err);
|
|
||||||
}
|
|
||||||
return callback(null, tx);
|
|
||||||
});
|
|
||||||
};
|
};
|
||||||
|
|
||||||
Bitcoin.prototype.getTransactionWithBlock = function(txid, blockhash, callback) {
|
Bitcoin.prototype.getTransactionWithBlock = function(txid, blockhash, callback) {
|
||||||
|
|
|
@ -804,39 +804,35 @@ async_get_tx(uv_work_t *req) {
|
||||||
uint256 blockhash;
|
uint256 blockhash;
|
||||||
CTransaction ctx;
|
CTransaction ctx;
|
||||||
|
|
||||||
{
|
if (data->queryMempool) {
|
||||||
|
LOCK(cs_main);
|
||||||
if (data->queryMempool) {
|
{
|
||||||
LOCK(cs_main);
|
if (mempool.lookup(hash, ctx))
|
||||||
{
|
{
|
||||||
if (mempool.lookup(hash, ctx))
|
return;
|
||||||
{
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
CDiskTxPos postx;
|
CDiskTxPos postx;
|
||||||
if (pblocktree->ReadTxIndex(hash, postx)) {
|
if (pblocktree->ReadTxIndex(hash, postx)) {
|
||||||
|
|
||||||
CAutoFile file(OpenBlockFile(postx, true), SER_DISK, CLIENT_VERSION);
|
CAutoFile file(OpenBlockFile(postx, true), SER_DISK, CLIENT_VERSION);
|
||||||
|
|
||||||
if (file.IsNull()) {
|
if (file.IsNull()) {
|
||||||
data->err_msg = std::string("%s: OpenBlockFile failed", __func__);
|
data->err_msg = std::string("%s: OpenBlockFile failed", __func__);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
const int HEADER_SIZE = sizeof(int32_t) + sizeof(uint32_t) * 3 + sizeof(char) * 64;
|
const int HEADER_SIZE = sizeof(int32_t) + sizeof(uint32_t) * 3 + sizeof(char) * 64;
|
||||||
|
|
||||||
try {
|
|
||||||
fseek(file.Get(), postx.nTxOffset + HEADER_SIZE, SEEK_CUR);
|
|
||||||
file >> ctx;
|
|
||||||
data->ctx = ctx;
|
|
||||||
} catch (const std::exception& e) {
|
|
||||||
data->err_msg = std::string("Deserialize or I/O error - %s", __func__);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
try {
|
||||||
|
fseek(file.Get(), postx.nTxOffset + HEADER_SIZE, SEEK_CUR);
|
||||||
|
file >> ctx;
|
||||||
|
data->ctx = ctx;
|
||||||
|
} catch (const std::exception& e) {
|
||||||
|
data->err_msg = std::string("Deserialize or I/O error - %s", __func__);
|
||||||
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue