)JfbdZddlZddlZddlmZejeZGddeZ dS)zHandle AMQP HeartbeatsN)frameceZdZdZdZdZedZedZdZ dZ dZ d Z d Z ed Zed Zd ZdZdZdZdS)HeartbeatCheckerzSends heartbeats to the broker. The provided timeout is used to determine if the connection is stale - no received heartbeats or other activity will close the connection. See the parameter list for more details. z@No activity or too many missed heartbeats in the last %i secondsc|dkrtd|||_||_t|dz |_|dz|_t d|j|j|jd|_d|_ d|_ d|_ d|_ d|_ d|_||dS)aCreate an object that will check for activity on the provided connection as well as receive heartbeat frames from the broker. The timeout parameter defines a window within which this activity must happen. If not, the connection is considered dead and closed. The value passed for timeout is also used to calculate an interval at which a heartbeat frame is sent to the broker. The interval is equal to the timeout value divided by two. :param pika.connection.Connection: Connection object :param int timeout: Connection idle timeout. If no activity occurs on the connection nor heartbeat frames received during the timeout window the connection will be closed. The interval used to send heartbeats is calculated from this value by dividing it by two. ztimeout must >= 0, but got z0timeout: %f send_interval: %f check_interval: %frN) ValueError _connection_timeoutfloat_send_interval_check_intervalLOGGERdebug_bytes_received _bytes_sent_heartbeat_frames_received_heartbeat_frames_sent_idle_byte_intervals _send_timer _check_timer_start_send_timer_start_check_timer)self connectiontimeouts Q/home/alex/cs2snipeproduction/venv/lib/python3.11/site-packages/pika/heartbeat.py__init__zHeartbeatChecker.__init__s$ Q;;*IJJ J%  #Gnnq0 '{ G]D$79M O O O !*+'&'#$%!      !!!!!c|jjS)zaReturn the number of bytes received by the connection bytes object. :rtype int )r bytes_receivedrs rbytes_received_on_connectionz-HeartbeatChecker.bytes_received_on_connectionRs..r c|jdkS)zsReturns true if the byte count hasn't changed in enough intervals to trip the max idle threshold. r)rr#s rconnection_is_idlez#HeartbeatChecker.connection_is_idle[s (1,,r cZtd|xjdz c_dS)z#Called when a heartbeat is receivedzReceived heartbeat framerN)rrrr#s rreceivedzHeartbeatChecker.receivedcs/ /000 ''1,''''r ctd||dS)zAInvoked by a timer to send a heartbeat when we need to. Sending heartbeat frameN)rr_send_heartbeat_framerr#s r_send_heartbeatz HeartbeatChecker._send_heartbeathsA  ./// ""$$$      r c|jrd|_n|xjdz c_td|j|j|j|jr|dS|dS)zInvoked by a timer to check for broker heartbeats. Checks to see if we've missed any heartbeats and disconnect our connection if it's been idle too long. rrz8Received %i heartbeat frames, sent %i, idle intervals %iN) _has_received_datarrrrrr&_close_connectionrr#s r_check_heartbeatz!HeartbeatChecker._check_heartbeatps  " +()D % %  % % * % %  !%!@  ')B D D D  "   " " $ $ $ F !!!!!r c&|jr@td|j|jd|_|jrBtd|j|jd|_dSdS)zStop the heartbeat checkerz/Removing timer for next heartbeat send intervalNz0Removing timer for next heartbeat check interval)rrrr _adapter_remove_timeoutrr#s rstopzHeartbeatChecker.stops   $ LLJ K K K   4 4T5E F F F#D    % LLK L L L   4 4T5F G G G $D    % %r ctd|jtj|jz}|jtj |dS)z;Close the connection with the AMQP Connection-Forced value.z+Connection is idle, %i stale byte intervalsN) rinforr_STALE_CONNECTIONr r _terminate_streampika exceptionsAMQPHeartbeatTimeout)rtexts rr/z"HeartbeatChecker._close_connectionsj A- / / /1DMA ** O 0 0 6 6 8 8 8 8 8r c"|j|jkS)zQReturns True if the connection has received data. :rtype: bool )rr$r#s rr.z#HeartbeatChecker._has_received_datas#t'HHHr c(tjS)zLReturn a new heartbeat frame. :rtype pika.frame.Heartbeat )r Heartbeatr r_new_heartbeat_framez%HeartbeatChecker._new_heartbeat_frames   r ctd|j||xjdz c_dS)z3Send a heartbeat frame on the connection. r*rN)rrr _send_framer@rr#s rr+z&HeartbeatChecker._send_heartbeat_frames[  ./// $$  % % ' ' ) ) ) ##q(####r cZ|j|j|j|_dS)z!Start a new heartbeat send timer.N)r _adapter_call_laterrr,rr#s rrz"HeartbeatChecker._start_send_timers/+??    ""r c||j|j|j|_dS)z"Start a new heartbeat check timer.N)_update_countersr rDrr0rr#s rrz#HeartbeatChecker._start_check_timersC  ,@@   !##r cJ|jj|_|jj|_dS)zlUpdate the internal counters for bytes sent and received and the number of frames received N)r bytes_sentrr"rr#s rrFz!HeartbeatChecker._update_counterss&  +6#/>r N)__name__ __module__ __qualname____doc__r6rpropertyr$r&r(r,r0r3r/r. staticmethodr@r+rrrFr?r rrr s- [="="="~//X/--X---- !!!""". % % % 8 8 8IIXI!!\!)))""" # # #?????r r) rLloggingpika.exceptionsr8r getLoggerrIrobjectrr?r rrSs  8 $ $G?G?G?G?G?vG?G?G?G?G?r