o åÅecRã@s¨ddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl Zddl Zej jZej d¡ZGdd„deƒZGdd„deƒZGdd„deƒZdS) éNÚjsonrpcc@s°eZdZdZdZdZdZedededediZd d „ZdZ e d d „ƒZ e d d„ƒZ e dd„ƒZ e dd„ƒZe dd„ƒZe dd„ƒZdd„Zdd„Ze dd„ƒZdd„Zdd „Zd!S)"ÚMessageréééÚrequestÚ notificationÚreplyÚerrorcCs(||_||_||_||_||_||_dS©N)ÚtypeÚmethodÚparamsÚresultr Úid)ÚselfÚtype_r rrr r©rú-/usr/lib/python3/dist-packages/ovs/jsonrpc.pyÚ__init__+s  zMessage.__init__cCstj}tjd7_|S©Nr)rÚ_next_id)Úthis_idrrrÚ _create_id5szMessage._create_idcCsttj||ddt ¡ƒSr )rÚ T_REQUESTr©r rrrrÚcreate_request;sÿzMessage.create_requestcCsttj||dddƒSr )rÚT_NOTIFYrrrrÚ create_notify@sÿzMessage.create_notifycCsttjdd|d|ƒSr )rÚT_REPLY)rrrrrÚ create_replyEózMessage.create_replycCsttjddd||ƒSr )rÚT_ERROR)r rrrrÚ create_errorIr!zMessage.create_errorcCs tj|Sr )rÚ_Message__types)rrrrÚtype_to_stringMs zMessage.type_to_stringcCs<|du|dkkr dSt |j¡}|rd}nd}d|||fS)NrÚmustzmust notz%s %s have "%s")rr%r )rÚvalueÚnameÚ must_haveÚ type_nameÚverbrrrÚ__validate_argQs zMessage.__validate_argcCs´|jdur t|jtƒs dStjdtjdtjdtjdi |j ¡}|dur(d|j S|  |j d|d@¡pY|  |jd |d @¡pY|  |j d |d @¡pY|  |j d |d@¡pY|  |jd|d@¡S)Nz"params" must be JSON arrayiiiéz invalid JSON-RPC message type %sr irérér érr)rÚ isinstanceÚlistrrrrr"Úgetr Ú_Message__validate_argr rr r)rÚpatternrrrÚis_valid\s(ýý ÿþýûzMessage.is_validc Csät|tƒsdSt|ƒ}d|vr| d¡}t|tƒsdSnd}| dd¡}| dd¡}| dd¡}| dd¡}t|ƒrBd| ¡d S|durJtj}n|durRtj}n |durZtj }ntj }t||||||ƒ}|  ¡}|durp|S|S) Nzmessage is not a JSON objectr zmethod is not a JSON stringrrr rz"message has unexpected member "%s"r) r1ÚdictÚpopÚstrÚlenÚpopitemrrr"rrr6) Újsonr rrr Úid_Úmsg_typeÚmsgÚvalidation_errorrrrÚ from_jsonns6   ÿ    zMessage.from_jsoncCsi}|jdur |j|d<|jdur|j|d<|jdus!|jtjkr&|j|d<|jdus1|jtjkr6|j|d<|jdusA|jtj krF|j|d<|S)Nr rrr r) r rrr rr"r rrr)rr<rrrÚto_json”s       zMessage.to_jsoncCsºt |j¡g}|jdur| d|j¡|jdur%| dtj |j¡¡|j dur6| dtj |j ¡¡|j durG| dtj |j ¡¡|j durX| dtj |j ¡¡d  |¡S)Nz method="%s"zparams=zresult=zerror=zid=z, ) rr%r r ÚappendrÚovsr<Ú to_stringrr rÚjoin)rÚsrrrÚ__str__¨s      zMessage.__str__N)Ú__name__Ú __module__Ú __qualname__rrrr"r$rrÚ staticmethodrrrr r#r%r4r6rArBrHrrrrr s<ý        % rc@sŒeZdZdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd „Zd!S)"Ú ConnectioncCs0|j|_||_d|_d|_d|_d|_d|_dS©NrÚ)r(ÚstreamÚstatusÚinputÚoutputÚparserÚreceived_bytes)rrPrrrr¸s zConnection.__init__cCs|j ¡d|_dSr )rPÚclose©rrrrrVÁs  zConnection.closecCs†|jrdSt|jƒrA|j |j¡}|dkr|j|d…|_n|tj kr8t d|j t   | ¡f¡|  | ¡dSt|jƒs dSdS)Nrz%s: send error: %s) rQr:rSrPÚsendÚerrnoÚEAGAINÚvlogÚwarnr(ÚosÚstrerrorr )rÚretvalrrrÚrunÅs  ÿ ÷zConnection.runcCs4|js|j |¡t|jƒr|j |¡dSdSdSr )rQrPÚrun_waitr:rSÚ send_wait©rÚpollerrrrÚwaitÔs   ýzConnection.waitcCó|jSr )rQrWrrrÚ get_statusÚózConnection.get_statuscCs|jdkrdSt|jƒS©Nr)rQr:rSrWrrrÚ get_backlogÝs  zConnection.get_backlogcCrfr )rUrWrrrÚget_received_bytesãrhzConnection.get_received_bytescCs&t ¡rt d|j||f¡dSdS)Nz %s: %s %s)r[Údbg_is_enabledÚdbgr()rÚtitler?rrrÚ __log_msgæsÿzConnection.__log_msgcCsR|jr|jS| d|¡t|jƒdk}|jtj | ¡¡7_|r&| ¡|jS)NrXr) rQÚ_Connection__log_msgr:rSrDr<rErBr`)rr?Ú was_emptyrrrrXês zConnection.sendcCsP| |¡}|r |S | ¡| ¡r| ¡r|jStj ¡}| |¡|  ¡q r ) rXr`rjrgrQrDrdÚPollerreÚblock)rr?r rdrrrÚ send_blockös   ùzConnection.send_blockcCsŠ|jr|jdfSt d¡ƒ} |js}|j d¡\}}|r2|s2z| |¡}Wn ty1tj }Ynw|rat j dkrA|tj krAtj }|tj krJ|dfSt d|jt |¡f¡| |¡|jdfS|sl| t¡tdfS|j|7_|jt|ƒ7_nG|jdurˆtj ¡|_tjjtjjkr£|j d¡|j |j¡d… ¡|_n |j|j |j¡d…|_|j ¡rÄ|  ¡}|r¿d|fS|jdfSq)Nzutf-8Tr.Úwin32z%s: receive error: %sr)!rQÚcodecsÚgetincrementaldecoderrRrPÚrecvÚdecodeÚ UnicodeErrorrYÚEILSEQÚsysÚplatformÚWSAEWOULDBLOCKrZr[r\r(r]r^r ÚEOFrUr:rTrDr<ÚParserÚPARSERÚPARSER_CÚencodeÚfeedÚis_doneÚ_Connection__process_msg)rÚdecoderr Údatar?rrrrxsV    ÿ   ÿ      ÿÿ  ÔzConnection.recvcCsP | ¡\}}|tjkr||fS| ¡tj ¡}| |¡| |¡|  ¡qr ) rxrYrZr`rDrdrrreÚ recv_waitrs)rr r?rdrrrÚ recv_block7s     özConnection.recv_blockcCs`|j}| |¡}d}|s,| ¡\}}|r*|jtjks |jtjkr*|j|kr* ||fS|r ||fSr )rrXrŠr rrr")rrr=r r rrrÚtransact_blockDs     ùzConnection.transact_blockcCs†|j ¡}d|_t|tƒrt d|j|f¡| tj ¡dSt   |¡}t|t ƒs;t d|j|f¡| tj ¡dS|  d|¡|S)Nz%s: error parsing stream: %sz%%s: received bad JSON-RPC message: %sÚreceived) rTÚfinishr1r9r[r\r(r rYÚEPROTOrrArp)rr<r?rrrÚ __process_msgRs     ÿ  zConnection.__process_msgcCs(|js|jr | ¡dS|j |¡dSr )rQrRÚimmediate_wakerPr‰rcrrrr‰fs  zConnection.recv_waitcCs(|jdkr||_|j ¡d|_dSdSrN)rQrPrVrS)rr rrrr ls   ýzConnection.errorN)rIrJrKrrVr`rergrjrkrprXrtrxrŠr‹r†r‰r rrrrrM·s"  3  rMc@sÈeZdZdZdd„Zed-dd„ƒZed-dd„ƒZed d „ƒZd d „Z d d„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd„Zdd „Zd!d"„Zd#d$„Zd%d&„Zd'd(„Zd)d*„Zd+d,„ZdS).ÚSessionz%A JSON-RPC session with reconnection.cCsL||_||_d|_d|_d|_t|ƒtur|g}||_t  |j¡d|_ dSri) Ú reconnectÚrpcrPÚpstreamÚseqnor r2ÚremotesÚrandomÚshuffleÚ next_remote)rr’r“r–rrrrvs   zSession.__init__NcCstj|g|dS)a=Creates and returns a Session that maintains a JSON-RPC session to 'name', which should be a string acceptable to ovs.stream.Stream or ovs.stream.PassiveStream's initializer. If 'name' is an active connection method, e.g. "tcp:127.1.2.3", the new session connects and reconnects, with back-off, to 'name'. If 'name' is a passive connection method, e.g. "ptcp:", the new session listens for connections to 'name'. It maintains at most one connection at any given time. Any new connection causes the previous one (if any) to be dropped. If "probe_interval" is zero it disables the connection keepalive feature. If non-zero the value will be forced to at least 1000 milliseconds. If None it will just use the default value in OVS. )Úprobe_interval)r‘Ú open_multiple)r(ršrrrÚopen‚sz Session.opencCsœtj tj ¡¡}t|d|ƒ}| ¡| tj ¡¡| t |ƒ¡tj j   |  ¡¡r4| dtj ¡¡tj  |  ¡¡sC| d¡|S|durL| |¡|S©NTr)rDr’Ú ReconnectÚtimevalÚmsecr‘Ú pick_remoteÚenableÚset_backoff_free_triesr:rPÚ PassiveStreamÚ is_valid_nameÚget_nameÚ set_passiveÚstream_or_pstream_needs_probesÚset_probe_interval)r–ršr’Úsessionrrrr›–s  ý zSession.open_multiplecCsRtj tj ¡¡}t|d|jgƒ}| d¡| ¡|  d¡|  tj ¡¡|Sr) rDr’ržrŸr r‘r(Ú set_quietr¡Ú set_max_triesÚ connected)rr’rªrrrÚopen_unreliably§s  zSession.open_unreliablycCs.|j |j|j¡|jdt|jƒ|_dSr)r’Úset_namer–r™r:rWrrrr¡±szSession.pick_remotecCsV|jdur |j ¡d|_|jdur|j ¡d|_|jdur)|j ¡d|_dSdSr )r“rVrPr”rWrrrrVµs       þz Session.closecCsb|jdur|j t¡|j ¡d|_n|jdur"|j ¡d|_ndS|jd7_| ¡dSr)r“r rrVrPr•r¡rWrrrÚ __disconnectÀs      zSession.__disconnectcCsÐ| ¡|j ¡}|j ¡s6tjj |¡\}|_|s$|j tj   ¡¡n;|j  tj   ¡|¡d|_|  ¡n)|j dur_tjj |¡\}|_ |sQ|j tj   ¡¡n|j  tj   ¡|¡|  ¡|jd7_dSr)Ú_Session__disconnectr’r¦Ú is_passiverDrPÚStreamrœÚ connectingrŸr Úconnect_failedr¡r”r¤Ú listeningr•)rr(r rrrÚ __connectÎs     zSession.__connectcCs$|jdurJ|j ¡\}}|dkr3|js|jr$t d|j ¡¡| ¡|j  t j   ¡¡t |ƒ|_n|tjkrJ|j t j   ¡|¡|j ¡d|_|jr|j ¡}|j ¡|j ¡|krg|j t j   ¡¡|j ¡}|dkr~|j t j   ¡|¡| ¡nA|jdurÀ|j ¡|j ¡}|dkr¥|j  t j   ¡¡t |jƒ|_d|_n|tjkrÀ|j t j   ¡|¡| ¡|j ¡d|_|j t j   ¡¡}|t jjkrÕ| ¡dS|t jjkrë|j t j   ¡d¡| ¡dS|t jjkr |jrt dg¡}d|_ |j !|¡dSdS|dusJ‚dS)Nrz.%s: new connection replacing active connectionÚecho)"r”Úacceptr“rPr[Úinfor’r¦r±r­rDrŸr rMrYrZÚ listen_errorrVrjr`ÚactivityrgÚ disconnectedÚconnectrµr¡ÚCONNECTÚ_Session__connectÚ DISCONNECTÚPROBErrrrX)rr rPÚbacklogÚactionrrrrr`äsb  ÿ      €           ýz Session.runcCsh|jdur |j |¡n|jdur|j |¡|j |¡|jdur(|j |¡|j |tj  ¡¡dSr ) r“rerPraÚ connect_waitr”r’rDrŸr rcrrrre s      z Session.waitcCs|jdur |j ¡SdSri)r“rjrWrrrrj*s  zSession.get_backlogcCs |j ¡Sr )r’r¦rWrrrr¦0ó zSession.get_namecCs|jdur |j |¡StjSr )r“rXrYÚENOTCONN)rr?rrrrX3s  z Session.sendcCsª|jdurS|j ¡}|j ¡\}}tj ¡}|j |¡||j ¡kr)|j |¡|sS|j t j krC|j dkrC|  t  |j|j¡¡dS|j t jkrQ|jdkrQ dS|SdS)Nr¸)r“rkrxrDrŸr r’Úreceive_attemptedr¼r rrr rXr rrr)rrUr r?Únowrrrrx9s     ûÿz Session.recvcCs|jdur |j |¡dSdSr )r“r‰rcrrrr‰Ss ÿzSession.recv_waitcCs2|jdus |jdur dS|j ¡}|dup|dkSr)r“rPr’Ú get_max_tries)rÚ max_triesrrrÚis_aliveWs zSession.is_alivecCs |jduSr )r“rWrrrÚ is_connected^rÆzSession.is_connectedcCrfr )r•rWrrrÚ get_seqnoarhzSession.get_seqnocCs|j tj ¡¡dSr )r’Úforce_reconnectrDrŸr rWrrrrÏdszSession.force_reconnectcCs*t|jƒ}| ¡r |d7}|j |¡dS)zÑ Resets the reconnect backoff by allowing as many free tries as the number of configured remotes. This is to be used by upper layers before calling force_reconnect() if backoff is undesirable.rN)r:r–rÍr’r£)rÚ free_triesrrrÚ reset_backoffgs zSession.reset_backoffcCs t|jƒSr )r:r–rWrrrÚget_num_of_remotestrÆzSession.get_num_of_remotesr )rIrJrKÚ__doc__rrLrœr›r®r¡rVr±rÀr`rerjr¦rXrxr‰rÌrÍrÎrÏrÑrÒrrrrr‘ss4     <  r‘)rvrYr]r—r|Úovs.jsonrDÚ ovs.pollerÚ ovs.reconnectÚ ovs.streamÚ ovs.timevalÚovs.utilÚovs.vlogÚutilrr[ÚVlogÚobjectrrMr‘rrrrÚs&  =