mJ]c@`sdZddlmZmZmZmZddlZejeZ ddl Z ddl m Z m Z ddlmZddlmZdZd Zd Zd efdYZdS(u( Provides the ``ServerSession`` class. i(tabsolute_importtdivisiontprint_functiontunicode_literalsN(tgentlocksi(tyield_for_all_futuresi(t_DocumentCallbackGroupu current_timeu ServerSessionc`stjfd}|S(uDecorator that adds the necessary locking and post-processing to manipulate the session's document. Expects to decorate a method on ServerSession and transforms it into a coroutine if it wasn't already. c ?`s|jr(tjdtjdn|jz|jjVy|j dk rht ddng|_ zt |||V}Wd|j }d|_ Xx|D] }|VqWWdQXtj|Wd|j XdS(Nu6Ignoring locked callback on already-destroyed session.u3internal class invariant violated: _pending_writes u"should be None if lock is not held( t destroyedtlogtdebugRtReturntNonetblock_expirationt_locktacquiret_pending_writest RuntimeErrorRtunblock_expiration(tselftargstkwargstresulttpending_writestp(tfunc(s3lib/python2.7/site-packages/bokeh/server/session.pyt_needs_document_lock_wrapper5s$        (Rt coroutine(RR((Rs3lib/python2.7/site-packages/bokeh/server/session.pyt_needs_document_lock/scC`s+ytjdSWntjdSXdS(uWReturn the time in milliseconds since the epoch as a floating point number. iN(ttimet monotonic(((s3lib/python2.7/site-packages/bokeh/server/session.pyt current_timeXst ServerSessioncB`seZdZddZedZedZedZedZ edZ edZ dZ d Z d Zd Zd Zd ZedZedZedZdZdZdZdZedZdZdZedZedZedZ edZ!edZ"edZ#edZ$RS( u^ Hosts an application "instance" (an instantiated Document) for one or more connections. cC`s|dkrtdn|dkr6tdn||_||_||_t|_t|_t j |_ d|_ |jj |t||_d|_t|_t|_d|_|j|jj}|jj|dS(NuSessions must have an iduSessions must have a documenti(R t ValueErrort_idt _documentt_looptsett_subscribed_connectionsRt_last_unsubscribe_timeRtLockRt_current_patch_connectionton_change_dispatch_toRt _callbacksRtFalset _destroyedt_expiration_requestedt_expiration_blocked_countt_wrap_session_callbackstsession_callbackstadd_session_callbacks(Rt session_idtdocumenttio_looptwrapped_callbacks((s3lib/python2.7/site-packages/bokeh/server/session.pyt__init__hs&            cC`s|jS(N(R#(R((s3lib/python2.7/site-packages/bokeh/server/session.pyR4~scC`s|jS(N(R"(R((s3lib/python2.7/site-packages/bokeh/server/session.pytidscC`s|jS(N(R-(R((s3lib/python2.7/site-packages/bokeh/server/session.pyRscC`s|jS(N(R.(R((s3lib/python2.7/site-packages/bokeh/server/session.pytexpiration_requestedscC`s |jdkS(Ni(R/(R((s3lib/python2.7/site-packages/bokeh/server/session.pytexpiration_blockedscC`s|jS(N(R/(R((s3lib/python2.7/site-packages/bokeh/server/session.pytexpiration_blocked_countscC`s6t|_|jj||`|jj|`dS(N(tTrueR-R#tdestroyR+tremove_all_callbacks(R((s3lib/python2.7/site-packages/bokeh/server/session.pyR=s   cC`s t|_dS(uK Used in test suite for now. Forces immediate expiration if no connections.N(R<R.(R((s3lib/python2.7/site-packages/bokeh/server/session.pytrequest_expirationscC`s|jd7_dS(Ni(R/(R((s3lib/python2.7/site-packages/bokeh/server/session.pyR scC`s1|jdkrtdn|jd8_dS(Niu0mismatched block_expiration / unblock_expirationi(R/R(R((s3lib/python2.7/site-packages/bokeh/server/session.pyRscC`s|jj|dS(ugThis should only be called by ``ServerConnection.subscribe_session`` or our book-keeping will be brokenN(R&tadd(Rt connection((s3lib/python2.7/site-packages/bokeh/server/session.pyt subscribescC`s |jj|t|_dS(uiThis should only be called by ``ServerConnection.unsubscribe_session`` or our book-keeping will be brokenN(R&tdiscardRR'(RRA((s3lib/python2.7/site-packages/bokeh/server/session.pyt unsubscribescC`s t|jS(N(tlenR&(R((s3lib/python2.7/site-packages/bokeh/server/session.pytconnection_countscC`st|jS(N(RR'(R((s3lib/python2.7/site-packages/bokeh/server/session.pyt#milliseconds_since_last_unsubscribescO`s |||S(uH Asynchronously locks the document and runs the function with it locked.((RRRR((s3lib/python2.7/site-packages/bokeh/server/session.pytwith_document_lockedsc`s,tdtrSfd}|S(Nunolockc`sj||S(N(RH(RR(tcallbackR(s3lib/python2.7/site-packages/bokeh/server/session.pytwrapped_callbacks(tgetattrR,(RRIRJ((RIRs3lib/python2.7/site-packages/bokeh/server/session.pyt_wrap_document_callbackscC`s|j|j}|j|S(N(RLRIt_copy_with_changed_callback(RRItwrapped((s3lib/python2.7/site-packages/bokeh/server/session.pyt_wrap_session_callbackscC`s1g}x$|D]}|j|j|q W|S(N(tappendRO(Rt callbacksRNtcb((s3lib/python2.7/site-packages/bokeh/server/session.pyR0s cC`s|j|k}|jdkr-tdnxR|jD]G}|re||jkretjd|q7|jj|j |q7WdS(Nuv_pending_writes should be non-None when we have a document lock, and we should have the lock when the document changesuDNot sending notification back to client %r for a change it requested( tsetterRR RR&R)R ttraceRPtsend_patch_document(Rteventt may_suppressRA((s3lib/python2.7/site-packages/bokeh/server/session.pyt_document_patchedscC`s3tjd|j|jjd|jd|jS(Nu&Sending pull-doc-reply from session %ruPULL-DOC-REPLYumsgid(R R R8tprotocoltcreatetheaderR4(RtmessageRA((s3lib/python2.7/site-packages/bokeh/server/session.pyt _handle_pullscC`s&|j|j}|jj|dS(N(RORIR+tadd_session_callback(RRVRN((s3lib/python2.7/site-packages/bokeh/server/session.pyt_session_callback_addedscC`s|jj|jdS(N(R+tremove_session_callbackRI(RRV((s3lib/python2.7/site-packages/bokeh/server/session.pyt_session_callback_removedscC`s|jj||S(u? Handle a PULL-DOC, return a Future with work to be scheduled. (tsessionR](tclsR\RA((s3lib/python2.7/site-packages/bokeh/server/session.pytpullscC`s0tjd|j|j|j|j|S(Nupushing doc to session %r(R R R8tpush_to_documentR4tok(RR\RA((s3lib/python2.7/site-packages/bokeh/server/session.pyt _handle_pushscC`s|jj||S(u? Handle a PUSH-DOC, return a Future with work to be scheduled. (RbRg(RcR\RA((s3lib/python2.7/site-packages/bokeh/server/session.pytpushscC`s:||_z|j|j|Wdd|_X|j|S(N(R)tapply_to_documentR4R Rf(RR\RA((s3lib/python2.7/site-packages/bokeh/server/session.pyt _handle_patchs   cC`s|j|j|j|S(N(t notify_eventR4Rf(RR\RA((s3lib/python2.7/site-packages/bokeh/server/session.pyt _handle_eventscC`s|jj||S(N(RbRl(RcR\RA((s3lib/python2.7/site-packages/bokeh/server/session.pyRV scC`s|jj||S(u@ Handle a PATCH-DOC, return a Future with work to be scheduled. (RbRj(RcR\RA((s3lib/python2.7/site-packages/bokeh/server/session.pytpatchsN(%t__name__t __module__t__doc__R R7tpropertyR4R8RR9R:R;R=R?R RRBRDRFRGRRHRLROR0RXR]R_Rat classmethodRdRgRhRjRlRVRm(((s3lib/python2.7/site-packages/bokeh/server/session.pyR cs>             (u current_timeu ServerSession(Rpt __future__RRRRtloggingt getLoggerRnR RttornadoRRt util.tornadoRRQRt__all__RRtobjectR (((s3lib/python2.7/site-packages/bokeh/server/session.pyt s"   )