;ò éÿó|i o/||_d|_|ii|i|iƒndS(Ni(sselfs _isConnectedssocks _connections evhandlers PushReadEvents_In(sselfssock((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pys_SetConnectionOpenPs   cCst|ƒ}y>|ii|ƒ}||jo||}|i|ƒnWn?t i j o0\}}|djo|i|ƒqŒ‚nXdS(Ni ( slensdatasnumBytesToSendsselfs _connectionssends numBytesSents remainings_QueuessocketserrorserrNumserrText(sselfsdatas numBytesSentserrNumsnumBytesToSends remainingserrText((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pys _SendOrQueueVs    cCsA|idjo|ii|i|iƒn|i||_dS(Ns(sselfs_pendingOutputs evhandlersPushWriteEvents _connections _QueuedWrites strToQueue(sselfs strToQueue((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pys_QueuecscCs˜t|iƒ}yS|iitƒ}||jo d|_|ii |iƒn|i||_Wn/t i j o \}}|djoq”nXdS(Nsi (slensselfs_pendingOutputsnumBytesToSends _connectionssendserlStrs numBytesSents evhandlers PopWriteEventssocketserrorserrNumserrText(sselfs numBytesSentserrNumsnumBytesToSendserrText((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pys _QueuedWritehs   cCsdGH|iidƒ}dS(Ns"erl_sync_conn: please override me!i'(sselfs _connectionsrecvsnewData(sselfsnewData((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pys_InwscCsti|ƒSdS(N(s erl_commonsReadInt1ss(sselfss((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pysReadInt1{scCsti|ƒSdS(N(s erl_commonsReadInt2ss(sselfss((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pysReadInt2~scCsti|ƒSdS(N(s erl_commonsReadInt4ss(sselfss((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pysReadInt4scCsti|ƒSdS(N(s erl_commonsPackInt1si(sselfsi((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pysPackInt1„scCsti|ƒSdS(N(s erl_commonsPackInt2si(sselfsi((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pysPackInt2‡scCsti|ƒSdS(N(s erl_commonsPackInt4si(sselfsi((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pysPackInt4Šs(s__name__s __module__sNones__init__sClosesSends GetConnections_Inits_SetConnectionCloseds_SetConnectionOpens _SendOrQueues_Queues _QueuedWrites_InsReadInt1sReadInt2sReadInt4sPackInt1sPackInt2sPackInt4(((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pysErlAsyncPeerConnection%s"             sErlAsyncClientConnectioncBstZd„Zd„ZRS(NcCsti|ƒdS(N(sErlAsyncPeerConnections__init__sself(sself((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pys__init__scCs•tititiƒ}yG|i||fƒ|idƒ||_||_|i |ƒdSWn/ti j o }dG|GH|i ƒdSnXdS(Niis socket error:( ssocketsAF_INETs SOCK_STREAMsssconnectshostnamesportNums setblockingsselfs_SetConnectionOpenserrorserrInfos_SetConnectionClosed(sselfshostnamesportNumssserrInfo((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pysConnect“s      (s__name__s __module__s__init__sConnect(((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pysErlAsyncClientConnectionŽs sErlAsyncServercBs2tZd„Zddd„Zd„Zd„ZRS(NcCsti|ƒdS(N(sErlAsyncPeerConnections__init__sself(sself((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pys__init__£siscCsÃtititiƒ}y|ititidƒ|i||fƒ|i ƒ\}}|idƒ|idƒ||_||_ |i|ƒ|SWn%tij o}dG|GHtSnXdS(Niiis socket error:(ssocketsAF_INETs SOCK_STREAMsss setsockoptsSOCKETs SOL_SOCKETs SO_REUSEADDRsbindsifacesportNums getsocknamesipNums resultPortNumslistens setblockingsselfshostnames_SetConnectionOpenserrorserrInfosNone(sselfsportNumsifacesipNumsss resultPortNumserrInfo((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pysStart¦s      cCs>|iƒ}|iƒ\}\}}|i|||fƒdS(N(sselfs GetConnectionsssacceptss2s remoteHosts remotePorts_NewConnection(sselfss2s remoteHostsss remotePort((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pys_In¶s cCsttƒ}dS(N(sErlAsyncPeerConnectionss2sasyncConnection(sselfssockConns remoteAddrsasyncConnection((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pys_NewConnection»s (s__name__s __module__s__init__sStarts_Ins_NewConnection(((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pysErlAsyncServer¢s  (ssocketsSOCKETs ImportErrors erl_commonserl_eventhandlersErlAsyncPeerConnectionsErlAsyncClientConnectionsErlAsyncServer(serl_eventhandlerssocketsErlAsyncServersErlAsyncClientConnectionsErlAsyncPeerConnections erl_commonsSOCKET((sR/mnt/gmirror/ports/devel/py_otp_interface/work/py_interface-0.93/erl_async_conn.pys?s     i