RanchiMall/flocore-node
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor. comments.

Browse Source
This commit is contained in:
Christopher Jeffrey 2014-08-20 17:00:09 -07:00
parent 8537ad3ebf
commit 3f06092afa
1 changed files with 41 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
src/bitcoindjs.cc
View File

@ -8,7 +8,10 @@
#include "nan.h" #include "nan.h"
// bitcoind headers: /**
* Bitcoin headers
*/
#include "core.h" #include "core.h"
#include "addrman.h" #include "addrman.h"
#include "checkpoints.h" #include "checkpoints.h"
@ -61,6 +64,23 @@
#include "threadsafety.h" #include "threadsafety.h"
#include "version.h" #include "version.h"
/**
* Bitcoin Globals
* Relevant:
* ~/bitcoin/src/init.cpp
* ~/bitcoin/src/bitcoind.cpp
* ~/bitcoin/src/main.h
*/
extern void (ThreadImport)(std::vector<boost::filesystem::path>);
extern void (DetectShutdownThread)(boost::thread_group*);
extern int nScriptCheckThreads;
// extern const int DEFAULT_SCRIPTCHECK_THREADS; // static!!
#ifdef ENABLE_WALLET
extern std::string strWalletFile;
extern CWallet *pwalletMain;
#endif
#include <node.h> #include <node.h>
#include <string> #include <string>
@ -90,6 +110,11 @@ start_node(void);
extern "C" void extern "C" void
init(Handle<Object>); init(Handle<Object>);
/**
* async_data
* Where the uv async request data resides.
*/
struct async_data { struct async_data {
Persistent<Function> callback; Persistent<Function> callback;
bool err; bool err;
@ -127,6 +152,11 @@ NAN_METHOD(StartBitcoind) {
NanReturnValue(Undefined()); NanReturnValue(Undefined());
} }
/**
* async_work()
* Call start_node() and start all our boost threads.
*/
static void static void
async_work(uv_work_t *req) { async_work(uv_work_t *req) {
async_data* data = static_cast<async_data*>(req->data); async_data* data = static_cast<async_data*>(req->data);
@ -134,6 +164,11 @@ async_work(uv_work_t *req) {
data->result = (char *)strdup("opened"); data->result = (char *)strdup("opened");
} }
/**
* async_after()
* Execute our callback.
*/
static void static void
async_after(uv_work_t *req) { async_after(uv_work_t *req) {
NanScope(); NanScope();
@ -171,21 +206,11 @@ async_after(uv_work_t *req) {
delete req; delete req;
} }
extern void (ThreadImport)(std::vector<boost::filesystem::path>); /**
extern void (DetectShutdownThread)(boost::thread_group*); * start_node(void)
extern int nScriptCheckThreads; * A reimplementation of AppInit2 minus
// extern const int DEFAULT_SCRIPTCHECK_THREADS; // static!! * the logging and argument parsing.
// #ifdef ENABLE_WALLET */
// extern std::string strWalletFile;
// extern CWallet *pwalletMain;
// #endif
// Relevant:
// ~/bitcoin/src/init.cpp
// ~/bitcoin/src/bitcoind.cpp
// ~/bitcoin/src/main.h
// Similar to AppInit2 - minus logs and arg parsing:
static int static int
start_node(void) { start_node(void) {
@ -194,7 +219,6 @@ start_node(void) {
detectShutdownThread = new boost::thread( detectShutdownThread = new boost::thread(
boost::bind(&DetectShutdownThread, &threadGroup)); boost::bind(&DetectShutdownThread, &threadGroup));
// int nScriptCheckThreads = 0;
for (int i = 0; i < nScriptCheckThreads - 1; i++) { for (int i = 0; i < nScriptCheckThreads - 1; i++) {
threadGroup.create_thread(&ThreadScriptCheck); threadGroup.create_thread(&ThreadScriptCheck);
} }
@ -206,9 +230,7 @@ start_node(void) {
#ifdef ENABLE_WALLET #ifdef ENABLE_WALLET
if (pwalletMain) { if (pwalletMain) {
// Add wallet transactions that aren't already in a block to mapTransactions
pwalletMain->ReacceptWalletTransactions(); pwalletMain->ReacceptWalletTransactions();
// Run a thread to flush wallet periodically
threadGroup.create_thread(boost::bind(&ThreadFlushWalletDB, boost::ref(pwalletMain->strWalletFile))); threadGroup.create_thread(boost::bind(&ThreadFlushWalletDB, boost::ref(pwalletMain->strWalletFile)));
} }
#endif #endif