ó ÐH/\c@`spdZddlmZddlmZddlmZddddd d d d d dddddddddddddddddgZy$ddlmZdd lmZWn e k rÐgZd!„ZnXeZye d"ƒWne k rþeZ nIXdd#l m Z dd$lZzyejƒWnnXWd$[Xd%„Z dd&lmZdd'lmZdd(lmZd efd)„ƒYZd efd*„ƒYZdefd+„ƒYZdefd,„ƒYZeeƒdefd-„ƒYƒZdefd.„ƒYZd/efd0„ƒYZeeƒd efd1„ƒYƒZd efd2„ƒYZeeƒd efd3„ƒYƒZdefd4„ƒYZeeƒdefd5„ƒYƒZ defd6„ƒYZ!de"fd7„ƒYZ#ee!ƒde fd8„ƒYƒZ$defd9„ƒYZ%ee%ƒd:e fd;„ƒYƒZ&de!fd<„ƒYZ'ee'ƒde$fd=„ƒYƒZ(de%fd>„ƒYZ)ee)ƒde&fd?„ƒYƒZ*de!fd@„ƒYZ+dAefdB„ƒYZ,ee+ƒde,e$fdC„ƒYƒZ-de%fdD„ƒYZ.ee.ƒde,e&fdE„ƒYƒZ/de%fdF„ƒYZ0ee0ƒde,e&fdG„ƒYƒZ1d$S(HsD Publish/subscribe event infrastructure. When certain "interesting" things happen during the lifetime of the process, gevent will "publish" an event (an object). That event is delivered to interested "subscribers" (functions that take one parameter, the event object). Higher level frameworks may take this foundation and build richer models on it. If :mod:`zope.event` is installed, then it will be used to provide the functionality of `notify` and `subscribers`. See :mod:`zope.event.classhandler` for a simple class-based approach to subscribing to a filtered list of events, and see `zope.component `_ for a much higher-level, flexible system. If you are using one of these systems, you generally will not want to directly modify `subscribers`. .. versionadded:: 1.3b1 i(tabsolute_import(tdivision(tprint_functiont subscriberstIEventLoopBlockedtEventLoopBlockedtIMemoryUsageThresholdExceededtMemoryUsageThresholdExceededtIMemoryUsageUnderThresholdtMemoryUsageUnderThresholdtIPeriodicMonitorThreadt"IPeriodicMonitorThreadStartedEventt!PeriodicMonitorThreadStartedEventtIGeventPatchEventtGeventPatchEventtIGeventWillPatchEventt DoNotPatchtGeventWillPatchEventtIGeventDidPatchEventtIGeventWillPatchModuleEventtGeventWillPatchModuleEventtIGeventDidPatchModuleEventtGeventDidPatchModuleEventtIGeventWillPatchAllEventtGeventWillPatchAllEventt"IGeventDidPatchBuiltinModulesEventt!GeventDidPatchBuiltinModulesEventtIGeventDidPatchAllEventtGeventDidPatchAllEvent(R(tnotifycC`sxtD]}||ƒqWdS(s6 Notify all subscribers of ``event``. N(R(teventt subscriber((s,lib/python2.7/site-packages/gevent/events.pyRPs t pkg_resources(titer_entry_pointsNcC`s>t|ƒx-t|jƒD]}|jƒ}||ƒqWdS(N(RR!tENTRY_POINT_NAMEtload(RtpluginR((s,lib/python2.7/site-packages/gevent/events.pytnotify_and_call_entry_pointsms  (t Interface(t implementer(t AttributecB`seZdZd„ZRS(sY The contract for the periodic monitoring thread that is started by the hub. cC`sdS(s8 Schedule the *function* to be called approximately every *period* fractional seconds. The *function* receives one argument, the hub being monitored. It is called in the monitoring thread, *not* the hub thread. It **must not** attempt to use the gevent asynchronous API. If the *function* is already a monitoring function, then its *period* will be updated for future runs. If the *period* is ``None``, then the function will be removed. A *period* less than or equal to zero is not allowed. N((tfunctiontperiod((s,lib/python2.7/site-packages/gevent/events.pytadd_monitoring_function~s(t__name__t __module__t__doc__R+(((s,lib/python2.7/site-packages/gevent/events.pyR xscB`seZdZedƒZRS(s The event emitted when a hub starts a periodic monitoring thread. You can use this event to add additional monitoring functions. s:The instance of `IPeriodicMonitorThread` that was started.(R,R-R.R(tmonitor(((s,lib/python2.7/site-packages/gevent/events.pyR ŽscB`seZdZdZd„ZRS(sL The implementation of :class:`IPeriodicMonitorThreadStartedEvent`. s2gevent.plugins.hub.periodic_monitor_thread_startedcC`s ||_dS(N(R/(tselfR/((s,lib/python2.7/site-packages/gevent/events.pyt__init__ s(R,R-R.R"R1(((s,lib/python2.7/site-packages/gevent/events.pyR —scB`s2eZdZedƒZedƒZedƒZRS(sm The event emitted when the event loop is blocked. This event is emitted in the monitor thread. s3The greenlet that appeared to be blocking the loop.s:The approximate time in seconds the loop has been blocked.s0A sequence of string lines providing extra info.(R,R-R.R(tgreenlett blocking_timetinfo(((s,lib/python2.7/site-packages/gevent/events.pyR£s  cB`seZdZd„ZRS(s` The event emitted when the event loop is blocked. Implements `IEventLoopBlocked`. cC`s||_||_||_dS(N(R2R3R4(R0R2R3R4((s,lib/python2.7/site-packages/gevent/events.pyR1¶s  (R,R-R.R1(((s,lib/python2.7/site-packages/gevent/events.pyR®scB`s2eZdZedƒZedƒZedƒZRS(sE The event emitted when the memory usage threshold is exceeded. This event is emitted only while memory continues to grow above the threshold. Only if the condition or stabilized is corrected (memory usage drops) will the event be emitted in the future. This event is emitted in the monitor thread. s+The current process memory usage, in bytes.s+The maximum allowed memory usage, in bytes.s1The tuple of memory usage stats return by psutil.(R,R-R.R(t mem_usaget max_allowedt memory_info(((s,lib/python2.7/site-packages/gevent/events.pyR»s   t_AbstractMemoryEventcB`seZd„Zd„ZRS(cC`s||_||_||_dS(N(R5R6R7(R0R5R6R7((s,lib/python2.7/site-packages/gevent/events.pyR1Ìs  cC`s#d|jj|j|j|jfS(Ns<%s used=%d max=%d details=%r>(t __class__R,R5R6R7(R0((s,lib/python2.7/site-packages/gevent/events.pyt__repr__Ñs  (R,R-R1R:(((s,lib/python2.7/site-packages/gevent/events.pyR8Ês cB`seZdZRS(s< Implementation of `IMemoryUsageThresholdExceeded`. (R,R-R.(((s,lib/python2.7/site-packages/gevent/events.pyRÙscB`s>eZdZedƒZedƒZedƒZedƒZRS(sÄ The event emitted when the memory usage drops below the threshold after having previously been above it. This event is emitted only the first time memory usage is detected to be below the threshold after having previously been above it. If memory usage climbs again, a `IMemoryUsageThresholdExceeded` event will be broadcast, and then this event could be broadcast again. This event is emitted in the monitor thread. s+The current process memory usage, in bytes.s+The maximum allowed memory usage, in bytes.sNThe memory usage that caused the previous IMemoryUsageThresholdExceeded event.s1The tuple of memory usage stats return by psutil.(R,R-R.R(R5R6tmax_memory_usageR7(((s,lib/python2.7/site-packages/gevent/events.pyRàs     cB`seZdZd„ZRS(s9 Implementation of `IMemoryUsageUnderThreshold`. cC`s)tt|ƒj|||ƒ||_dS(N(tsuperR R1R;(R0R5R6R7t max_usage((s,lib/python2.7/site-packages/gevent/events.pyR1ús(R,R-R.R1(((s,lib/python2.7/site-packages/gevent/events.pyR ôscB`s&eZdZedƒZedƒZRS(s< The root for all monkey-patch events gevent emits. s)The source object containing the patches.s%The destination object to be patched.(R,R-R.R(tsourcettarget(((s,lib/python2.7/site-packages/gevent/events.pyR ÿs cB`s eZdZd„Zd„ZRS(s0 Implementation of `IGeventPatchEvent`. cC`s||_||_dS(N(R>R?(R0R>R?((s,lib/python2.7/site-packages/gevent/events.pyR1 s cC`s&d|jj|j|jt|ƒfS(Ns<%s source=%r target=%r at %x>(R9R,R>R?tid(R0((s,lib/python2.7/site-packages/gevent/events.pyR:s (R,R-R.R1R:(((s,lib/python2.7/site-packages/gevent/events.pyRs cB`seZdZRS(sª An event emitted *before* gevent monkey-patches something. If a subscriber raises `DoNotPatch`, then patching this particular item will not take place. (R,R-R.(((s,lib/python2.7/site-packages/gevent/events.pyRscB`seZdZRS(s‚ Subscribers to will-patch events can raise instances of this class to tell gevent not to patch that particular item. (R,R-R.(((s,lib/python2.7/site-packages/gevent/events.pyR scB`seZdZRS(s4 Implementation of `IGeventWillPatchEvent`. (R,R-R.(((s,lib/python2.7/site-packages/gevent/events.pyR'scB`seZdZRS(s@ An event emitted *after* gevent has patched something. (R,R-R.(((s,lib/python2.7/site-packages/gevent/events.pyR-stGeventDidPatchEventcB`seZdZRS(s3 Implementation of `IGeventDidPatchEvent`. (R,R-R.(((s,lib/python2.7/site-packages/gevent/events.pyRA2scB`s&eZdZedƒZedƒZRS(sŒ An event emitted *before* gevent begins patching a specific module. Both *source* and *target* attributes are module objects. sNThe name of the module being patched. This is the same as ``target.__name__``.sLThe list of item names to patch. This can be modified in place with caution.(R,R-R.R(t module_namettarget_item_names(((s,lib/python2.7/site-packages/gevent/events.pyR8s cB`seZdZdZd„ZRS(s: Implementation of `IGeventWillPatchModuleEvent`. s'gevent.plugins.monkey.will_patch_modulecC`s/tt|ƒj||ƒ||_||_dS(N(R<RR1RBRC(R0RBR>R?titems((s,lib/python2.7/site-packages/gevent/events.pyR1Os (R,R-R.R"R1(((s,lib/python2.7/site-packages/gevent/events.pyREscB`seZdZedƒZRS(sW An event emitted *after* gevent has completed patching a specific module. sNThe name of the module being patched. This is the same as ``target.__name__``.(R,R-R.R(RB(((s,lib/python2.7/site-packages/gevent/events.pyRUscB`seZdZdZd„ZRS(s9 Implementation of `IGeventDidPatchModuleEvent`. s&gevent.plugins.monkey.did_patch_modulecC`s&tt|ƒj||ƒ||_dS(N(R<RR1RB(R0RBR>R?((s,lib/python2.7/site-packages/gevent/events.pyR1is(R,R-R.R"R1(((s,lib/python2.7/site-packages/gevent/events.pyR_scB`s/eZdZedƒZedƒZd„ZRS(s· An event emitted *before* gevent begins patching the system. Following this event will be a series of `IGeventWillPatchModuleEvent` and `IGeventDidPatchModuleEvent` for each patched module. Once the gevent builtin modules have been processed, `IGeventDidPatchBuiltinModulesEvent` will be emitted. Processing this event is an ideal time for third-party modules to be imported and patched (which may trigger its own will/did patch module events). Finally, a `IGeventDidPatchAllEvent` will be sent. If a subscriber to this event raises `DoNotPatch`, no patching will be done. The *source* and *target* attributes have undefined values. shA dictionary of all the arguments to `gevent.monkey.patch_all`. This dictionary should not be modified. sjA dictionary of the extra arguments to `gevent.monkey.patch_all`. This dictionary should not be modified. cC`sdS(sP Return whether the module named *module_name* will be patched. N((RB((s,lib/python2.7/site-packages/gevent/events.pytwill_patch_modules(R,R-R.R(tpatch_all_argumentstpatch_all_kwargsRE(((s,lib/python2.7/site-packages/gevent/events.pyRps   t_PatchAllMixincB`s8eZd„Zed„ƒZed„ƒZd„ZRS(cC`s/tt|ƒjddƒ||_||_dS(N(R<RHR1tNonet_patch_all_argumentst_patch_all_kwargs(R0RFRG((s,lib/python2.7/site-packages/gevent/events.pyR1–s cC`s |jjƒS(N(RJtcopy(R0((s,lib/python2.7/site-packages/gevent/events.pyRF›scC`s |jjƒS(N(RKRL(R0((s,lib/python2.7/site-packages/gevent/events.pyRGŸscC`s d|jj|jt|ƒfS(Ns <%s %r at %x>(R9R,RJR@(R0((s,lib/python2.7/site-packages/gevent/events.pyR:£s (R,R-R1tpropertyRFRGR:(((s,lib/python2.7/site-packages/gevent/events.pyRH•s cB`seZdZdZd„ZRS(s7 Implementation of `IGeventWillPatchAllEvent`. s$gevent.plugins.monkey.will_patch_allcC`s|jj|ƒS(N(RFtget(R0RB((s,lib/python2.7/site-packages/gevent/events.pyRE²s(R,R-R.R"RE(((s,lib/python2.7/site-packages/gevent/events.pyR¨scB`s&eZdZedƒZedƒZRS(s Event emitted *after* the builtin modules have been patched. The values of the *source* and *target* attributes are undefined. shA dictionary of all the arguments to `gevent.monkey.patch_all`. This dictionary should not be modified. sjA dictionary of the extra arguments to `gevent.monkey.patch_all`. This dictionary should not be modified. (R,R-R.R(RFRG(((s,lib/python2.7/site-packages/gevent/events.pyRµs  cB`seZdZdZRS(sA Implementation of `IGeventDidPatchBuiltinModulesEvent`. s(gevent.plugins.monkey.did_patch_builtins(R,R-R.R"(((s,lib/python2.7/site-packages/gevent/events.pyRÆscB`seZdZRS(sÀ Event emitted after gevent has patched all modules, both builtin and those provided by plugins/subscribers. The values of the *source* and *target* attributes are undefined. (R,R-R.(((s,lib/python2.7/site-packages/gevent/events.pyRÐscB`seZdZdZRS(s6 Implementation of `IGeventDidPatchAllEvent`. s#gevent.plugins.monkey.did_patch_all(R,R-R.R"(((s,lib/python2.7/site-packages/gevent/events.pyRØs(2R.t __future__RRRt__all__t zope.eventRRt ImportErrort __import__R%R R!tplatformtunamet gevent._utilR&R'R(R R tobjectR RRRR8RRR R RRt BaseExceptionRRRRARRRRRRHRRRRR(((s,lib/python2.7/site-packages/gevent/events.pyts¶                    %