/* * R : A Computer Langage for Statistical Data Analysis * Copyright (C) 1995, 1996 Robert Gentleman and Ross Ihaka * (C) 2004 The R Foundation * Copyright (C) 1998-2012 The R Core Team. * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) anylater version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, a copy is available at * http://www.r-project.org/Licenses/ */ #ifdef HAVE_CONFIG_H #include #endif #include "Defn.h" #include /* S4 bit */ /* duplicate - object duplication */ /* Because we try to maintain the illusion of call by * value, we often need to duplicate entire data * objects. There are a couple of points to note. * First, duplication of list-like objects is done * iteratively to prevent growth of the pointer * protection stack, and second, the duplication of * promises requires that the promises be forced and * the value duplicated. */ /* This macro pulls out the common code in copying an atomic vector. The special handling of the scalar case (__n__ == 1) seems to make a small but measurable difference, at least for some cases and when (as in R 2.15.x) a for() loop was used. */ #ifdef __APPLE__ /* it seems some OS X builds do not copy >= 2^32 bytes fully */ #define DUPLICATE_ATOMIC_VECTOR(type, fun, to, from, deep) do { \ R_xlen_t __n__ = XLENGTH(from); \ PROTECT(from); \ PROTECT(to = allocVector(TYPEOF(from), __n__)); \ if (__n__ == 1) fun(to)[0] = fun(from)[0]; \ else { \ R_xlen_t __this; \ type *__to = fun(to), *__from = fun(from); \ do { \ __this = (__n__ < 1000000) ? __n__ : 1000000; \ memcpy(__to, __from, __this * sizeof(type)); \ __n__ -= __this; __to += __this; __from += __this; \ } while(__n__ > 0); \ } \ DUPLICATE_ATTRIB(to, from, deep); \ SET_TRUELENGTH(to, XTRUELENGTH(from)); \ UNPROTECT(2); \ } while (0) #else #define DUPLICATE_ATOMIC_VECTOR(type, fun, to, from, deep) do { \ R_xlen_t __n__ = XLENGTH(from); \ PROTECT(from); \ PROTECT(to = allocVector(TYPEOF(from), __n__)); \ if (__n__ == 1) fun(to)[0] = fun(from)[0]; \ else memcpy(fun(to), fun(from), __n__ * sizeof(type)); \ DUPLICATE_ATTRIB(to, from, deep); \ SET_TRUELENGTH(to, XTRUELENGTH(from)); \ UNPROTECT(2); \ } while (0) #endif /* The following macros avoid the cost of going through calls to the assignment functions (and duplicate in the case of ATTRIB) when the ATTRIB or TAG value to be stored is R_NilValue, the value the field will have been set to by the allocation function */ #define DUPLICATE_ATTRIB(to, from, deep) do { \ SEXP __a__ = ATTRIB(from); \ if (__a__ != R_NilValue) { \ SET_ATTRIB(to, duplicate1(__a__, deep)); \ SET_OBJECT(to, OBJECT(from)); \ IS_S4_OBJECT(from) ? SET_S4_OBJECT(to) : UNSET_S4_OBJECT(to); \ } \ } while (0) #define COPY_TAG(to, from) do { \ SEXP __tag__ = TAG(from); \ if (__tag__ != R_NilValue) SET_TAG(to, __tag__); \ } while (0) /* For memory profiling. */ /* We want a count of calls to duplicate from outside which requires a wrapper function. The original duplicate() function is now duplicate1(). I don't see how to make the wrapper go away when R_PROFILING is not defined, because we still need to be able to optionally rename duplicate() as Rf_duplicate(). */ static SEXP duplicate1(SEXP, Rboolean deep); #ifdef R_PROFILING static unsigned long duplicate_counter = (unsigned long)-1; unsigned long attribute_hidden get_duplicate_counter(void) { return duplicate_counter; } void attribute_hidden reset_duplicate_counter(void) { duplicate_counter = 0; return; } #endif SEXP duplicate(SEXP s){ SEXP t; #ifdef R_PROFILING duplicate_counter++; #endif t = duplicate1(s, TRUE); #ifdef R_MEMORY_PROFILING if (RTRACE(s) && !(TYPEOF(s) == CLOSXP || TYPEOF(s) == BUILTINSXP || TYPEOF(s) == SPECIALSXP || TYPEOF(s) == PROMSXP || TYPEOF(s) == ENVSXP)){ memtrace_report(s,t); SET_RTRACE(t,1); } #endif return t; } SEXP shallow_duplicate(SEXP s) { SEXP t; #ifdef R_PROFILING duplicate_counter++; #endif t = duplicate1(s, FALSE); #ifdef R_MEMORY_PROFILING if (RTRACE(s) && !(TYPEOF(s) == CLOSXP || TYPEOF(s) == BUILTINSXP || TYPEOF(s) == SPECIALSXP || TYPEOF(s) == PROMSXP || TYPEOF(s) == ENVSXP)){ memtrace_report(s,t); SET_RTRACE(t,1); } #endif return t; } SEXP lazy_duplicate(SEXP s) { switch (TYPEOF(s)) { case NILSXP: case SYMSXP: case ENVSXP: case SPECIALSXP: case BUILTINSXP: case EXTPTRSXP: case BCODESXP: case WEAKREFSXP: case CHARSXP: case PROMSXP: break; case CLOSXP: case LISTSXP: case LANGSXP: case DOTSXP: case EXPRSXP: case VECSXP: case LGLSXP: case INTSXP: case REALSXP: case CPLXSXP: case RAWSXP: case STRSXP: case S4SXP: SET_NAMED(s, 2); break; default: UNIMPLEMENTED_TYPE("lazy_duplicate", s); } return s; } static SEXP duplicate_child(SEXP s, Rboolean deep) { if (deep) return duplicate1(s, TRUE); else return lazy_duplicate(s); } /*****************/ /* Detect cycles that would be created by assigning 'child' as a component of 's' in a complex assignment without duplicating 'child'. This is called quite often but almost always returns FALSE. Could be made more efficient, at least with partial inlining, but probably not worth while until it starts showing up significantly in profiling. Based on code from Michael Lawrence. */ Rboolean R_cycle_detected(SEXP s, SEXP child) { if (s == child) { switch (TYPEOF(child)) { case NILSXP: case SYMSXP: case ENVSXP: case SPECIALSXP: case BUILTINSXP: case EXTPTRSXP: case BCODESXP: case WEAKREFSXP: /* it's a cycle but one that is OK */ return FALSE; default: return TRUE; } } if (ATTRIB(child) != R_NilValue) { if (R_cycle_detected(s, ATTRIB(child))) return TRUE; } if (isPairList(child)) { SEXP el = child; while(el != R_NilValue) { if (s == el || R_cycle_detected(s, CAR(el))) return TRUE; if (ATTRIB(el) != R_NilValue && R_cycle_detected(s, ATTRIB(el))) return TRUE; el = CDR(el); } } else if (isVectorList(child)) { for(int i = 0 ; i < length(child); i++) if (R_cycle_detected(s, VECTOR_ELT(child, i))) return TRUE; } return FALSE; } static R_INLINE SEXP duplicate_list(SEXP s, Rboolean deep) { SEXP sp, vp, val; PROTECT(s); val = R_NilValue; for (sp = s; sp != R_NilValue; sp = CDR(sp)) val = CONS(R_NilValue, val); PROTECT(val); for (sp = s, vp = val; sp != R_NilValue; sp = CDR(sp), vp = CDR(vp)) { SETCAR(vp, duplicate_child(CAR(sp), deep)); COPY_TAG(vp, sp); DUPLICATE_ATTRIB(vp, sp, deep); } UNPROTECT(2); return val; } static SEXP duplicate1(SEXP s, Rboolean deep) { SEXP t; R_xlen_t i, n; switch (TYPEOF(s)) { case NILSXP: case SYMSXP: case ENVSXP: case SPECIALSXP: case BUILTINSXP: case EXTPTRSXP: case BCODESXP: case WEAKREFSXP: return s; case CLOSXP: PROTECT(s); if (R_jit_enabled > 1 && TYPEOF(BODY(s)) != BCODESXP) { int old_enabled = R_jit_enabled; SEXP new_s; R_jit_enabled = 0; new_s = R_cmpfun(s); SET_BODY(s, BODY(new_s)); R_jit_enabled = old_enabled; } PROTECT(t = allocSExp(CLOSXP)); SET_FORMALS(t, FORMALS(s)); SET_BODY(t, BODY(s)); SET_CLOENV(t, CLOENV(s)); DUPLICATE_ATTRIB(t, s, deep); UNPROTECT(2); break; case LISTSXP: PROTECT(s); t = duplicate_list(s, deep); UNPROTECT(1); break; case LANGSXP: PROTECT(s); PROTECT(t = duplicate_list(s, deep)); SET_TYPEOF(t, LANGSXP); DUPLICATE_ATTRIB(t, s, deep); UNPROTECT(2); break; case DOTSXP: PROTECT(s); PROTECT(t = duplicate_list(s, deep)); SET_TYPEOF(t, DOTSXP); DUPLICATE_ATTRIB(t, s, deep); UNPROTECT(2); break; case CHARSXP: return s; break; case EXPRSXP: case VECSXP: n = XLENGTH(s); PROTECT(s); PROTECT(t = allocVector(TYPEOF(s), n)); for(i = 0 ; i < n ; i++) SET_VECTOR_ELT(t, i, duplicate_child(VECTOR_ELT(s, i), deep)); DUPLICATE_ATTRIB(t, s, deep); SET_TRUELENGTH(t, TRUELENGTH(s)); UNPROTECT(2); break; case LGLSXP: DUPLICATE_ATOMIC_VECTOR(int, LOGICAL, t, s, deep); break; case INTSXP: DUPLICATE_ATOMIC_VECTOR(int, INTEGER, t, s, deep); break; case REALSXP: DUPLICATE_ATOMIC_VECTOR(double, REAL, t, s, deep); break; case CPLXSXP: DUPLICATE_ATOMIC_VECTOR(Rcomplex, COMPLEX, t, s, deep); break; case RAWSXP: DUPLICATE_ATOMIC_VECTOR(Rbyte, RAW, t, s, deep); break; case STRSXP: /* direct copying and bypassing the write barrier is OK since t was just allocated and so it cannot be older than any of the elements in s. LT */ DUPLICATE_ATOMIC_VECTOR(SEXP, STRING_PTR, t, s, deep); break; case PROMSXP: return s; break; case S4SXP: PROTECT(s); PROTECT(t = allocS4Object()); DUPLICATE_ATTRIB(t, s, deep); UNPROTECT(2); break; default: UNIMPLEMENTED_TYPE("duplicate", s); t = s;/* for -Wall */ } if(TYPEOF(t) == TYPEOF(s) ) { /* surely it only makes sense in this case*/ SET_OBJECT(t, OBJECT(s)); (IS_S4_OBJECT(s) ? SET_S4_OBJECT(t) : UNSET_S4_OBJECT(t)); } return t; } void copyVector(SEXP s, SEXP t) { R_xlen_t i, ns, nt; SEXPTYPE sT = TYPEOF(s), tT = TYPEOF(t); if (sT != tT) error("vector types do not match in copyVector"); nt = XLENGTH(t); ns = XLENGTH(s); switch (sT) { case STRSXP: for (i = 0; i < ns; i++) SET_STRING_ELT(s, i, STRING_ELT(t, i % nt)); break; case EXPRSXP: for (i = 0; i < ns; i++) SET_VECTOR_ELT(s, i, VECTOR_ELT(t, i % nt)); break; case LGLSXP: for (i = 0; i < ns; i++) LOGICAL(s)[i] = LOGICAL(t)[i % nt]; break; case INTSXP: for (i = 0; i < ns; i++) INTEGER(s)[i] = INTEGER(t)[i % nt]; break; case REALSXP: for (i = 0; i < ns; i++) REAL(s)[i] = REAL(t)[i % nt]; break; case CPLXSXP: for (i = 0; i < ns; i++) COMPLEX(s)[i] = COMPLEX(t)[i % nt]; break; case VECSXP: for (i = 0; i < ns; i++) SET_VECTOR_ELT(s, i, VECTOR_ELT(t, i % nt)); break; case RAWSXP: for (i = 0; i < ns; i++) RAW(s)[i] = RAW(t)[i % nt]; break; default: UNIMPLEMENTED_TYPE("copyVector", s); } } void copyListMatrix(SEXP s, SEXP t, Rboolean byrow) { SEXP pt, tmp; int i, j, nr, nc; R_xlen_t ns; nr = nrows(s); nc = ncols(s); ns = ((R_xlen_t) nr) * nc; pt = t; if(byrow) { R_xlen_t NR = nr; PROTECT(tmp = allocVector(STRSXP, ns)); for (i = 0; i < nr; i++) for (j = 0; j < nc; j++) { SET_STRING_ELT(tmp, i + j * NR, duplicate(CAR(pt))); pt = CDR(pt); if(pt == R_NilValue) pt = t; } for (i = 0; i < ns; i++) { SETCAR(s, STRING_ELT(tmp, i++)); s = CDR(s); } UNPROTECT(1); } else { for (i = 0; i < ns; i++) { SETCAR(s, duplicate(CAR(pt))); s = CDR(s); pt = CDR(pt); if(pt == R_NilValue) pt = t; } } } void copyMatrix(SEXP s, SEXP t, Rboolean byrow) { int i, j, nr, nc; R_xlen_t k, nt; nr = nrows(s); nc = ncols(s); nt = XLENGTH(t); k = 0; if (byrow) { R_xlen_t NR = nr; switch (TYPEOF(s)) { case STRSXP: for (i = 0; i < nr; i++) for (j = 0; j < nc; j++) SET_STRING_ELT(s, i + j * NR, STRING_ELT(t, k++ % nt)); break; case LGLSXP: for (i = 0; i < nr; i++) for (j = 0; j < nc; j++) LOGICAL(s)[i + j * NR] = LOGICAL(t)[k++ % nt]; break; case INTSXP: for (i = 0; i < nr; i++) for (j = 0; j < nc; j++) INTEGER(s)[i + j * NR] = INTEGER(t)[k++ % nt]; break; case REALSXP: for (i = 0; i < nr; i++) for (j = 0; j < nc; j++) REAL(s)[i + j * NR] = REAL(t)[k++ % nt]; break; case CPLXSXP: for (i = 0; i < nr; i++) for (j = 0; j < nc; j++) COMPLEX(s)[i + j * NR] = COMPLEX(t)[k++ % nt]; break; case VECSXP: for (i = 0; i < nr; i++) for (j = 0; j < nc; j++) SET_VECTOR_ELT(s, i + j * NR, VECTOR_ELT(t, k++ % nt)); break; case RAWSXP: for (i = 0; i < nr; i++) for (j = 0; j < nc; j++) RAW(s)[i + j * NR] = RAW(t)[k++ % nt]; break; default: UNIMPLEMENTED_TYPE("copyMatrix", s); } } else copyVector(s, t); }