Codablecashのテストコードから、ノードの起動〜終了を追う

// src_test/blockchain/testnet/test_first_net.cpp
TEST(TestFirstNetGroup, case01){
	// ・・・・・
	CodablecashSystemParam param;
	DebugCodablecashSystemParamSetup::setupConfig02(param);   // テスト用のパラメータ

	CodablecashNetworkNodeConfig nwconfig;
	nwconfig.setSysConfig(&param);

	// network config
	CodablecashNetworkNodeConfig* config01 = new CodablecashNetworkNodeConfig(nwconfig); __STP(config01);
	config01->setCanonicalName(L"node_01");
	CodablecashNetworkNodeConfig* config02 = new CodablecashNetworkNodeConfig(nwconfig); __STP(config02);
	config02->setOriginalNwtworkKey();     // 2台目のネットワークキーを新しく作る
	config02->setCanonicalName(L"node_02");
	CodablecashNetworkNodeConfig* config03 = new CodablecashNetworkNodeConfig(nwconfig); __STP(config03);
	config03->setOriginalNwtworkKey();     // 3台目のネットワークキーを新しく作る
	config03->setCanonicalName(L"node_03");
	// ・・・・・（1台目にウォレット・最初の残高・マイナーの設定、そしてネットワークキーを作る）
		NodeIdentifierSource* networkKey =  NodeIdentifierSource::create(); __STP(networkKey);
		config01->setNetworkKey(networkKey);
	// ・・・・・

	NodeIdentifier nodeId01 = config01->getNodeId();   // ネットワークキーからノードIDを取り出す
	NodeIdentifier nodeId02 = config02->getNodeId();
	NodeIdentifier nodeId03 = config03->getNodeId();

// src_blockchain/bc_network_instance/CodablecashNetworkNodeConfig.cpp
NodeIdentifier CodablecashNetworkNodeConfig::getNodeId() const noexcept {
	return this->networkKeys->toNodeIdentifier();
}

// src_blockchain/bc_network/NodeIdentifierSource.cpp
NodeIdentifier NodeIdentifierSource::toNodeIdentifier() const noexcept {
	const BigInteger* pubkey = this->pair->getPubKey();

	return NodeIdentifier(pubkey);
}

	ArrayNetworkSheeder seeder;    // 空の「シーダー」

	CodablecashNetworkNode node01(dirNode01, config01, &logger);
	{
		// First
		node01.setNodeName(L"node01");
		node01.generateNetwork(0, 1); // zone 0    // 最初のブロックを作る

		// after init
		node01.startNetwork(&seeder, false);       // 空のシーダーで起動

		node01.startMiner();
		node01.startStakePool();

		{
			uint16_t zone = 0;
			const NodeIdentifierSource* source = config01->getNetworkKey();
			NodeIdentifier nodeId = source->toNodeIdentifier();
			const wchar_t* host = L"::1";
			int port = config01->getPort();

			const UnicodeString* cname = config01->getCanonicalName();
			P2pNodeRecord* rec = P2pNodeRecord::createIpV6Record(zone, &nodeId, cname, host, port); __STP(rec);
			seeder.addRecord(rec);       // 1台目の連絡先をシーダーに入れる
		}
	}

	{
		config02->setPort(port02);
	}
	CodablecashNetworkNode node02(dirNode02, config02, &logger);
	{
		// second
		node02.initBlank(0, 1); // zone 0     // 空のデータフォルダを用意

		// after init
		node02.setNodeName(L"node02");
		node02.startNetwork(&seeder, true);  // 1台目のデータ入りシーダーで起動
		node02.syncNetwork();                // 仲間に追いつく

		// test commections
		{
			// node01
			{
				BlockchainNodeHandshake* hs01 = node01.getNodeHandshakeByNodeId(&nodeId01);
				StackHandshakeReleaser __releaser(hs01);
				CHECK(hs01 == nullptr);      // 1台目は、自分自身とはつながっていない
			}
			{
				BlockchainNodeHandshake* hs02 = node01.getNodeHandshakeByNodeId(&nodeId02);
				StackHandshakeReleaser __releaser(hs02);
				CHECK(hs02 != nullptr);      // 1台目から見て、2台目がつながっている
			}

			// node02
			{
				BlockchainNodeHandshake* hs01 = node02.getNodeHandshakeByNodeId(&nodeId01);
				StackHandshakeReleaser __releaser(hs01);
				CHECK(hs01 != nullptr);     // 2台目から見て、1台目がつながっている
			}
			// ・・・・・
		}

		// update seeder
		{
			// ・・・・・（1台目のときと同じ手順で、2台目の連絡先もシーダーに足す）
			seeder.addRecord(rec);
		}
	}

// src_blockchain/bc_network_instance/CodablecashNetworkNode.cpp
void CodablecashNetworkNode::startNetwork(INetworkSeeder* seeder, bool pending) {
	// ・・・・・
	this->inst->startNetwork(host, port);    // 自分のポートで待ち受けを始める

	// start processors
	{
		const NodeIdentifierSource* networkKey = this->nwconfig->getNetworkKey();
		this->inst->startProcessors(networkKey, pending);  // 命令の処理担当を立ち上げる。pendingはここへ
	}

	// init database
	if(seeder != nullptr){
		ArrayList<P2pNodeRecord>* seedList = seeder->getSeedNodes(); __STP(seedList);   // シーダーの連絡先を取り出す
		// ・・・・・
		if(seedList != nullptr && !seedList->isEmpty()){
			initDatabase(seedList);    // 連絡先が1件でもあれば、それを元に台帳を作る
		}
	}

	// init connections
	maintainNetwork();   // 台帳から相手を選んでつなぐ
}

// src_blockchain_p2p/bc_p2p_processor/P2pRequestProcessor.cpp
void P2pRequestProcessor::open(const NodeIdentifierSource *networkKey, CodablecashNodeInstance *inst, bool suspend) {
	// ・・・・・
	this->queueProcessor = new P2pRequestQueueProcessor(this->baseDir, this->p2pManager, this->transferProcessor, inst, this->logger);
	this->queueProcessor->open(suspend);  
	// ・・・・・
}

// src_blockchain/bc_network_instance/CodablecashNetworkNode.cpp
void CodablecashNetworkNode::syncNetwork() {
	NetworkNodeSync sync(this);
	sync.sync(); 

	this->inst->resumeRequestProcessor(); 
}

	BlockchainNodeHandshake* hs01 = node01.getNodeHandshakeByNodeId(&nodeId01);
	StackHandshakeReleaser __releaser(hs01);
	CHECK(hs01 == nullptr);

	{
		config03->setPort(port03);
	}
	CodablecashNetworkNode node03(dirNode03, config03, &logger);
	{
		// third
		node03.initBlank(0, 1); // zone 0

		// after init
		node03.setNodeName(L"node03");
		node03.startNetwork(&seeder, true);  // 1台目・2台目入りのシーダーで起動
		node03.syncNetwork();

		// test connections
		{
			// ・・・・・（3台×3台の9通りを全部確かめる。自分自身の3通りだけがnullptr）
			{
				BlockchainNodeHandshake* hs03 = node01.getNodeHandshakeByNodeId(&nodeId03);
				StackHandshakeReleaser __releaser(hs03);
				CHECK(hs03 != nullptr);                   // 1台目から見て、3台目がつながっている
			}
			// ・・・・・
		}
	}

	int maxHeight = 0;
	while(maxHeight < 5){
		Os::usleep(100000);
		maxHeight = node03.getMaxHeight(0);  // 3台目のブロックが高さ5になるまで待つ
	}

	node01.suspendMining();

	node03.shutdown();
	node02.shutdown();
	node01.shutdown();
}