Create tmporary directory for dumpCell request

Author: JohanMabille

ipykernel/compiler.py

@@ -1,8 +1,12 @@
 from IPython.core.compilerop import CachingCompiler
 import murmurhash.mrmr
+import tempfile
+import os
 
 def get_tmp_directory():
-    return '/tmp/ipykernel_debugger/'
+    tmp_dir = tempfile.gettempdir()
+    pid = os.getpid()
+    return tmp_dir + '/ipykernel_' + str(pid)
 
 def get_tmp_hash_seed():
     hash_seed = 0xc70f6907
@@ -12,7 +16,7 @@ def get_file_name(code):
     name = murmurhash.mrmr.hash(code, seed = get_tmp_hash_seed(), murmur_version=2)
     if name < 0:
         name += 2**32
-    return get_tmp_directory() + str(name) + '.py'
+    return get_tmp_directory() + '/' + str(name) + '.py'
 
 class XCachingCompiler(CachingCompiler):
 

ipykernel/debugger.py

@@ -10,7 +10,6 @@
 from .compiler import (get_file_name, get_tmp_directory, get_tmp_hash_seed)
 
 import debugpy
-import time
 
 class DebugpyMessageQueue:
 
@@ -163,7 +162,6 @@ def get_host_port(self):
             self.debugpy_port = self.endpoint[index+1:]
         return self.debugpy_host, self.debugpy_port
 
-
     def connect_tcp_socket(self):
         self.debugpy_stream.socket.connect(self._get_endpoint())
         self.routing_id = self.debugpy_stream.socket.getsockopt(zmq.ROUTING_ID)
@@ -238,6 +236,9 @@ def tcp_client(self):
 
     def start(self):
         if not self.debugpy_initialized:
+            tmp_dir = get_tmp_directory()
+            if not os.path.exists(tmp_dir):
+                os.makedirs(tmp_dir)
             host, port = self.debugpy_client.get_host_port()
             code = 'import debugpy;'
             code += 'debugpy.listen(("' + host + '",' + port + '))'
@@ -350,7 +351,7 @@ async def debugInfo(self, message):
                 'isStarted': self.is_started,
                 'hashMethod': 'Murmur2',
                 'hashSeed': get_tmp_hash_seed(),
-                'tmpFilePrefix': get_tmp_directory(),
+                'tmpFilePrefix': get_tmp_directory() + '/',
                 'tmpFileSuffix': '.py',
                 'breakpoints': breakpoint_list,
                 'stoppedThreads': self.stopped_threads