o y.e.@sddlZddlZddlZddlZddlZddlZddlZddlZddl Zzddl Z Wn e y5dZ Ynwej dkrEddl mZddlZejdZddZddZd"d d Zd d Zd dZddZddZddZddZddZdaddZddZddZd d!Z dS)#Nwin32 socket_utilc Cs|durdStj|}tj|}tdd}tddD]I}d|tdd|f}zt||t j |tj |tj |WStyf}z|jtjkr\WYd}~tdWYd}~qd}~wwtd)NTMPDIRz/tmpriz%s/ovs-un-py-%d-%di'z"Failed to create temporary symlink)ospathabspathdirnamegetenvrangerandomrandintsymlinkovs fatal_signaladd_file_to_unlinkjoinbasenameOSErrorerrnoEEXIST Exception) long_name long_dirnametmpdirx link_nameer1/usr/lib/python3/dist-packages/ovs/socket_util.pymake_short_name&s(        rcCs(|durdStj|}tj|dS)N)rrrrrunlink_file_now) short_namerrrrfree_short_name9s r"Fc Csz ttj|}Wntjy"}z t|dfWYd}~Sd}~wwz|r*t||duryzt|Wn$tyY}z|jtj krO|jdfWYd}~WSWYd}~nd}~wwt j || |z t|dWn tyxYnw|durz||Wntjy}zt|tjkrWYd}~nd}~wwd|fWStjy }zY||durtj|rt j |t j|}|dkrtddkrd}d} d} d} |dur"tj|} tj|} z t| tjtjB} Wnty}zt|dfWYd}~WYd}~Sd}~wwd| | f}|duretj|} tj|} z t| tjtjB} Wnty^}zt|dfWYd}~WYd}~Sd}~wwd| | f} z)t||| |W| durwt| | durt| WYd}~SWYd}~S| durt| | durt| ww|dkr|rt|dfWYd}~Sd} z t|} t|}Wnt| tj dfYWYd}~Szt||| |ddWt| t|WYd}~St| t|wt|dfWYd}~Sd}~ww) aCreates a Unix domain socket in the given 'style' (either socket.SOCK_DGRAM or socket.SOCK_STREAM) that is bound to 'bind_path' (if 'bind_path' is not None) and connected to 'connect_path' (if 'connect_path' is not None). If 'nonblock' is true, the socket is made non-blocking. Returns (error, socket): on success 'error' is 0 and 'socket' is a new socket object, on failure 'error' is a positive errno value and 'socket' is None.NirzAF_UNIX path too longLinuxz/proc/self/fd/%d/%sT)short)!socketAF_UNIXerrorget_exception_errnoset_nonblockingrunlinkrrENOENTrrrbindfchmodfilenoconnect EINPROGRESScloserexistsr runamerropen O_DIRECTORYO_RDONLYmake_unix_socketrr" ENAMETOOLONG)stylenonblock bind_path connect_pathr$sockrenoshort_connect_pathshort_bind_path connect_dirfd bind_dirfdrrerrrrrr7@s                $   $         r7c Cs$tjdkr)tj}tdddd}t||tj tj Btj B| |tjj n tj}| |tjj |d}t|dkr|dd}|tjj@sS|tjj@rz"trdt|tjrd|dn |dtjtdtjWStjy}z t|WYd}~Sd}~wwdStj S)NrFTrz&poll return POLLERR but send succeeded)!sysplatformrpoller SelectPollwinutils get_new_event win32fileWSAEventSelectFD_WRITE FD_CONNECTFD_CLOSEregisterPOLLOUTget_system_pollpolllenPOLLERRPOLLHUPssl isinstance SSLSocketsendencoder% MSG_DONTWAITvlogrCrEPROTOr'r(EAGAIN)r=peventpfdsreventsrrrrcheck_connection_completions:       rec Csdz ttj|WdSty'z t|WYdStjy&YYdSwtjy1YdSw)NFT)r% inet_ptonAF_INETAttributeError inet_atonr')addressrrris_valid_ipv4_addresss rkcCsx|d}t|dkr!d|dddd}t|d}n|r&|}ntd||d}|s8td|||fS) N:r[]z!%s: port number must be specifiedz%s: bad peer name format)splitrUrlstriprstripint ValueError)target default_portrj host_nameportrrrinet_parse_actives    rzc Csz)t|d}|rttj|d}tj}nttj|d}tj}W||fSW||fStjyB}z t|dfWYd}~Sd}~wwNr)rkr%rgAF_INET6r'r()r9rj is_addr_inetr=familyrrrrinet_create_socket_actives rc Cs|z"t|t|||||}|dtjtjfvr ||WSWdStjy=}z|t |WYd}~Sd}~wwr{) r)set_dscp connect_exrr0 EWOULDBLOCKr1r%r'r()r=rjr~dscpr'rrrrinet_connect_actives  rcCsJt||}t||\}}|dur||fSt||||}|r!|dfSd|fSr{)rzrr)r9rvrwrrjr~r=r'rrrinet_open_actives rcCst|jtr |jdStjS)zA lot of methods on Python socket objects raise socket.error, but that exception is documented as having two completely different forms of arguments: either a string or a (errno, string) tuple. We only want the errno.r)rYargstuplerr_rrrrr(s  r(rnc Csltdkr4z ttjtjaWtSty3}ztdtjt|j f|j WYd}~Sd}~wwtS)zReturns a readable and writable fd for /dev/null, if successful, otherwise a negative errno value. The caller must not close the returned fd (because the same fd will be handed out to subsequent callers).rzcould not open %s: %sN) null_fdrr4devnullO_RDWRrr^rCstrerrorrrrrr get_null_fd!s  rc Csd}t|dkr dSt|tst|d} z6t||}|dks"J|t|kr1d|t|fWS|dkr@tdtj|fWS||7}|d|}Wnt yb}z |j|fWYd}~Sd}~wwq)aReturns an (error, bytes_written) tuple where 'error' is 0 on success, otherwise a positive errno value, and 'bytes_written' is the number of bytes that were written before the error occurred. 'error' is 0 if and only if 'bytes_written' is len(buf).r)rrzutf-8Tzwrite returned 0N) rUrYbytesrwriter^warnrr_r)fdbuf bytes_writtenretvalrrrr write_fully2s*        rc CsRz|dWdStjy(}ztdtt|WYd}~dSd}~ww)Nrz,could not set nonblocking mode on socket: %s) setblockingr%r'r^rCrrr()r=rrrrr)Ls r)cCsh|dkr td||d>}|tjkr|tjtj|dS|tjkr.|tjtj|dStd|)N?zInvalid dscp %drmzInvalid family %d) rur%rg setsockopt IPPROTO_IPIP_TOSr| IPPROTO_IPV6 IPV6_TCLASS)r=r~rvalrrrrTs    r)F)!rros.pathr r%rFovs.fatal_signalr ovs.pollerovs.vlogrX ImportErrorrG ovs.winutilsrJrLr^Vlogrr"r7rerkrzrrrr(rrrr)rrrrrsB      f'