ó æ™xTc@ s6ddlmZddlZddlZddlZddlZdd d„ƒYZd„Zd„Ze dkr2ddl Z ddl Z ddl Z e jjdd ƒZejZejd kráejejeeefƒnejejeeefƒe jd ƒe jƒZeGHer2ejƒGHq2ndS( iÿÿÿÿ(tdivisionNt FileClientcB s¤eZddd„Zd„Zd„Zd„Zd„Zd„Zd„Zd „Z d „Z d „Z d „Z d „Z d„Zdid„Zd„Zd„ZRS(ti@cC s¤|dks|dkr!d}n|s6tjƒ}n||_|jjdƒdkrs|jjdƒd|_ntj|jƒ|_t|ƒ|_d|_ dS(Ns 127.0.0.1t localhostRs iÿÿÿÿi( tsockettgetfqdnthosttfindtsplitt gethostbynametIPtinttporttNonetsock(tselfRR ((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyt__init__ s  cO s|jd||ƒS(NtGetServerDetails(t _remote_call(Rtargtkw((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyRscO s|jd||ƒS(NtGetHost(R(RRR((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyRscO s|jd||ƒS(NtGetPort(R(RRR((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyRscO s|jd||ƒS(NtLockFile(R(RRR((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyR'scO s|jd||ƒS(NtReadFile(R(RRR((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyR*scO s|jd||ƒS(Nt WriteFile(R(RRR((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyR-scO s|jd||ƒS(NtReadPickleFile(R(RRR((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyR0scO s|jd||ƒS(NtWritePickleFile(R(RRR((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyR3scO s|jd||ƒS(Nt UnlockFile(R(RRR((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyR6scO s|jd||ƒS(Nt FileExists(R(RRR((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyR9scO s|jd||ƒS(Ntgetpid(R(RRR((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyR?scO s|jd||ƒS(Nttester(R(RRR((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyRBscC s,d}|jdkrytjtjtjƒ|_|jj|j|jfƒ|jjdƒ|_ |jjdƒ|_ nt j ||j dƒt j ||j dƒt j ||j dƒ|j j ƒyt j|j ƒ}Wntk r÷d}nX|j jƒ|j jƒ|jjƒd|_|S(Ntwbtrbi(R RRtAF_INETt SOCK_STREAMtconnectRR tmakefiletsendtrecvtpickletdumptflushtloadt Exceptiontclose(Rtmethtargstkwdstresult((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyRIs&       cC s¶d|jj}|dt|jƒ7}|dt|jƒ7}|dt|jƒ7}|dt|jƒ7}y2|dt|jƒ7}|dt|jƒ7}Wnt k r±nX|S(Ns Class s host s IP s port s sock s send s recv ( t __class__t__name__tstrRR R RR&R'R,(Rtoutl((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyt__repr__is cC sƒyk|jddiƒd|_|jddiƒd|_|jddiƒd|_|jddiƒWntk r~nXdS(Ntshutdown(((((RR RR,(R((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyR7vs    ((R3t __module__RRRRRRRRRRRRRRR6R7(((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyRs$             cC sl|j||ƒzD|j|ƒ}d}|rS||ƒ\}}|j||ƒnWd|j||ƒX|S(sä This method will lock a file, read the contents and pass it to the user defined function. This function should return the return item and the new contents of the file. The contents is writing and the file unlocked. N(RRR RR(tclienttfiletidtfunctlinest return_item((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pytLockReadProcessWriteUnlock†scC sl|j||ƒzD|j|ƒ}d}|rS||ƒ\}}|j||ƒnWd|j||ƒX|S(s1 Same as above except a pickled obj is used. N(RRR RR(R9R:R;R<tobjR>((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyt&LockReadPickleProcessWritePickleUnlock›st__main__tlibtbxslibtbx/server/StartServer.pytwin32i((t __future__RR(RtsystosRR?RAR3t FileServerttimetlibtbx.load_envRCtenvt under_disttcmdt executablet python_pathtplatformtspawnvtP_NOWAITtspawnvptsleeptGetServerClientR9R(((sF/public2/ftp/pub/ccp4/6.5/ccp4-6.5/lib/py2/libtbx/server/FileClient.pyts.