ó Ì g]c@sWdZddlZddlZddlmZejeƒZdefd„ƒYZ dS(sHandle AMQP HeartbeatsiÿÿÿÿN(tframetHeartbeatCheckercBsªeZdZdZd„Zed„ƒZed„ƒZd„Zd„Z d„Z d„Z d „Z ed „ƒZ ed „ƒZd „Zd „Zd„Zd„ZRS(såSends 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. s@No activity or too many missed heartbeats in the last %i secondscCsÊ|dkr"td|fƒ‚n||_||_t|ƒd|_|d|_tjd|j|j|jƒd|_d|_ d|_ d|_ d|_ d|_d|_|jƒ|jƒdS(s©Create 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. istimeout must >= 0, but got %riis0timeout: %f send_interval: %f check_interval: %fiN(t ValueErrort _connectiont_timeouttfloatt_send_intervalt_check_intervaltLOGGERtdebugt_bytes_receivedt _bytes_sentt_heartbeat_frames_receivedt_heartbeat_frames_sentt_idle_byte_intervalstNonet _send_timert _check_timert_start_send_timert_start_check_timer(tselft connectionttimeout((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pyt__init__s"            cCs |jjS(saReturn the number of bytes received by the connection bytes object. :rtype int (Rtbytes_received(R((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pytbytes_received_on_connectionRscCs |jdkS(ssReturns true if the byte count hasn't changed in enough intervals to trip the max idle threshold. i(R(R((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pytconnection_is_idle[scCs tjdƒ|jd7_dS(s#Called when a heartbeat is receivedsReceived heartbeat frameiN(RR R (R((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pytreceivedcs cCs%tjdƒ|jƒ|jƒdS(sAInvoked by a timer to send a heartbeat when we need to. sSending heartbeat frameN(RR t_send_heartbeat_frameR(R((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pyt_send_heartbeaths  cCsh|jrd|_n|jd7_tjd|j|j|jƒ|jrZ|jƒdS|jƒdS(s³Invoked 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. iis8Received %i heartbeat frames, sent %i, idle intervals %iN( t_has_received_dataRRR R R Rt_close_connectionR(R((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pyt_check_heartbeatps    cCsn|jr5tjdƒ|jj|jƒd|_n|jrjtjdƒ|jj|jƒd|_ndS(sStop the heartbeat checkers/Removing timer for next heartbeat send intervals0Removing timer for next heartbeat check intervalN(RRR Rt_adapter_remove_timeoutRR(R((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pytstop‡s     cCsCtjd|jƒtj|j}|jjtj j |ƒƒdS(s;Close the connection with the AMQP Connection-Forced value.s+Connection is idle, %i stale byte intervalsN( RtinfoRRt_STALE_CONNECTIONRRt_terminate_streamtpikat exceptionstAMQPHeartbeatTimeout(Rttext((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pyR’s    cCs|j|jkS(sQReturns True if the connection has received data. :rtype: bool (R R(R((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pyRžscCs tjƒS(sLReturn a new heartbeat frame. :rtype pika.frame.Heartbeat (Rt Heartbeat(((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pyt_new_heartbeat_frame§scCs6tjdƒ|jj|jƒƒ|jd7_dS(s3Send a heartbeat frame on the connection. sSending heartbeat frameiN(RR Rt _send_frameR+R (R((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pyR°s   cCs"|jj|j|jƒ|_dS(s!Start a new heartbeat send timer.N(Rt_adapter_call_laterRRR(R((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pyR¹s cCs,|jƒ|jj|j|jƒ|_dS(s"Start a new heartbeat check timer.N(t_update_countersRR-RR R(R((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pyR¿s  cCs"|jj|_|jj|_dS(slUpdate the internal counters for bytes sent and received and the number of frames received N(Rt bytes_sentR RR (R((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pyR.Ës(t__name__t __module__t__doc__R$RtpropertyRRRRR R"RRt staticmethodR+RRRR.(((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pyR s  ?        ( R2tloggingtpika.exceptionsR&Rt getLoggerR0RtobjectR(((s3/srv/kernel/kteam-tools/dashboard/pika/heartbeat.pyts