Ë Ÿõfãój—dZddlmZddlZddlmZddlmZddlm Z Gd„d«Z e «Z dd gZ y) z(Tracker for zero-copy messages with 0MQ.é)Ú annotationsN)ÚEvent)ÚFrame)ÚNotDonecóH—eZdZUdZded<ded<d d„Zed„«Zd d d„Zy ) ÚMessageTrackera­A class for tracking if 0MQ is done using one or more messages. When you send a 0MQ message, it is not sent immediately. The 0MQ IO thread sends the message at some later time. Often you want to know when 0MQ has actually sent the message though. This is complicated by the fact that a single 0MQ message can be sent multiple times using different sockets. This class allows you to track all of the 0MQ usages of a message. Parameters ---------- towatch : Event, MessageTracker, zmq.Frame This objects to track. This class can track the low-level Events used by the Message class, other MessageTrackers or actual Messages. z set[Event]Úeventszset[MessageTracker]ÚpeerscóÄ—t«|_t«|_|D]½}t|t«r|jj |«Œ/t|t «r|jj |«Œ[t|t«r=|js td«‚|jj |j«Œ¨tdt|«›«‚y)a\Create a message tracker to track a set of messages. Parameters ---------- *towatch : tuple of Event, MessageTracker, Message instances. This list of objects to track. This class can track the low-level Events used by the Message class, other MessageTrackers or actual Messages. zNot a tracked messagez&Require Events or Message Frames, not N) Úsetr r Ú isinstancerÚaddrrÚtrackerÚ ValueErrorÚ TypeErrorÚtype)ÚselfÚtowatchÚobjs úL/var/www/cvtools/html/venv/lib/python3.12/site-packages/zmq/sugar/tracker.pyÚ__init__zMessageTracker.__init__#s£€ô“eˆŒ Ü“UˆŒ Øò VˆCܘ#œuÔ%Ø— ‘ —‘ Õ$ܘC¤Ô0Ø— ‘ —‘˜sÕ#ܘC¤Ô'Ø—{’{Ü$Ð%<Ó=Ð=Ø— ‘ —‘˜sŸ{™{Õ+äÐ"HÌÈcËÈ Ð TÓUÐUñ Vócóˆ—|jD]}|j«rŒy|jD]}|jrŒyy)z9Is 0MQ completely done with the message(s) being tracked?FT)r Úis_setr Údone)rÚevtÚpms rrzMessageTracker.done;sG€ð—;‘;ò ˆCØ—:‘:•<Ùð ð—*‘*ò ˆBØ—7“7Ùð ðrcó¤—tj«}|dus|dkrd}n|}|jD]S}|dkrt‚|j|¬«|j «st‚tj«}|||z z}|}ŒU|j D]=}|dkrt‚|j|¬«tj«}|||z z}|}Œ?y)a¬Wait for 0MQ to be done with the message or until `timeout`. Parameters ---------- timeout : float default: -1, which means wait forever. Maximum time in (s) to wait before raising NotDone. Returns ------- None if done before `timeout` Raises ------ NotDone if `timeout` reached before I am done. Fri€: )ÚtimeoutN)Útimer rÚwaitrr )rrÚticÚ remainingrÚtocÚpeers rr!zMessageTracker.waitFsÍ€ô&i‰i‹kˆà eÑ ˜w¨š{Ø%‰IàˆIØ—;‘;ò ˆCؘ1Š}Ü Ø H‰H˜YˆHÔ 'Ø—:‘:”<Ü Ü—)‘)“+ˆCØ ˜˜s™Ñ "ˆI؉Cð ð—J‘Jò ˆDؘ1Š}Ü Ø I‰I˜iˆIÔ (Ü—)‘)“+ˆCØ ˜˜s™Ñ "ˆI؉Cñ  rN)rz%tuple[MessageTracker | Event | Frame])éÿÿÿÿ)rz float | int) Ú__name__Ú __module__Ú __qualname__Ú__doc__Ú__annotations__rÚpropertyrr!©rrrrs4…ñð ÓØ ÓóVð0ñóðõ)rrÚ_FINISHED_TRACKER) r*Ú __future__rr Ú threadingrÚ zmq.backendrÚ zmq.errorrrr.Ú__all__r-rrúr4s<ðÙ.õ #ã ÝåÝ÷`ñ`ñF#Ó$Ðà Ð0Ð 1r