Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
sobomax committed Apr 2, 2024
1 parent f884b17 commit ad30675
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions Rtp_cluster.py
Original file line number Diff line number Diff line change
Expand Up @@ -229,7 +229,6 @@ def up_command(self, clim, orig_cmd):
out_cmd = Rtp_proxy_cmd(orig_cmd)
out_cmd.ul_opts.local_ip = rtpp.lan_address
out_cmd.ul_opts.destination_ip = None
out_cmd = str(out_cmd)
else:
out_cmd = orig_cmd
rtpp.send_command(out_cmd, self.merge_results, br, rtpp)
Expand Down Expand Up @@ -271,10 +270,9 @@ def up_command(self, clim, orig_cmd):
out_cmd = Rtp_proxy_cmd(orig_cmd)
out_cmd.ul_opts.local_ip = rtpp.lan_address
out_cmd.ul_opts.destination_ip = None
out_cmd = str(out_cmd)
else:
out_cmd = orig_cmd
rtpp.send_command(out_cmd, partial(response_handler, clim, cmd, out_cmd, rtpp))
rtpp.send_command(str(out_cmd), partial(response_handler, clim, cmd, out_cmd, rtpp))

def ignore_response(self, clim, cmd, out_cmd, rtpp, result):
if result is None:
Expand All @@ -294,7 +292,7 @@ def down_command(self, clim, cmd, out_cmd, rtpp, result):
#print(f'down_command: {cmd.ul_opts.destination_ip=}, {cmd.ul_opts.local_ip=}, {rtpp.wan_address=}')
req_dip = cmd.ul_opts.destination_ip
req_lip = cmd.ul_opts.local_ip
req_lip_out = cmd_out.ul_opts.local_ip_out
req_lip_out = out_cmd.ul_opts.local_ip_out
result_parts = result.strip().split()
if result_parts[0] != '0' and req_dip != None and not is_dst_local(req_dip) and \
req_lip != rtpp.lan_address:
Expand Down

0 comments on commit ad30675

Please sign in to comment.