ó mÜJ]c@`sãdZddlmZmZmZmZddlZejeƒZ ddl Z ddl m Z ddl mZddlZddlmZddlmZdZejd „ƒZd efd „ƒYZd efd„ƒYZdS(u$ Internal utils related to Tornado i(tabsolute_importtdivisiontprint_functiontunicode_literalsN(t defaultdict(tformat_exception(tgeni(tmake_iduyield_for_all_futurescc`sbxLtrN|dkrPnytj|ƒ}Wntjk rCPqX|V}qWtj|ƒ‚dS(uè Converts result into a Future by collapsing any futures inside result. If result is a Future we yield until it's done, then if the value inside the Future is another Future we yield until it's done as well, and so on. N(tTruetNoneRtconvert_yieldedt BadYieldErrortReturn(tresulttfuture((s1lib/python2.7/site-packages/bokeh/util/tornado.pytyield_for_all_futures0s   t_AsyncPeriodiccB`s2eZdZd„Zd„Zd„Zd„ZRS(uLike ioloop.PeriodicCallback except the 'func' can be async and return a Future, and we wait for func to finish each time before we call it again. Plain ioloop.PeriodicCallback can "pile up" invocations if they are taking too long. cC`s1||_||_||_t|_t|_dS(N(t_funct_loopt_periodtFalset_startedt_stopped(tselftfunctperiodtio_loop((s1lib/python2.7/site-packages/bokeh/util/tornado.pyt__init__Xs     c`s3tjƒ‰|jj|jd‡fd†ƒˆS(Ng@@c`s ˆjdƒS(N(t set_resultR ((tf(s1lib/python2.7/site-packages/bokeh/util/tornado.pytct(RtFutureRt call_laterR(R((Rs1lib/python2.7/site-packages/bokeh/util/tornado.pytsleepas #c`sbˆjrtdƒ‚ntˆ_‡fd†‰‡‡‡fd†‰ˆjjˆjƒˆƒdS(Nu&called start() twice on _AsyncPeriodicc`sjˆjƒ}ˆjƒ}|dkr(|Sytj|ƒ}Wntjk rR|SXtj||gƒSdS(N(R"RR RR R tmulti(t sleep_futureR tcallback_future(R(s1lib/python2.7/site-packages/bokeh/util/tornado.pytinvokeks   c`sšˆjs"ˆjjˆƒˆƒn|jƒ}|dk r–tjdƒtjret |j ƒŒ}nt |j ||j ƒ}tjdj |ƒƒndS(Nu$Error thrown from periodic callback:u(RRt add_futuret exceptionR tlogterrortsixtPY2Rtexc_infot __class__t __traceback__tjoin(Rtextlines(R&ton_doneR(s1lib/python2.7/site-packages/bokeh/util/tornado.pyR3s     (Rt RuntimeErrorRRR'R"(R((R&R3Rs1lib/python2.7/site-packages/bokeh/util/tornado.pytstartfs    cC`s t|_dS(N(RR(R((s1lib/python2.7/site-packages/bokeh/util/tornado.pytstops(t__name__t __module__t__doc__RR"R5R6(((s1lib/python2.7/site-packages/bokeh/util/tornado.pyRPs   't_CallbackGroupcB`s}eZdZd d„Zd„Zd„Zd„Zd„Zd d„Z d„Z d d„Z d „Z d d „Z d „ZRS( u` A collection of callbacks added to a Tornado IOLoop that we may want to remove as a group. cC`s|dkrtdƒ‚n||_i|_i|_i|_tjƒ|_t t ƒ|_ t t ƒ|_ t t ƒ|_ dS(Numust provide an io loop(R t ValueErrorRt_next_tick_callback_removerst_timeout_callback_removerst_periodic_callback_removerst threadingtLockt_removers_lockRtsett_next_tick_removers_by_callablet_timeout_removers_by_callablet_periodic_removers_by_callable(RR((s1lib/python2.7/site-packages/bokeh/util/tornado.pyR”s     cC`s‹x*t|jjƒƒD]}|j|ƒqWx*t|jjƒƒD]}|j|ƒqCWx*t|jjƒƒD]}|j|ƒqpWdS(u" Removes all registered callbacks.N(tlistR<tkeystremove_next_tick_callbackR=tremove_timeout_callbackR>tremove_periodic_callback(Rtcb_id((s1lib/python2.7/site-packages/bokeh/util/tornado.pytremove_all_callbacks¤s cC`sU||jkr|jS||jkr,|jS||jkrB|jStd|ƒ‚dS(NuUnhandled removers(R<RCR=RDR>RER4(Rtremovers((s1lib/python2.7/site-packages/bokeh/util/tornado.pyt_get_removers_ids_by_callable­scC`sU|jF|dkr"tƒ}n||kr=tdƒ‚n|||<|SWdQXdS(Nu?A callback of the same type has already been added with this ID(RAR RR;(Rtcallbackt callback_idRMtremover((s1lib/python2.7/site-packages/bokeh/util/tornado.pyt_assign_remover·s     c C`s¸y|j~|j|ƒ}xgt|j|ƒjƒƒD]J\}}y*|j|ƒ|sm|j|ƒ|=nWq8tk rq8Xq8WWdQXWntk r¬tdƒ‚nX|ƒdS(Nu:Removing a callback twice (or after it's already been run)(RAtpopRFRNtitemstremovetKeyErrorR;(RRPRMRQtcbtcb_ids((s1lib/python2.7/site-packages/bokeh/util/tornado.pyt_execute_removerÀs (   c`s_‡‡‡‡fd†‰tˆ_‡fd†}ˆjˆˆˆj|ƒ‰ˆjjˆƒˆS(us Adds a callback to be run on the next tick. Returns an ID that can be used with remove_next_tick_callback.c`s+ˆjs#ˆjˆƒˆ||ŽSdSdS(N(tremovedRHR (targstkwargs(RORPRtwrapper(s1lib/python2.7/site-packages/bokeh/util/tornado.pyR]Òs   c`s tˆ_dS(N(RRZ((R](s1lib/python2.7/site-packages/bokeh/util/tornado.pyRQßs(RRZRRR<Rt add_callback(RRORPRQ((RORPRR]s1lib/python2.7/site-packages/bokeh/util/tornado.pytadd_next_tick_callbackÏs  cC`s|j||jƒdS(u6 Removes a callback added with add_next_tick_callback.N(RYR<(RRP((s1lib/python2.7/site-packages/bokeh/util/tornado.pyRHæsc`se‡‡‡fd†}d‰‡‡fd†}ˆjˆˆˆj|ƒ‰ˆjj|d|ƒ‰ˆS(u€ Adds a callback to be run once after timeout_milliseconds. Returns an ID that can be used with remove_timeout_callback.c`sˆjˆƒˆ||ŽS(N(RI(R[R\(RORPR(s1lib/python2.7/site-packages/bokeh/util/tornado.pyR]ís c`s#ˆdk rˆjjˆƒndS(N(R Rtremove_timeout((thandleR(s1lib/python2.7/site-packages/bokeh/util/tornado.pyRQós g@@N(R RRR=RR!(RROttimeout_millisecondsRPR]RQ((RORPRaRs1lib/python2.7/site-packages/bokeh/util/tornado.pytadd_timeout_callbackês cC`s|j||jƒdS(uD Removes a callback added with add_timeout_callback, before it runs.N(RYR=(RRP((s1lib/python2.7/site-packages/bokeh/util/tornado.pyRIûscC`sDt||d|jƒ}|j|||j|jƒ}|jƒ|S(u Adds a callback to be run every period_milliseconds until it is removed. Returns an ID that can be used with remove_periodic_callback.R(RRRRR>R6R5(RROtperiod_millisecondsRPRW((s1lib/python2.7/site-packages/bokeh/util/tornado.pytadd_periodic_callbackÿs cC`s|j||jƒdS(u5 Removes a callback added with add_periodic_callback.N(RYR>(RRP((s1lib/python2.7/site-packages/bokeh/util/tornado.pyRJsN(R7R8R9R RRLRNRRRYR_RHRcRIReRJ(((s1lib/python2.7/site-packages/bokeh/util/tornado.pyR:s       (uyield_for_all_futures(R9t __future__RRRRtloggingt getLoggerR7R)R?t collectionsRt tracebackRR+ttornadoRtutil.serializationRt__all__t coroutineRtobjectRR:(((s1lib/python2.7/site-packages/bokeh/util/tornado.pyt s"    @