Rev 11368 | Blame | Compare with Previous | Last modification | View Log | Download | RSS feed
/** R : A Computer Language for Statistical Data Analysis* Copyright (C) 1995, 1996 Robert Gentleman and Ross Ihaka* Copyright (C) 1998--2000 The R Development 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) any later 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, write to the Free Software* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA*//** This code implements a non-moving generational collector* with two or three generations.** Memory allocated by R_alloc is maintained in a stack. Code* that R_allocs memory must use vmaxget and vmaxset to obtain* and reset the stack pointer.*/#define USE_RINTERNALS#ifdef HAVE_CONFIG_H#include <config.h>#endif#include <Defn.h>#include <Graphics.h> /* display lists */#include <Devices.h> /* GetDevice */static int gc_reporting = 0;static int gc_count = 0;#define GC_TORTURE#ifdef GC_TORTURE# define FORCE_GC !gc_inhibit_torture#else# define FORCE_GC 0#endifextern SEXP framenames;#define GC_PROT(X) {int __t = gc_inhibit_torture; \gc_inhibit_torture = 1 ; X ; gc_inhibit_torture = __t;}static void R_gc_internal(int size_needed);static void mem_err_heap(long size);static SEXPREC UnmarkedNodeTemplate;#define NODE_IS_MARKED(s) (MARK(s)==1)#define MARK_NODE(s) (MARK(s)=1)#define UNMARK_NODE(s) (MARK(s)=0)/* Tuning Constants. Most of these could be made settable from R,within some reasonable constraints at least. Since there are quitea lot of constants it would probably make sense to put togetherseveral "packages" representing different space/speed tradeoffs(e.g. very aggressive freeing and small increments to conservememory; much less frequent releasing and larger increments toincrease speed). *//* There are three levels of collections. Level 0 collects only theyoungest generation, level 1 collects the two youngest generations,and level 2 collects all generations. Higher level collectionsoccur at least after specified numbers of lower level ones. AfterLEVEL_0_FREQ level zero collections a level 1 collection is done;after every LEVEL_1_FREQ level 1 collections a level 2 collectionoccurs. Thus, roughly, every LEVEL_0_FREQ-th collection is a level1 collection and every (LEVEL_0_FREQ * LEVEL_1_FREQ)-th collectionis a level 2 collection. */#define LEVEL_0_FREQ 20#define LEVEL_1_FREQ 5static int collect_counts_max[] = { LEVEL_0_FREQ, LEVEL_1_FREQ };/* When a level N collection fails to produce at least MinFreeFrac *R_NSize free nodes and MinFreeFrac * R_VSize free vector space, thenext collection will be a level N + 1 collection.This constant is also used in heap size adjustment as a minimalfraction of the minimal heap size levels that should be availablefor allocation. */static double R_MinFreeFrac = 0.2;/* When pages are released, a number of free nodes equal toR_MaxKeepFrac times the number of allocated nodes for each class isretained. Pages not needed to meet this requirement are released.An attempt to release pages is made every R_PageReleaseFreq level 1or level 2 collections. */static double R_MaxKeepFrac = 0.5;static int R_PageReleaseFreq = 1;/* The heap size constants R_NSize and R_VSize are used for triggeringcollections. The initial values set by defaults or command linearguments are used as minimal values. After full collections theselevels are adjusted up or down, though not below the minimal valuesor above the maximum values, towards maintain heap occupancy withina specified range. When the number of nodes in use reachesR_NGrowFrac * R_NSize, the value of R_NSize is incremented byR_NGrowIncrMin + R_NGrowIncrFrac * R_NSize. When the number ofnodes in use falls below R_NShrinkFrac, R_NSize is decremented byR_NShrinkIncrMin * R_NShrinkFrac * R_NSize. Analogous adjustmentsare made to R_VSize.This mechanism for adjusting the heap size constants is veryprimitive but hopefully adequate for now. Some modeling andexperimentation would be useful. We want the heap sizes to get setat levels adequate for the current computations. The presentmechanism uses only the size of the current live heap to provideinformation about the current needs; since the current live heapsize can be very volatile, the adjustment mechanism only makesgradual adjustments. A more sophisticated strategy would use moreof the live heap history. */static double R_NGrowFrac = 0.70;static double R_NShrinkFrac = 0.30;static double R_VGrowFrac = 0.70;static double R_VShrinkFrac = 0.30;#ifdef SMALL_MEMORY/* On machines with only 32M of memory (or on a classic Mac OS port)it might be a good idea to use settings like these that are moreaggressive at keeping memory usage down. */static double R_NGrowIncrFrac = 0.0, R_NShrinkIncrFrac = 0.2;static int R_NGrowIncrMin = 50000, R_NShrinkIncrMin = 0;static double R_VGrowIncrFrac = 0.0, R_VShrinkIncrFrac = 0.2;static int R_VGrowIncrMin = 100000, R_VShrinkIncrMin = 0;#elsestatic double R_NGrowIncrFrac = 0.05, R_NShrinkIncrFrac = 0.2;static int R_NGrowIncrMin = 40000, R_NShrinkIncrMin = 0;static double R_VGrowIncrFrac = 0.05, R_VShrinkIncrFrac = 0.2;static int R_VGrowIncrMin = 80000, R_VShrinkIncrMin = 0;#endif/* Maximal Heap Limits. These variables contain upper limits on theheap sizes. They could be made adjustable from the R level,perhaps by a handler for a recoverable error. For now both are setto INT_MAX to insure that the heap counters do not wrap on systemswith that much memory.Access to these values is provided with reader and writerfunctions; the writer function insures that the maximal values arenever set below the current ones. */static int R_MaxVSize = INT_MAX;static int R_MaxNSize = INT_MAX;static int vsfac = 1; /* current units for vsize: changes at initialization */int R_GetMaxVSize(void){if (R_MaxVSize == INT_MAX) return INT_MAX;return R_MaxVSize*vsfac;}void R_SetMaxVSize(int size){if (size == INT_MAX) return;if (size / vsfac >= R_VSize) R_MaxVSize = (size+1)/sizeof(VECREC);}int R_GetMaxNSize(void){return R_MaxNSize;}void R_SetMaxNSize(int size){if (size >= R_NSize) R_MaxNSize = size;}/* Miscellaneous Globals. */static SEXP R_VStack = NULL; /* R_alloc stack pointer */static int R_LargeVallocSize = 0;static int R_SmallVallocSize = 0;static int orig_R_NSize;static int orig_R_VSize;/* Node Classes. Non-vector nodes are of class zero. Small vectornodes are in classes 1, ..., NUM_SMALL_NODE_CLASSES, and largevector nodes are in class LARGE_NODE_CLASS. For vector nodes thenode header is followed in memory by the vector data, offset fromthe header by SEXPREC_ALIGN. */#define NUM_NODE_CLASSES 8/* sxpinfo allocates 3 bits for the node class, so at most 8 are allowed */#if NUM_NODE_CLASSES > 8# error NUM_NODE_CLASSES must be at most 8#endif#define LARGE_NODE_CLASS (NUM_NODE_CLASSES - 1)#define NUM_SMALL_NODE_CLASSES (NUM_NODE_CLASSES - 1)/* the number of VECREC's in nodes of the small node classes */static int NodeClassSize[NUM_SMALL_NODE_CLASSES] = { 0, 1, 2, 4, 6, 8, 16 };#define NODE_CLASS(s) ((s)->sxpinfo.gccls)#define SET_NODE_CLASS(s,v) (((s)->sxpinfo.gccls) = (v))/* Node Generations. */#define NUM_OLD_GENERATIONS 2/* sxpinfo allocates one bit for the old generation count, so only 1or 2 is allowed */#if NUM_OLD_GENERATIONS > 2 || NUM_OLD_GENERATIONS < 1# error number of old generations must be 1 or 2#endif#define NODE_GENERATION(s) ((s)->sxpinfo.gcgen)#define SET_NODE_GENERATION(s,g) ((s)->sxpinfo.gcgen=(g))#define NODE_GEN_IS_YOUNGER(s,g) \(! NODE_IS_MARKED(s) || NODE_GENERATION(s) < (g))#define NODE_IS_OLDER(x, y) \(NODE_IS_MARKED(x) && \(! NODE_IS_MARKED(y) || NODE_GENERATION(x) > NODE_GENERATION(y)))static int num_old_gens_to_collect = 0;static int gen_gc_counts[NUM_OLD_GENERATIONS + 1];static int collect_counts[NUM_OLD_GENERATIONS];/* Node Pages. Non-vector nodes and small vector nodes are allocatedfrom fixed size pages. The pages for each node class are kept in alinked list. */typedef union PAGE_HEADER {union PAGE_HEADER *next;double align;} PAGE_HEADER;#define BASE_PAGE_SIZE 2000#define R_PAGE_SIZE \(((BASE_PAGE_SIZE - sizeof(PAGE_HEADER)) / sizeof(SEXPREC)) \* sizeof(SEXPREC) \+ sizeof(PAGE_HEADER))#define NODE_SIZE(c) \((c) == 0 ? sizeof(SEXPREC) : \sizeof(SEXPREC_ALIGN) + NodeClassSize[c] * sizeof(VECREC))#define PAGE_DATA(p) ((void *) (p + 1))#define VHEAP_FREE() (R_VSize - R_LargeVallocSize - R_SmallVallocSize)/* The Heap Structure. Nodes for each class/generation combinationare arranged in circular doubly-linked lists. The double linkingallows nodes to be removed in constant time; this is used by thecollector to move reachable nodes out of free space and into theappropriate generation. The circularity eliminates the need forend checks. In addition, each link is anchored at an artificialnode, the Peg SEXPREC's in the structure below, which simplifiespointer maintenance. The circular doubly-linked arrangement istaken from Baker's in-place incremental collector design; seeftp://ftp.netcom.com/pub/hb/hbaker/NoMotionGC.html or the Jones andLins GC book. The linked lists are implemented by adding twopointer fields to the SEXPREC structure, which increases its sizefrom 5 to 7 words. Other approaches are possible but don't seemworth pursuing for R.There are two options for dealing with old-to-new pointers. Thefirst option is to make sure they never occur by transferring allreferenced younger objects to the generation of the referrer when areference to a newer object is assigned to an older one. This isenabled by defining EXPEL_OLD_TO_NEW. The second alternative is tokeep track of all nodes that may contain references to newer nodesand to "age" the nodes they refer to at the beginning of eachcollection. This is the default. The first option is simpler insome ways, but will create more floating garbage and add a bit tothe execution time, though the difference is probably marginal onboth counts.*//*#define EXPEL_OLD_TO_NEW*/static struct {SEXP Old[NUM_OLD_GENERATIONS], New, Free;SEXPREC OldPeg[NUM_OLD_GENERATIONS], NewPeg;#ifndef EXPEL_OLD_TO_NEWSEXP OldToNew[NUM_OLD_GENERATIONS];SEXPREC OldToNewPeg[NUM_OLD_GENERATIONS];#endifint OldCount[NUM_OLD_GENERATIONS], AllocCount, PageCount;PAGE_HEADER *pages;} R_GenHeap[NUM_NODE_CLASSES];static int R_NodesInUse = 0;#define NEXT_NODE(s) (s)->gengc_next_node#define PREV_NODE(s) (s)->gengc_prev_node#define SET_NEXT_NODE(s,t) (NEXT_NODE(s) = (t))#define SET_PREV_NODE(s,t) (PREV_NODE(s) = (t))/* Node List Manipulation *//* unsnap node s from its list */#define UNSNAP_NODE(s) do { \SEXP un__n__ = (s); \SEXP next = NEXT_NODE(un__n__); \SEXP prev = PREV_NODE(un__n__); \SET_NEXT_NODE(prev, next); \SET_PREV_NODE(next, prev); \} while(0)/* snap in node s before node t */#define SNAP_NODE(s,t) do { \SEXP sn__n__ = (s); \SEXP next = (t); \SEXP prev = PREV_NODE(next); \SET_NEXT_NODE(sn__n__, next); \SET_PREV_NODE(next, sn__n__); \SET_NEXT_NODE(prev, sn__n__); \SET_PREV_NODE(sn__n__, prev); \} while (0)/* move all nodes on from_peg to to_peg */#define BULK_MOVE(from_peg,to_peg) do { \SEXP __from__ = (from_peg); \SEXP __to__ = (to_peg); \SEXP first_old = NEXT_NODE(__from__); \SEXP last_old = PREV_NODE(__from__); \SEXP first_new = NEXT_NODE(__to__); \SET_PREV_NODE(first_old, __to__); \SET_NEXT_NODE(__to__, first_old); \SET_PREV_NODE(first_new, last_old); \SET_NEXT_NODE(last_old, first_new); \SET_NEXT_NODE(__from__, __from__); \SET_PREV_NODE(__from__, __from__); \} while (0);/* Processing Node Children *//* This macro calls dc__action__ for each child of __n__, passingdc__extra__ as a second argument for each call. */#define DO_CHILDREN(__n__,dc__action__,dc__extra__) do { \if (ATTRIB(__n__) != R_NilValue) \dc__action__(ATTRIB(__n__), dc__extra__); \switch (TYPEOF(__n__)) { \case NILSXP: \case BUILTINSXP: \case SPECIALSXP: \case CHARSXP: \case LGLSXP: \case INTSXP: \case REALSXP: \case CPLXSXP: \break; \case STRSXP: \case EXPRSXP: \case VECSXP: \{ \int i; \for (i = 0; i < LENGTH(__n__); i++) \dc__action__(STRING_ELT(__n__, i), dc__extra__); \} \break; \case ENVSXP: \dc__action__(FRAME(__n__), dc__extra__); \dc__action__(ENCLOS(__n__), dc__extra__); \dc__action__(HASHTAB(__n__), dc__extra__); \break; \case CLOSXP: \case PROMSXP: \case LISTSXP: \case LANGSXP: \case DOTSXP: \case SYMSXP: \dc__action__(TAG(__n__), dc__extra__); \dc__action__(CAR(__n__), dc__extra__); \dc__action__(CDR(__n__), dc__extra__); \break; \case EXTPTRSXP: \dc__action__(EXTPTR_PROT(__n__), dc__extra__); \dc__action__(EXTPTR_TAG(__n__), dc__extra__); \break; \default: \abort(); \} \} while(0)/* Forwarding Nodes. These macros mark nodes or chindren of nodes andplace them on the forwarding list. The forwarding list is assumedto be in a local variable of the caller named namedforwarded_nodes. */#define FORWARD_NODE(s) do { \SEXP fn__n__ = (s); \if (fn__n__ && ! NODE_IS_MARKED(fn__n__)) { \MARK_NODE(fn__n__); \UNSNAP_NODE(fn__n__); \SET_NEXT_NODE(fn__n__, forwarded_nodes); \forwarded_nodes = fn__n__; \} \} while (0)#define FC_FORWARD_NODE(__n__,__dummy__) FORWARD_NODE(__n__)#define FORWARD_CHILDREN(__n__) DO_CHILDREN(__n__,FC_FORWARD_NODE, 0)/* Node Allocation. */#define CLASS_GET_FREE_NODE(c,s) do { \SEXP __n__ = R_GenHeap[c].Free; \if (__n__ == R_GenHeap[c].New) { \GetNewPage(c); \__n__ = R_GenHeap[c].Free; \} \R_GenHeap[c].Free = NEXT_NODE(__n__); \R_NodesInUse++; \(s) = __n__; \} while (0)#define NO_FREE_NODES() (R_NodesInUse >= R_NSize)#define GET_FREE_NODE(s) CLASS_GET_FREE_NODE(0,s)/* Debugging Routines. */#ifdef DEBUG_GCstatic void CheckNodeGeneration(SEXP x, int g){if (NODE_GENERATION(x) < g) {REprintf("untraced old-to-new reference\n");}}static void DEBUG_CHECK_NODE_COUNTS(char *where){int i, OldCount, NewCount, OldToNewCount, gen;SEXP s;REprintf("Node counts %s:\n", where);for (i = 0; i < NUM_NODE_CLASSES; i++) {for (s = NEXT_NODE(R_GenHeap[i].New), NewCount = 0;s != R_GenHeap[i].New;s = NEXT_NODE(s)) {NewCount++;if (i != NODE_CLASS(s))REprintf("Inconsistent class assignment for node!\n");}for (gen = 0, OldCount = 0, OldToNewCount = 0;gen < NUM_OLD_GENERATIONS;gen++) {for (s = NEXT_NODE(R_GenHeap[i].Old[gen]);s != R_GenHeap[i].Old[gen];s = NEXT_NODE(s)) {OldCount++;if (i != NODE_CLASS(s))REprintf("Inconsistent class assignment for node!\n");if (gen != NODE_GENERATION(s))REprintf("Inconsistent node generation\n");DO_CHILDREN(s, CheckNodeGeneration, gen);}for (s = NEXT_NODE(R_GenHeap[i].OldToNew[gen]);s != R_GenHeap[i].OldToNew[gen];s = NEXT_NODE(s)) {OldToNewCount++;if (i != NODE_CLASS(s))REprintf("Inconsistent class assignment for node!\n");if (gen != NODE_GENERATION(s))REprintf("Inconsistent node generation\n");}}REprintf("Class: %d, New = %d, Old = %d, OldToNew = %d, Total = %d\n",i,NewCount, OldCount, OldToNewCount,NewCount + OldCount + OldToNewCount);}}static void DEBUG_GC_SUMMARY(int full_gc){int i, gen, OldCount;REprintf("\n%s, VSize = %d", full_gc ? "Full" : "Minor",R_SmallVallocSize + R_LargeVallocSize);for (i = 1; i < NUM_NODE_CLASSES; i++) {for (gen = 0, OldCount = 0; gen < NUM_OLD_GENERATIONS; gen++)OldCount += R_GenHeap[i].OldCount[gen];REprintf(", class %d: %d", i, OldCount);}}#else#define DEBUG_CHECK_NODE_COUNTS(s)#define DEBUG_GC_SUMMARY(x)#endif /* DEBUG_GC */#ifdef DEBUG_ADJUST_HEAPstatic void DEBUG_ADJUST_HEAP_PRINT(double node_occup, double vect_occup){int i;int alloc;REprintf("Node occupancy: %.0f%%\nVector occupancy: %.0f%%\n",100.0 * node_occup, 100.0 * vect_occup);alloc = R_LargeVallocSize +sizeof(SEXPREC_ALIGN) * R_GenHeap[LARGE_NODE_CLASS].AllocCount;for (i = 0; i < NUM_SMALL_NODE_CLASSES; i++)alloc += R_PAGE_SIZE * R_GenHeap[i].PageCount;REprintf("Total allocation: %d\n", alloc);REprintf("Ncells %d\nVcells %d\n", R_NSize, R_VSize);}#else#define DEBUG_ADJUST_HEAP_PRINT(node_occup, vect_occup)#endif /* DEBUG_ADJUST_HEAP */#ifdef DEBUG_RELEASE_MEMstatic void DEBUG_RELEASE_PRINT(int rel_pages, int maxrel_pages, int i){if (maxrel_pages > 0) {int gen, n;REprintf("Class: %d, pages = %d, maxrel = %d, released = %d\n", i,R_GenHeap[i].PageCount, maxrel_pages, rel_pages);for (gen = 0, n = 0; gen < NUM_OLD_GENERATIONS; gen++)n += R_GenHeap[i].OldCount[gen];REprintf("Allocated = %d, in use = %d\n", R_GenHeap[i].AllocCount, n);}}#else#define DEBUG_RELEASE_PRINT(rel_pages, maxrel_pages, i)#endif /* DEBUG_RELEASE_MEM *//* Page Allocation and Release. */static void GetNewPage(int node_class){SEXP s, base;char *data;PAGE_HEADER *page;int node_size, page_count, i;node_size = NODE_SIZE(node_class);page_count = (R_PAGE_SIZE - sizeof(PAGE_HEADER)) / node_size;page = malloc(R_PAGE_SIZE);if (page == NULL)mem_err_heap(NodeClassSize[node_class]);page->next = R_GenHeap[node_class].pages;R_GenHeap[node_class].pages = page;R_GenHeap[node_class].PageCount++;data = PAGE_DATA(page);base = R_GenHeap[node_class].New;for (i = 0; i < page_count; i++, data += node_size) {s = (SEXP) data;R_GenHeap[node_class].AllocCount++;SNAP_NODE(s, base);s->sxpinfo = UnmarkedNodeTemplate.sxpinfo;SET_NODE_CLASS(s, node_class);base = s;R_GenHeap[node_class].Free = s;}}static void ReleasePage(PAGE_HEADER *page, int node_class){SEXP s;char *data;int node_size, page_count, i;node_size = NODE_SIZE(node_class);page_count = (R_PAGE_SIZE - sizeof(PAGE_HEADER)) / node_size;data = PAGE_DATA(page);for (i = 0; i < page_count; i++, data += node_size) {s = (SEXP) data;UNSNAP_NODE(s);R_GenHeap[node_class].AllocCount--;}R_GenHeap[node_class].PageCount--;free(page);}static void TryToReleasePages(void){SEXP s;int i;static int release_count = 0;if (release_count == 0) {release_count = R_PageReleaseFreq;for (i = 0; i < NUM_SMALL_NODE_CLASSES; i++) {int pages_free = 0;PAGE_HEADER *page, *last, *next;int node_size = NODE_SIZE(i);int page_count = (R_PAGE_SIZE - sizeof(PAGE_HEADER)) / node_size;int maxrel, maxrel_pages, rel_pages, gen;maxrel = R_GenHeap[i].AllocCount;for (gen = 0; gen < NUM_OLD_GENERATIONS; gen++)maxrel -= (1.0 + R_MaxKeepFrac) * R_GenHeap[i].OldCount[gen];maxrel_pages = maxrel > 0 ? maxrel / page_count : 0;/* all nodes in New space should be both free and unmarked */for (page = R_GenHeap[i].pages, rel_pages = 0, last = NULL;rel_pages < maxrel_pages && page != NULL;) {int j, in_use;char *data = PAGE_DATA(page);next = page->next;for (in_use = 0, j = 0; j < page_count;j++, data += node_size) {s = (SEXP) data;if (NODE_IS_MARKED(s)) {in_use = 1;break;}}if (! in_use) {ReleasePage(page, i);if (last == NULL)R_GenHeap[i].pages = next;elselast->next = next;pages_free++;rel_pages++;}else last = page;page = next;}DEBUG_RELEASE_PRINT(rel_pages, maxrel_pages, i);R_GenHeap[i].Free = NEXT_NODE(R_GenHeap[i].New);}}else release_count--;}static void ReleaseLargeFreeVectors(void){SEXP s = NEXT_NODE(R_GenHeap[LARGE_NODE_CLASS].New);while (s != R_GenHeap[LARGE_NODE_CLASS].New) {SEXP next = NEXT_NODE(s);if (CHAR(s) != NULL) {int size;switch (TYPEOF(s)) { /* get size in bytes */case CHARSXP:size = LENGTH(s) + 1;break;case LGLSXP:case INTSXP:size = LENGTH(s) * sizeof(int);break;case REALSXP:size = LENGTH(s) * sizeof(double);break;case CPLXSXP:size = LENGTH(s) * sizeof(Rcomplex);break;case STRSXP:case EXPRSXP:case VECSXP:size = LENGTH(s) * sizeof(SEXP);break;default:abort();}size = BYTE2VEC(size);UNSNAP_NODE(s);R_LargeVallocSize -= size;R_GenHeap[LARGE_NODE_CLASS].AllocCount--;free(s);}s = next;}}/* Heap Size Adjustment. */static void AdjustHeapSize(int size_needed){int R_MinNFree = orig_R_NSize * R_MinFreeFrac;int R_MinVFree = orig_R_VSize * R_MinFreeFrac;int NNeeded = R_NodesInUse + R_MinNFree;int VNeeded = R_SmallVallocSize + R_LargeVallocSize+ size_needed + R_MinVFree;double node_occup = ((double) NNeeded) / R_NSize;double vect_occup = ((double) VNeeded) / R_VSize;if (node_occup > R_NGrowFrac) {int change = R_NGrowIncrMin + R_NGrowIncrFrac * R_NSize;if (R_MaxNSize - R_NSize >= change)R_NSize += change;}else if (node_occup < R_NShrinkFrac) {R_NSize -= R_NShrinkIncrMin + R_NShrinkIncrFrac * R_NSize;if (R_NSize < NNeeded)R_NSize = (NNeeded < R_MaxNSize) ? NNeeded: R_MaxNSize;if (R_NSize < orig_R_NSize)R_NSize = orig_R_NSize;}if (vect_occup > 1.0 && VNeeded < R_MaxVSize)R_VSize = VNeeded;if (vect_occup > R_VGrowFrac) {int change = R_VGrowIncrMin + R_VGrowIncrFrac * R_NSize;if (R_MaxVSize - R_VSize >= change)R_VSize += change;}else if (vect_occup < R_VShrinkFrac) {R_VSize -= R_VShrinkIncrMin + R_VShrinkIncrFrac * R_VSize;if (R_VSize < VNeeded)R_VSize = VNeeded;if (R_VSize < orig_R_VSize)R_VSize = orig_R_VSize;}DEBUG_ADJUST_HEAP_PRINT(node_occup, vect_occup);}/* Managing Old-to-New References. */#define AGE_NODE(s,g) do { \SEXP an__n__ = (s); \int an__g__ = (g); \if (an__n__ && NODE_GEN_IS_YOUNGER(an__n__, an__g__)) { \if (NODE_IS_MARKED(an__n__)) \R_GenHeap[NODE_CLASS(an__n__)].OldCount[NODE_GENERATION(an__n__)]--; \else \MARK_NODE(an__n__); \SET_NODE_GENERATION(an__n__, an__g__); \UNSNAP_NODE(an__n__); \SET_NEXT_NODE(an__n__, forwarded_nodes); \forwarded_nodes = an__n__; \} \} while (0)static void AgeNodeAndChildren(SEXP s, int gen){SEXP forwarded_nodes = NULL;AGE_NODE(s, gen);while (forwarded_nodes != NULL) {SEXP s = forwarded_nodes;forwarded_nodes = NEXT_NODE(forwarded_nodes);if (NODE_GENERATION(s) != gen)REprintf("****snapping into wrong generation\n");SNAP_NODE(s, R_GenHeap[NODE_CLASS(s)].Old[gen]);R_GenHeap[NODE_CLASS(s)].OldCount[gen]++;DO_CHILDREN(s, AGE_NODE, gen);}}static void old_to_new(SEXP x, SEXP y){#ifdef EXPEL_OLD_TO_NEWAgeNodeAndChildren(y, NODE_GENERATION(x));#elseUNSNAP_NODE(x);SNAP_NODE(x, R_GenHeap[NODE_CLASS(x)].OldToNew[NODE_GENERATION(x)]);#endif}#define CHECK_OLD_TO_NEW(x,y) do { \if (NODE_IS_OLDER(x, y)) old_to_new(x,y); } while (0)/* Node Sorting. SortNodes attempts to improve locality of referenceby rearranging the free list to place nodes on the same place pagetogether and order nodes within pages. This involves a sweep of theheap, so it should not be done too often, but doing it at leastoccasionally does seem essential. Sorting on each full colllection isprobably sufficient.*/#define SORT_NODES#ifdef SORT_NODESstatic void SortNodes(void){SEXP s;int i;for (i = 0; i < NUM_SMALL_NODE_CLASSES; i++) {PAGE_HEADER *page;int node_size = NODE_SIZE(i);int page_count = (R_PAGE_SIZE - sizeof(PAGE_HEADER)) / node_size;SET_NEXT_NODE(R_GenHeap[i].New, R_GenHeap[i].New);SET_PREV_NODE(R_GenHeap[i].New, R_GenHeap[i].New);for (page = R_GenHeap[i].pages; page != NULL; page = page->next) {int j;char *data = PAGE_DATA(page);for (j = 0; j < page_count; j++, data += node_size) {s = (SEXP) data;if (! NODE_IS_MARKED(s))SNAP_NODE(s, R_GenHeap[i].New);}}R_GenHeap[i].Free = NEXT_NODE(R_GenHeap[i].New);}}#endif/* Finalization */static SEXP R_fin_registered = NULL;static void CheckFinalizers(void){SEXP s;for (s = R_fin_registered; s != R_NilValue; s = CDR(s))if (! NODE_IS_MARKED(CAR(s)) && s->sxpinfo.gp == 0)s->sxpinfo.gp = 1;}static Rboolean RunFinalizers(void){volatile SEXP s, last;volatile Rboolean finalizer_run = FALSE;for (s = R_fin_registered, last = R_NilValue; s != R_NilValue;) {SEXP next = CDR(s);if (s->sxpinfo.gp != 0) {RCNTXT thiscontext;RCNTXT * volatile saveToplevelContext;volatile int savestack;volatile SEXP topExp;finalizer_run = TRUE;/* A top level context is established for the finalizer toinsure that any errors that might occur do not spillinto the call that triggered the collection. */begincontext(&thiscontext, CTXT_TOPLEVEL, R_NilValue, R_GlobalEnv,R_NilValue, R_NilValue);saveToplevelContext = R_ToplevelContext;PROTECT(topExp = R_CurrentExpr);savestack = R_PPStackTop;if (! SETJMP(thiscontext.cjmpbuf)) {SEXP val, fun, e;R_GlobalContext = R_ToplevelContext = &thiscontext;/* The entry in the finalization list is removedbefore running the finalizer. This insures that afinalizer is run only once, even if running itraises an error. */if (last == R_NilValue)R_fin_registered = next;elseSETCDR(last, next);PROTECT(s);val = CAR(s);fun = TAG(s);if (TYPEOF(fun) == EXTPTRSXP) {/* Must be a C finalizer. */R_CFinalizer_t cfun = R_ExternalPtrAddr(fun);cfun(val);}else {/* An R finalizer. */PROTECT(e = LCONS(fun, LCONS(val, R_NilValue)));eval(e, R_GlobalEnv);UNPROTECT(1);}UNPROTECT(1);}endcontext(&thiscontext);R_ToplevelContext = saveToplevelContext;R_PPStackTop = savestack;R_CurrentExpr = topExp;UNPROTECT(1);}else last = s;s = next;}return finalizer_run;}void R_RegisterFinalizer(SEXP s, SEXP fun){switch (TYPEOF(s)) {case ENVSXP:case EXTPTRSXP:switch (TYPEOF(fun)) {case CLOSXP:case BUILTINSXP:case SPECIALSXP:break;default:error("finalizer function must be a closure");}R_fin_registered = CONS(s, R_fin_registered);SET_TAG(R_fin_registered, fun);R_fin_registered->sxpinfo.gp = 0;break;default: error("can only finalize reference objects");}}void R_RegisterCFinalizer(SEXP s, R_CFinalizer_t fun){/* We need to protect s since otherwise when R_MakeExternalPtr iscalled, its only link visible to the garbage collector might bethe one in the finalization chain, resulting in it beingregistered as elligible for finalization. */PROTECT(s);R_fin_registered = CONS(s, R_fin_registered);SET_TAG(R_fin_registered, R_MakeExternalPtr(fun, R_NilValue, R_NilValue));R_fin_registered->sxpinfo.gp = 0;UNPROTECT(1);}/* The Generational Collector. */#define PROCESS_NODES() do { \while (forwarded_nodes != NULL) { \s = forwarded_nodes; \forwarded_nodes = NEXT_NODE(forwarded_nodes); \SNAP_NODE(s, R_GenHeap[NODE_CLASS(s)].Old[NODE_GENERATION(s)]); \R_GenHeap[NODE_CLASS(s)].OldCount[NODE_GENERATION(s)]++; \FORWARD_CHILDREN(s); \} \} while (0)static void RunGenCollect(int size_needed){int i, gen, gens_collected;DevDesc *dd;RCNTXT *ctxt;SEXP s;SEXP forwarded_nodes;/* determine number of generations to collect */while (num_old_gens_to_collect < NUM_OLD_GENERATIONS) {if (collect_counts[num_old_gens_to_collect]-- <= 0) {collect_counts[num_old_gens_to_collect] =collect_counts_max[num_old_gens_to_collect];num_old_gens_to_collect++;}else break;}again:gens_collected = num_old_gens_to_collect;#ifndef EXPEL_OLD_TO_NEW/* eliminate old-to-new references in generations to collect bytransferring referenced nodes to referring generation */for (gen = 0; gen < num_old_gens_to_collect; gen++) {for (i = 0; i < NUM_NODE_CLASSES; i++) {s = NEXT_NODE(R_GenHeap[i].OldToNew[gen]);while (s != R_GenHeap[i].OldToNew[gen]) {SEXP next = NEXT_NODE(s);DO_CHILDREN(s, AgeNodeAndChildren, gen);UNSNAP_NODE(s);if (NODE_GENERATION(s) != gen)REprintf("****snapping into wrong generation\n");SNAP_NODE(s, R_GenHeap[i].Old[gen]);s = next;}}}#endifDEBUG_CHECK_NODE_COUNTS("at start");/* unmark all marked nodes in old generations to be collected andmove to New space */for (gen = 0; gen < num_old_gens_to_collect; gen++) {for (i = 0; i < NUM_NODE_CLASSES; i++) {R_GenHeap[i].OldCount[gen] = 0;s = NEXT_NODE(R_GenHeap[i].Old[gen]);while (s != R_GenHeap[i].Old[gen]) {SEXP next = NEXT_NODE(s);if (gen < NUM_OLD_GENERATIONS - 1)SET_NODE_GENERATION(s, gen + 1);UNMARK_NODE(s);s = next;}if (NEXT_NODE(R_GenHeap[i].Old[gen]) != R_GenHeap[i].Old[gen])BULK_MOVE(R_GenHeap[i].Old[gen], R_GenHeap[i].New);}}forwarded_nodes = NULL;#ifndef EXPEL_OLD_TO_NEW/* scan nodes in uncollected old generations with old-to-new pointers */for (gen = num_old_gens_to_collect; gen < NUM_OLD_GENERATIONS; gen++)for (i = 0; i < NUM_NODE_CLASSES; i++)for (s = NEXT_NODE(R_GenHeap[i].OldToNew[gen]);s != R_GenHeap[i].OldToNew[gen];s = NEXT_NODE(s))FORWARD_CHILDREN(s);#endif/* forward all roots */FORWARD_NODE(R_NilValue); /* Builtin constants */FORWARD_NODE(NA_STRING);FORWARD_NODE(R_BlankString);FORWARD_NODE(R_UnboundValue);FORWARD_NODE(R_MissingArg);FORWARD_NODE(R_CommentSxp);FORWARD_NODE(R_GlobalEnv); /* Global environment */FORWARD_NODE(R_Warnings); /* Warnings, if any */for (i = 0; i < HSIZE; i++) /* Symbol table */FORWARD_NODE(R_SymbolTable[i]);if (R_CurrentExpr != NULL) /* Current expression */FORWARD_NODE(R_CurrentExpr);for (i = 0; i < R_MaxDevices; i++) { /* Device display lists */dd = GetDevice(i);if (dd)FORWARD_NODE(dd->displayList);}for (ctxt = R_GlobalContext ; ctxt != NULL ; ctxt = ctxt->nextcontext)FORWARD_NODE(ctxt->conexit); /* on.exit expressions */FORWARD_NODE(framenames); /* used for interprocedurecommunication in model.c */FORWARD_NODE(R_PreciousList);for (i = 0; i < R_PPStackTop; i++) /* Protected pointers */FORWARD_NODE(R_PPStack[i]);FORWARD_NODE(R_VStack); /* R_alloc stack *//* main processing loop */PROCESS_NODES();/* mark nodes ready for finalizing */CheckFinalizers();/* process finalizers */FORWARD_NODE(R_fin_registered);PROCESS_NODES();DEBUG_CHECK_NODE_COUNTS("after processing forwarded list");/* release large vector allocations */ReleaseLargeFreeVectors();DEBUG_CHECK_NODE_COUNTS("after releasing large allocated nodes");/* reset Free pointers */for (i = 0; i < NUM_NODE_CLASSES; i++)R_GenHeap[i].Free = NEXT_NODE(R_GenHeap[i].New);/* update heap statistics */R_Collected = R_NSize;R_SmallVallocSize = 0;for (gen = 0; gen < NUM_OLD_GENERATIONS; gen++) {for (i = 1; i < NUM_SMALL_NODE_CLASSES; i++)R_SmallVallocSize += R_GenHeap[i].OldCount[gen] * NodeClassSize[i];for (i = 0; i < NUM_NODE_CLASSES; i++)R_Collected -= R_GenHeap[i].OldCount[gen];}R_NodesInUse = R_NSize - R_Collected;if (num_old_gens_to_collect < NUM_OLD_GENERATIONS) {if (R_Collected < R_MinFreeFrac * R_NSize ||VHEAP_FREE() - size_needed < R_MinFreeFrac * R_VSize) {num_old_gens_to_collect++;if (R_Collected <= 0 || VHEAP_FREE() < size_needed)goto again;}else num_old_gens_to_collect = 0;}else num_old_gens_to_collect = 0;gen_gc_counts[gens_collected]++;if (gens_collected == NUM_OLD_GENERATIONS) {/**** do some adjustment for intermediate collections? */AdjustHeapSize(size_needed);TryToReleasePages();DEBUG_CHECK_NODE_COUNTS("after heap adjustment");}else if (gens_collected > 0) {TryToReleasePages();DEBUG_CHECK_NODE_COUNTS("after heap adjustment");}#ifdef SORT_NODESif (gens_collected == NUM_OLD_GENERATIONS)SortNodes();#endifif (gc_reporting) {REprintf("Garbage collection %d = %d", gc_count, gen_gc_counts[0]);for (i = 0; i < NUM_OLD_GENERATIONS; i++)REprintf("+%d", gen_gc_counts[i + 1]);REprintf(" (level %d) ... ", gens_collected);DEBUG_GC_SUMMARY(gens_collected == NUM_OLD_GENERATIONS);}}SEXP do_gctorture(SEXP call, SEXP op, SEXP args, SEXP rho){int i;SEXP old = allocVector(LGLSXP, 1);checkArity(op, args);i = asLogical(CAR(args));LOGICAL(old)[0] = !gc_inhibit_torture;if (i != NA_LOGICAL)gc_inhibit_torture = !i;return old;}SEXP do_gcinfo(SEXP call, SEXP op, SEXP args, SEXP rho){int i;SEXP old = allocVector(LGLSXP, 1);checkArity(op, args);i = asLogical(CAR(args));LOGICAL(old)[0] = gc_reporting;if (i != NA_LOGICAL)gc_reporting = i;return old;}SEXP do_gc(SEXP call, SEXP op, SEXP args, SEXP rho){SEXP value;int ogc, onsize=R_NSize, ovsize=R_VSize;checkArity(op, args);ogc = gc_reporting;gc_reporting = asLogical(CAR(args));num_old_gens_to_collect = NUM_OLD_GENERATIONS;R_gc();gc_reporting = ogc;/*- now return the [used , gc trigger size] for cells and heap */PROTECT(value = allocVector(INTSXP, 10));INTEGER(value)[0] = onsize - R_Collected;INTEGER(value)[1] = ovsize - VHEAP_FREE();INTEGER(value)[4] = R_NSize;INTEGER(value)[5] = R_VSize;/* next four are in 0.1Mb, rounded up */INTEGER(value)[2] = 10.0 * (onsize - R_Collected)/1048576.0 *sizeof(SEXPREC) + 0.999;INTEGER(value)[3] = 10.0 * (ovsize - VHEAP_FREE())/131072.0 + 0.999;INTEGER(value)[6] = 10.0 * R_NSize/1048576.0 * sizeof(SEXPREC) + 0.999;INTEGER(value)[7] = 10.0 * R_VSize/131072.0 + 0.999;INTEGER(value)[8] = (R_MaxNSize < INT_MAX) ?(10.0 * R_MaxNSize/1048576.0 * sizeof(SEXPREC) + 0.999) : NA_INTEGER;INTEGER(value)[9] = (R_MaxVSize < INT_MAX) ?(10.0 * R_MaxVSize/131072.0 + 0.999) : NA_INTEGER;UNPROTECT(1);return value;}static void mem_err_heap(long size){errorcall(R_NilValue, "vector memory exhausted (limit reached?)");}static void mem_err_cons(){errorcall(R_NilValue, "cons memory exhausted (limit reached?)");}/* InitMemory : Initialise the memory to be used in R. *//* This includes: stack space, node space and vector space */void InitMemory(){int i;int gen;gc_reporting = R_Verbose;if (!(R_PPStack = (SEXP *) malloc(R_PPStackSize * sizeof(SEXP))))R_Suicide("couldn't allocate memory for pointer stack");R_PPStackTop = 0;vsfac = sizeof(VECREC);R_VSize = (((R_VSize + 1)/ vsfac));UNMARK_NODE(&UnmarkedNodeTemplate);for (i = 0; i < NUM_NODE_CLASSES; i++) {for (gen = 0; gen < NUM_OLD_GENERATIONS; gen++) {R_GenHeap[i].Old[gen] = &R_GenHeap[i].OldPeg[gen];SET_PREV_NODE(R_GenHeap[i].Old[gen], R_GenHeap[i].Old[gen]);SET_NEXT_NODE(R_GenHeap[i].Old[gen], R_GenHeap[i].Old[gen]);#ifndef EXPEL_OLD_TO_NEWR_GenHeap[i].OldToNew[gen] = &R_GenHeap[i].OldToNewPeg[gen];SET_PREV_NODE(R_GenHeap[i].OldToNew[gen], R_GenHeap[i].OldToNew[gen]);SET_NEXT_NODE(R_GenHeap[i].OldToNew[gen], R_GenHeap[i].OldToNew[gen]);#endifR_GenHeap[i].OldCount[gen] = 0;}R_GenHeap[i].New = &R_GenHeap[i].NewPeg;SET_PREV_NODE(R_GenHeap[i].New, R_GenHeap[i].New);SET_NEXT_NODE(R_GenHeap[i].New, R_GenHeap[i].New);}for (i = 0; i < NUM_NODE_CLASSES; i++)R_GenHeap[i].Free = NEXT_NODE(R_GenHeap[i].New);SET_NODE_CLASS(&UnmarkedNodeTemplate, 0);orig_R_NSize = R_NSize;orig_R_VSize = R_VSize;/* R_NilValue *//* THIS MUST BE THE FIRST CONS CELL ALLOCATED *//* OR ARMAGEDDON HAPPENS. *//* Field assignments for R_NilValue must not go through write barriersince the write barrier prevents assignments to R_NilValue's fields.because of checks for nil */GET_FREE_NODE(R_NilValue);R_NilValue->sxpinfo = UnmarkedNodeTemplate.sxpinfo;TYPEOF(R_NilValue) = NILSXP;CAR(R_NilValue) = R_NilValue;CDR(R_NilValue) = R_NilValue;TAG(R_NilValue) = R_NilValue;ATTRIB(R_NilValue) = R_NilValue;R_fin_registered = R_NilValue;}/* Since memory allocated from the heap is non-moving, R_alloc justallocates off the heap as CHARSXP's and maintains the stack ofallocations thorugh the ATTRIB pointer. The stack pointer R_VStackis traced by the collector. */char *vmaxget(void){return (char *) R_VStack;}void vmaxset(char *ovmax){R_VStack = (SEXP) ovmax;}char *R_alloc(long nelem, int eltsize){unsigned int size = nelem * eltsize;if (size > 0) {SEXP s = allocString(size); /**** avoid extra null byte?? */ATTRIB(s) = R_VStack;R_VStack = s;return CHAR(s);}else return NULL;}/* S COMPATIBILITY */char *S_alloc(long nelem, int eltsize){unsigned int i, size = nelem * eltsize;char *p = R_alloc(nelem, eltsize);for(i = 0; i < size; i++)p[i] = 0;return p;}char *S_realloc(char *p, long new, long old, int size){int i, nold;char *q;/* shrinking is a no-op */if(new <= old) return p;q = R_alloc(new, size);nold = old * size;for(i = 0; i < nold; i++)q[i] = p[i];for(i = nold; i < new*size; i++)q[i] = 0;return q;}/* "allocSExp" allocate a SEXPREC *//* call gc if necessary */SEXP allocSExp(SEXPTYPE t){SEXP s;if (FORCE_GC || NO_FREE_NODES()) {R_gc_internal(0);if (NO_FREE_NODES())mem_err_cons();}GET_FREE_NODE(s);s->sxpinfo = UnmarkedNodeTemplate.sxpinfo;TYPEOF(s) = t;CAR(s) = R_NilValue;CDR(s) = R_NilValue;TAG(s) = R_NilValue;ATTRIB(s) = R_NilValue;return s;}static SEXP allocSExpNonCons(SEXPTYPE t){SEXP s;if (FORCE_GC || NO_FREE_NODES()) {R_gc_internal(0);if (NO_FREE_NODES())mem_err_cons();}GET_FREE_NODE(s);s->sxpinfo = UnmarkedNodeTemplate.sxpinfo;TYPEOF(s) = t;TAG(s) = R_NilValue;ATTRIB(s) = R_NilValue;return s;}/* cons is defined directly do avoid the need to protect its argumentsunless a GC will actually occur. */SEXP cons(SEXP car, SEXP cdr){SEXP s;if (FORCE_GC || NO_FREE_NODES()) {PROTECT(car);PROTECT(cdr);R_gc_internal(0);UNPROTECT(2);if (NO_FREE_NODES())mem_err_cons();}GET_FREE_NODE(s);s->sxpinfo = UnmarkedNodeTemplate.sxpinfo;TYPEOF(s) = LISTSXP;CAR(s) = car;CDR(s) = cdr;TAG(s) = R_NilValue;ATTRIB(s) = R_NilValue;return s;}/*----------------------------------------------------------------------NewEnvironmentCreate an environment by extending "rho" with a frame obtained bypairing the variable names given by the tags on "namelist" withthe values given by the elements of "valuelist".*//* NewEnvironment is defined directly do avoid the need to protect itsarguments unless a GC will actually occur. This definition allowsthe namelist argument to be shorter than the valuelist; in thiscase the remaining values must be named already. (This is usefulin cses where the entire valuelist is already named--namelist canthen be R_NilValue */SEXP NewEnvironment(SEXP namelist, SEXP valuelist, SEXP rho){SEXP v, n, newrho;if (FORCE_GC || NO_FREE_NODES()) {PROTECT(namelist);PROTECT(valuelist);PROTECT(rho);R_gc_internal(0);UNPROTECT(3);if (NO_FREE_NODES())mem_err_cons();}GET_FREE_NODE(newrho);newrho->sxpinfo = UnmarkedNodeTemplate.sxpinfo;TYPEOF(newrho) = ENVSXP;FRAME(newrho) = valuelist;ENCLOS(newrho) = rho;HASHTAB(newrho) = R_NilValue;ATTRIB(newrho) = R_NilValue;v = valuelist;n = namelist;while (v != R_NilValue && n != R_NilValue) {SET_TAG(v, TAG(n));v = CDR(v);n = CDR(n);}return (newrho);}/* mkPROMISE is defined directly do avoid the need to protect its argumentsunless a GC will actually occur. */SEXP mkPROMISE(SEXP expr, SEXP rho){SEXP s;if (FORCE_GC || NO_FREE_NODES()) {PROTECT(expr);PROTECT(rho);R_gc_internal(0);UNPROTECT(2);if (NO_FREE_NODES())mem_err_cons();}GET_FREE_NODE(s);s->sxpinfo = UnmarkedNodeTemplate.sxpinfo;TYPEOF(s) = PROMSXP;PREXPR(s) = expr;PRENV(s) = rho;PRVALUE(s) = R_UnboundValue;PRSEEN(s) = 0;ATTRIB(s) = R_NilValue;return s;}/* "allocString" allocate a string on the (vector) heap. *//* All vector objects must be a multiple of sizeof(ALIGN) *//* bytes so that alignment is preserved for all objects */SEXP allocString(int length){return allocVector(CHARSXP, length);}/* Allocate a vector object on the heap */SEXP allocVector(SEXPTYPE type, int length){SEXP s; /* For the generational collector it would be safer towork in terms of a VECSEXP here, but that wouldrequire several casts below... */int i;long size=0;int alloc_size;int node_class;int old_R_VSize;if (length < 0 )errorcall(R_GlobalContext->call,"negative length vectors are not allowed");/* number of vector cells to allocate */switch (type) {case NILSXP:return R_NilValue;case CHARSXP:size = BYTE2VEC(length + 1);break;case LGLSXP:case INTSXP:if (length <= 0)size = 0;elsesize = INT2VEC(length);break;case REALSXP:if (length <= 0)size = 0;elsesize = FLOAT2VEC(length);break;case CPLXSXP:if (length <= 0)size = 0;elsesize = COMPLEX2VEC(length);break;case STRSXP:case EXPRSXP:case VECSXP:if (length <= 0)size = 0;elsesize = PTR2VEC(length);break;case LANGSXP:if(length == 0) return R_NilValue;s = allocList(length);TYPEOF(s) = LANGSXP;return s;case LISTSXP:return allocList(length);default:error("invalid type/length (%d/%d) in vector allocation", type, length);}if (size <= NodeClassSize[1]) {node_class = 1;alloc_size = NodeClassSize[1];}else {node_class = LARGE_NODE_CLASS;alloc_size = size;for (i = 2; i < NUM_SMALL_NODE_CLASSES; i++) {if (size <= NodeClassSize[i]) {node_class = i;alloc_size = NodeClassSize[i];break;}}}/* save current R_VSize to roll back adjustment if malloc fails */old_R_VSize = R_VSize;/* we need to do the gc here so allocSExp doesn't! */if (FORCE_GC || NO_FREE_NODES() || alloc_size > VHEAP_FREE()) {R_gc_internal(alloc_size);if (NO_FREE_NODES())mem_err_cons();if (VHEAP_FREE() < alloc_size)mem_err_heap(size);}if (size > 0) {if (node_class < NUM_SMALL_NODE_CLASSES) {CLASS_GET_FREE_NODE(node_class, s);s->sxpinfo = UnmarkedNodeTemplate.sxpinfo;SET_NODE_CLASS(s, node_class);R_SmallVallocSize += alloc_size;}else {s = NULL; /* initialize to suppress warning */if (size >= (LONG_MAX / sizeof(VECREC)) - sizeof(SEXPREC_ALIGN) ||(s = malloc(sizeof(SEXPREC_ALIGN) + size * sizeof(VECREC)))== NULL) {/* reset the vector heap limit */R_VSize = old_R_VSize;errorcall(R_NilValue, "cannot allocate vector of size %ld Kb",(size * sizeof(VECREC))/1024);}s->sxpinfo = UnmarkedNodeTemplate.sxpinfo;SET_NODE_CLASS(s, LARGE_NODE_CLASS);R_LargeVallocSize += alloc_size;R_GenHeap[LARGE_NODE_CLASS].AllocCount++;SNAP_NODE(s, R_GenHeap[LARGE_NODE_CLASS].New);}ATTRIB(s) = R_NilValue;TYPEOF(s) = type;}else {GC_PROT(s = allocSExpNonCons(type));}LENGTH(s) = length;NAMED(s) = 0;/* The following prevents disaster in the case *//* that an uninitialised string vector is marked *//* Direct assignment is OK since the node was just allocated and *//* so is at least as new as R_NilValue and R_BlankString */if (type == EXPRSXP || type == VECSXP) {SEXP *data = STRING_PTR(s);for (i = 0; i < length; i++)data[i] = R_NilValue;}else if(type == STRSXP) {SEXP *data = STRING_PTR(s);for (i = 0; i < length; i++)data[i] = R_BlankString;}return s;}SEXP allocList(int n){int i;SEXP result;result = R_NilValue;for (i = 0; i < n; i++) {result = CONS(R_NilValue, result);}return result;}/* "gc" a mark-sweep or in-place generational garbage collector */void R_gc(void){R_gc_internal(0);}#ifdef HAVE_TIMESdouble R_getClockIncrement(void);void R_getProcTime(double *data);static double gctimes[5], gcstarttimes[5];SEXP do_gctime(SEXP call, SEXP op, SEXP args, SEXP env){SEXP ans;ans = allocVector(REALSXP, 5);REAL(ans)[0] = gctimes[0];REAL(ans)[1] = gctimes[1];REAL(ans)[2] = gctimes[2];REAL(ans)[3] = gctimes[3];REAL(ans)[4] = gctimes[4];return ans;}#endif /* HAVE_TIMES */static void gc_start_timing(void){#ifdef HAVE_TIMESR_getProcTime(gcstarttimes);#endif /* HAVE_TIMES */}static void gc_end_timing(void){#ifdef HAVE_TIMESdouble times[5], delta;R_getProcTime(times);delta = R_getClockIncrement();/* add delta to compensate for timer resolution */gctimes[0] += times[0] - gcstarttimes[0] + delta;gctimes[1] += times[1] - gcstarttimes[1] + delta;gctimes[2] += times[2] - gcstarttimes[2] + delta;gctimes[3] += times[3] - gcstarttimes[3];gctimes[4] += times[4] - gcstarttimes[4];#endif /* HAVE_TIMES */}static void R_gc_internal(int size_needed){int vcells;double vfrac;Rboolean first = TRUE;again:gc_count++;BEGIN_SUSPEND_INTERRUPTS {gc_start_timing();RunGenCollect(size_needed);gc_end_timing();} END_SUSPEND_INTERRUPTS;if (gc_reporting) {REprintf("\n%d cons cells free (%d%%)\n",R_Collected, (100 * R_Collected / R_NSize));vcells = VHEAP_FREE();vfrac = (100.0 * vcells) / R_VSize;/* arrange for percentage to be rounded down, or we get`100% free' ! */REprintf("%.1f Mbytes of heap free (%d%%)\n",vcells * sizeof(VECREC) / Mega, (int)vfrac);}if (first) {first = FALSE;/* Run any eligible finalizers. The return result ofRunFinalizers is TRUE if any finalizers are actually run.There is a small chance that running finalizers here maychew up enough memory to make another immediate collectionnecessary. If so, we jump back to the beginning and runthe collection, but on this second pass we do not runfinalizers. */if (RunFinalizers() &&(NO_FREE_NODES() || size_needed > VHEAP_FREE()))goto again;}}SEXP do_memlimits(SEXP call, SEXP op, SEXP args, SEXP env){SEXP ans;int nsize, vsize, tmp;checkArity(op, args);nsize = asInteger(CAR(args));vsize = asInteger(CADR(args));if(nsize != NA_INTEGER) R_SetMaxNSize(nsize);if(vsize != NA_INTEGER) R_SetMaxVSize(vsize);PROTECT(ans = allocVector(INTSXP, 2));tmp = R_GetMaxNSize();INTEGER(ans)[0] = (tmp == INT_MAX) ? NA_INTEGER : tmp;tmp = R_GetMaxVSize();INTEGER(ans)[1] = (tmp == INT_MAX) ? NA_INTEGER : tmp;UNPROTECT(1);return ans;}SEXP do_memoryprofile(SEXP call, SEXP op, SEXP args, SEXP env){SEXP ans, nms;int i;PROTECT(ans = allocVector(INTSXP, 23));PROTECT(nms = allocVector(STRSXP, 23));for (i = 0; i < 23; i++) {INTEGER(ans)[i] = 0;SET_STRING_ELT(nms, i, R_BlankString);}SET_STRING_ELT(nms, NILSXP, mkChar("NILSXP"));SET_STRING_ELT(nms, SYMSXP, mkChar("SYMSXP"));SET_STRING_ELT(nms, LISTSXP, mkChar("LISTSXP"));SET_STRING_ELT(nms, CLOSXP, mkChar("CLOSXP"));SET_STRING_ELT(nms, ENVSXP, mkChar("ENVSXP"));SET_STRING_ELT(nms, PROMSXP, mkChar("PROMSXP"));SET_STRING_ELT(nms, LANGSXP, mkChar("LANGSXP"));SET_STRING_ELT(nms, SPECIALSXP, mkChar("SPECIALSXP"));SET_STRING_ELT(nms, BUILTINSXP, mkChar("BUILTINSXP"));SET_STRING_ELT(nms, CHARSXP, mkChar("CHARSXP"));SET_STRING_ELT(nms, LGLSXP, mkChar("LGLSXP"));SET_STRING_ELT(nms, INTSXP, mkChar("INTSXP"));SET_STRING_ELT(nms, REALSXP, mkChar("REALSXP"));SET_STRING_ELT(nms, CPLXSXP, mkChar("CPLXSXP"));SET_STRING_ELT(nms, STRSXP, mkChar("STRSXP"));SET_STRING_ELT(nms, DOTSXP, mkChar("DOTSXP"));SET_STRING_ELT(nms, ANYSXP, mkChar("ANYSXP"));SET_STRING_ELT(nms, VECSXP, mkChar("VECSXP"));SET_STRING_ELT(nms, EXPRSXP, mkChar("EXPRSXP"));SET_STRING_ELT(nms, EXTPTRSXP, mkChar("EXTPTRSXP"));setAttrib(ans, R_NamesSymbol, nms);BEGIN_SUSPEND_INTERRUPTS {int gen;/* run a full GC to make sure that all stuff in use in in Old space */num_old_gens_to_collect = NUM_OLD_GENERATIONS;R_gc();for (gen = 0; gen < NUM_OLD_GENERATIONS; gen++) {for (i = 0; i < NUM_NODE_CLASSES; i++) {SEXP s;for (s = NEXT_NODE(R_GenHeap[i].Old[gen]);s != R_GenHeap[i].Old[gen];s = NEXT_NODE(s))INTEGER(ans)[TYPEOF(s)]++;}}} END_SUSPEND_INTERRUPTS;UNPROTECT(2);return ans;}/* "protect" push a single argument onto R_PPStack *//* In handling a stack overflow we have to be careful not touse PROTECT. error("protect(): stack overflow") would calldeparse1, which uses PROTECT and segfaults */SEXP protect(SEXP s){if (R_PPStackTop >= R_PPStackSize)errorcall(R_NilValue, "protect(): stack overflow");R_PPStack[R_PPStackTop++] = s;return s;}/* "unprotect" pop argument list from top of R_PPStack */void unprotect(int l){if (R_PPStackTop >= l)R_PPStackTop -= l;elseerror("unprotect(): stack imbalance");}/* "unprotect_ptr" remove pointer from somewhere in R_PPStack */void unprotect_ptr(SEXP s){int i = R_PPStackTop;/* go look for s in R_PPStack *//* (should be among the top few items) */do {if (i == 0)error("unprotect_ptr: pointer not found");} while ( R_PPStack[--i] != s );/* OK, got it, and i is indexing its location *//* Now drop stack above it */do {R_PPStack[i] = R_PPStack[i + 1];} while ( i++ < R_PPStackTop );R_PPStackTop--;}void R_ProtectWithIndex(SEXP s, PROTECT_INDEX *pi){protect(s);*pi = R_PPStackTop - 1;}void R_Reprotect(SEXP s, PROTECT_INDEX i){R_PPStack[i] = s;}/* "initStack" initialize environment stack */void initStack(void){R_PPStackTop = 0;}/* Wrappers for malloc/alloc/free *//* These allow automatic freeing of malloc-ed *//* blocks during error recovery. */#define MAXPOINTERS 100static char *C_Pointers[MAXPOINTERS];void Init_C_alloc(){int i;for(i=0 ; i<MAXPOINTERS ; i++)C_Pointers[i] = NULL;}void Reset_C_alloc(){int i;for(i=0 ; i<MAXPOINTERS ; i++) {if(C_Pointers[i] != NULL)free(C_Pointers[i]);C_Pointers[i] = NULL;}}char *C_alloc(long nelem, int eltsize){int i;for(i=0 ; i<MAXPOINTERS ; i++) {if(C_Pointers[i] == NULL) {C_Pointers[i] = malloc(nelem * eltsize);if(C_Pointers[i] == NULL)error("C_alloc(): unable to malloc memory");else return C_Pointers[i];}}error("C_alloc(): all pointers in use (sorry)");/*-Wall:*/return C_Pointers[0];}void C_free(char *p){int i;for(i=0 ; i<MAXPOINTERS ; i++) {if(C_Pointers[i] == p) {free(p);C_Pointers[i] = NULL;return;}}error("C_free(): attempt to free pointer not allocated by C_alloc()");}/* S-like wrappers for calloc, realloc and free that check for errorconditions */void *R_chk_calloc(size_t nelem, size_t elsize){void *p;#ifdef CALLOC_BROKENif(nelem == 0)return(NULL);#endifp = calloc(nelem, elsize);if(!p) error("Calloc could not allocate (%d of %d) memory", nelem, elsize);return(p);}void *R_chk_realloc(void *ptr, size_t size){void *p;p = realloc(ptr, size);if(!p) error("Realloc could not re-allocate (size %d) memory", size);return(p);}void R_chk_free(void *ptr){/* S-PLUS warns here, but there seems no reason to do so *//* if(!ptr) warning("attempt to free NULL pointer by Free"); */if(ptr) free(ptr); /* ANSI C says free has no effect on NULL, butbetter to be safe here */}/* This code keeps a list of objects which are not assigned to variablesbut which are required to persist across garbage collections. Theobjects are registered with R_PreserveObject and deregistered withR_UnpreserveObject. This is experimental code, it would not be wiseto rely on it at this point - ihaka */void R_PreserveObject(SEXP object){R_PreciousList = CONS(object, R_PreciousList);}static SEXP RecursiveRelease(SEXP object, SEXP list){if (!isNull(list)) {if (object == CAR(list))return CDR(list);elseCDR(list) = RecursiveRelease(object, CDR(list));}return list;}void R_ReleaseObject(SEXP object){R_PreciousList = RecursiveRelease(object, R_PreciousList);}/* External Pointer Objects */SEXP R_MakeExternalPtr(void *p, SEXP tag, SEXP prot){SEXP s = allocSExp(EXTPTRSXP);EXTPTR_PTR(s) = p;EXTPTR_PROT(s) = prot;EXTPTR_TAG(s) = tag;return s;}void *R_ExternalPtrAddr(SEXP s){return EXTPTR_PTR(s);}SEXP R_ExternalPtrTag(SEXP s){return EXTPTR_TAG(s);}SEXP R_ExternalPtrProtected(SEXP s){return EXTPTR_PROT(s);}void R_ClearExternalPtr(SEXP s){EXTPTR_PTR(s) = NULL;}void R_SetExternalPtrAddr(SEXP s, void *p){EXTPTR_PTR(s) = p;}void R_SetExternalPtrTag(SEXP s, SEXP tag){CHECK_OLD_TO_NEW(s, tag);EXTPTR_TAG(s) = tag;}void R_SetExternalPtrProtected(SEXP s, SEXP p){CHECK_OLD_TO_NEW(s, p);EXTPTR_PROT(s) = p;}/* The following functions are replacements for the accessor macros.They are used by code that does not have direct access to theinternal representation of objects. The assignment functionsimplement the write barrier. *//* General Cons Cell Attributes */SEXP (ATTRIB)(SEXP x) { return ATTRIB(x); }int (OBJECT)(SEXP x) { return OBJECT(x); }int (MARK)(SEXP x) { return MARK(x); }int (TYPEOF)(SEXP x) { return TYPEOF(x); }int (NAMED)(SEXP x) { return NAMED(x); }void (SET_ATTRIB)(SEXP x, SEXP v) { CHECK_OLD_TO_NEW(x, v); ATTRIB(x) = v; }void (SET_OBJECT)(SEXP x, int v) { SET_OBJECT(x, v); }void (SET_TYPEOF)(SEXP x, int v) { SET_TYPEOF(x, v); }void (SET_NAMED)(SEXP x, int v) { SET_NAMED(x, v); }/* Vector Accessors */int (LENGTH)(SEXP x) { return LENGTH(x); }int (TRUELENGTH)(SEXP x) { return TRUELENGTH(x); }char *(R_CHAR)(SEXP x) { return CHAR(x); }SEXP (STRING_ELT)(SEXP x, int i) { return STRING_ELT(x, i); }SEXP (VECTOR_ELT)(SEXP x, int i) { return VECTOR_ELT(x, i); }int (LEVELS)(SEXP x) { return LEVELS(x); }int *(LOGICAL)(SEXP x) { return LOGICAL(x); }int *(INTEGER)(SEXP x) { return INTEGER(x); }double *(REAL)(SEXP x) { return REAL(x); }Rcomplex *(COMPLEX)(SEXP x) { return COMPLEX(x); }SEXP *(STRING_PTR)(SEXP x) { return STRING_PTR(x); }SEXP *(VECTOR_PTR)(SEXP x){error("not safe to return vector pointer");return NULL;}void (SETLENGTH)(SEXP x, int v) { SETLENGTH(x, v); }void (SET_TRUELENGTH)(SEXP x, int v) { SET_TRUELENGTH(x, v); }void (SET_STRING_ELT)(SEXP x, int i, SEXP v) { CHECK_OLD_TO_NEW(x, v); STRING_ELT(x, i) = v; }SEXP (SET_VECTOR_ELT)(SEXP x, int i, SEXP v) { CHECK_OLD_TO_NEW(x, v); return VECTOR_ELT(x, i) =v; }int (SETLEVELS)(SEXP x, int v) { return SETLEVELS(x, v); }/* List Accessors */SEXP (TAG)(SEXP e) { return TAG(e); }SEXP (CAR)(SEXP e) { return CAR(e); }SEXP (CDR)(SEXP e) {return CDR(e); }SEXP (CAAR)(SEXP e) { return CAAR(e); }SEXP (CDAR)(SEXP e) { return CDAR(e); }SEXP (CADR)(SEXP e) { return CADR(e); }SEXP (CDDR)(SEXP e) { return CDDR(e); }SEXP (CADDR)(SEXP e) { return CADDR(e); }SEXP (CADDDR)(SEXP e) { return CADDDR(e); }SEXP (CAD4R)(SEXP e) { return CAD4R(e); }int (MISSING)(SEXP x) { return MISSING(x); }void (SET_TAG)(SEXP x, SEXP v) { CHECK_OLD_TO_NEW(x, v); TAG(x) = v; }SEXP (SETCAR)(SEXP x, SEXP y){if (x == NULL || x == R_NilValue)error("bad value");CHECK_OLD_TO_NEW(x, y);CAR(x) = y;return y;}SEXP (SETCDR)(SEXP x, SEXP y){if (x == NULL || x == R_NilValue)error("bad value");CHECK_OLD_TO_NEW(x, y);CDR(x) = y;return y;}SEXP (SETCADR)(SEXP x, SEXP y){SEXP cell;if (x == NULL || x == R_NilValue ||CDR(x) == NULL || CDR(x) == R_NilValue)error("bad value");cell = CDR(x);CHECK_OLD_TO_NEW(cell, y);CAR(cell) = y;return y;}SEXP (SETCADDR)(SEXP x, SEXP y){SEXP cell;if (x == NULL || x == R_NilValue ||CDR(x) == NULL || CDR(x) == R_NilValue ||CDDR(x) == NULL || CDDR(x) == R_NilValue)error("bad value");cell = CDDR(x);CHECK_OLD_TO_NEW(cell, y);CAR(cell) = y;return y;}#define CDDDR(x) CDR(CDR(CDR(x)))SEXP (SETCADDDR)(SEXP x, SEXP y){SEXP cell;if (x == NULL || x == R_NilValue ||CDR(x) == NULL || CDR(x) == R_NilValue ||CDDR(x) == NULL || CDDR(x) == R_NilValue ||CDDDR(x) == NULL || CDDDR(x) == R_NilValue)error("bad value");cell = CDDDR(x);CHECK_OLD_TO_NEW(cell, y);CAR(cell) = y;return y;}#define CD4R(x) CDR(CDR(CDR(CDR(x))))SEXP (SETCAD4R)(SEXP x, SEXP y){SEXP cell;if (x == NULL || x == R_NilValue ||CDR(x) == NULL || CDR(x) == R_NilValue ||CDDR(x) == NULL || CDDR(x) == R_NilValue ||CDDDR(x) == NULL || CDDDR(x) == R_NilValue ||CD4R(x) == NULL || CD4R(x) == R_NilValue)error("bad value");cell = CD4R(x);CHECK_OLD_TO_NEW(cell, y);CAR(cell) = y;return y;}void (SET_MISSING)(SEXP x, int v) { SET_MISSING(x, v); }/* Closure Accessors */SEXP (FORMALS)(SEXP x) { return FORMALS(x); }SEXP (BODY)(SEXP x) { return BODY(x); }SEXP (CLOENV)(SEXP x) { return CLOENV(x); }int (DEBUG)(SEXP x) { return DEBUG(x); }int (TRACE)(SEXP x) { return TRACE(x); }void (SET_FORMALS)(SEXP x, SEXP v) { CHECK_OLD_TO_NEW(x, v); FORMALS(x) = v; }void (SET_BODY)(SEXP x, SEXP v) { CHECK_OLD_TO_NEW(x, v); BODY(x) = v; }void (SET_CLOENV)(SEXP x, SEXP v) { CHECK_OLD_TO_NEW(x, v); CLOENV(x) = v; }void (SET_DEBUG)(SEXP x, int v) { SET_DEBUG(x, v); }void (SET_TRACE)(SEXP x, int v) { SET_TRACE(x, v); }/* Primitive Accessors */int (PRIMOFFSET)(SEXP x) { return PRIMOFFSET(x); }void (SET_PRIMOFFSET)(SEXP x, int v) { SET_PRIMOFFSET(x, v); }/* Symbol Accessors */SEXP (PRINTNAME)(SEXP x) { return PRINTNAME(x); }SEXP (SYMVALUE)(SEXP x) { return SYMVALUE(x); }SEXP (INTERNAL)(SEXP x) { return INTERNAL(x); }int (DDVAL)(SEXP x) { return DDVAL(x); }void (SET_PRINTNAME)(SEXP x, SEXP v) { CHECK_OLD_TO_NEW(x, v); PRINTNAME(x) = v; }void (SET_SYMVALUE)(SEXP x, SEXP v) { CHECK_OLD_TO_NEW(x, v); SYMVALUE(x) = v; }void (SET_INTERNAL)(SEXP x, SEXP v) { CHECK_OLD_TO_NEW(x, v); INTERNAL(x) = v; }void (SET_DDVAL)(SEXP x, int v) { SET_DDVAL(x, v); }/* Environment Accessors */SEXP (FRAME)(SEXP x) { return FRAME(x); }SEXP (ENCLOS)(SEXP x) { return ENCLOS(x); }SEXP (HASHTAB)(SEXP x) { return HASHTAB(x); }int (ENVFLAGS)(SEXP x) { return ENVFLAGS(x); }void (SET_FRAME)(SEXP x, SEXP v) { CHECK_OLD_TO_NEW(x, v); FRAME(x) = v; }void (SET_ENCLOS)(SEXP x, SEXP v) { CHECK_OLD_TO_NEW(x, v); ENCLOS(x) = v; }void (SET_HASHTAB)(SEXP x, SEXP v) { CHECK_OLD_TO_NEW(x, v); HASHTAB(x) = v; }void (SET_ENVFLAGS)(SEXP x, int v) { SET_ENVFLAGS(x, v); }/* Promise Accessors */SEXP (PREXPR)(SEXP x) { return PREXPR(x); }SEXP (PRENV)(SEXP x) { return PRENV(x); }SEXP (PRVALUE)(SEXP x) { return PRVALUE(x); }int (PRSEEN)(SEXP x) { return PRSEEN(x); }void (SET_PREXPR)(SEXP x, SEXP v) { CHECK_OLD_TO_NEW(x, v); PREXPR(x) = v; }void (SET_PRENV)(SEXP x, SEXP v){ CHECK_OLD_TO_NEW(x, v); PRENV(x) = v; }void (SET_PRVALUE)(SEXP x, SEXP v) { CHECK_OLD_TO_NEW(x, v); PRVALUE(x) = v; }void (SET_PRSEEN)(SEXP x, int v) { SET_PRSEEN(x, v); }/* Hashing Accessors */int (HASHASH)(SEXP x) { return HASHASH(x); }int (HASHVALUE)(SEXP x) { return HASHVALUE(x); }void (SET_HASHASH)(SEXP x, int v) { SET_HASHASH(x, v); }void (SET_HASHVALUE)(SEXP x, int v) { SET_HASHVALUE(x, v); }