o i e@sdZddlZddlZddlZddlZddlZddlmZddlmZddl m Z ddZ dd Z Gd d d Z e rVGd d d e ejjZGdddejjZeZejZnGdddeZdaddZddZddZddZdS)z"Library for multi-process testing.N)app)logging)testcCsttjdko dtjdvS)z*Returns whether the test is run under OSS.bazelr)lensysargvr r ]/var/www/myenv/lib/python3.10/site-packages/tensorflow/python/distribute/multi_process_lib.pyis_osssr cCsBddtjD}tr|rdStjdkrtdkrdStjdkS)NcSsg|] }|dr|qS)z--tpu) startswith).0argr r r $sz_is_enabled..F)Linuxwin32)rr r version_infoplatformsystem)tpu_argsr r r _is_enabled!s   rcs(eZdZdZfddZddZZS) _AbslProcessz'A process that runs using absl.app.run.cs.tt|j|i|t|d|_|j|_dS)Nrun)superr__init__getattr _run_impl_run_with_abslrselfargskwargs __class__r r r/s  z_AbslProcess.__init__cstfdddS)NcsS)N)r)_r"r r 6sz-_AbslProcess._run_with_absl..)rrr(r r(r r 5sz_AbslProcess._run_with_absl)__name__ __module__ __qualname____doc__rr __classcell__r r r%r r,s rc@seZdZdZdS)AbslForkServerProcessz^An absl-compatible Forkserver process. Note: Forkserver is not available in windows. N)r*r+r,r-r r r r r/;sr/c@seZdZdZeZdS)AbslForkServerContextabsl_forkserverN)r*r+r,_namer/Processr r r r r0Bsr0c@seZdZdZddZdS)r3z7A process that skips test (until windows is supported).cOs~~td)NzBTODO(b/150264776): Windows is not supported in MultiProcessRunner.)unittestSkipTestr!r r r rNszProcess.__init__N)r*r+r,r-rr r r r r3Ks r3FcCsttjddr.dd}|d}|s|d}|dur)tdtjdtjtd |tjd<t tjddS) aSet the path to the executable for spawned processes. This utility searches for the binary the parent process is using, and sets the executable of multiprocessing's context accordingly. Raises: RuntimeError: If the binary path cannot be determined. rz.pycSsdtjdvrD|tjdvrFtjddtjd|}tjdddddd}tj|||}t d|t |tj rB|SdSdSdS) Nz bazel-outr TEST_TARGET:/rzGuessed test binary path: %s) rr rfindosenvironreplacepathjoinrinfoaccessX_OK) package_rootpackage_root_basebinary possible_pathr r r guess_pathbs  z'_set_spawn_exe_path..guess_pathorg_tensorflow org_kerasNz:Cannot determine binary path. sys.argv[0]=%s os.environ=%szCannot determine binary path) rr endswithrerrorr;r< RuntimeErrormultiprocessing get_contextset_executable)rGr>r r r _set_spawn_exe_pathWs   rPcCsrdtjddvotjtjddd}|sdStjtjdd}tjddt_t|tddS)zDIf spawned process, run requested spawn task and exit. Else a no-op.z-crNzfrom multiprocessing.r)rr indexr execexit) is_spawnedcmdr r r _if_spawn_run_and_exitsrVcCs,dadtjd<trtttdS)z
s2      *