stderr = None

[1500] Fix | Delete

[1501] Fix | Delete

# Only create this mapping if we haven't already.

[1502] Fix | Delete

if not self._communication_started:

[1503] Fix | Delete

self._fileobj2output = {}

[1504] Fix | Delete

if self.stdout:

[1505] Fix | Delete

self._fileobj2output[self.stdout] = []

[1506] Fix | Delete

if self.stderr:

[1507] Fix | Delete

self._fileobj2output[self.stderr] = []

[1508] Fix | Delete

[1509] Fix | Delete

if self.stdout:

[1510] Fix | Delete

stdout = self._fileobj2output[self.stdout]

[1511] Fix | Delete

if self.stderr:

[1512] Fix | Delete

stderr = self._fileobj2output[self.stderr]

[1513] Fix | Delete

[1514] Fix | Delete

self._save_input(input)

[1515] Fix | Delete

[1516] Fix | Delete

if self._input:

[1517] Fix | Delete

input_view = memoryview(self._input)

[1518] Fix | Delete

[1519] Fix | Delete

with _PopenSelector() as selector:

[1520] Fix | Delete

if self.stdin and input:

[1521] Fix | Delete

selector.register(self.stdin, selectors.EVENT_WRITE)

[1522] Fix | Delete

if self.stdout:

[1523] Fix | Delete

selector.register(self.stdout, selectors.EVENT_READ)

[1524] Fix | Delete

if self.stderr:

[1525] Fix | Delete

selector.register(self.stderr, selectors.EVENT_READ)

[1526] Fix | Delete

[1527] Fix | Delete

while selector.get_map():

[1528] Fix | Delete

timeout = self._remaining_time(endtime)

[1529] Fix | Delete

if timeout is not None and timeout < 0:

[1530] Fix | Delete

raise TimeoutExpired(self.args, orig_timeout)

[1531] Fix | Delete

[1532] Fix | Delete

ready = selector.select(timeout)

[1533] Fix | Delete

self._check_timeout(endtime, orig_timeout)

[1534] Fix | Delete

[1535] Fix | Delete

# XXX Rewrite these to use non-blocking I/O on the file

[1536] Fix | Delete

# objects; they are no longer using C stdio!

[1537] Fix | Delete

[1538] Fix | Delete

for key, events in ready:

[1539] Fix | Delete

if key.fileobj is self.stdin:

[1540] Fix | Delete

chunk = input_view[self._input_offset :

[1541] Fix | Delete

self._input_offset + _PIPE_BUF]

[1542] Fix | Delete

try:

[1543] Fix | Delete

self._input_offset += os.write(key.fd, chunk)

[1544] Fix | Delete

except BrokenPipeError:

[1545] Fix | Delete

selector.unregister(key.fileobj)

[1546] Fix | Delete

key.fileobj.close()

[1547] Fix | Delete

else:

[1548] Fix | Delete

if self._input_offset >= len(self._input):

[1549] Fix | Delete

selector.unregister(key.fileobj)

[1550] Fix | Delete

key.fileobj.close()

[1551] Fix | Delete

elif key.fileobj in (self.stdout, self.stderr):

[1552] Fix | Delete

data = os.read(key.fd, 32768)

[1553] Fix | Delete

if not data:

[1554] Fix | Delete

selector.unregister(key.fileobj)

[1555] Fix | Delete

key.fileobj.close()

[1556] Fix | Delete

self._fileobj2output[key.fileobj].append(data)

[1557] Fix | Delete

[1558] Fix | Delete

self.wait(timeout=self._remaining_time(endtime))

[1559] Fix | Delete

[1560] Fix | Delete

# All data exchanged. Translate lists into strings.

[1561] Fix | Delete

if stdout is not None:

[1562] Fix | Delete

stdout = b''.join(stdout)

[1563] Fix | Delete

if stderr is not None:

[1564] Fix | Delete

stderr = b''.join(stderr)

[1565] Fix | Delete

[1566] Fix | Delete

# Translate newlines, if requested.

[1567] Fix | Delete

# This also turns bytes into strings.

[1568] Fix | Delete

if self.encoding or self.errors or self.universal_newlines:

[1569] Fix | Delete

if stdout is not None:

[1570] Fix | Delete

stdout = self._translate_newlines(stdout,

[1571] Fix | Delete

self.stdout.encoding,

[1572] Fix | Delete

self.stdout.errors)

[1573] Fix | Delete

if stderr is not None:

[1574] Fix | Delete

stderr = self._translate_newlines(stderr,

[1575] Fix | Delete

self.stderr.encoding,

[1576] Fix | Delete

self.stderr.errors)

[1577] Fix | Delete

[1578] Fix | Delete

return (stdout, stderr)

[1579] Fix | Delete

[1580] Fix | Delete

[1581] Fix | Delete

def _save_input(self, input):

[1582] Fix | Delete

# This method is called from the _communicate_with_*() methods

[1583] Fix | Delete

# so that if we time out while communicating, we can continue

[1584] Fix | Delete

# sending input if we retry.

[1585] Fix | Delete

if self.stdin and self._input is None:

[1586] Fix | Delete

self._input_offset = 0

[1587] Fix | Delete

self._input = input

[1588] Fix | Delete

if input is not None and (

[1589] Fix | Delete

self.encoding or self.errors or self.universal_newlines):

[1590] Fix | Delete

self._input = self._input.encode(self.stdin.encoding,

[1591] Fix | Delete

self.stdin.errors)

[1592] Fix | Delete

[1593] Fix | Delete

[1594] Fix | Delete

def send_signal(self, sig):

[1595] Fix | Delete

"""Send a signal to the process."""

[1596] Fix | Delete

# Skip signalling a process that we know has already died.

[1597] Fix | Delete

if self.returncode is None:

[1598] Fix | Delete

os.kill(self.pid, sig)

[1599] Fix | Delete

[1600] Fix | Delete

def terminate(self):

[1601] Fix | Delete

"""Terminate the process with SIGTERM

[1602] Fix | Delete

"""

[1603] Fix | Delete

self.send_signal(signal.SIGTERM)

[1604] Fix | Delete

[1605] Fix | Delete

def kill(self):

[1606] Fix | Delete

"""Kill the process with SIGKILL

[1607] Fix | Delete

"""

[1608] Fix | Delete

self.send_signal(signal.SIGKILL)

[1609] Fix | Delete

[1610] Fix | Delete