o eT@sddlZddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl m Z Gddde j ZddZddZejGd d d eZejGd d d eZdS) N)errorc@seZdZdddZdS)ConstraintViolationNcCstjj|||dddS)Nzconstraint violation)tag)rError__init__)selfmsgjsonr -/usr/lib/python3/dist-packages/ovs/db/data.pyrszConstraintViolation.__init__N)__name__ __module__ __qualname__rr r r r rsrcCsg}|D]i}|dvr|d|qt|dkrh|dkr"|dq|dkr,|dq|dkr6|d q|d kr@|d q|d krJ|d q|dkrT|dq|dkr^|dq|dt|q||qd|S)Nz\"\  z\n z\rz\az\b z\f z\t z\vz\%03o)appendordjoin)srcdstcr r r escapeCString"s,          r cCs|Sr r )xr r r returnUnchanged=sr"c@seZdZdZd$ddZddZddZd d Zd d Ze d dZ ddZ e d$ddZ e ddZ ddZddZddZefddZedZe ddZd d!Ze d"d#ZdS)%Atom)valuetypeNcCs&||_|dur ||_dS||_dSr )r%r$ default_atom)rtype_r$r r r rEs z Atom.__init__cCs.t|tr |j|jkr tS|j|jkrdSdSNTF isinstancer#r%NotImplementedr$rotherr r r __eq__Lz Atom.__eq__cCs.t|tr |j|jkr tS|j|jkrdSdSr(r)r,r r r __lt__Qr/z Atom.__lt__cCs>t|tr |j|jkr tS|j|jkrdS|j|jkrdSdSNrr)r,r r r __cmp__Vs  z Atom.__cmp__cC t|jSr )hashr$rr r r __hash__` z Atom.__hash__cCst|S)aIReturns the default value for the given type_, which must be an instance of ovs.db.types.AtomicType. The default value for each atomic type is; - 0, for integer or real atoms. - False, for a boolean atom. - "", for a string atom. - The all-zeros UUID, for a UUID atom.)r#)r'r r r defaultcsz Atom.defaultcCs|||jkSr )r:r%r7r r r is_defaultszAtom.is_defaultcCs|j}tjj|}tg}|tgt|}|tjj j kr#t |tsG|tjj j kr/t ||sG|tjj j kr;t |tsG|tjj jkrMt |trMt||}n|tjj jkr_t|tj||}n td|||||S)Nz expected %s)r%ovsdbparser float_to_intintextendfloattupletypes IntegerTyper*RealType BooleanTypebool StringTypestrr#UuidTypeovsuuid from_jsonrr to_stringcheck_constraints)baser symtabr' real_typesatomr r r rNvs*   zAtom.from_jsoncCsPtjj|}t||jjrt|j|}n t d|jt|f| ||S)Nzexpected %s, got %s) r=r>r?r@r*r% python_typesr#rrrP)rQr$rTr r r from_pythons  zAtom.from_pythoncCsN|j|jksJ|jdur||jvrtd||jf|jtjjjtjjjfvrv|j dus7|j |j krD|j dusB|j |j krDdS|j dur[|j dur[td||j |j f|j durktd||j ftd||j f|jtjjj kr|j }t |}||jkrtd|||jf||jkrtd|||jfdSdS)aHChecks whether 'atom' meets the constraints (if any) defined in 'base' and raises an ovs.db.error.Error if any constraint is violated. 'base' and 'atom' must have the same type. Checking UUID constraints is deferred to transaction commit time, so this function does nothing for UUID constraints.Nz(%s is not one of the allowed values (%s)z7%s is not in the valid range %.15g to %.15g (inclusive)z+%s is less than minimum allowed value %.15gz.%s is greater than maximum allowed value %.15gz5"%s" length %d is less than minimum allowed length %dz8"%s" length %d is greater than maximum allowed length %d)r%enumrrOr=r>rErFrGminr$maxrJlen min_length max_length)rrQslengthr r r rPsZ        zAtom.check_constraintscCs$|jtjjjkrtj|jS|jSr )r%r=r>rErLrMto_jsonr$r7r r r r_sz Atom.to_jsoncCs|jtjjjkr d|jS|jtjjjkrd|jS|jtjjjkr)|jr'dSdS|jtjjjkr8dt |jS|jtjjj krIdtj |jSdS)Nz .integer = %dz .real = %.15gz.boolean = truez.boolean = falsez.s = %sz .uuid = %s) r%r=r>rErFr$rGrHrJr rLrMto_c_assignment)rvarr r r cInitAtoms  zAtom.cInitAtomcCs|jtjjjkr d|jS|jtjjjkrd|jS|jtjjjkr)|jr'dSdS|jtjjjkr6||jS|jtjjj krB|jjSdSNz%dz%.15gtruefalse) r%r=r>rErFr$rGrHrJrL)r escapeLiteralr r r toEnglishs   zAtom.toEnglishz&$|true|false|[^_a-zA-Z]|.*[^-._a-zA-Z]cCs tj|Sr )r#_Atom__need_quotes_rematch)r]r r r __string_needs_quotess zAtom.__string_needs_quotescCs|jtjjjkr d|jS|jtjjjkrd|jS|jtjjjkr)|jr'dSdS|jtjjjkrAt |jr>tj |jS|jS|jtjjj krNt|jSdSrc)r%r=r>rErFr$rGrHrJr#_Atom__string_needs_quotesr rOrLrKr7r r r rOs    zAtom.to_stringcCs|t|tr tjjj}n.t|trtjjj}n#t|tr!tjjj }nt|t r,tjjj }n t|t r7tjjj }ntt||Sr )r*rAr=r>rErFrCrGrIrHrKrJuuidrL TypeErrorr#)r!tr r r news           zAtom.newr )r rr __slots__rr.r0r4r8 staticmethodr:r;rNrVrPr_rbr"rgrecompilerhrkrOror r r r r#As0      *   r#c@seZdZdZifddZddZddZdd Zd Zd d Z d dZ e ddZ ddZ ddZe d1ddZddZddZddZddZdd Zd!d"Zd#d$Ze d%d&Zd'd(Zd1d)d*Zd+d,Zd-d.Zd/d0Zd S)2Datumr%valuescCs||_||_dSr ru)rr'rvr r r rs zDatum.__init__cCs"t|tstS|j|jkrdSdSr(r*rtr+rvr,r r r r. z Datum.__eq__cCs"t|tstS|j|jkrdSdSr(rwr,r r r r0rxz Datum.__lt__cCs2t|tstS|j|jkrdS|j|jkrdSdSr1rwr,r r r r4s   z Datum.__cmp__NcCs ||jvSr )rv)ritemr r r __contains__+r9zDatum.__contains__cCst|jt|jSr )rtr%dictrvr7r r r copy.sz Datum.copycCsF|jdkri}n|r|j|ji}n|jdi}t||S)Nr)n_minis_mapkeyr:r$rt)r'rvr r r r:1s  z Datum.defaultcCs|t|jkSr )rtr:r%r7r r r r;;r<zDatum.is_defaultcCs<|jD]\}}||jj|dur||jjqdS)aQChecks that each of the atoms in 'datum' conforms to the constraints specified by its 'type' and raises an ovs.db.error.Error. This function is not commonly useful because the most ordinary way to obtain a datum is ultimately via Datum.from_json() or Atom.from_json(), which check constraints themselves.N)rvitemsrPr%rr$)rkeyAtom valueAtomr r r rP>s zDatum.check_constraintsc Cs6|}|st|trt|dkr|ddkr|rd}nd}tjj||ttgd}t|}||j ks8||j krFt d||j |j |f|i}|D]<}|rhtjj |\} } t|j| |} t|j| |} n t|j||} d} | |vr|r}t dt d| || <qJt||St|j||} t|| diS) aParses 'json' as a datum of the type described by 'type'. If successful, returns a new datum. On failure, raises an ovs.db.error.Error. Violations of constraints expressed by 'type' are treated as errors. If 'symtab' is nonnull, then named UUIDs in 'symtab' are accepted. Refer to RFC 7047 for information about this, and for the syntax that this function accepts.rsetmaparrayz0%s must have %d to %d members but %d are presentNzmap contains duplicate keyzset contains duplicate)r~r*listrZr=r>r? unwrap_jsonrDr}n_maxrrparse_json_pairr#rNrr$rt) r'r rRr~class_innernrvelementrr$rrr r r rNJsH     zDatum.from_jsoncCsj|jrdddt|jDgSt|jdkr'tt|j}| Sdddt|jDgS)NrcSs g|] \}}||gqSr r_.0kvr r r sz!Datum.to_json..r3rcSsg|]}|qSr rrrr r r rs) r%r~sortedrvrrZnextiterkeysr_rrr r r r_}s  z Datum.to_jsoncCsd}}|jjdkst|jdkr|jrd}d}nd}d}g}|r(||tt|jD]&\}}|r:|d|||jrU|d||j|q/|r]||d |S) Nr3r{}[]z, =r) r%rrZrvr~r enumeraterrOr)rheadtailr]irr r r rOs*       zDatum.to_stringcCsb|jjdks t|jdkr/|jD]\}}||jvr'||j|kr'|j|=q||j|<q|S|S)Nr3r)r%rrZrvr)rdatumrrr r r diffs  z Datum.diffcCs2|jrdd|jDSdd|jDS)NcSsg|] \}}|j|jgqSr r$rr r r rsz!Datum.as_list..cSsg|]}|jqSr rrr r r rs)r%r~rvrrr7r r r as_lists z Datum.as_listcCr5r )r{rvr7r r r as_dictr9z Datum.as_dictcCsRt|jdkr'|jrtt|j\}}|j|jgStt|jjSdS)Nr3) rZrvr%r~rrrr$r)rrrr r r as_scalars   zDatum.as_scalarcCs|jr|||jj}|dur|jjS|S|jrIi}|jD] \}}||j|jj}||j|jj}|durF|durF|||<q&|St }|jD]}||j|jj}|durb| |qOt |S)aReturns this datum's value converted into a natural Python representation of this datum's type, according to the following rules: - If the type has exactly one value and it is not a map (that is, self.type.is_scalar() returns True), then the value is: * An int or long, for an integer column. * An int or long or float, for a real column. * A bool, for a boolean column. * A str or unicode object, for a string column. * A uuid.UUID object, for a UUID column without a ref_table. * An object represented the referenced row, for a UUID column with a ref_table. (For the Idl, this object will be an ovs.db.idl.Row object.) If some error occurs (e.g. the database server's idea of the column is different from the IDL's idea), then the default value for the scalar type is used (see Atom.default()). - Otherwise, if the type is not a map, then the value is a Python list whose elements have the types described above. - Otherwise, the type is a map, and the value is a Python dict that maps from key to value, with key and value types determined as described above. 'uuid_to_row' must be a function that takes a value and an ovs.db.types.BaseType and translates UUIDs into row objects.N) r% is_scalarrrr:r~rvrr$raddr)r uuid_to_rowr$rrdkdvr]r r r to_pythons* #    zDatum.to_pythonc Csi}t|tr'|D]\}}t|j||}t|j||}|||<q n(t|ttt frB|D]}t|j||}d||<q1n t|j||}d||<t ||}| | sjt dt||j|jf|S)aReturns a new Datum with the given ovs.db.types.Type 'type_'. The new datum's value is taken from 'value', which must take the form described as a valid return value from Datum.to_python() for 'type'. Each scalar value within 'value' is initially passed through 'row_to_uuid', which should convert objects that represent rows (if any) into uuid.UUID objects and return other data unchanged. Raises ovs.db.error.Error if 'value' is not in an appropriate form for 'type_'.Nz.%d values when type requires between %d and %d)r*r{rr#rVrr$rrrDrtrPconforms_to_typerrrZr}r) r'r$ row_to_uuiddrrkavarr r r rVs*    zDatum.from_pythoncCs<t|ts t|}|jst||jvrt|j|jSr ) r*r#ror%r~ IndexErrorrvKeyErrorr$rr r r __getitem__s     zDatum.__getitem__cCs.t|ts t|}||jvr|j|jS|Sr )r*r#rorvr$)rrr:r r r get&s    z Datum.getcCs|Sr )rOr7r r r __str__.sz Datum.__str__cCs*t|j}|jj|ko|jjkSSr )rZrvr%r}r)rrr r r r1s  zDatum.conforms_to_typecCst|j}|dkr dgSg}|jjjtjjjkrW|d||fg7}t|jD] }|dt |j g7}q&|dg7}|d||fg7}t |D] }|d||fg7}qE|dg7}nd||fg}t|jD] }|d| |g7}qc|dg7}|jj r|jj jtjjjkr|d ||fg7}t|jD]\}}|dt |j g7}q|dg7}|d ||fg7}t |D] }|d ||fg7}q|dg7}n"d ||fg}t|j D]\}}|d| |g7}q|dg7}|d |g7}|d |g7}|d|g7}|jj r|d|g7}|dg7}|S)Nrz*static struct ovsdb_datum %s = { .n = 0 };z)static struct json %s_key_strings[%d] = {z8 { .type = JSON_STRING, .string = "%s", .count = 2 },z};z'static union ovsdb_atom %s_keys[%d] = {z! { .s = &%s_key_strings[%d] },z { %s },z)static struct json %s_val_strings[%d] = {z)static union ovsdb_atom %s_values[%d] = {z! { .s = &%s_val_strings[%d] },z static struct ovsdb_datum %s = {z .n = %d,z .keys = %s_keys,z .values = %s_values,)rZrvr%rr=r>rErJrr r$rangerbr)rnamerr]rrrrr r r cDeclareDatum5s\           zDatum.cDeclareDatumr )r rrrprr.r0r4r8rzr|rqr:r;rPrNr_rOrrrrrrVrrrrrr r r r rt s:     2   9 !  rt) functoolsrrrl ovs.db.parserr= ovs.db.typesovs.json ovs.jsonrpc ovs.ovsuuid ovs.pollerovs.socket_utilovs.dbrrrr r"total_orderingobjectr#rtr r r r s& L