Skip to content

Commit

Permalink
Merge pull request #187 from weka-io/master
Browse files Browse the repository at this point in the history
another fix for SSL authentication, and some logging
  • Loading branch information
tomerfiliba committed Feb 10, 2016
2 parents 7dbc84b + cfc164b commit 1211fd1
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 4 deletions.
4 changes: 2 additions & 2 deletions bin/rpyc_classic.py
Original file line number Diff line number Diff line change
Expand Up @@ -70,8 +70,8 @@ def main(self):
self.registrar = TCPRegistryClient(ip = self.registry_host, port = self.registry_port)

if self.ssl_keyfile:
self.authenticator = SSLAuthenticator(str(self.ssl_keyfile), str(self.ssl_certfile),
str(self.ssl_cafile))
self.authenticator = SSLAuthenticator(self.ssl_keyfile, self.ssl_certfile,
self.ssl_cafile)
default_port = DEFAULT_SERVER_SSL_PORT
else:
self.authenticator = None
Expand Down
7 changes: 5 additions & 2 deletions rpyc/core/protocol.py
Original file line number Diff line number Diff line change
Expand Up @@ -320,16 +320,19 @@ def _netref_factory(self, oid, clsname, modname):
# dispatching
#
def _dispatch_request(self, seq, raw_args):
logger = self._config["logger"]
try:
handler, args = raw_args
if logger:
logger.debug("dispatching: %r (%r)", handler, seq)
args = self._unbox(args)
res = self._HANDLERS[handler](self, *args)
except:
# need to catch old style exceptions too
t, v, tb = sys.exc_info()
self._last_traceback = tb
if self._config["logger"] and t is not StopIteration:
self._config["logger"].debug("Exception caught", exc_info=True)
if logger and t is not StopIteration:
logger.debug("Exception caught", exc_info=True)
if t is SystemExit and self._config["propagate_SystemExit_locally"]:
raise
if t is KeyboardInterrupt and self._config["propagate_KeyboardInterrupt_locally"]:
Expand Down

0 comments on commit 1211fd1

Please sign in to comment.