1279 remoteAddress = "127.0.0.1" |
1279 remoteAddress = "127.0.0.1" |
1280 elif "@@i" in remoteAddress: |
1280 elif "@@i" in remoteAddress: |
1281 remoteAddress = remoteAddress.split("@@i")[0] |
1281 remoteAddress = remoteAddress.split("@@i")[0] |
1282 sock = socket.create_connection((remoteAddress, port)) |
1282 sock = socket.create_connection((remoteAddress, port)) |
1283 |
1283 |
1284 if not name: |
1284 stdinName = sys.stdin.name |
1285 name = "main" |
|
1286 self.__debuggerId = "{0}-{1}-{2}".format( |
|
1287 socket.gethostname(), os.getpid(), name |
|
1288 ) |
|
1289 |
|
1290 name = sys.stdin.name |
|
1291 # Special case if in a multiprocessing.Process |
1285 # Special case if in a multiprocessing.Process |
1292 if isinstance(name, int): |
1286 if isinstance(stdinName, int): |
1293 name = '<stdin>' |
1287 stdinName = '<stdin>' |
1294 |
1288 |
1295 self.readstream = AsyncFile(sock, sys.stdin.mode, name) |
1289 self.readstream = AsyncFile(sock, sys.stdin.mode, stdinName) |
1296 self.writestream = AsyncFile(sock, sys.stdout.mode, sys.stdout.name) |
1290 self.writestream = AsyncFile(sock, sys.stdout.mode, sys.stdout.name) |
1297 self.errorstream = AsyncFile(sock, sys.stderr.mode, sys.stderr.name) |
1291 self.errorstream = AsyncFile(sock, sys.stderr.mode, sys.stderr.name) |
1298 |
1292 |
1299 if redirect: |
1293 if redirect: |
1300 sys.stdin = self.readstream |
1294 sys.stdin = self.readstream |
1302 sys.stderr = self.errorstream |
1296 sys.stderr = self.errorstream |
1303 self.redirect = redirect |
1297 self.redirect = redirect |
1304 |
1298 |
1305 # attach to the main thread here |
1299 # attach to the main thread here |
1306 self.attachThread(mainThread=True) |
1300 self.attachThread(mainThread=True) |
|
1301 |
|
1302 if not name: |
|
1303 name = "main" |
|
1304 self.__debuggerId = "{0}/{1}/{2}".format( |
|
1305 socket.gethostname(), os.getpid(), name |
|
1306 ) |
1307 |
1307 |
1308 self.sendDebuggerId(self.__debuggerId) |
1308 self.sendDebuggerId(self.__debuggerId) |
1309 |
1309 |
1310 def __unhandled_exception(self, exctype, excval, exctb): |
1310 def __unhandled_exception(self, exctype, excval, exctb): |
1311 """ |
1311 """ |