lthn/mining-pool
6
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Adding a blockLocker to the system.

Browse source
This commit is contained in:
Alexander Blair 2017-02-13 11:26:30 -08:00
parent 2d97826020
commit 0efcd22a8a
2 changed files with 30 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
debug_scripts/block_locker.js Normal file
View file

@ -0,0 +1,19 @@
"use strict";
let mysql = require("promise-mysql");
let fs = require("fs");
let argv = require('minimist')(process.argv.slice(2));
let config = fs.readFileSync("../config.json");
let coinConfig = fs.readFileSync("../coinConfig.json");
let protobuf = require('protocol-buffers');
global.support = require("../lib/support.js")();
global.config = JSON.parse(config);
global.mysql = mysql.createPool(global.config.mysql);
global.protos = protobuf(fs.readFileSync('../lib/data.proto'));
let comms;
comms = require('../lib/local_comms');
global.database = new comms();
global.database.initEnv();
global.database.lockBlock(argv.blockID);
console.log("Block "+argv.blockID+" re-locked! Exiting!");
process.exit();

11
lib/local_comms.js
View file

@ -324,6 +324,17 @@ function Database(){
txn.commit();
};
this.lockBlock = function(blockId){
let txn = this.env.beginTxn();
let blockProto = txn.getBinary(this.blockDB, blockId);
if (blockProto !== null){
let blockData = global.protos.Block.decode(blockProto);
blockData['unlocked'] = false;
txn.putBinary(this.blockDB, blockId, global.protos.Block.encode(blockData));
}
txn.commit();
};
this.getCache = function(cacheKey){
debug("Getting Key: "+cacheKey);
try {