>SrSSKJr SSKrSSKJr "SS\5rg)z3Base class for implementing RPC of API proxy stubs.)absolute_importN) six_subsetc\rSrSrSrSrSrSrSSjrSr SS jr S r S r \ S 5r\ S 5rSrSrSrSrg)RPC zBase class for implementing RPC of API proxy stubs. To implement a RPC to make real asynchronous API call: - Extend this class. - Override _MakeCallImpl and/or _WaitImpl to do a real asynchronous call. rNcSUl[RUlSUlXlX lX0lX@lXPl X`l Xpl SUl g)aConstructor for the RPC object. All arguments are optional, and simply set members on the class. These data members will be overriden by values passed to MakeCall. Args: package: string, the package for the call call: string, the call within the package request: ProtocolMessage instance, appropriate for the arguments response: ProtocolMessage instance, appropriate for the response callback: callable, called when call is complete deadline: A double specifying the deadline for this call as the number of seconds from the current time. Ignored if non-positive. stub: APIProxyStub instance, used in default _WaitImpl to do real call Nr) _exceptionrIDLE_state _tracebackpackagecallrequestresponsecallbackdeadlinestubcpu_usage_mcycles)selfrrrrrrrs 0lib/googlecloudsdk/appengine/api/apiproxy_rpc.py__init__ RPC.__init__,sH"DO((DKDOLILMMMIDcUR[R:wa [S5eUR 5nUR R 5Hup#[XU5 M U$)zMake a shallow copy of this instances attributes, excluding methods. This is usually used when an RPC has been specified with some configuration options and is being used as a template for multiple RPCs outside of a developer's easy control. z'Cannot clone a call already in progress)staterr AssertionError __class____dict__itemssetattr)rclonekvs rClone RPC.CloneJsT zzSXX D EE NN E ##% e& Lrc0U=(d URUlU=(d URUlU=(d URUlU=(d URUlU=(d URUlU=(d UR UlUR [RLd$SUR<SUR<S35eURb[UR5(deUR5 g)aZMakes an asynchronous (i.e. non-blocking) API call within the specified package for the specified call method. It will call the _MakeRealCall to do the real job. Args: Same as constructor; see __init__. Raises: TypeError or AssertionError if an argument is of an invalid type. AssertionError or RuntimeError is an RPC is already in use. RPC for .z has already been startedN) rrrrrrr rr callable _MakeCallImpl)rrrrrrrs rMakeCall RPC.MakeCallYs- DM*dllDL! DI*dllDL- DM- DM ;;#(( "A'+||TYY&@A " == HT]]$;$;; ;rczUR5nU(d$SUR<SUR<S35eg)z/Waits on the API call associated with this RPC.r)r*z6 was not completed, and no other exception was raised N) _WaitImplrr)r rpc_completeds rWaitRPC.Waitss2NN$M P6:llDIIOP=rcUR(aRUR(aA[R"URRURUR5 gUR(a UReg)zgIf there was an exception, raise it now. Raises: Exception of the API call or the callback, if any. N) exceptionrrreraiserrs r CheckSuccessRPC.CheckSuccesszsN  ~~$//114>>*  NN rcUR$N)r r7s rr5 RPC.exceptions ??rcUR$r;)r r7s rr RPC.states ;;rc.[RUlg)z?Override this method to implement a real asynchronous call rpc.N)rRUNNINGr r7s rr,RPC._MakeCallImpls ++DKrcURRURURURUR 5 [RUl UR5 g![ a% [R"5uol Ul NTf=f![RUl UR5 f=f)zOverride this method to implement a real asynchronous call rpc. Returns: True if the async call was completed successfully. T)r MakeSyncCallrrrr Exceptionsysexc_infor rr FINISHINGr _Callbackr_s rr0 RPC._WaitImpls = t||TYY#||T]] < MMdk nn  =.1lln+?DO=MMdk nns$AA//,BB!BB!!'CcUR(aUR5 gg! [R"5uolUlXRle=fr;)rrErFr r_appengine_apiproxy_rpcrIs rrH RPC._CallbacksD }} .1lln+?DO26/ s %5A) r r rrrrrrrrr)NNNNNNN)NNNNNN)__name__ __module__ __qualname____firstlineno____doc__r r@rGrr&r-r2r8propertyr5rr,r0rH__static_attributes__rrrr sy $ ')EI26< FJ'+4P     $rr)rS __future__rrE"googlecloudsdk.appengine._internalrobjectrrVrrrZs# :' 9K&Kr