add listen_kernel method to IPEngineApp

IPython/parallel/apps/ipengineapp.py

@@ -37,7 +37,7 b' from IPython.parallel.apps.baseapp import ('
     catch_config_error,
 )
 from IPython.zmq.log import EnginePUBHandler
-from IPython.zmq.ipkernel import Kernel
+from IPython.zmq.ipkernel import Kernel, IPKernelApp
 from IPython.zmq.session import (
     Session, session_aliases, session_flags
 )
@@ -49,7 +49,7 b' from IPython.parallel.util import disambiguate_url'
 
 from IPython.utils.importstring import import_item
 from IPython.utils.py3compat import cast_bytes
-from IPython.utils.traitlets import Bool, Unicode, Dict, List, Float
+from IPython.utils.traitlets import Bool, Unicode, Dict, List, Float, Instance
 
 
 #-----------------------------------------------------------------------------
@@ -174,6 +174,9 b' class IPEngineApp(BaseParallelApplication):'
     log_url = Unicode('', config=True,
         help="""The URL for the iploggerapp instance, for forwarding
         logging to a central location.""")
+    
+    # an IPKernelApp instance, used to setup listening for shell frontends
+    kernel_app = Instance(IPKernelApp)
 
     aliases = Dict(aliases)
     flags = Dict(flags)
@@ -226,7 +229,41 b' class IPEngineApp(BaseParallelApplication):'
             config.EngineFactory.sshserver
         except AttributeError:
             config.EngineFactory.sshserver = d['ssh']
+    
+    def listen_kernel(self):
+        """setup engine as listening Kernel, for frontends"""
+        if self.kernel_app is not None:
+            return
+        
+        self.log.info("Opening ports for direct connections")
+        
+        kernel = self.kernel
+        
+        app = self.kernel_app = IPKernelApp(log=self.log, config=self.config,
+                                profile_dir = self.profile_dir,
+                                session=self.engine.session,
+        )
+        app.init_connection_file()
+        # relevant contents of init_sockets:
+        
+        app.shell_port = app._bind_socket(kernel.shell_streams[0], app.shell_port)
+        app.log.debug("shell ROUTER Channel on port: %i", app.shell_port)
         
+        app.iopub_port = app._bind_socket(kernel.iopub_socket, app.iopub_port)
+        app.log.debug("iopub PUB Channel on port: %i", app.iopub_port)
+        
+        kernel.stdin_socket = self.engine.context.socket(zmq.ROUTER)
+        app.stdin_port = app._bind_socket(kernel.stdin_socket, app.stdin_port)
+        app.log.debug("stdin ROUTER Channel on port: %i", app.stdin_port)
+        
+        # start the heartbeat, and log connection info:
+        
+        app.init_heartbeat()
+        
+        app.log_connection_info()
+        app.write_connection_file()
+        
+    
     def init_engine(self):
         # This is the working dir by now.
         sys.path.insert(0, '')