Merge branch 'flush'

IPython/frontend/html/notebook/static/js/notebook.js

@@ -762,6 +762,11 b' var IPython = (function (IPython) {'
         // console.log(reply);
         var msg_type = reply.header.msg_type;
         var cell = this.cell_for_msg(reply.parent_header.msg_id);
+        if (!cell){
+            // message not from this notebook
+            console.log("Received IOPub message not caused by one of my cells");
+            return;
+        }
         var output_types = ['stream','display_data','pyout','pyerr'];
         if (output_types.indexOf(msg_type) >= 0) {
             this.handle_output(cell, msg_type, content);

IPython/frontend/qt/base_frontend_mixin.py

@@ -106,4 +106,9 b' class BaseFrontendMixin(object):'
             from this frontend.
         """
         session = self._kernel_manager.session.session
-        return msg['parent_header']['session'] == session
+        parent = msg['parent_header']
+        if not parent:
+            # if the message has no parent, assume it is meant for all frontends
+            return True
+        else:
+            return parent.get('session') == session

IPython/lib/pylabtools.py

@@ -19,6 +19,7 b' Authors'
 # Imports
 #-----------------------------------------------------------------------------
 
+import sys
 from io import BytesIO
 
 from IPython.utils.decorators import flag_calls
@@ -317,6 +318,8 b' def pylab_activate(user_ns, gui=None, import_all=True, shell=None):'
     print """
 Welcome to pylab, a matplotlib-based Python environment [backend: %s].
 For more information, type 'help(pylab)'.""" % backend
+    # flush stdout, just to be safe
+    sys.stdout.flush()
     
     return gui
 

IPython/zmq/kernelapp.py

@@ -287,6 +287,10 b' class KernelApp(BaseIPythonApplication):'
         self.write_connection_file()
         self.init_io()
         self.init_kernel()
+        # flush stdout/stderr, so that anything written to these streams during
+        # initialization do not get associated with the first execution request
+        sys.stdout.flush()
+        sys.stderr.flush()
 
     def start(self):
         self.heartbeat.start()