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

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

src/share/vm/services/memoryManager.cpp

Tue, 11 May 2010 14:35:43 -0700

author

prr

date

Tue, 11 May 2010 14:35:43 -0700

changeset 1840

fb57d4cf76c2

parent 1524

db0d5eba9d20

child 1907

c18cbe5936b8

permissions

-rw-r--r--

6931180: Migration to recent versions of MS Platform SDK
6951582: Build problems on win64
Summary: Changes to enable building JDK7 with Microsoft Visual Studio 2010
Reviewed-by: ohair, art, ccheung, dcubed

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
tonyp@1524	75	GCMemoryManager* MemoryManager::get_g1YoungGen_memory_manager() {
tonyp@1524	76	return (GCMemoryManager*) new G1YoungGenMemoryManager();
tonyp@1524	77	}
tonyp@1524	78
tonyp@1524	79	GCMemoryManager* MemoryManager::get_g1OldGen_memory_manager() {
tonyp@1524	80	return (GCMemoryManager*) new G1OldGenMemoryManager();
tonyp@1524	81	}
tonyp@1524	82
duke@435	83	instanceOop MemoryManager::get_memory_manager_instance(TRAPS) {
duke@435	84	// Must do an acquire so as to force ordering of subsequent
duke@435	85	// loads from anything _memory_mgr_obj points to or implies.
duke@435	86	instanceOop mgr_obj = (instanceOop)OrderAccess::load_ptr_acquire(&_memory_mgr_obj);
duke@435	87	if (mgr_obj == NULL) {
duke@435	88	// It's ok for more than one thread to execute the code up to the locked region.
duke@435	89	// Extra manager instances will just be gc'ed.
duke@435	90	klassOop k = Management::sun_management_ManagementFactory_klass(CHECK_0);
duke@435	91	instanceKlassHandle ik(THREAD, k);
duke@435	92
duke@435	93	Handle mgr_name = java_lang_String::create_from_str(name(), CHECK_0);
duke@435	94
duke@435	95	JavaValue result(T_OBJECT);
duke@435	96	JavaCallArguments args;
duke@435	97	args.push_oop(mgr_name); // Argument 1
duke@435	98
duke@435	99	symbolHandle method_name;
duke@435	100	symbolHandle signature;
duke@435	101	if (is_gc_memory_manager()) {
duke@435	102	method_name = vmSymbolHandles::createGarbageCollector_name();
duke@435	103	signature = vmSymbolHandles::createGarbageCollector_signature();
duke@435	104	args.push_oop(Handle()); // Argument 2 (for future extension)
duke@435	105	} else {
duke@435	106	method_name = vmSymbolHandles::createMemoryManager_name();
duke@435	107	signature = vmSymbolHandles::createMemoryManager_signature();
duke@435	108	}
duke@435	109
duke@435	110	JavaCalls::call_static(&result,
duke@435	111	ik,
duke@435	112	method_name,
duke@435	113	signature,
duke@435	114	&args,
duke@435	115	CHECK_0);
duke@435	116
duke@435	117	instanceOop m = (instanceOop) result.get_jobject();
duke@435	118	instanceHandle mgr(THREAD, m);
duke@435	119
duke@435	120	{
duke@435	121	// Get lock before setting _memory_mgr_obj
duke@435	122	// since another thread may have created the instance
duke@435	123	MutexLocker ml(Management_lock);
duke@435	124
duke@435	125	// Check if another thread has created the management object. We reload
duke@435	126	// _memory_mgr_obj here because some other thread may have initialized
duke@435	127	// it while we were executing the code before the lock.
duke@435	128	//
duke@435	129	// The lock has done an acquire, so the load can't float above it, but
duke@435	130	// we need to do a load_acquire as above.
duke@435	131	mgr_obj = (instanceOop)OrderAccess::load_ptr_acquire(&_memory_mgr_obj);
duke@435	132	if (mgr_obj != NULL) {
duke@435	133	return mgr_obj;
duke@435	134	}
duke@435	135
duke@435	136	// Get the address of the object we created via call_special.
duke@435	137	mgr_obj = mgr();
duke@435	138
duke@435	139	// Use store barrier to make sure the memory accesses associated
duke@435	140	// with creating the management object are visible before publishing
duke@435	141	// its address. The unlock will publish the store to _memory_mgr_obj
duke@435	142	// because it does a release first.
duke@435	143	OrderAccess::release_store_ptr(&_memory_mgr_obj, mgr_obj);
duke@435	144	}
duke@435	145	}
duke@435	146
duke@435	147	return mgr_obj;
duke@435	148	}
duke@435	149
duke@435	150	void MemoryManager::oops_do(OopClosure* f) {
duke@435	151	f->do_oop((oop*) &_memory_mgr_obj);
duke@435	152	}
duke@435	153
duke@435	154	GCStatInfo::GCStatInfo(int num_pools) {
duke@435	155	// initialize the arrays for memory usage
duke@435	156	_before_gc_usage_array = (MemoryUsage*) NEW_C_HEAP_ARRAY(MemoryUsage, num_pools);
duke@435	157	_after_gc_usage_array = (MemoryUsage*) NEW_C_HEAP_ARRAY(MemoryUsage, num_pools);
duke@435	158	size_t len = num_pools * sizeof(MemoryUsage);
duke@435	159	memset(_before_gc_usage_array, 0, len);
duke@435	160	memset(_after_gc_usage_array, 0, len);
duke@435	161	_usage_array_size = num_pools;
duke@435	162	}
duke@435	163
duke@435	164	GCStatInfo::~GCStatInfo() {
duke@435	165	FREE_C_HEAP_ARRAY(MemoryUsage*, _before_gc_usage_array);
duke@435	166	FREE_C_HEAP_ARRAY(MemoryUsage*, _after_gc_usage_array);
duke@435	167	}
duke@435	168
duke@435	169	void GCStatInfo::copy_stat(GCStatInfo* stat) {
duke@435	170	set_index(stat->gc_index());
duke@435	171	set_start_time(stat->start_time());
duke@435	172	set_end_time(stat->end_time());
duke@435	173	assert(_usage_array_size == stat->usage_array_size(), "Must have same array size");
duke@435	174	for (int i = 0; i < _usage_array_size; i++) {
duke@435	175	set_before_gc_usage(i, stat->before_gc_usage_for_pool(i));
duke@435	176	set_after_gc_usage(i, stat->after_gc_usage_for_pool(i));
duke@435	177	}
duke@435	178	}
duke@435	179
duke@435	180	void GCStatInfo::set_gc_usage(int pool_index, MemoryUsage usage, bool before_gc) {
duke@435	181	MemoryUsage* gc_usage_array;
duke@435	182	if (before_gc) {
duke@435	183	gc_usage_array = _before_gc_usage_array;
duke@435	184	} else {
duke@435	185	gc_usage_array = _after_gc_usage_array;
duke@435	186	}
duke@435	187	gc_usage_array[pool_index] = usage;
duke@435	188	}
duke@435	189
duke@435	190	GCMemoryManager::GCMemoryManager() : MemoryManager() {
duke@435	191	_num_collections = 0;
duke@435	192	_last_gc_stat = NULL;
duke@435	193	_num_gc_threads = 1;
duke@435	194	}
duke@435	195
duke@435	196	GCMemoryManager::~GCMemoryManager() {
duke@435	197	delete _last_gc_stat;
duke@435	198	}
duke@435	199
duke@435	200	void GCMemoryManager::initialize_gc_stat_info() {
duke@435	201	assert(MemoryService::num_memory_pools() > 0, "should have one or more memory pools");
duke@435	202	_last_gc_stat = new GCStatInfo(MemoryService::num_memory_pools());
duke@435	203	}
duke@435	204
duke@435	205	void GCMemoryManager::gc_begin() {
duke@435	206	assert(_last_gc_stat != NULL, "Just checking");
duke@435	207	_accumulated_timer.start();
duke@435	208	_num_collections++;
duke@435	209	_last_gc_stat->set_index(_num_collections);
duke@435	210	_last_gc_stat->set_start_time(Management::timestamp());
duke@435	211
duke@435	212	// Keep memory usage of all memory pools
duke@435	213	for (int i = 0; i < MemoryService::num_memory_pools(); i++) {
duke@435	214	MemoryPool* pool = MemoryService::get_memory_pool(i);
duke@435	215	MemoryUsage usage = pool->get_memory_usage();
duke@435	216	_last_gc_stat->set_before_gc_usage(i, usage);
duke@435	217	HS_DTRACE_PROBE8(hotspot, mem__pool__gc__begin,
duke@435	218	name(), strlen(name()),
duke@435	219	pool->name(), strlen(pool->name()),
duke@435	220	usage.init_size(), usage.used(),
duke@435	221	usage.committed(), usage.max_size());
duke@435	222	}
duke@435	223	}
duke@435	224
duke@435	225	void GCMemoryManager::gc_end() {
duke@435	226	_accumulated_timer.stop();
duke@435	227	_last_gc_stat->set_end_time(Management::timestamp());
duke@435	228
duke@435	229	int i;
duke@435	230	// keep the last gc statistics for all memory pools
duke@435	231	for (i = 0; i < MemoryService::num_memory_pools(); i++) {
duke@435	232	MemoryPool* pool = MemoryService::get_memory_pool(i);
duke@435	233	MemoryUsage usage = pool->get_memory_usage();
duke@435	234
duke@435	235	HS_DTRACE_PROBE8(hotspot, mem__pool__gc__end,
duke@435	236	name(), strlen(name()),
duke@435	237	pool->name(), strlen(pool->name()),
duke@435	238	usage.init_size(), usage.used(),
duke@435	239	usage.committed(), usage.max_size());
duke@435	240
duke@435	241	_last_gc_stat->set_after_gc_usage(i, usage);
duke@435	242	}
duke@435	243
duke@435	244	// Set last collection usage of the memory pools managed by this collector
duke@435	245	for (i = 0; i < num_memory_pools(); i++) {
duke@435	246	MemoryPool* pool = get_memory_pool(i);
duke@435	247	MemoryUsage usage = pool->get_memory_usage();
duke@435	248
duke@435	249	// Compare with GC usage threshold
duke@435	250	pool->set_last_collection_usage(usage);
duke@435	251	LowMemoryDetector::detect_after_gc_memory(pool);
duke@435	252	}
duke@435	253	}