aboutsummaryrefslogtreecommitdiff
path: root/rpki/rtr/client.py
diff options
context:
space:
mode:
authorRob Austein <sra@hactrn.net>2014-06-23 00:23:49 +0000
committerRob Austein <sra@hactrn.net>2014-06-23 00:23:49 +0000
commitdf573c1d04192191476b778921b83b927da72747 (patch)
treef98153edabfbf926d06e140b8ea67f359684c5ad /rpki/rtr/client.py
parent9e52f16c2efad4b2835f004467abacf3c0f6b6a9 (diff)
Missed testing client mode properly after last refactoring.
svn path=/trunk/; revision=5872
Diffstat (limited to 'rpki/rtr/client.py')
-rw-r--r--rpki/rtr/client.py11
1 files changed, 7 insertions, 4 deletions
diff --git a/rpki/rtr/client.py b/rpki/rtr/client.py
index eb9ce5a0..a35ab81d 100644
--- a/rpki/rtr/client.py
+++ b/rpki/rtr/client.py
@@ -200,7 +200,10 @@ class ClientChannel(rpki.rtr.channels.PDUChannel):
Set up ssh connection and start listening for first PDU.
"""
- argv = ("ssh", "-p", port, "-s", host, "rpki-rtr")
+ if args.port is None:
+ argv = ("ssh", "-s", args.host, "rpki-rtr")
+ else:
+ argv = ("ssh", "-p", args.port, "-s", args.host, "rpki-rtr")
logging.debug("[Running ssh: %s]", " ".join(argv))
s = socket.socketpair()
return cls(sock = s[1],
@@ -214,9 +217,9 @@ class ClientChannel(rpki.rtr.channels.PDUChannel):
Set up TCP connection and start listening for first PDU.
"""
- logging.debug("[Starting raw TCP connection to %s:%s]", host, port)
+ logging.debug("[Starting raw TCP connection to %s:%s]", args.host, args.port)
try:
- addrinfo = socket.getaddrinfo(host, port, socket.AF_UNSPEC, socket.SOCK_STREAM)
+ addrinfo = socket.getaddrinfo(args.host, args.port, socket.AF_UNSPEC, socket.SOCK_STREAM)
except socket.error, e:
logging.debug("[socket.getaddrinfo() failed: %s]", e)
else:
@@ -264,7 +267,7 @@ class ClientChannel(rpki.rtr.channels.PDUChannel):
for such purposes this week).
"""
- argv = ("openssl", "s_client", "-tls1", "-quiet", "-connect", "%s:%s" % (host, port))
+ argv = ("openssl", "s_client", "-tls1", "-quiet", "-connect", "%s:%s" % (args.host, args.port))
logging.debug("[Running: %s]", " ".join(argv))
s = socket.socketpair()
return cls(sock = s[1],