ó O'—^c@@s˜ddlmZddlZddlmZddlmZddlmZmZddl m Z m Z de fd „ƒYZ d e fd „ƒYZ dS( i(tabsolute_importN(theappush(ttime(t LamportClockt timetuplei(tMocktCasettest_LamportClockcB@seZd„Zd„ZRS(cC@sítƒ}tƒ}|jƒ|jƒ|jƒ|jƒ|j|jƒ|j|j|jdƒ|jt|ƒƒ|j}|jƒ|jƒ|j|jƒ|j|j|ddƒ|j|jƒ|j|j|jdƒdS(Nii(Rtforwardtadjusttvaluet assertEqualt assertTruetrepr(tselftc1tc2tc2_val((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_clocks.pyt test_clockss          c C@s'tƒ}d}d}g}|jƒ|f}t||ƒ|jƒ|f}t||ƒ|jƒ|f}t||ƒd|f}t||ƒd|f} t|| ƒ|jt|ƒt|jƒƒ|j|j|ƒ|ƒ|j|j|| gƒ|ƒ|j|j|| |gƒ|ƒdS(Nsa.example.com:312sb.example.com:311i(RRRR tstrR t sort_heap( Rtctpid1tpid2teventstm1tm2tm3tm4tm5((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_clocks.pyt test_sort$s$        (t__name__t __module__RR(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_clocks.pyR s ttest_timetuplecB@s#eZd„Zd„Zd„ZRS(cC@s2tdtƒdtƒƒ}|jt|ƒƒdS(Ni…tid(RRRR R (Rtx((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_clocks.pyt test_repr?scC@sDtdtƒddƒ}|jtjtj|ƒƒt|ƒƒdS(Ni…R"tobj(RRR tpickletloadstdumpsttuple(RR#((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_clocks.pyttest_pickleableCscC@stƒ}tƒd}td|ddƒ}td|ddƒ}|j|jƒƒ|j|jdƒ|j|j|ƒ|j|jdƒ|j|jdƒ|j||kƒ|j||kƒ|jtdtƒddƒj t ƒƒt ƒ|j td|ddƒtd|ddƒƒ|j td|ddƒtd|ddƒƒ|j td|ddƒtd|ddƒƒdS(Ni,i…tAR%iŒi†tB(RRR t__getnewargs__R tclockt timestampR"R%t__lt__R)tNotImplementedt assertGreatertNone(Rtt1tt2tatb((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_clocks.pyt test_orderGs2    !(RR R$R*R8(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_clocks.pyR!=s  (t __future__RR&theapqRRt kombu.clocksRRtcaseRRRR!(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_clocks.pyts 0