Sha256: 51c81ac9a00dddef8e6e15b71968db69b5107562e7c836c71782c0759471505e
Contents?: true
Size: 1.63 KB
Versions: 7
Compression:
Stored size: 1.63 KB
Contents
static inline void
yield_each_with_index(dtype x, size_t *c, VALUE *a, int nd, int md)
{
int j;
a[0] = m_data_to_num(x);
for (j=0; j<=nd; j++) {
a[j+1] = SIZET2NUM(c[j]);
}
rb_yield(rb_ary_new4(md,a));
}
static void
<%=c_iter%>(cumo_na_loop_t *const lp)
{
size_t i, s1;
char *p1;
size_t *idx1;
dtype x;
VALUE *a;
size_t *c;
int nd, md;
c = (size_t*)(lp->opt_ptr);
nd = lp->ndim;
if (nd > 0) {nd--;}
md = nd + 2;
a = ALLOCA_N(VALUE,md);
CUMO_INIT_COUNTER(lp, i);
CUMO_INIT_PTR_IDX(lp, 0, p1, s1, idx1);
c[nd] = 0;
CUMO_SHOW_SYNCHRONIZE_WARNING_ONCE("<%=name%>", "<%=type_name%>");
if (idx1) {
for (; i--;) {
cumo_cuda_runtime_check_status(cudaDeviceSynchronize());
CUMO_GET_DATA_INDEX(p1,idx1,dtype,x);
yield_each_with_index(x,c,a,nd,md);
c[nd]++;
}
} else {
for (; i--;) {
cumo_cuda_runtime_check_status(cudaDeviceSynchronize());
CUMO_GET_DATA_STRIDE(p1,s1,dtype,x);
yield_each_with_index(x,c,a,nd,md);
c[nd]++;
}
}
}
/*
Invokes the given block once for each element of self,
passing that element and indices along each axis as parameters.
@overload <%=name%>
@return [Cumo::NArray] self
For a block {|x,i,j,...| ... }
@yield [x,i,j,...] x is an element, i,j,... are multidimensional indices.
*/
static VALUE
<%=c_func(0)%>(VALUE self)
{
cumo_ndfunc_arg_in_t ain[1] = {{Qnil,0}};
cumo_ndfunc_t ndf = {<%=c_iter%>, CUMO_FULL_LOOP_NIP, 1,0, ain,0};
cumo_na_ndloop_with_index(&ndf, 1, self);
return self;
}
Version data entries
7 entries across 7 versions & 1 rubygems