ó mÜJ]c@`sdZddlmZmZmZmZddlZejeƒZ ddl m Z ddl m Z ddlmZmZdd lmZdd lmZdd lmZmZdZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdS(uA Provides the Application, Server, and Session context classes. i(tabsolute_importtdivisiontprint_functiontunicode_literalsN(tgeni(t ServerSessioni(t ServerContexttSessionContext(tDocument(t ProtocolError(t_CallbackGrouptyield_for_all_futuresuApplicationContextuBokehServerContextuBokehSessionContexttBokehServerContextcB`s_eZd„Zd„Zed„ƒZd„Zd„Zd„Zd„Z d„Z d„Z RS( cC`s"||_t|jjƒ|_dS(N(tapplication_contextR tio_loopt _callbacks(tselfR ((s4lib/python2.7/site-packages/bokeh/server/contexts.pyt__init__;s cC`s|jjƒdS(N(Rtremove_all_callbacks(R((s4lib/python2.7/site-packages/bokeh/server/contexts.pyt_remove_all_callbacks?scC`s.g}x!|jjD]}|j|ƒqW|S(N(R tsessionstappend(Rtresulttsession((s4lib/python2.7/site-packages/bokeh/server/contexts.pyRBscC`s|jj|ƒS(N(Rtadd_next_tick_callback(Rtcallback((s4lib/python2.7/site-packages/bokeh/server/contexts.pyRIscC`s|jj|ƒdS(N(Rtremove_next_tick_callback(Rt callback_id((s4lib/python2.7/site-packages/bokeh/server/contexts.pyRLscC`s|jj||ƒS(N(Rtadd_timeout_callback(RRttimeout_milliseconds((s4lib/python2.7/site-packages/bokeh/server/contexts.pyROscC`s|jj|ƒdS(N(Rtremove_timeout_callback(RR((s4lib/python2.7/site-packages/bokeh/server/contexts.pyRRscC`s|jj||ƒS(N(Rtadd_periodic_callback(RRtperiod_milliseconds((s4lib/python2.7/site-packages/bokeh/server/contexts.pyRUscC`s|jj|ƒdS(N(Rtremove_periodic_callback(RR((s4lib/python2.7/site-packages/bokeh/server/contexts.pyR!Xs( t__name__t __module__RRtpropertyRRRRRRR!(((s4lib/python2.7/site-packages/bokeh/server/contexts.pyR :s       tBokehSessionContextcB`sYeZd„Zd„Zejd„ƒZed„ƒZed„ƒZ ed„ƒZ RS(cC`s8||_d|_tt|ƒj||ƒd|_dS(N(t _documenttNonet_sessiontsuperR%Rt_request(Rt session_idtserver_contexttdocument((s4lib/python2.7/site-packages/bokeh/server/contexts.pyR\s   cC`s ||_dS(N(R((RR((s4lib/python2.7/site-packages/bokeh/server/contexts.pyt _set_sessiondscc`s@|jdkr&t||jƒƒVn|jj||jƒdS(N(R(R'R R&twith_document_locked(Rtfunc((s4lib/python2.7/site-packages/bokeh/server/contexts.pytwith_locked_documentgscC`s!|jdkrtS|jjSdS(N(R(R'tFalset destroyed(R((s4lib/python2.7/site-packages/bokeh/server/contexts.pyR3pscC`s|jS(N(R*(R((s4lib/python2.7/site-packages/bokeh/server/contexts.pytrequestxscC`s|jS(N(R((R((s4lib/python2.7/site-packages/bokeh/server/contexts.pyR|s( R"R#RR.Rt coroutineR1R$R3R4R(((s4lib/python2.7/site-packages/bokeh/server/contexts.pyR%[s    tApplicationContextcB`s¼eZdZd d d„Zed„ƒZed„ƒZed„ƒZed„ƒZ ed„ƒZ d„Z d„Z e jd d „ƒZd „Ze jd „ƒZe jd „ƒZRS(uè Server-side holder for ``bokeh.application.Application`` plus any associated data. This holds data that's global to all sessions, while ``ServerSession`` holds data specific to an "instance" of the application. cC`sL||_||_tƒ|_tƒ|_tƒ|_d|_||_dS(N( t _applicationt_looptdictt _sessionst_pending_sessionst_session_contextsR't_server_contextt_url(Rt applicationRturl((s4lib/python2.7/site-packages/bokeh/server/contexts.pyR‡s      cC`s|jS(N(R8(R((s4lib/python2.7/site-packages/bokeh/server/contexts.pyRscC`s|jS(N(R7(R((s4lib/python2.7/site-packages/bokeh/server/contexts.pyR?”scC`s|jS(N(R>(R((s4lib/python2.7/site-packages/bokeh/server/contexts.pyR@˜scC`s(|jdkr!t|ƒ|_n|jS(N(R=R'R (R((s4lib/python2.7/site-packages/bokeh/server/contexts.pyR,œscC`s |jjƒS(N(R:tvalues(R((s4lib/python2.7/site-packages/bokeh/server/contexts.pyR¢scC`sky;|jj|jƒ}t|tjƒr:tjdƒnWn)tk rf}tjd|dt ƒnXdS(Nuqon_server_loaded returned a Future; this doesn't make sense because we run this hook before starting the IO loop.uError in server loaded hook %rtexc_info( R7ton_server_loadedR,t isinstanceRtFuturetlogterrort ExceptiontTrue(RRte((s4lib/python2.7/site-packages/bokeh/server/contexts.pyt run_load_hook¦s cC`sxy;|jj|jƒ}t|tjƒr:tjdƒnWn)tk rf}tjd|dt ƒnX|jj ƒdS(Nu†on_server_unloaded returned a Future; this doesn't make sense because we stop the IO loop right away after calling on_server_unloaded.u Error in server unloaded hook %rRB( R7ton_server_unloadedR,RDRRERFRGRHRIR(RRRJ((s4lib/python2.7/site-packages/bokeh/server/contexts.pytrun_unload_hook¯scc`s|t|ƒdkr!tdƒ‚n||jkr<||jkr<tjƒ}|j| s "  !&®