never use memoryview for noncopying recv.

IPython/parallel/streamsession.py

@@ -308,7 +308,7 b' class StreamSession(object):'
         if isinstance(socket, ZMQStream):
             socket = socket.socket
         try:
-            msg = socket.recv_multipart(mode)
+            msg = socket.recv_multipart(mode, copy=copy)
         except zmq.ZMQError as e:
             if e.errno == zmq.EAGAIN:
                 # We can convert EAGAIN to None as we know in this case

IPython/parallel/util.py

@@ -315,10 +315,13 b' def unpack_apply_message(bufs, g=None, copy=True):'
         if sa.data is None:
             m = bufs.pop(0)
             if sa.getTypeDescriptor() in ('buffer', 'ndarray'):
-                if copy:
-                    sa.data = buffer(m)
-                else:
-                    sa.data = m.buffer
+                # always use a buffer, until memoryviews get sorted out
+                sa.data = buffer(m)
+                # disable memoryview support
+                # if copy:
+                #     sa.data = buffer(m)
+                # else:
+                #     sa.data = m.buffer
             else:
                 if copy:
                     sa.data = m
@@ -332,10 +335,13 b' def unpack_apply_message(bufs, g=None, copy=True):'
         if sa.data is None:
             m = bufs.pop(0)
             if sa.getTypeDescriptor() in ('buffer', 'ndarray'):
-                if copy:
-                    sa.data = buffer(m)
-                else:
-                    sa.data = m.buffer
+                # always use a buffer, until memoryviews get sorted out
+                sa.data = buffer(m)
+                # disable memoryview support
+                # if copy:
+                #     sa.data = buffer(m)
+                # else:
+                #     sa.data = m.buffer
             else:
                 if copy:
                     sa.data = m