si3zddlZddlZddlZddlmZddlmZdZdZGdde Z Gdd e Z dS) N)deepcopy)BytesIOcJ|d|dko|d|dkSNri1i2s \/home/mmwave/public_html/mmwave/venv/lib/python3.11/site-packages/pymysqlreplication/gtid.pyoverlapr s% a52a5= *RURU]*cJ|d|dko|d|dkSrrr s r containsr s% a5BqE> ,ber!un,rceZdZdZedZedZdZdZdZ dgfdZ d Z d Z d Z d Zed ZdZedZdZdZdZdZdZdS)GtidaA mysql GTID is composed of a server-id and a set of right-open intervals [a,b), and represent all transactions x that happened on server SID such as a <= x < b The human representation of it, though, is either represented by a single transaction number A=a (when only one transaction is covered, ie b = a+1) SID:A Or a closed interval [A,B] for at least two transactions (note, in that case, that b=B+1) SID:A-B We can also have a mix of ranges for a given SID: SID:1-2:4:6-74 For convenience, a Gtid accepts adding Gtid's to it and will merge the existing interval representation. Adding TXN 3 to the human representation above would produce: SID:1-4:6-74 and adding 5 to this new result: SID:1-74 Raises: ValueError: If construction parsing from string fails Exception: Adding an already present transaction number (one that overlaps). Exception: Adding a Gtid with a different SID. ctjd|}|std|t|d}t|dp|}||dzfS)z We parse a human-generated string here. So our end value b is incremented to conform to the internal representation format. Raises: - ValueError if GTID format is incorrect z^([0-9]+)(?:-([0-9]+))?$GTID format is incorrect: r)research ValueErrorintgroup)intervalmabs r parse_intervalzGtid.parse_interval5ss I0( ; ; HF(FFGG G  OO  a !a%xrctjd|}|std||d}|d}d|dddD}||fS)zxParse a GTID from mysql textual format. Raises: - ValueError: if GTID format is incorrect. zG^([0-9a-fA-F]{8}(?:-[0-9a-fA-F]{4}){3}-[0-9a-fA-F]{12})((?::[0-9-]+)+)$rrrcBg|]}t|Sr)rr.0xs r zGtid.parse..Ws&UUUqD//22UUUr:N)rrrrsplit)gtidrsid intervalsintervals_parseds r parsez Gtid.parseEs I      DB$BBCC CggajjGGAJJ UUIOOCz&Gtid.__add_interval..hs-88Awq$888888rzOverlapping interval N) Exceptionanyr*sortedappendselfr3newexistings ` r __add_intervalzGtid.__add_interval[s  7T!W  8$8899 9 8888888 8 8 <:D::;; ;t~.. ! !HAw(1+%%  T!W-Aw(1+%%Q!- JJx tf --rcg}ddkrtdtfd|jDsdSt|jD]}t |rk|ddkr#||ddf|ddkr#|d|df}||||_dS)zdUsing the internal representation, remove an interval Raises: Exception if itvl malformatedrrr.c38K|]}t|VdSr0r1r2s r r4z&Gtid.__sub_interval..s-<<71d##<<<<<..s-<.sT  AEC<<<.format_intervalsItax1Q4A$++1+++qt99 rr&)joinmapr*r))r:rZinterval_strings r __str__z Gtid.__str__sF    ((3#G#GHH(.._...rcd|dS)Nzrr:s r __repr__z Gtid.__repr__s!!!!!rc6ddt|jzzS)N)lenr*r`s r encoded_lengthzGtid.encoded_lengths( $.!!" " rcJd}|tj|jddz }|t jdt |jz }|jD]>}|t jd|dz }|t jd|dz }?|S)aEncode a Gtid in binary Bytes are in **little endian**. Format: - sid will be uncoded as hex-binary without the dashes as a [u8; 16] - size of the interval list as a u64 - all the interval as a pair: (start: u64, end: u64). ## Diagram ```txt Alligned on u64 bit. +-+-+-+-+-+-+-+-+-+-+ | sid [16;u8] | | | +-+-+-+-+-+-+-+-+-+-+ | intervals_len u64 | +-+-+-+-+-+-+-+-+-+-+ |start u64 <-+ - - - - - - - - - - - + Repeated |stop u64 <-+ interval_len times - - - - - - - - - - - ``` rrV%>???&+dC$7$7888 5 5H fk$ 44 4F fk$ 44 4FF rc t|ts Jdd}|tj|dz}|dz}|tj|dz}|dz}|tj|dz}|dz}|tj|dz}|dz}|tj|dz}t jd|d\}g}td |D]G}t jd |d \}}|||d z fHd d fd|D}|| dd|S)zLDecode from binary a Gtid :param BytesIO payload to decode #payload is expected to be a BytesIOr-rrirz.format_intervals7!U## (A$''1'''6Mrr&c&g|] }|Srr)r#r$rZs r r%zGtid.decode..$s#$K$K$KA__Q%7%7$K$K$Krascii) rxrrjhexlifyreadrmunpackranger8r[decode) clspayloadr) n_intervalsr*istartendintervals_stringrZs @r rz Gtid.decodes '7++RR-RRRRH$W\\!__555DjH$W\\!__555DjH$W\\!__555DjH$W\\!__555DjH$W\\!__555tW\\!__== q+&& / /Augll2.>.>??JE3   eS1W- . . . .    88$K$K$K$K$K$K$KLLscjj))>>,<>>???rcF|j|jkrdS|j|jkS)NFr)r*rGs r __eq__z Gtid.__eq__(s% 9 5~00rcb|j|jkr|j|jkS|j|jkSr0rrGs r __lt__z Gtid.__lt__-/ 9 8ei' '~//rcb|j|jkr|j|jkS|j|jkSr0rrGs r __le__z Gtid.__le__2/ 9 8uy( (~00rcb|j|jkr|j|jkS|j|jkSr0rrGs r __gt__z Gtid.__gt__7rrcb|j|jkr|j|jkS|j|jkSr0rrGs r __ge__z Gtid.__ge__<rr)__name__ __module__ __qualname____doc__ staticmethodrr,rKrRrIrLrPrSr^rapropertyrfrp classmethodrrrrrrrrr rrsn""H  \ %%\%*...<2    "& & & & &       / / /"""  X &&&P@@[@@111 000 111 000 11111rrcreZdZdZdZdZdZdZdZdZ e dZ d Z e Z ed Zd Zd S) GtidSetzRepresents a set of Gtidcd|s g|_dSt|ttfrfd|D|_dSd|dD|_dS)a Construct a GtidSet initial state depends of the nature of `gtid_set` param. params: - gtid_set: - None: then the GtidSet start empty - a set of Gtid either as a their textual representation separated by comma - A set or list of gtid - A GTID alone. Raises: - ValueError: if `gtid_set` is a string separated with comma, but with malformated Gtid. - Exception: if Gtid interval are either malformated or overlapping ctt|tr|St|dS)N )rxrstrip)elements r _to_gtidz"GtidSet.__init__.._to_gtidUs3'4((  e,,-- -rc&g|] }|Srr)r#r$rs r r%z$GtidSet.__init__..]s!888!((1++888rcRg|]$}t|d%S)r)rrr"s r r%z$GtidSet.__init__.._s*LLL1$qwwu~~..LLLr,N)gtidsrxlistsetr')r:gtid_setrs @r rLzGtidSet.__init__Es  . . .  MDJJJ 4+ . . M8888x888DJJJLLs8K8KLLLDJJJrcg}|jD]@}|j|jkr|||z+||A|jd|Dvr||||_dS)z!Insert a Gtid in current GtidSet.c3$K|] }|jV dSr0)r)r"s r r4z%GtidSet.merge_gtid..is$55aAE555555rN)rr)r8)r:r( new_gtidsr<s r merge_gtidzGtidSet.merge_gtidas   + +H|tx''  D1111  **** 8559555 5 5   T " " " rcttr tfdjDSttr t fdjDSt )z Test if self contains other, could be a GtidSet or a Gtid. Raises: - NotImplementedError other is not a GtidSet neither a Gtid, please convert it first to one of them c3*K|] }|jvVdSr0r)r# other_gtidr:s r r4z'GtidSet.__contains__..vs*NNJzTZ/NNNNNNrc3 K|]}|vV dSr0r)r#r$rHs r r4z'GtidSet.__contains__..xs'66auz666666r)rxrrFrrr6NotImplementedErrorrGs``r rIzGtidSet.__contains__ms{ eW % % ONNNN%+NNNNN N eT " " 766664:66666 6!!rc$t|tr+t|j}|||St|tr5t|j}|jD]}|||St )z Merge current instance with an other GtidSet or with a Gtid alone. Raises: - NotImplementedError other is not a GtidSet neither a Gtid, please convert it first to one of them )rxrrrrr)r:rHr;r(s r rPzGtidSet.__add__{s eT " " $*%%C NN5 ! ! !J eW % % $*%%C  % %t$$$$J!!rcJdd|jDS)z< Returns a comma separated string of gtids. rc34K|]}t|VdSr0rWr"s r r4z"GtidSet.__str__..s(331A333333r)r[rr`s r r^zGtidSet.__str__s'xx33 333333rcd|jdS)Nz rr`s r razGtidSet.__repr__s(4:((((rcDdtd|jDzS)Nrvc3$K|] }|jV dSr0)rfr"s r r4z)GtidSet.encoded_length..s%<K|]}|VdSr0)rpr"s r r4z"GtidSet.encoded..s*66aqxxzz666666r)rmrnrerr[r`s r encodedzGtidSet.encodedsM" Kc$*oo . .hh664:66666 7  rctts Jdtjdd\}|fdt d|DS)zPDecode a GtidSet from binary. :param BytesIO payload to decode rrrirvcDg|]}tSr)rr)r#_rs r r%z"GtidSet.decode..s%BBBQDKK((BBBrr)rxrrmr~r}r)rrn_sids ` r rzGtidSet.decodesn '7++RR-RRRR=w||A77sBBBB%5//BBBCCCrc"|j|jkSr0rrGs r rzGtidSet.__eq__szU[((rN)rrrrrLrrIrPr^rarrfrrprrrrrr rrBs""MMM8    " " """"*444 )))==X=   ,FDD[D)))))rr) rrmrjcopyriorr robjectrrrrr rs +++---o1o1o1o1o16o1o1o1d )))))f)))))r