tkdlqm2
commented
3 years ago peer connection 이슈와는 다른 이슈지만, emulation result 관련 함수들을 refacoring 하였음.
def count_block(node_output_file):
block_count = 0
f = open(node_output_file, "r")
while True:
line = f.readline()
if not line: break
result = line.find("UpdateTip")
if result != -1:
block_count += 1
f.close()
return block_count
def get_last_blockHash(node_output_file):
f = open(node_output_file, "r")
for line in f.readlines()[::-1]:
result = line.find("UpdateTip")
if result != -1:
split_data = line.split(" ")[3].split("=")[1]
break
f.close()
return split_data
def get_blockHash_list(node_output_file):
block_hash_list = []
f = open(node_output_file, "r")
while True:
line = f.readline()
if not line: break
result = line.find("UpdateTip")
if result != -1:
block_hash_list.append(line.split(" ")[3].split("=")[1])
f.close()
return block_hash_list
def summary_result(node_list, node_output_file, sim_time):
last_blockHash_list = []
block_count_list = []
for z in range(0,len(node_list)):
path = "./shadow.data/result_"+time.strftime('%H:%M:%S')+"_%d.log"%z
f = open(path, "w")
txs = test_modules.test_transaction_count(node_output_file)
f.write("---------------------------------------------------------------------------------\n")
f.write("1. node 갯수 : %d\n" %len(node_list))
f.write("2. simulation time : %s sec\n" %sim_time)
for i in range(0,len(node_list)):
f.write("3. ")
f.write("\t3-%d IP address : %s\n" %(i+1, node_list[i]))
block_count = count_block(node_output_file[z])
block_count_list.append(block_count)
f.write("4. 생성된 블록 개수 : %d\n" %block_count)
f.write("5. 마지막 블록의 hash 값 : %s\n" %get_last_blockHash(node_output_file[z]))
last_blockHash_list.append(get_last_blockHash(node_output_file[z]))
f.write("6. 생성된 트랜잭션 개수 : %d\n" %txs)
f.write("7. TPS : %s\n" %(txs/int(sim_time)))
f.write("---------------------------------------------------------------------------------\n")
f.write("8. Blockhash list\n")
block_hash_list = get_blockHash_list(node_output_file[z])
for i in range(0,len(block_hash_list)):
f.write("%d blockhash : %s\n" %((i+1), block_hash_list[i]))
f.close()
path = "./shadow.data/total_summary.txt"
f = open(path, "w")
filter_duplicate_value = set(last_blockHash_list)
last_blockHash_list = list(filter_duplicate_value)
filter_duplicate_value = set(block_count_list)
block_count_list = list(filter_duplicate_value)
f.write("------- Total summary --------\n")
if 1 == len(last_blockHash_list):
f.write("Last block hash match rate : %d/%d" %(len(node_list),len(node_list)))
else:
f.write("Last block hash match rate : %d/%d" %(len(last_blockHash_list), len(node_list)))
print(block_count_list)
f.close()원래는 위의 소스코드가 startemultaion.py 에 구현이 되었는데, 이를 testlibs/test_result.py 파일로 refactoring을 시킴. 또한 기존의 소스코드에서 적용안된 멀티노드 테스팅 환경을 추가를 하였고, peer connection의 결과 로그 저장도 같이 구현을 함.
peer connection의 결과들은 별도의 "peers" 폴더에 몰아서 저장을 시킴. 그 외에 전체 시뮬레이션 결과를 프린트해줄 파일은 "total_result.txt"파일에 프린트 하도록 하였음. (이 댓글 위에 글이 total_result.txt의 결과값.)
peer connection 적용
Originally posted by @tkdlqm2 in https://github.com/kaistshadow/blockchain-sim/issues/242#issuecomment-800108949