\ K]c@@sdZddlmZmZddlmZddlZddlZddlm Z ddl Z ddl m Z ddlmZddlmZdd lmZmZdd lmZmZdd lmZdd lmZd ZdZdZdefdYZdZ defdYZ!defdYZ"dZ#dZ$dZ%dZ&defdYZ'defdYZ(defd YZ)d!efd"YZ*dS(#sA Implements custom ufunc dispatch mechanism for non-CPU devices. i(tprint_functiontabsolute_import(t OrderedDictN(treduce(texec_(tlongint(tIS_PY3(t_BaseUFuncBuildertparse_identity(tsigutilsttypes(t signature(tparse_signaturecC@sL||kr|S|dkr |S|dkr0|Stdj||dS(s= Raises ------ ValueError if broadcast fails isfailed to broadcast {0} and {1}N(t ValueErrortformat(tatb((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyt_broadcast_axiss   cC@stt||g\}}x&t|t|krCd|}qWx&t|t|krld|}qGWtdt||DS(s= Raises ------ ValueError if broadcast fails ics@s$|]\}}t||VqdS(N(R(t.0RR((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pys 4s(i(i(tmapttupletlentzip(tshape1tshape2((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyt_pairwise_broadcast&s cG@s|s t|d}|d}y6x/t|ddD]\}}t||}q6WWn&tk r~tdj|nX|SdS(s= Raises ------ ValueError if broadcast fails iitstarts!failed to broadcast argument #{0}N(tAssertionErrort enumerateRR R(t shapelisttresulttotherstiteach((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyt_multi_broadcast7s    tUFuncMechanismcB@seZdZdZeZdZdZdZ dZ dZ dZ dZ dZd Zd Zd Zd Zed ZdZdZdZdZRS(s0 Prepare ufunc arguments for vectorize. cC@sW||_||_t|j}dg||_g|_d|_dg||_dS(sFNever used directly by user. Invoke by UFuncMechanism.call(). N(ttypemaptargsRtNonetargtypest scalarposR tarrays(tselfR$R%tnargs((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyt__init__Qs    cC@sxt|jD]\}}t|tjr>||j|Wt |r|j |qqWn|s g}xL|jD]>}t dt||jD}|r|j |qqWn|s"t dnt |dkrCt dn|d|_dS(s<Resolve signature. May have ambiguous case. cs@s-|]#\}}|dkp$||kVqdS(N(R&(Rtformaltactual((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pys ssNo matching version. GPU ufunc requires array arguments to have the exact types. This behaves like regular ufunc with casting='no'.isqFailed to resolve ufunc due to ambiguous signature. Too many untyped scalars. Use numpy dtype object to type tag.iN(R(R$RRR'R&R.tasarrayR%R;R6tallR7R(R*tmatchest formaltyst match_mapR R>R?t all_matches((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyt_resolve_signaturets.     cC@sHx>|jD]3}tj|j|gd|j||j|s(R&RiRjtDeprecationWarningRRR tnormalize_signatureR RR~t_get_kernel_sourcet_kernel_templatet _compile_coret _get_globalsR tvoidRt_compile_kernelR%RR(R*tsigR'trestypeR%t return_typetdevfnsigtfuncnamet kernelsourcetcorefntglblRtstagertkernelt argdtypestresdtype((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pytaddys.      .  cC@s tdS(N(R](R*((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyt build_ufuncsc C@spgtt|jD]}d|^q}td|ddj|ddjd|D}|j|S(Nsa%dtnameR%s, targitemscs@s|]}d|VqdS(s %s[__tid__]N((RR ((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pys s(RLRR%tdictRkR(R*ttemplateRRR R%tfmts((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRs , cC@s tdS(N(R](R*R((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRscC@s tdS(N(R](R*R((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRscC@s tdS(N(R](R*tfnobjR((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRsN( R~RR&R[R,tpropertyRRRRRRR(((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRks     tDeviceGUFuncVectorizecB@sMeZdeidZedZddddZdZdZ RS(c C@s|rtdn|jdts6tdn|rdjg|jD]}t|^qO}d}t|j|n||_t||_ ||_ t |j \|_ |_ t|j dkstdt|_dS(Nscaching is not supportedtnopythonsnopython flag must be Trues, s3The following target options are not supported: {0}isonly support 1 output(R7RgRlRktkeystreprRRRRR R tinputsigt outputsigRRRR( R*RuRRRRtktoptstfmt((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyR,s.  !cC@s|jS(N(R(R*((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRscC@s|dk rXtjdt|dks.t|dkrIt|}qX||}n~~g|jD]}t|^qh}g|jD]}t|^q}t j |\}}|j j } t |j||| |} |j|} t| | | djd| } tt|||} |j| dt| }td| D}|d|f|jt|d si(R&RiRjRRRRRRR RRR~texpand_gufunc_templateRRRRRNt_determine_gufunc_outer_typesRR(R*RR'RtxtindimstoutdimsR%RRtsrctglblsRtoutertysRtdtypes((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRs,   ""   cC@s tdS(N(R](R*RR((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRscC@s tdS(N(R](R*R((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRsN( R~RR&R[R,RRRRR(((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRs  cc@sxt||D]n\}}t|tjrF|jd|dVq|dkratdntjd|ddddVqWdS(NRMiis,gufunc signature mismatch: ndim>0 for scalarR;tlayouttA(RR-R tArraytcopyR (targtystdimstattnd((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRs  c C@s8||}gtt|D]}dj|^q}djdjg|D]}dj|^qK} gt|||D]!\} } } t| | | ^q} gt|t|||t|D]!\} } } t| | | ^q}| |}|jd|ddj|d| ddj|}|S( s"Expand gufunc source template sarg{0}smin({0})s, s {0}.shape[0]RR%t checkedargR(RLRRRkRt_gen_src_for_indexing(RRRRR'targdimsR targnamesRRtareftadimstatypetinputstoutputsRR((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRs .%78 cC@sdjd|dt||S(Ns{aref}[{sliced}]Rtsliced(Rt_gen_src_index(RRR((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyR scC@sX|dkr'djdgdg|St|tjrP|jd|krPdSdSdS(Nit,t__tid__t:is__tid__:(__tid__ + 1)(RkR-R RRM(RR((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRs  %t GUFuncEnginecB@s/eZdZedZdZdZRS(sZDetermine how to broadcast and execute a gufunc base on input shape and signature cC@s|t|S(N(R (RrR ((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pytfrom_signature scC@s:||_||_t|j|_t|j|_dS(N(tsintsoutRtnintnout(R*RR((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyR,$s  cC@st||jkr$tdni}g}g}x9tt||jD]\}\}}|d7}t|}t||krd} t| |fn|r|| } || } n d} |} xtt| |D]j\} \} }| t| 7} ||krF||| krFd} t| || fqFn| ||sisoutput shape mismatch( RIRRRRtKeyErrort_search_matching_signatureR&RR ( R*RR_Rt input_shapesRtidtypesR R((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRs "cC@sMxF|jjD])}tdt||Dr|SqWtddS(s Given the input types in `idtypes`, return a compatible sequence of types that is defined in `kernelmap`. Note: Ordering is guaranteed by `kernelmap` being a OrderedDict cs@s'|]\}}tj||VqdS(N(R.tcan_cast(RR?tdesired((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pys ssno matching signatureN(RRRARR7(R*RR((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRs  c C@s|jdkstd|js*dn|j}g}xtt||jD]`\}}| r|jdkr|j||}|j|qL|j|j|||qLW|j ||j d} || fS(Niszero looping dimensioni( RRRRRtsizet_broadcast_scalar_inputR6t_broadcast_arrayRpR( R*RtparamstretvaltodimR tptcsR|R((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRXs cC@s|f|}|j|kr |St|jt|krt|t|j |jksdtd|j||S|j|SdS(Ns+cannot add dim and reshape at the same time(RIRRt_broadcast_add_axisRp(R*R<tnewdimtinnerdimtnewshape((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRs   cC@stddS(Nscannot add new axis(R](R*R<R!((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRscC@s tdS(N(R](R*R<RI((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRs( R~RR,RRRRXRRR(((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyR|s       tGUFuncCallStepscB@seZddddddddgZdZd Zd Zd Zd Zd ZdZ dZ dZ dZ dZ RS(R%tkwargsRRRRt_is_device_arrayt_need_device_conversionc C@s{|dkrtdn||_||_t}|jjd|_|jdk r|j|j}|r|j|j|_qng|jD]}|j|^q|_ t |j  o| |_ g}xXt |j|j D]A\}}|r|j |j|q|j tj|qW|| |_||} | rw|jdk rhtdqw| \|_ndS(Nis multiple output is not supportedR_s>cannot specify 'out' as both a positional and keyword argument(R R%R#R[tgetRR&R0R1R$tanyR%RR6R.R@R( R*RRR%R#tuser_output_is_deviceRRtisdevt unused_inputs((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyR,s0   ( "  cC@sxtt||jD]m\}\}}||jkrt|dsmdjt|}t|n|j||j||j|q|jj|qWtfd|Dszt|_dS(Nc3@s|]}j|VqdS(N(R0(RR(R*(s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pys +s(RRR$R6RcRARR(R*RtinpR)((R*s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyR$s""cC@sL|jr$|j|j|j}n$|jdkr?|j}n |j}|S(N(R%RbRRR&(R*R_((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyR .s    cC@sdS(N((R*((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyR7scC@s tdS(N(R](R*RtnelemR%((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyR:scC@s tdS(N(R](R*R\((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyR0=scC@s|S(N((R*R\((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyR1@scC@s tdS(N(R](R*Rd((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRcCscC@s tdS(N(R](R*RIR;((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyRmFs(R~Rt __slots__R,RRRR RRR0R1RcRm(((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyR"s&  !      (+Rt __future__RRt collectionsRRRit functoolsRtnumpyR.t numba.sixRt numba.utilsRRtnumba.npyufunc.ufuncbuilderRRtnumbaR R t numba.typingR tnumba.npyufunc.sigparseR RRR"tobjectR#RRRRRRRRRRR"(((s9lib/python2.7/site-packages/numba/npyufunc/deviceufunc.pyts:       B@   Ka