[c@`sddlmZmZmZmZddlZddlmZddl m Z ddl m Z ddl mZd gZd efd YZdS( i(tabsolute_importtdivisiontprint_functiontunicode_literalsNi(t xmlrpc_clienti(t SAMPHubError(tServerProxyPool(tget_main_running_hubu SAMPHubProxyt SAMPHubProxycB`seZdZdZedZddddZdZdZ edZ dZ d Z d Z d Zd Zd ZdZdZdZdZdZdZdZdZdZdZRS(uh Proxy class to simplify the client interaction with a SAMP hub (via the standard profile). cC`sd|_t|_dS(N(tNonetproxytFalset _connected(tself((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyt__init__s cC`s|jS(uH Whether the hub proxy is currently connected to a hub. (R (R ((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyt is_connectedsicC`s7t|_i|_|d k r9|d k r9tdn|d kr|d k ru|jsitdq~|j}qt}ny]|dj dd}t |t j |dd|_ |jtj||_t|_WnRt jk r2}|jdkrtd q3td j|j|jnXd S( u Connect to the current SAMP Hub. Parameters ---------- hub : `~astropy.samp.SAMPHubServer`, optional The hub to connect to. hub_params : dict, optional Optional dictionary containing the lock-file content of the Hub with which to connect. This dictionary has the form ``{: , ...}``. pool_size : int, optional The number of socket connections opened to communicate with the Hub. u&Cannot specify both hub and hub_paramsuHub is not runningusamp.hub.xmlrpc.urlu\ut allow_noneiiu=Unauthorized access. Basic Authentication required or failed.uProtocol Error {}: {}N(R R tlockfileR t ValueErrort is_runningRtparamsRtreplaceRtxmlrpct ServerProxyR tpingtcopytdeepcopytTruet ProtocolErrorterrcodetformatterrmsg(R thubt hub_paramst pool_sizeturltp((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pytconnect#s,          cC`sd|_t|_i|_dS(u7 Disconnect from the current SAMP Hub. N(R R R R R(R ((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyt disconnect[s  cC`s|jjdS(N(R t server_close(R ((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyR'cscC`s |jjjS(u Property to abstract away the path to the hub, which allows this class to be used for other profiles. (R tsampR (R ((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyt _samp_hubfscC`s |jjS(uL Proxy to ``ping`` SAMP Hub method (Standard Profile only). (R)R(R ((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyRnscC`s|jj||S(uY Proxy to ``setXmlrpcCallback`` SAMP Hub method (Standard Profile only). (R)tsetXmlrpcCallback(R t private_keyt xmlrpc_addr((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pytset_xmlrpc_callbacktscC`s|jj|S(u8 Proxy to ``register`` SAMP Hub method. (R)tregister(R tsecret((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyR.zscC`s|jj|S(u: Proxy to ``unregister`` SAMP Hub method. (R)t unregister(R R+((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyR0scC`s|jj||S(u? Proxy to ``declareMetadata`` SAMP Hub method. (R)tdeclareMetadata(R R+tmetadata((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pytdeclare_metadatascC`s|jj||S(u; Proxy to ``getMetadata`` SAMP Hub method. (R)t getMetadata(R R+t client_id((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyt get_metadatascC`s|jj||S(uD Proxy to ``declareSubscriptions`` SAMP Hub method. (R)tdeclareSubscriptions(R R+t subscriptions((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pytdeclare_subscriptionsscC`s|jj||S(u@ Proxy to ``getSubscriptions`` SAMP Hub method. (R)tgetSubscriptions(R R+R5((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pytget_subscriptionsscC`s|jj|S(uD Proxy to ``getRegisteredClients`` SAMP Hub method. (R)tgetRegisteredClients(R R+((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pytget_registered_clientsscC`s|jj||S(uD Proxy to ``getSubscribedClients`` SAMP Hub method. (R)tgetSubscribedClients(R R+tmtype((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pytget_subscribed_clientsscC`s|jj|||S(u6 Proxy to ``notify`` SAMP Hub method. (R)tnotify(R R+t recipient_idtmessage((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyRAscC`s|jj||S(u9 Proxy to ``notifyAll`` SAMP Hub method. (R)t notifyAll(R R+RC((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyt notify_allscC`s|jj||||S(u4 Proxy to ``call`` SAMP Hub method. (R)tcall(R R+RBtmsg_tagRC((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyRFscC`s|jj|||S(u7 Proxy to ``callAll`` SAMP Hub method. (R)tcallAll(R R+RGRC((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pytcall_allscC`s|jj||||S(u; Proxy to ``callAndWait`` SAMP Hub method. (R)t callAndWait(R R+RBRCttimeout((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyt call_and_waitscC`s|jj|||S(u5 Proxy to ``reply`` SAMP Hub method. (R)treply(R R+tmsg_idtresponse((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyRMsN(t__name__t __module__t__doc__RtpropertyRR R%R&R'R)RR-R.R0R3R6R9R;R=R@RARERFRIRLRM(((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyRs. 8                 (t __future__RRRRRtextern.six.movesRRterrorsRtutilsRtlockfile_helpersRt__all__tobjectR(((s5lib/python2.7/site-packages/astropy/samp/hub_proxy.pyts"