"Override default maximum ABI serialization time allowed in ms")
("chain-state-db-size-mb",bpo::value<uint64_t>()->default_value(config::default_state_size/(1024*1024)),"Maximum size (in MiB) of the chain state database")
"offset of non last block producing time in micro second. Negative number results in blocks to go out sooner, and positive number results in blocks to go out later")
"offset of non last block producing time in microseconds. Negative number results in blocks to go out sooner, and positive number results in blocks to go out later")
"offset of last block producing time in micro second. Negative number results in blocks to go out sooner, and positive number results in blocks to go out later")
"offset of last block producing time in microseconds. Negative number results in blocks to go out sooner, and positive number results in blocks to go out later")
if(subapp->got_subcommand("listproducers")||subapp->got_subcommand("listbw")||subapp->got_subcommand("bidnameinfo"))// system list* do not require wallet
std::cerr<<"ERROR: Either --buy-ram or --buy-ram-kbytes with non-zero value is required"<<std::endl;
return;
}
EOSC_ASSERT(buy_ram_eos.size()||buy_ram_bytes_in_kbytes||buy_ram_bytes,"ERROR: One of --buy-ram, --buy-ram-kbytes or --buy-ram-bytes should have non-zero value");
EOSC_ASSERT(!buy_ram_bytes_in_kbytes||!buy_ram_bytes,"ERROR: --buy-ram-kbytes and --buy-ram-bytes cannot be set at the same time");
buyram->add_option("amount",amount,localized("The amount of EOS to pay for RAM, or number of kbytes of RAM if --kbytes is set"))->required();
buyram->add_flag("--kbytes,-k",kbytes,localized("buyram in number of kbytes"));
buyram->add_option("amount",amount,localized("The amount of EOS to pay for RAM, or number of bytes/kibibytes of RAM if --bytes/--kbytes is set"))->required();
buyram->add_flag("--kbytes,-k",kbytes,localized("buyram in number of kibibytes (KiB)"));
buyram->add_flag("--bytes,-b",bytes,localized("buyram in number of bytes"));
ilog("existing reversible block num ${first} through block num ${last} ",("first",first->get_block()->block_num())("last",last->get_block()->block_num()));
else{
elog("no blocks available in reversible block database: only block_log blocks are available");
reversible_blocks.reset();
}
}catch(conststd::runtime_error&e){
if(std::string(e.what())=="database dirty flag set"){
elog("database dirty flag set (likely due to unclean shutdown): only block_log blocks are available");
}elseif(std::string(e.what())=="database metadata dirty flag set"){
elog("database metadata dirty flag set (likely due to unclean shutdown): only block_log blocks are available");
("mode,m",bpo::value<vector<string>>()->multitoken()->default_value({"any"},"any"),"connection mode, combination of \"any\", \"producers\", \"specified\", \"none\"")
("shape,s",bpo::value<string>(&shape)->default_value("star"),"network topology, use \"star\"\"mesh\" or give a filename for custom")
("p2p-plugin",bpo::value<string>()->default_value("net"),"select a p2p plugin to use (either net or bnet). Defaults to net.")
("genesis,g",bpo::value<bfs::path>(&genesis)->default_value("./genesis.json"),"set the path to genesis.json")
("genesis,g",bpo::value<string>()->default_value("./genesis.json"),"set the path to genesis.json")
("skip-signature",bpo::bool_switch(&skip_transaction_signatures)->default_value(false),"nodeos does not require transaction signatures.")
("nodeos",bpo::value<string>(&eosd_extra_args),"forward nodeos command line argument(s) to each instance of nodeos, enclose arg(s) in quotes")
("specific-num",bpo::value<vector<uint>>()->composing(),"forward nodeos command line argument(s) (using \"--specific-nodeos\" flag) to this specific instance of nodeos. This parameter can be entered multiple times and requires a paired \"--specific-nodeos\" flag")
("delay,d",bpo::value<int>(&start_delay)->default_value(0),"seconds delay before starting each node after the first")
("boot",bpo::bool_switch(&boot)->default_value(false),"After deploying the nodes and generating a boot script, invoke it.")
("nogen",bpo::bool_switch(&nogen)->default_value(false),"launch nodes without writing new config files")
("host-map",bpo::value<bfs::path>(&host_map_file)->default_value(""),"a file containing mapping specific nodes to hosts. Used to enhance the custom shape argument")
("servers",bpo::value<bfs::path>(&server_ident_file)->default_value(""),"a file containing ip addresses and names of individual servers to deploy as producers or non-producers ")
("host-map",bpo::value<string>(),"a file containing mapping specific nodes to hosts. Used to enhance the custom shape argument")
("servers",bpo::value<string>(),"a file containing ip addresses and names of individual servers to deploy as producers or non-producers ")
("per-host",bpo::value<int>(&per_host)->default_value(0),"specifies how many nodeos instances will run on a single host. Use 0 to indicate all on one.")
("network-name",bpo::value<string>(&network.name)->default_value("testnet_"),"network name prefix used in GELF logging source")
("enable-gelf-logging",bpo::value<bool>(&gelf_enabled)->default_value(true),"enable gelf logging appender in logging configuration file")
("gelf-endpoint",bpo::value<string>(&gelf_endpoint)->default_value("10.160.11.21:12201"),"hostname:port or ip:port of GELF endpoint")
assertisinstance(newKey,str),print("ERROR: Trying to use %s as a key"%(newKey))
subSection=self.sections[-1]
assertisinstance(subSection,dict),print("ERROR: Calling \"add\" method when context is not a dictionary. %s in %s"%(self.__contextDesc(),self.__json()))
assertnewKeyinsubSection,print("ERROR: %s%s does not contain key \"%s\". %s"%(self.__contextDesc(),key,self.__json()))
current=subSection[newKey]
self.sections.append(current)
self.keyContext.append(newKey)
returncurrent
defindex(self,i):
assertisinstance(i,int),print("ERROR: Trying to use \"%s\" as a list index"%(i))
cur=self.getCurrent()
assertisinstance(cur,list),print("ERROR: Calling \"index\" method when context is not a list. %s in %s"%(self.__contextDesc(),self.__json()))
listLen=len(cur)
asserti<listLen,print("ERROR: Index %s is beyond the size of the current list (%s). %s in %s"%(i,listLen,self.__contextDesc(),self.__json()))
returnself.sections.append(cur[i])
defgetCurrent(self):
returnself.sections[-1]
@staticmethod
defgetTransStatus(trans):
cntxt=Node.Context(trans,"trans")
cntxt.add("processed")
cntxt.add("receipt")
returncntxt.add("status")
@staticmethod
defgetTransBlockNum(trans):
cntxt=Node.Context(trans,"trans")
cntxt.add("processed")
cntxt.add("action_traces")
cntxt.index(0)
returncntxt.add("block_num")
@staticmethod
defstdinAndCheckOutput(cmd,subcommand):
...
...
@@ -140,17 +211,22 @@ class Node(object):
asserttrans
assertisinstance(trans,dict),print("Input type is %s"%type(trans))
#Utils.Print("%s" % trans)
assert"transaction_id"intrans,print("trans does not contain key %s. trans={%s}"%("transaction_id",json.dumps(trans,indent=2,sort_keys=True)))
transId=trans["transaction_id"]
returntransId
@staticmethod
defisTrans(obj):
"""Identify if this is a transaction dictionary."""
