o iUO@sdZddlZddlZddlZddlmZGdddeZ e eeZGdddeZ dd Z e Gd d d eZ d d Z ddZddZddZddZddZddZddZddZddZdS) z} `fallback_mode` for cupy. Whenever a method is not yet implemented in CuPy, it will fallback to corresponding NumPy method. N) notificationc@sReZdZdZdddZddZddZd d Zed d Ze d dZ ddZ dS)_RecursiveAttrz RecursiveAttr class to catch all attributes corresponding to numpy, when user calls fallback_mode. numpy is an instance of this class. NcCs||_||_||_dS)a _RecursiveAttr initializer. Args: numpy_object (method): NumPy method. cupy_method (method): Corresponding CuPy method. array (ndarray): Acts as flag to know if _RecursiveAttr object is called from ``ndarray`` class. Also, acts as container for modifying args in case it is called from ``ndarray``. None otherwise. N) _numpy_object _cupy_object_fallback_array)self numpy_object cupy_objectarrayr Y/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/cupyx/fallback_mode/fallback.py__init__s  z_RecursiveAttr.__init__cCs"|jdur t||jSt||jS)z Enable support for isinstance(instance, _RecursiveAttr instance) by redirecting it to appropriate isinstance method. N)r isinstancer)rinstancer r r __instancecheck__&s   z _RecursiveAttr.__instancecheck__cCsLt|j|}t|j|d}|tjurtS|tjurtS||ur!|St||S)a5 Catches attributes corresponding to numpy. Runs recursively till attribute gets called. Or numpy ScalarType is retrieved. Args: attr (str): Attribute of _RecursiveAttr class object. Returns: (_RecursiveAttr object, NumPy scalar): Returns_RecursiveAttr object with new numpy_object, cupy_object. OR Returns objects in cupy which is an alias of numpy object. OR Returns wrapper objects, `ndarray`, `vectorize`. N)getattrrrnpndarray vectorizer)rattrrr r r r __getattr__1s    z_RecursiveAttr.__getattr__cCs8t|jtjrd|jjt|jddSd|j|jS)Nz%__name__z)rrtypes ModuleTypeformatrrrrr r r __repr__Rs z_RecursiveAttr.__repr__cCs|jjSN)r__doc__rr r r r\sz_RecursiveAttr.__doc__cs\ttr js dStttfrtddDSttr,fddD}t|SdS)a- Returns False if CuPy's functions never accept the arguments as parameters due to the following reasons. - The inputs include an object of a NumPy's specific class other than `np.ndarray`. - The inputs include a dtype which is not supported in CuPy. Fcss|]}t|VqdSrr_is_cupy_compatible.0ir r r osz5_RecursiveAttr._is_cupy_compatible..csg|] }t|qSr rr!argr r rsz6_RecursiveAttr._is_cupy_compatible..T)rr_supports_cupytuplelistalldict)r&boolsr r%r r `s  z"_RecursiveAttr._is_cupy_compatiblecOst|jstdt|jj|jdur|jf|}|jdur@t ||fr@zt |j||WSt y?t |j||YSwt |jt |j||S)aR Gets invoked when last attribute of _RecursiveAttr class gets called. Calls _cupy_object if not None else call _numpy_object. Args: args (tuple): Arguments. kwargs (dict): Keyword arguments. Returns: (res, ndarray): Returns of methods call_cupy or call_numpy z'{}' object is not callableN)callabler TypeErrorrtyperrrrr _call_cupy Exception _call_numpyr_dispatch_notificationrargskwargsr r r __call__ws        z_RecursiveAttr.__call__r) r __module__ __qualname__rr rrrproperty staticmethodr r8r r r r rs  !   rc@steZdZdZejjZddZddZeddZ edd Z e d d Z d d Z ddZddZddZddZdS)rz~ Wrapper around cupy.ndarray Supports cupy.ndarray.__init__ as well as, gets initialized with a cupy ndarray. cOs:|dd}|durt|Stj|i|}||ddS)z If `_initial_array` and `_supports_cupy` are arguments, initialize cls(ndarray). Else get cupy.ndarray from provided arguments, then initialize cls(ndarray). _initial_arrayNTr=r()getobject__new__cpr)clsr6r7r=cupy_ndarray_initr r r rAs   zndarray.__new__cOs|dd}|dd}|durdSd|_d|_d|_||_t|tjtjfs)J|rBt |tjur:||_d|_ dS||_d|_ dS||_dS)a Args: _initial_array (None, cp.ndarray/np.ndarray(including variants)): If _initial_array is None, object is not initialized. Otherwise, _initial_array (ndarray) would be set to _cupy_array and/or _numpy_array depending upon _supports_cupy. _supports_cupy (bool): If _supports_cupy is True, _initial_array is set as _cupy_array and _numpy_array. Otherwise, _initial_array is set as only _numpy_array. Attributes: _cupy_array (None or cp.ndarray): ndarray fully compatible with CuPy. This will be always set to a ndarray in GPU. _numpy_array (None or np.ndarray(including variants)): ndarray not supported by CuPy. Such as np.ndarray (where dtype is not in '?bhilqBHILQefdFD') and it's variants. This will be always set to a ndarray in CPU. _supports_cupy (bool): If _supports_cupy is True, data of array will contain in _cupy_array and _numpy_array. Else only _numpy_array will have the data. r(Nr=FT) pop _cupy_array _numpy_arraybaser(rrBrrr0_remember_numpy)rr6r7r(r=r r r r s     zndarray.__init__cCs ||ddS)NTr>r rCr r r r _store_array_from_cupys zndarray._store_array_from_cupycCs2t|tjur|jjdvr||ddS||ddS)Nz?bhilqBHILQefdFDTr>F)r0rrdtypekindrJr r r _store_array_from_numpys   zndarray._store_array_from_numpycCs|jr |js |jjS|jjSr)r(rIrFrLrGrr r r rLs z ndarray.dtypecCst|jrttj|d}ttj|}n d}t|jj|}t|s4|jr.|jr(| t|j |St|j|St |||S)aQ Catches attributes corresponding to ndarray. Args: attr (str): Attribute of ndarray class. Returns: (_RecursiveAttr object, self._array.attr): Returns_RecursiveAttr object with numpy_object, cupy_object. Returns self._array.attr if attr is not callable. N) r(rrBrrrG __class__r.rI_update_cupy_arrayrFr)rrr rr r r rs    zndarray.__getattr__cCs |j}|dur d|_d|_|jS)z Returns _cupy_array (cupy.ndarray) of ndarray object. And marks self(ndarray) and it's base (if exist) as numpy not up-to-date. NF)rHrIrFrrHr r r _get_cupy_arrays zndarray._get_cupy_arraycCs,|j}|dur |jr d|_|jrd|_|jS)z Returns _numpy_array (ex: np.ndarray, numpy.ma.MaskedArray, numpy.chararray etc.) of ndarray object. And marks self(ndarray) and it's base (if exist) as numpy up-to-date. NT)rHr(rIrGrQr r r _get_numpy_array s zndarray._get_numpy_arraycCs|j}|jr tjn|jj}|jra|dur1|js/|jdur%t|j |_dS|j j |jddSdS|js[| |jdur]|jj |d|_|j j |j_ |jj|j jkr_|j j|j_dSdSdSdS|durs|jsjJ|jsu| dSdSdS)zn Updates _numpy_array from _cupy_array. To be executed before calling numpy function. N)out)r0)rHr(rrrGrOrIrBasnumpyrFr?_update_numpy_arrayviewshapestrides)rrH_typer r r rV-s<       zndarray._update_numpy_arraycCs^|j}|dur$|jr"|jdurt|j|_dS|j|jdd<dSdS|jr-|dSdS)zm Updates _cupy_array from _numpy_array. To be executed before calling cupy function. N)rHrIrFrBr rGrPrQr r r rPOs  zndarray._update_cupy_arrayN)rr9r:rrrrAr classmethodrKrNr;rLrrRrSrVrPr r r r rs 0     "rcCs&dd}dD] }tt|||qdS)zK Set magic methods of cupy.ndarray as methods of fallback.ndarray. cs fdd}ttjj|_|S)NcsF|jrtjn|jj}t|}|f|}|jrt|||St|||Sr)r(rBrrGrOrr1r3)rr6r7CLASS_methodnamer r methodhs     z:_create_magic_methods..make_method..method)rrrr)r_r`r r^r make_methodgs z*_create_magic_methods..make_method)?__eq____ne____lt____gt____le____ge____neg____pos____abs__ __invert____add____sub____mul__ __truediv__ __floordiv____mod__ __divmod____pow__ __lshift__ __rshift____and____or____xor____iadd____isub____imul__ __itruediv__ __ifloordiv____imod____ipow__ __ilshift__ __irshift____iand____ior____ixor__ __matmul____radd____rsub____rmul__ __rtruediv__ __rfloordiv____rmod__ __rdivmod____rpow__ __rlshift__ __rrshift____rand____ror____rxor__ __rmatmul____copy__ __deepcopy__ __reduce____iter____len__ __getitem__ __setitem____bool____int__ __float__ __complex__r__str__N)setattrr)rar`r r r _create_magic_methodsas $rc@s4eZdZejjZddZddZddZddZ d S) rcOsd|jd<d|jd<t|dtr,d|jd<|djr d|jd<|djf|dd}ttjtj|i||jd<|jdj |jd<dS) NF_is_numpy_pyfunc _cupy_supportrTvec_objr) __dict__rrrrrr4rrrr5r r r r s      zvectorize.__init__cCst|jd|S)Nr)rr)rrr r r rzvectorize.__getattr__cCst|j||Sr)rr)rr_valuer r r __setattr__szvectorize.__setattr__cOs&|jr t|jj|jt|j||Sr)rrr4rpyfuncrr3r5r r r r8s  zvectorize.__call__N) rr9r:rrrr rrr8r r r r rs   rcsxt|r |St|trtfdd|DSt|tr+fdd|DSt|tr:fdd|DS|S)a Converts ndarray_instance type object to target object using to_xp. Args: ndarray_instance (numpy.ndarray, cupy.ndarray or fallback.ndarray): Objects of type `ndarray_instance` will be converted using `to_xp`. to_xp (FunctionType): Method to convert ndarray_instance type objects. arg (object): `ndarray_instance`, `tuple`, `list` and `dict` type objects will be returned by either converting the object or it's elements, if object is iterable. Objects of other types is returned as it is. Returns: Return data structure will be same as before after converting ndarrays. cg|]}t|qSr  _get_xp_argsr"xndarray_instanceto_xpr r r'z _get_xp_args..csi|] \}}|t|qSr r)r"x_namerrr r sz _get_xp_args..crr rrrr r r'r)rr)r,itemsr*)rrr&r rr rs     rcCttjtj|Sr)rrrrN) numpy_resr r r _convert_numpy_to_fallbackrrcCtttj||fSr)rrrSr6r7r r r _convert_fallback_to_numpyrcCrr)rrrRrr r r _convert_fallback_to_cupyrrcCrr)rrBrrK)cupy_resr r r _convert_cupy_to_fallbackrrcCrr)rrrVrr r r _update_numpy_argsrrcCrr)rrrPrr r r _update_cupy_argsrrc Ct||t||\}}||i|}t|||||}|dur!|St|tjrD|jdur2t|}|St|j||||}t|}||_|S|S)a8 Calls cupy function with *args and **kwargs and does necessary data transfers. Args: func: A cupy function that needs to be called. args (tuple): Arguments. kwargs (dict): Keyword arguments. Returns: Result after calling func and performing data transfers. N)rr_get_same_referencerrBrrHr) funcr6r7 cupy_args cupy_kwargsrext_res fallback_resbase_argr r r r1&     r1c Cr)a: Calls numpy function with *args and **kwargs and does necessary data transfers. Args: func: A numpy function that needs to be called. args (tuple): Arguments. kwargs (dict): Keyword arguments. Returns: Result after calling func and performing data transfers. N)rrrrrrrHr) rr6r7 numpy_args numpy_kwargsrrrrr r r r3$rr3cCsPtt|D]}|||ur||Sq|D]}|||ur%||SqdS)z_ Returns object corresponding to res in (args, kwargs) from (ret_args, ret_kwargs) N)rangelen)resr6r7ret_args ret_kwargsr#keyr r r rJs    r)rrnumpyrcupyrBcupyx.fallback_moderr@rrrrrrrrrrrr1r3rr r r r s.  C9#! & &