Drop legacy write_unsigned()
parent
7f0f2e52a9
commit
163f747afb
|
@ -16,7 +16,7 @@ from multiprocessing import (
|
||||||
forkserver, semaphore_tracker, spawn, process, util
|
forkserver, semaphore_tracker, spawn, process, util
|
||||||
)
|
)
|
||||||
from multiprocessing.forkserver import (
|
from multiprocessing.forkserver import (
|
||||||
ForkServer, MAXFDS_TO_SEND, write_unsigned,
|
ForkServer, MAXFDS_TO_SEND
|
||||||
# _serve_one,
|
# _serve_one,
|
||||||
)
|
)
|
||||||
from multiprocessing.context import reduction
|
from multiprocessing.context import reduction
|
||||||
|
@ -156,8 +156,7 @@ def main(listener_fd, alive_r, preload, main_path=None, sys_path=None):
|
||||||
returncode = os.WEXITSTATUS(sts)
|
returncode = os.WEXITSTATUS(sts)
|
||||||
# Send exit code to client process
|
# Send exit code to client process
|
||||||
try:
|
try:
|
||||||
# write_signed(child_w, returncode)
|
write_signed(child_w, returncode)
|
||||||
write_unsigned(child_w, returncode)
|
|
||||||
except BrokenPipeError:
|
except BrokenPipeError:
|
||||||
# client vanished
|
# client vanished
|
||||||
pass
|
pass
|
||||||
|
@ -206,8 +205,7 @@ def main(listener_fd, alive_r, preload, main_path=None, sys_path=None):
|
||||||
else:
|
else:
|
||||||
# Send pid to client process
|
# Send pid to client process
|
||||||
try:
|
try:
|
||||||
# write_signed(child_w, pid)
|
write_signed(child_w, pid)
|
||||||
write_unsigned(child_w, pid)
|
|
||||||
except BrokenPipeError:
|
except BrokenPipeError:
|
||||||
# client vanished
|
# client vanished
|
||||||
pass
|
pass
|
||||||
|
|
Loading…
Reference in New Issue