Lines Matching refs:transport
102 def _check_transport_error(self, transport):
103 error = transport.get_exception()
105 transport.close()
110 """Return a socket for use in instantiating a paramiko transport. Does
112 paramiko.Transport constructor accepts."""
118 transport = paramiko.Transport(self._connect_socket())
120 transport.start_client(completed)
123 self._check_transport_error(transport)
125 transport.auth_publickey(self.user, pkey, completed)
128 self._check_transport_error(transport)
129 if not transport.is_authenticated():
130 transport.close()
132 return transport
135 # HACK: we can't count on transport.join not hanging now, either
136 transport.join = lambda: None
137 transport.close()
148 transport = self._connect_transport(key)
149 transport.set_keepalive(self.KEEPALIVE_TIMEOUT_SECONDS)
150 self.transport = transport
167 self.transport.join = lambda: None
168 self.transport.atfork()
176 channel = self.transport.open_session()
183 # we couldn't get a channel; re-initing transport should fix that
185 self.transport.close()
187 logging.debug("paramiko.Transport.close failed with %s", e)
189 return self.transport.open_session()
196 self.transport.close()
