o åÅe«.ã@s€ddlZddlZddlZddlZddlmZdd„ZGdd„deƒZ Gdd„de ƒZ d d „Z Gd d „d eƒZ Gd d„deƒZ dS)éN)ÚerrorcCs4| d¡r t d|¡‚tjj |¡st d|¡‚dS)NÚ_z%names beginning with "_" are reservedzname must be a valid id)Ú startswithrÚErrorÚovsÚdbÚparserÚ is_identifier)ÚnameÚjson©r ú//usr/lib/python3/dist-packages/ovs/db/schema.pyÚ _check_ids   ÿrc@sHeZdZdZddd„Zdd„Zeddd„ƒZd d „Zd d „Z d d„Z dS)ÚDbSchemazSchema for an OVSDB database.FcCs|||_||_||_| ¡dkr|j ¡D]}d|_q|j ¡D]}|j ¡D]}| ||jj d¡| ||jj d¡q&qdS)NrTÚkeyÚvalue) r ÚversionÚtablesÚ_DbSchema__root_set_sizeÚvaluesÚis_rootÚcolumnsÚ_DbSchema__follow_ref_tableÚtyperr)Úselfr rrÚallow_extensionsÚtableÚcolumnr r r Ú__init__!s þÿzDbSchema.__init__cCs&d}|j ¡D] }|jr|d7}q|S)z6Returns the number of tables in the schema's root set.ré)rrr)rÚn_rootrr r r Ú__root_set_size8s €zDbSchema.__root_set_sizec Cs°tjj |d¡}| ddg¡}| dtf¡}| dtf¡| dtg¡}| ¡|dur9t   d|¡s9t   d|¡‚i}|  ¡D]\}}t||ƒt |||¡||<q?t|||ƒS) Nzdatabase schemar ÚidrÚcksumrz[0-9]+\.[0-9]+\.[0-9]+$z'schema version "%s" not in format x.y.z)rrrÚParserÚgetÚ get_optionalÚstrÚdictÚfinishÚreÚmatchrrÚitemsrÚ TableSchemaÚ from_jsonr) r rrr rÚ tablesJsonrÚ tableNameÚ tableJsonr r r r.@s& ÿÿ  ÿ zDbSchema.from_jsoncCsV| ¡t|jƒk}i}|j ¡D] }| |¡||j<q|j|dœ}|jr)|j|d<|S)N)r rr)rÚlenrrÚto_jsonr r)rÚdefault_is_rootrrr r r r r3Vs  zDbSchema.to_jsoncCst | ¡¡S©N)rr.r3)rr r r Úcopyesz DbSchema.copycCsr|r |jtjjjks |jsdS|j |j¡|_|js(t j d|j ||jfdd‚|  ¡r5|jj s7d|_dSdSdS)Nz)column %s %s refers to undefined table %sz syntax error)ÚtagT)rrrÚtypesÚUuidTypeÚref_table_namerr%Ú ref_tablerrr Ú is_strong_refrÚ persistent)rrÚbaseÚ base_namer r r Ú__follow_ref_tablehsÿ ÿþ øzDbSchema.__follow_ref_tableN©F) Ú__name__Ú __module__Ú __qualname__Ú__doc__rrÚ staticmethodr.r3r6rr r r r rs   rc@s eZdZdd„Zedd„ƒZdS)Ú IdlSchemacCs,t ||||¡||_||_||_||_dSr5)rrÚ idlPrefixÚ idlHeaderÚcDeclsÚhDecls)rr rrrHrIrJrKr r r rs  zIdlSchema.__init__cCs tjj |d¡}| dtf¡}| dtf¡}| dtfd¡}| dtfd¡}t|ƒ}|d=|d=| dd¡| dd¡t j |dd}t |j |j |j||||ƒS) Nz IDL schemarHrIrJÚrKT)r)rrrr$r%r'r&r(Úpoprr.rGr rr)r rrHrIrJrKÚsubjsonÚschemar r r r.‡s  ÿzIdlSchema.from_jsonN)rBrCrDrrFr.r r r r rG~srGcs”|durtˆƒSt|tƒst d|¡‚|D]}t|tƒs"t d|¡‚|ˆvr.t d||¡‚qtt|ƒƒt|ƒkr?t d|¡‚t‡fdd„|DƒƒS)Nz'array of distinct column names expectedz%s is not a valid column namecsg|]}ˆ|‘qSr r )Ú.0Ú column_name©rr r Ú ªsz(column_set_from_json..)ÚtupleÚ isinstanceÚlistrrr'r2Úset)r rrQr rRr Úcolumn_set_from_jsonšs&   ÿÿÿÿ rXc@s:eZdZdejdgifdd„Zed dd„ƒZd dd„Zd S) r-TcCs.||_||_||_||_||_||_||_dSr5)r rÚmutableÚmax_rowsrÚindexesÚ extensions)rr rrYrZrr[r\r r r r®s zTableSchema.__init__FcCsftjj |d|¡}| dtg¡}| dtgd¡}| dtg¡}| dtgd¡}| dt gg¡}|r;| d tgi¡} ni} |  ¡|durIt j }n |d krSt  d |¡‚|s[t  d |¡‚i} | ¡D]\} } t| |ƒt | | |¡| | <qag} |D]0}t|| ƒ}|s‡t  d |¡‚t|ƒdkr’d|d _|D]}|js¢t  d|j|¡‚q”|  |¡qxt|| |||| | ƒS)Nztable schema for table %srrYTÚmaxRowsÚisRootFr[r\rzmaxRows must be at least 1z#table must have at least one columnz#index must have at least one columnrz1ephemeral columns (such as %s) may not be indexed)rrrr$r%r(r&ÚboolÚintrVr)ÚsysÚmaxsizerrr,rÚ ColumnSchemar.rXr2Úuniquer=r Úappendr-)r r rrÚ columns_jsonrYrZrÚ indexes_jsonr\rrQÚ column_jsonr[Ú index_jsonÚindexrr r r r.¸sT    þ    ÿÿÿ ÿzTableSchema.from_jsoncCs¨i}|js d|d<||jkr|j|d<i|d<}|j ¡D]}|j d¡s-| ¡||j<q|jtj kr9|j|d<|j rRg|d<|j D]}|d  dd „|Dƒ¡qC|S) aReturns this table schema serialized into JSON. The "isRoot" member is included in the JSON only if its value would differ from 'default_is_root'. Ordinarily 'default_is_root' should be false, because ordinarily a table would be not be part of the root set if its "isRoot" member is omitted. However, garbage collection was not originally included in OVSDB, so in older schemas that do not include any "isRoot" members, every table is implicitly part of the root set. To serialize such a schema in a way that can be read by older OVSDB tools, specify 'default_is_root' as True. FrYr^rrr]r[cSsg|]}|j‘qSr )r )rPrr r r rSsz'TableSchema.to_json..) rYrrrr rr3rZrarbr[re)rr4r rrrjr r r r3ås"     €   zTableSchema.to_jsonNrA) rBrCrDrarbrrFr.r3r r r r r-­s ÿ ,r-c@s.eZdZifdd„Zed dd„ƒZdd„ZdS) rccCs(||_||_||_||_d|_||_dS)NF)r rYr=rrdr\)rr rYr=Útype_r\r r r rs  zColumnSchema.__init__Fc Cs´tjj |d|¡}| dtgd¡}| dtgd¡}tg}| tg¡tjj j   |  d|¡¡}|r:| dtgi¡}ni}|  ¡|sQ|j ¡sO|jrQ|j ¡rQd}t||| ||ƒS)Nzschema for column %srYTÚ ephemeralFrr\)rrrr$r&r_r'Úextendr(r8ÚTyper.r%r)rÚ is_weak_refrrc) r r rrrYrlÚ_typesrkr\r r r r.s" ÿÿzColumnSchema.from_jsoncCs>d|j ¡i}|jsd|d<|jsd|d<|jr|j|d<|S)NrFrYTrlr\)rr3rYr=r\)rr r r r r3&s zColumnSchema.to_jsonNrA)rBrCrDrrFr.r3r r r r rcs    rc)r*raÚ ovs.db.parserrÚ ovs.db.typesÚovs.dbrrÚobjectrrGrXr-rcr r r r Ús `Z