E/SSKJr SSKrSSKrSSKJrJrJr SSKrSSK J r SSK J r \R"\5r\\ R r"SS5r"SS \5rg) ) OrderedDictN)DictOptionalType)types) exceptionsc4\rSrSrSrS\S\S\4SjrSrSr g ) _QuantityReservationz2A (partial) reservation of quantifiable resources.bytes_reserved bytes_neededhas_slotc(XlX lX0lg)Nr r r)selfr r rs Clib/third_party/google/cloud/pubsub_v1/publisher/flow_controller.py__init___QuantityReservation.__init__"s,( c[U5RSURSURSURS3$)Nz(bytes_reserved=z, bytes_needed=z , has_slot=))type__name__r r r)rs r__repr___QuantityReservation.__repr__'sNDz""#$"1123 --./ a ) r)r r rN) r __module__ __qualname____firstlineno____doc__intboolrr__static_attributes__rrr r s$<!s!#!!  rr c\rSrSrSrS\R 4SjrS\SS4Sjr S\SS4S jr SS jr S\ 4S jr S\S\ 4S jrSS \\S\\S\4SjjrSrg)FlowController0zzA class used to control the flow of messages passing through it. Args: settings: Desired flow control configuration. settingscXlSUlSUl[5UlSUlSUl[R"5Ul [R"URS9Ul g)Nr)lock) _settings_message_count _total_bytesr_waiting_reserved_bytes_reserved_slots threadingLock_operational_lock Condition _has_capacity)rr's rrFlowController.__init__7sb!  GRm   "+!1'00d6L6LMrmessagereturnNcpURR[RR:XagUR  UR U5(dLU=RS- slU=RURR5- slSSS5 gURR[RR:XaiURURS-URURR5-S9nSRU5n[R"U5eURR[RR :XdeURR5URR":dURR$S:aOURSURR5S9nSRU5n[R"U5e[&R("5nUR U5(aX@R*;a1[-SURR5SS9nXPR*U'[.R1S RUR555 UR2R55 [.R1S RUR555 UR U5(aMU=RS- slU=RURR5- slU=R6UR*UR8-slU=R:S-slUR*U SSS5 g!,(df  g=f) aAdd a message to flow control. Adding a message updates the internal load statistics, and an action is taken if these limits are exceeded (depending on the flow control settings). Args: message: The message entering the flow control. Raises: :exception:`~pubsub_v1.publisher.exceptions.FlowControlLimitError`: Raised when the desired action is :attr:`~google.cloud.pubsub_v1.types.LimitExceededBehavior.ERROR` and the message would exceed flow control limits, or when the desired action is :attr:`~google.cloud.pubsub_v1.types.LimitExceededBehavior.BLOCK` and the message would block forever against the flow control limits. N) message_count total_bytesz+Flow control limits would be exceeded - {}.zLTotal flow control limits too low for the message, would block forever - {}.rFrz>Blocking until there is enough free capacity in the flow - {}.z7Woke up from waiting on free capacity in the flow - {}.)r*limit_exceeded_behaviorrLimitExceededBehaviorIGNOREr2_would_overflowr+r,_pbByteSizeERROR _load_infoformatrFlowControlLimitErrorBLOCK byte_limit message_limitr0current_threadr-r _LOGGERdebugr4waitr.r r/)rr6 load_info error_msgrI reservations raddFlowController.addNs$ >> 1 1U5P5P5W5W W   # #''00##q(#!!W[[%9%9%;;! $ #66..445 !OO"&"5"5"9 $ 1 1GKK4H4H4J J, JPP !66yAA66..445 5 $$&)B)BB>>//!3 OO"#1E1E1G, 006y0A!66yAA&557N&&w//!6"6'(%,[[%9%9%;!&#K 5@MM.1  &!23 ""'')  &!23!&&w//,   1 $    !5!5!7 7   DMM.$A$P$P P  A %  n-O$ # #sAN'#I)N'BN'' N5cURR[RR:XagUR  U=R S-slU=RURR5-slUR S:dURS:aP[R"S[SS9 [SUR 5Ul[SUR5UlUR5 UR5(a/[ R#S5 UR$R'5 SSS5 g!,(df  g=f)zgRelease a mesage from flow control. Args: message: The message entering the flow control. Nr9rz=Releasing a message that was never added or already released.)category stacklevelz2Notifying threads waiting to add messages to flow.)r*r<rr=r>r2r+r,r@rAwarningswarnRuntimeWarningmax_distribute_available_capacity_ready_to_unblockrJrKr4 notify_all)rr6s rreleaseFlowController.releases >> 1 1U5P5P5W5W W   # #   1 $    !5!5!7 7 ""Q&$*;*;a*? S+  '*!T-@-@&A#$'4+<+<$=!  / / 1%%'' RS""--/'$ # #s DE EcURRUR- UR- nURRUR - UR - nURR5HnUS::aUS::a gUS:a2UR(d!SUl U=RS- slUS-nUS::aMQURUR- nUS:aASRURUR5n[R"U[S9 Sn[!XB5nU=RU- sl U=R U- slX&-nM g)zDistribute available capacity among the waiting threads in FIFO order. The method assumes that the caller has obtained ``_operational_lock``. rTr9z Too many bytes reserved: {} / {})rTN)r*rHr+r/rGr,r.r-valuesrr r rDrVrWrXmin)ravailable_slotsavailable_bytesrObytes_still_neededmsgcan_gives rrZ-FlowController._distribute_available_capacitysN NN ( (4+>+> >AUAU U  NN % %(9(9 9D*>*@%A B !004E4R4RR/%..  rc URR[R"55nU(a&URUR :nUR nOSnSnURUR-URR5-nXPRR:=(a U(+nU(+=(a3 URUR-S-URR:nU=(d U$)zDetermine if accepting a message would exceed flow control limits. The method assumes that the caller has obtained ``_operational_lock``. Args: message: The message entering the flow control. Fr9)r-getr0rIr r rr,r.r@rAr*rGr+r/rH)rr6rOenough_reservedr bytes_taken size_overflowmsg_count_overflows rr?FlowController._would_overflowsmm'' (@(@(BC )88K*>>AUAUAWW #nn&?&??WDW !)\  4#7#7 7! ;nn** +  2 22rr:r;c Uc URnUc URnSUSURRSURSUSURR SUR S3 $)apReturn the current flow control load information. The caller can optionally adjust some of the values to fit its reporting needs. The method assumes that the caller has obtained ``_operational_lock``. Args: message_count: The value to override the current message count with. total_bytes: The value to override the current total bytes with. z messages: z / z (reserved: z ), bytes: r)r+r,r*rHr/rGr.)rr:r;s rrCFlowController._load_infos   //M  ++Ks4>>+G+G*HI../0!]#dnn&?&?%@A../q 2 r)r4r+r2r.r/r*r,r-)r7N)NN)rrrrrrPublishFlowControlr MessageTyperPr]rZr!r[r?rr strrCr"r#rrr%r%0s N!9!9N.\.;\.4\.|0{0t0>&(P4 3{3t38QU %c] @H    rr%) collectionsrloggingr0typingrrrrVgoogle.cloud.pubsub_v1r google.cloud.pubsub_v1.publisherr getLoggerrrJ PubsubMessagerwr objectr%r#rrrs[$''(7   H %5&&'   "I VI r