jacob.eva/Reticulum
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added timeout to rnprobe

Browse Source
This commit is contained in:
Mark Qvist 2023-09-22 10:04:37 +02:00
parent 8f6c6b76de
commit 5872108da3
1 changed files with 40 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
RNS/Utilities/rnprobe.py
View File

@ -110,7 +110,7 @@ def program_setup(configdir, destination_hexhash, size=None, full_name = None, v
print("\rSent "+str(size)+" byte probe to "+RNS.prettyhexrep(destination_hash)+more+" ", end=" ") print("\rSent "+str(size)+" byte probe to "+RNS.prettyhexrep(destination_hash)+more+" ", end=" ")
i = 0 i = 0
while not receipt.status == RNS.PacketReceipt.DELIVERED: while receipt.status == RNS.PacketReceipt.SENT:
time.sleep(0.1) time.sleep(0.1)
print(("\b\b"+syms[i]+" "), end="") print(("\b\b"+syms[i]+" "), end="")
sys.stdout.flush() sys.stdout.flush()
@ -119,46 +119,50 @@ def program_setup(configdir, destination_hexhash, size=None, full_name = None, v
print("\b\b ") print("\b\b ")
sys.stdout.flush() sys.stdout.flush()
hops = RNS.Transport.hops_to(destination_hash) if receipt.status == RNS.PacketReceipt.DELIVERED:
if hops != 1: hops = RNS.Transport.hops_to(destination_hash)
ms = "s" if hops != 1:
else: ms = "s"
ms = "" else:
ms = ""
rtt = receipt.get_rtt() rtt = receipt.get_rtt()
if (rtt >= 1): if (rtt >= 1):
rtt = round(rtt, 3) rtt = round(rtt, 3)
rttstring = str(rtt)+" seconds" rttstring = str(rtt)+" seconds"
else: else:
rtt = round(rtt*1000, 3) rtt = round(rtt*1000, 3)
rttstring = str(rtt)+" milliseconds" rttstring = str(rtt)+" milliseconds"
reception_stats = "" reception_stats = ""
if reticulum.is_connected_to_shared_instance: if reticulum.is_connected_to_shared_instance:
reception_rssi = reticulum.get_packet_rssi(receipt.proof_packet.packet_hash) reception_rssi = reticulum.get_packet_rssi(receipt.proof_packet.packet_hash)
reception_snr = reticulum.get_packet_snr(receipt.proof_packet.packet_hash) reception_snr = reticulum.get_packet_snr(receipt.proof_packet.packet_hash)
if reception_rssi != None: if reception_rssi != None:
reception_stats += " [RSSI "+str(reception_rssi)+" dBm]" reception_stats += " [RSSI "+str(reception_rssi)+" dBm]"
if reception_snr != None:
reception_stats += " [SNR "+str(reception_snr)+" dB]"
else:
if receipt.proof_packet != None:
if receipt.proof_packet.rssi != None:
reception_stats += " [RSSI "+str(receipt.proof_packet.rssi)+" dBm]"
if receipt.proof_packet.snr != None: if reception_snr != None:
reception_stats += " [SNR "+str(receipt.proof_packet.snr)+" dB]" reception_stats += " [SNR "+str(reception_snr)+" dB]"
print( else:
"Valid reply received from "+ if receipt.proof_packet != None:
RNS.prettyhexrep(receipt.destination.hash)+ if receipt.proof_packet.rssi != None:
"\nRound-trip time is "+rttstring+ reception_stats += " [RSSI "+str(receipt.proof_packet.rssi)+" dBm]"
" over "+str(hops)+" hop"+ms+
reception_stats if receipt.proof_packet.snr != None:
) reception_stats += " [SNR "+str(receipt.proof_packet.snr)+" dB]"
print(
"Valid reply received from "+
RNS.prettyhexrep(receipt.destination.hash)+
"\nRound-trip time is "+rttstring+
" over "+str(hops)+" hop"+ms+
reception_stats
)
else:
print("Probe timed out")