U @f @sedZddlZedZddlmZddlmZddlmZddlm Z ddl m Z ej Z d d d d d dgZ e eee eeddd ZejZdd ZejZdd Zdd ZejZdd ZejZdddZdS)osNsocket)greenio) get_errno) greenthread)hubs)slurp_propertiesfdopenreadwritewaitwaitpidopen)ignoreZsrckeysc Os\t|tstd|ztj|f||WStk rV}zt|jW5d}~XYnXdS)zrfdopen(fd [, mode='r' [, bufsize]]) -> file_object Return an open file object connected to a file descriptor.zfd should be int, not %rN) isinstanceint TypeErrorrZ GreenPipeOSErrorargs)fdrkwerK/var/www/html/chatgpt/venv/lib/python3.8/site-packages/eventlet/green/os.pyr s   c Csz t||WStk rV}z,t|tjkr6WYdSt|tjkrFW5d}~XYnXztj|ddWqtjk rYdSXqdS)z;read(fd, buffersize) -> string Read a file descriptor.NT)r ) __original_read__rrerrnoEPIPEEAGAINr trampolineZIOClosed)rnrrrrr $s  c CsZz t||WStk rD}zt|tjtjfkr4W5d}~XYnXtj|ddqdS)zPwrite(fd, string) -> byteswritten Write a string to a file descriptor. NT)r )__original_write__rrrrrrr)rstrrrrr 9s  cCs tddS)zDwait() -> (pid, status) Wait for completion of a child process.r)r rrrrr GscCsT|tj@dkrt||S|tjB}t||\}}|rD|dkrD||fStdq"dS)zjwaitpid(...) waitpid(pid, options) -> (pid, status) Wait for completion of a given child process.rg{Gz?N)os_origWNOHANG__original_waitpid__rsleep)pidoptions new_optionsZrpidstatusrrrr Qs   cCsVt|jdkr"|||df\}}}}|dk rs2