• file
• revisions
• annotate
• diff
• comparison
• raw

src/share/vm/services/memoryManager.cpp@7bb995fbd3c0 (annotated)

src/share/vm/services/memoryManager.cpp

Thu, 12 Mar 2009 18:16:36 -0700

author

trims

date

Thu, 12 Mar 2009 18:16:36 -0700

changeset 1063

7bb995fbd3c0

parent 435

a61af66fc99e

child 1524

db0d5eba9d20

permissions

-rw-r--r--

Merge

duke@435	1	/*
duke@435	2	* Copyright 2003-2005 Sun Microsystems, Inc. All Rights Reserved.
duke@435	3	* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
duke@435	4	*
duke@435	5	* This code is free software; you can redistribute it and/or modify it
duke@435	6	* under the terms of the GNU General Public License version 2 only, as
duke@435	7	* published by the Free Software Foundation.
duke@435	8	*
duke@435	9	* This code is distributed in the hope that it will be useful, but WITHOUT
duke@435	10	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
duke@435	11	* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
duke@435	12	* version 2 for more details (a copy is included in the LICENSE file that
duke@435	13	* accompanied this code).
duke@435	14	*
duke@435	15	* You should have received a copy of the GNU General Public License version
duke@435	16	* 2 along with this work; if not, write to the Free Software Foundation,
duke@435	17	* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
duke@435	18	*
duke@435	19	* Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
duke@435	20	* CA 95054 USA or visit www.sun.com if you need additional information or
duke@435	21	* have any questions.
duke@435	22	*
duke@435	23	*/
duke@435	24
duke@435	25	# include "incls/_precompiled.incl"
duke@435	26	# include "incls/_memoryManager.cpp.incl"
duke@435	27
duke@435	28	HS_DTRACE_PROBE_DECL8(hotspot, mem__pool__gc__begin, char*, int, char*, int,
duke@435	29	size_t, size_t, size_t, size_t);
duke@435	30	HS_DTRACE_PROBE_DECL8(hotspot, mem__pool__gc__end, char*, int, char*, int,
duke@435	31	size_t, size_t, size_t, size_t);
duke@435	32
duke@435	33	MemoryManager::MemoryManager() {
duke@435	34	_num_pools = 0;
duke@435	35	_memory_mgr_obj = NULL;
duke@435	36	}
duke@435	37
duke@435	38	void MemoryManager::add_pool(MemoryPool* pool) {
duke@435	39	assert(_num_pools < MemoryManager::max_num_pools, "_num_pools exceeds the max");
duke@435	40	if (_num_pools < MemoryManager::max_num_pools) {
duke@435	41	_pools[_num_pools] = pool;
duke@435	42	_num_pools++;
duke@435	43	}
duke@435	44	pool->add_manager(this);
duke@435	45	}
duke@435	46
duke@435	47	MemoryManager* MemoryManager::get_code_cache_memory_manager() {
duke@435	48	return (MemoryManager*) new CodeCacheMemoryManager();
duke@435	49	}
duke@435	50
duke@435	51	GCMemoryManager* MemoryManager::get_copy_memory_manager() {
duke@435	52	return (GCMemoryManager*) new CopyMemoryManager();
duke@435	53	}
duke@435	54
duke@435	55	GCMemoryManager* MemoryManager::get_msc_memory_manager() {
duke@435	56	return (GCMemoryManager*) new MSCMemoryManager();
duke@435	57	}
duke@435	58
duke@435	59	GCMemoryManager* MemoryManager::get_parnew_memory_manager() {
duke@435	60	return (GCMemoryManager*) new ParNewMemoryManager();
duke@435	61	}
duke@435	62
duke@435	63	GCMemoryManager* MemoryManager::get_cms_memory_manager() {
duke@435	64	return (GCMemoryManager*) new CMSMemoryManager();
duke@435	65	}
duke@435	66
duke@435	67	GCMemoryManager* MemoryManager::get_psScavenge_memory_manager() {
duke@435	68	return (GCMemoryManager*) new PSScavengeMemoryManager();
duke@435	69	}
duke@435	70
duke@435	71	GCMemoryManager* MemoryManager::get_psMarkSweep_memory_manager() {
duke@435	72	return (GCMemoryManager*) new PSMarkSweepMemoryManager();
duke@435	73	}
duke@435	74
duke@435	75	instanceOop MemoryManager::get_memory_manager_instance(TRAPS) {
duke@435	76	// Must do an acquire so as to force ordering of subsequent
duke@435	77	// loads from anything _memory_mgr_obj points to or implies.
duke@435	78	instanceOop mgr_obj = (instanceOop)OrderAccess::load_ptr_acquire(&_memory_mgr_obj);
duke@435	79	if (mgr_obj == NULL) {
duke@435	80	// It's ok for more than one thread to execute the code up to the locked region.
duke@435	81	// Extra manager instances will just be gc'ed.
duke@435	82	klassOop k = Management::sun_management_ManagementFactory_klass(CHECK_0);
duke@435	83	instanceKlassHandle ik(THREAD, k);
duke@435	84
duke@435	85	Handle mgr_name = java_lang_String::create_from_str(name(), CHECK_0);
duke@435	86
duke@435	87	JavaValue result(T_OBJECT);
duke@435	88	JavaCallArguments args;
duke@435	89	args.push_oop(mgr_name); // Argument 1
duke@435	90
duke@435	91	symbolHandle method_name;
duke@435	92	symbolHandle signature;
duke@435	93	if (is_gc_memory_manager()) {
duke@435	94	method_name = vmSymbolHandles::createGarbageCollector_name();
duke@435	95	signature = vmSymbolHandles::createGarbageCollector_signature();
duke@435	96	args.push_oop(Handle()); // Argument 2 (for future extension)
duke@435	97	} else {
duke@435	98	method_name = vmSymbolHandles::createMemoryManager_name();
duke@435	99	signature = vmSymbolHandles::createMemoryManager_signature();
duke@435	100	}
duke@435	101
duke@435	102	JavaCalls::call_static(&result,
duke@435	103	ik,
duke@435	104	method_name,
duke@435	105	signature,
duke@435	106	&args,
duke@435	107	CHECK_0);
duke@435	108
duke@435	109	instanceOop m = (instanceOop) result.get_jobject();
duke@435	110	instanceHandle mgr(THREAD, m);
duke@435	111
duke@435	112	{
duke@435	113	// Get lock before setting _memory_mgr_obj
duke@435	114	// since another thread may have created the instance
duke@435	115	MutexLocker ml(Management_lock);
duke@435	116
duke@435	117	// Check if another thread has created the management object. We reload
duke@435	118	// _memory_mgr_obj here because some other thread may have initialized
duke@435	119	// it while we were executing the code before the lock.
duke@435	120	//
duke@435	121	// The lock has done an acquire, so the load can't float above it, but
duke@435	122	// we need to do a load_acquire as above.
duke@435	123	mgr_obj = (instanceOop)OrderAccess::load_ptr_acquire(&_memory_mgr_obj);
duke@435	124	if (mgr_obj != NULL) {
duke@435	125	return mgr_obj;
duke@435	126	}
duke@435	127
duke@435	128	// Get the address of the object we created via call_special.
duke@435	129	mgr_obj = mgr();
duke@435	130
duke@435	131	// Use store barrier to make sure the memory accesses associated
duke@435	132	// with creating the management object are visible before publishing
duke@435	133	// its address. The unlock will publish the store to _memory_mgr_obj
duke@435	134	// because it does a release first.
duke@435	135	OrderAccess::release_store_ptr(&_memory_mgr_obj, mgr_obj);
duke@435	136	}
duke@435	137	}
duke@435	138
duke@435	139	return mgr_obj;
duke@435	140	}
duke@435	141
duke@435	142	void MemoryManager::oops_do(OopClosure* f) {
duke@435	143	f->do_oop((oop*) &_memory_mgr_obj);
duke@435	144	}
duke@435	145
duke@435	146	GCStatInfo::GCStatInfo(int num_pools) {
duke@435	147	// initialize the arrays for memory usage
duke@435	148	_before_gc_usage_array = (MemoryUsage*) NEW_C_HEAP_ARRAY(MemoryUsage, num_pools);
duke@435	149	_after_gc_usage_array = (MemoryUsage*) NEW_C_HEAP_ARRAY(MemoryUsage, num_pools);
duke@435	150	size_t len = num_pools * sizeof(MemoryUsage);
duke@435	151	memset(_before_gc_usage_array, 0, len);
duke@435	152	memset(_after_gc_usage_array, 0, len);
duke@435	153	_usage_array_size = num_pools;
duke@435	154	}
duke@435	155
duke@435	156	GCStatInfo::~GCStatInfo() {
duke@435	157	FREE_C_HEAP_ARRAY(MemoryUsage*, _before_gc_usage_array);
duke@435	158	FREE_C_HEAP_ARRAY(MemoryUsage*, _after_gc_usage_array);
duke@435	159	}
duke@435	160
duke@435	161	void GCStatInfo::copy_stat(GCStatInfo* stat) {
duke@435	162	set_index(stat->gc_index());
duke@435	163	set_start_time(stat->start_time());
duke@435	164	set_end_time(stat->end_time());
duke@435	165	assert(_usage_array_size == stat->usage_array_size(), "Must have same array size");
duke@435	166	for (int i = 0; i < _usage_array_size; i++) {
duke@435	167	set_before_gc_usage(i, stat->before_gc_usage_for_pool(i));
duke@435	168	set_after_gc_usage(i, stat->after_gc_usage_for_pool(i));
duke@435	169	}
duke@435	170	}
duke@435	171
duke@435	172	void GCStatInfo::set_gc_usage(int pool_index, MemoryUsage usage, bool before_gc) {
duke@435	173	MemoryUsage* gc_usage_array;
duke@435	174	if (before_gc) {
duke@435	175	gc_usage_array = _before_gc_usage_array;
duke@435	176	} else {
duke@435	177	gc_usage_array = _after_gc_usage_array;
duke@435	178	}
duke@435	179	gc_usage_array[pool_index] = usage;
duke@435	180	}
duke@435	181
duke@435	182	GCMemoryManager::GCMemoryManager() : MemoryManager() {
duke@435	183	_num_collections = 0;
duke@435	184	_last_gc_stat = NULL;
duke@435	185	_num_gc_threads = 1;
duke@435	186	}
duke@435	187
duke@435	188	GCMemoryManager::~GCMemoryManager() {
duke@435	189	delete _last_gc_stat;
duke@435	190	}
duke@435	191
duke@435	192	void GCMemoryManager::initialize_gc_stat_info() {
duke@435	193	assert(MemoryService::num_memory_pools() > 0, "should have one or more memory pools");
duke@435	194	_last_gc_stat = new GCStatInfo(MemoryService::num_memory_pools());
duke@435	195	}
duke@435	196
duke@435	197	void GCMemoryManager::gc_begin() {
duke@435	198	assert(_last_gc_stat != NULL, "Just checking");
duke@435	199	_accumulated_timer.start();
duke@435	200	_num_collections++;
duke@435	201	_last_gc_stat->set_index(_num_collections);
duke@435	202	_last_gc_stat->set_start_time(Management::timestamp());
duke@435	203
duke@435	204	// Keep memory usage of all memory pools
duke@435	205	for (int i = 0; i < MemoryService::num_memory_pools(); i++) {
duke@435	206	MemoryPool* pool = MemoryService::get_memory_pool(i);
duke@435	207	MemoryUsage usage = pool->get_memory_usage();
duke@435	208	_last_gc_stat->set_before_gc_usage(i, usage);
duke@435	209	HS_DTRACE_PROBE8(hotspot, mem__pool__gc__begin,
duke@435	210	name(), strlen(name()),
duke@435	211	pool->name(), strlen(pool->name()),
duke@435	212	usage.init_size(), usage.used(),
duke@435	213	usage.committed(), usage.max_size());
duke@435	214	}
duke@435	215	}
duke@435	216
duke@435	217	void GCMemoryManager::gc_end() {
duke@435	218	_accumulated_timer.stop();
duke@435	219	_last_gc_stat->set_end_time(Management::timestamp());
duke@435	220
duke@435	221	int i;
duke@435	222	// keep the last gc statistics for all memory pools
duke@435	223	for (i = 0; i < MemoryService::num_memory_pools(); i++) {
duke@435	224	MemoryPool* pool = MemoryService::get_memory_pool(i);
duke@435	225	MemoryUsage usage = pool->get_memory_usage();
duke@435	226
duke@435	227	HS_DTRACE_PROBE8(hotspot, mem__pool__gc__end,
duke@435	228	name(), strlen(name()),
duke@435	229	pool->name(), strlen(pool->name()),
duke@435	230	usage.init_size(), usage.used(),
duke@435	231	usage.committed(), usage.max_size());
duke@435	232
duke@435	233	_last_gc_stat->set_after_gc_usage(i, usage);
duke@435	234	}
duke@435	235
duke@435	236	// Set last collection usage of the memory pools managed by this collector
duke@435	237	for (i = 0; i < num_memory_pools(); i++) {
duke@435	238	MemoryPool* pool = get_memory_pool(i);
duke@435	239	MemoryUsage usage = pool->get_memory_usage();
duke@435	240
duke@435	241	// Compare with GC usage threshold
duke@435	242	pool->set_last_collection_usage(usage);
duke@435	243	LowMemoryDetector::detect_after_gc_memory(pool);
duke@435	244	}
duke@435	245	}