³ò ”ö²Mc@sŽddklZlZddklZlZlZddkZddkZddk Z ddk Z ddk Z ddk Z ddk Z ddk Z ee dƒoddk lZnddk lZe idƒZeeid ƒd joddd „Zee i_nd efd „ƒYZd e ifd„ƒYZde ifd„ƒYZddd„ƒYZd„Zedjo eƒndS(iÿÿÿÿ(tPopentPIPE(tenvirontreadtgetcwdNtpoll(tpoll2(Rs[ ]+igÍÌÌÌÌÌ@cCsAd|_d|_tiƒ|_tii|d|d|ƒdS(Nttsocktmap(t ac_in_buffert ac_out_buffertasynchattfifot producer_fifotasyncoret dispatchert__init__(tselftconnR ((s./Pd.pytasynchat_monkey_inits  t PdExceptioncBseZRS((t__name__t __module__(((s./Pd.pyR#stPdSendcBsAeZdd„Zd„Zd„Zd„Zd„Zd„ZRS(cCs,tii|d|ƒg|_t|_dS(NR (R t async_chatRt_cachetFalset_success(RR ((s./Pd.pyR's cCs8t|_g}|iD]}||i|ƒq~dS(N(tTrueRRtSend(Rt_[1]td((s./Pd.pythandle_connect,s cCs|iƒdS(N(tclose(R((s./Pd.pyt handle_close0scCsdGH|iƒdS(Ns3PdSend: connection failed (win) or OOB data (linux)(R"(R((s./Pd.pyt handle_expt3scCs'|ititiƒ|i|ƒdS(N(t create_sockettsockettAF_INETt SOCK_STREAMtconnect(Rtaddr((s./Pd.pytConnect7scCsc|ioEtii|dig}|D]}|t|ƒq'~ƒdƒn|ii|ƒdS(Nt s; (RR RtpushtjointstrRtappend(RtdataRR ((s./Pd.pyR;s EN( RRtNoneRR!R#R$R+R(((s./Pd.pyR&s      t PdReceivecBs;eZddd„Zd„Zd„Zd„Zd„ZRS( s 127.0.0.1irvcCs¬||_tii|d|ƒd|_|idƒd|_tid|ƒ|_ |i |i _ |i i t it iƒ|i iƒ|i i|ƒ|i idƒdS(NR Rs; i(t_parentR RRt_ibuffertset_terminatort_remoteRRt _serversocketthandle_accept_servert handle_acceptR%R&R'R(tset_reuse_addrtbindtlisten(Rtparentt localaddrR ((s./Pd.pyRBs     cCsc|iiƒ}|o9|\}}||_|iiƒ|`|i|ƒndG|iG|GHdS(Ns+Dropped spurious PdReceive connect! socket:(R8tacceptR7R"t set_sockett_socket(RtacceptedRR*((s./Pd.pyR9Qs   cCs|ii|iƒdS(N(R4R+R7(R((s./Pd.pyR!^scCs|i|7_dS(N(R5(RR1((s./Pd.pytcollect_incoming_dataascCsh|iidƒ}d|_t|id|ddƒ}|o|||dƒn|ii|ƒdS(NR,RtPd_ii(R5tsplittgetattrR4R2t PdMessage(RR1tmethod((s./Pd.pytfound_terminatords  (s 127.0.0.1irvN(RRR2RR9R!RDRJ(((s./Pd.pyR3As   tPdcBs˜eZdZhZdedddgded„Zd„Zd„Zd„Z d„Z d „Z d „Z d „Z d „Zd „Zd„Zd„ZRS(sj Start Pure Data in a subprocess. >>> from time import time, sleep >>> from os import path, getcwd >>> >>> start = time() >>> # launching pd >>> pd = Pd(nogui=False) >>> pd.Send(["test message", 1, 2, 3]) >>> >>> def Pd_hello(self, message): ... print "Pd called Pd_hello(%s)" % message ... >>> pd.Pd_hello = Pd_hello >>> >>> sentexit = False >>> # running a bunch of stuff for up to 20 seconds >>> while time() - start < 20 and pd.Alive(): ... if time() - start > 0.5 and not sentexit: ... pd.Send(["exit"]) ... sentexit = True ... pd.Update() ... ... Pd called Pd_hello(['this', 'is', 'my', 'message', 'to', 'python']) untrapped message: ['this', 'is', 'another', 'message'] untrapped stderr output: "connecting to port 30322" untrapped stderr output: "python-connected: 0" untrapped stderr output: "python-connected: 1" untrapped stderr output: "from-python: test message 1 2 3" untrapped stderr output: "closing audio..." untrapped stderr output: "pd_gui: pd process exited" untrapped stderr output: "closing MIDI..."... Pd died! >>> pd.Exit() iqvspython-interface-help.pdtpatchesc Csçd|_tidjo d}nHtidjo d}n.tidjo d}ntdtiƒ‚|g} |o| idƒn|o| id ƒn|o| id ƒ| i|ƒn|o| id ƒ| i|ƒnx(|D] } | id ƒ| i| ƒqôW|o| |id ƒ7} ny4t| dddtdtdtidjƒ|_ Wn,t j o td|t ƒfƒ‚nX|o ||_ nh|_ td|i ƒ|_t|d|i ƒ|_dS(sq port - what port to connect to [netreceive] on. nogui - boolean: whether to start Pd with or without a gui. Defaults to nogui=True open - string: full path to a .pd file to open on startup. cmd - message to send to Pd on startup. path - an array of paths to add to Pd startup path. extra - a string containing extra command line arguments to pass to Pd. twin32s pd\bin\pd.exetlinux2tpdtdarwins"./Pd.app/Contents/Resources/bin/pds7Unknown Pd executable location on your platform ('%s').s-stderrs-noguis-opens-sends-pathR,tstdintstderrtstdoutt close_fdssProblem running `%s` from '%s'R N(R2tconnectCallbacktsystplatformRR0RFRRROtOSErrorRtportt_mapRt_pdSendR3t _pdReceive( RRYtnoguitopentcmdtpathtextraRRtpdexetargstp((s./Pd.pyR•sD        4  cCsÀtd|iƒ|iiƒ}|iiƒ}|o@g}ti|ƒD]!}|o||i|ƒqIqI~n|o@g}ti|ƒD]!}|o||i|ƒqq~ndS(NR ( RRZROtrecvtrecv_errtcrRFt CheckStarttError(RRQRRRttt_[2]((s./Pd.pytUpdateÌs@cCs|ii|ƒdS(s’ Send an array of data to Pd. It will arrive at the [python-interface] object as a space delimited list. p.Send(["my", "test", "yay"]) N(R[R(Rtmsg((s./Pd.pyRÕscCs dG|GHdS(s7 Override this method to receive messages from Pd. suntrapped message:N((RR1((s./Pd.pyRHÞscCs!|ii|d|ifƒdS(Ni(R[R+RY(RR*((s./Pd.pyR+äscCsd|jo|iƒndS(Ns_Start() called(t PdStarted(RRm((s./Pd.pyRhçs cCsq|idƒ}t|d|ddƒ}|o||ƒn0||ijo|i|ƒnd|dGHdS(sR Override this to catch anything sent by Pd to stderr (e.g. [print] objects). R,tError_isuntrapped stderr output: "t"N(RFRGR2terrorCallbacks(RterrorterrorsRI((s./Pd.pyRiëscCsd|_|iƒdS(N(R2ROtPdDied(R((s./Pd.pytDeadøs cCsdS(s4 Override this to catch the definitive start of Pd. N((R((s./Pd.pyRnüscCs dGHdS(s7 Override this to catch the Pd subprocess exiting. sPd died!N((R((s./Pd.pyRtscCs#t|io|iiƒdjƒS(s5 Check whether the Pd subprocess is still alive. i(tboolROR(R((s./Pd.pytAlivescCs’|iƒoftidjo,ddk}|it|iiƒdƒqsddkl }||ii t i ƒn|io|ii ƒndS(s$ Kill the Pd process right now. RMiÿÿÿÿN(tkill(RwRVRWtwin32apitTerminateProcesstintROt_handletosRxtpidtsignaltSIGINTtwait(RRyRx((s./Pd.pytExit s    N(RRt__doc__RqRR2RRlRRHR+RhRiRuRnRtRwR‚(((s./Pd.pyRKns%!7       cCs#ddk}|id|iƒdS(Niÿÿÿÿt optionflags(tdoctestttestmodtELLIPSIS(R…((s./Pd.pyt_tests t__main__(( tmonkeysubprocessRRR}RRRRVRRR R&tselecttrethasattrRRtcompileRgtfloattversionR2RRRt ExceptionRRR3RKRˆR(((s./Pd.pyss.        -¯