x[hSrSSKrSSKrSSKrSSKrSSKJr SSKJr SSK J r \R"\ 5r S\4Sjr"SS 5rg) z#A module for common socket helpers.N)suppress) performance)DEFAULT_RUN_DIRmessagec[RRSS5nU(dgUSS:XaURSSS5 OUSS:wa [ S 5e[ R "[ R [ R[ R-5n[RS [U55 URU5 URURS 55 SSS5 g!,(df  g=f) zSSend a sd_notify message. :param message: sd-notify message (must be valid ascii) NOTIFY_SOCKETNr@/zUnsupported socket typezSending sd_notify(%s)ascii)osenvirongetreplaceOSErrorsocketAF_UNIX SOCK_DGRAM SOCK_CLOEXECLOGinfostrconnectsendallencode)r socket_pathsocks 2/usr/lib/python3/dist-packages/cloudinit/socket.py sd_notifyr!s **.."5K  Q3 Cq) Q3 /00 ))F,?,??   (#g,7 [! W^^G,-    s AC88 Dc@\rSrSrSrS\4SjrS\4SjrSrSr S r g ) SocketSync*zSet the stage before entering context. This enables the context manager to be initialized separately from each stage synchronization. :param stage: the name of a stage to synchronize Example: sync = SocketSync("stage 1", "stage 2"): with sync("stage 1"): pass with sync("stage 2"): pass zInvalid stage name: )r/ ValueErrorr*)r5r*s r __call__SocketSync.__call__Ms+  $3E7;< <  c[R"[RR 55(a[ R S5 gSUl[SURS35 URURn[R"SUR35 URS5uo lSSS5 SW:wa+URSSS5 [!S [#U5S 35e[$S URS 3[#UR5:wa+URSSS5 [!S UR35e[SURS35 U$!,(df  N=f)zwWait until a message has been received on this stage's socket. Once the message has been received, enter the context. z:Stdin is a tty, so skipping stage synchronization protocolNrzDSTATUS=Waiting on external services to complete before starting the z stage.zWaiting to start stage sstartzReceived invalid message: []r)z -return.sockz Unexpected path to unix socket: zSTATUS=Running (z stage))risattysysstdinfilenorrr-r!r*r/rTimedrecvfromr+__exit__r:rr)r5rchunks r __enter__SocketSync.__enter__asK 99SYY%%' ( ( HHL  !" ,,0JJrcsE) !. !.s.6AAr=