Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
openanolis
dragonwell8_jdk
提交
b595fd36
D
dragonwell8_jdk
项目概览
openanolis
/
dragonwell8_jdk
通知
4
Star
2
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
D
dragonwell8_jdk
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
b595fd36
编写于
12月 28, 2012
作者:
S
smarks
浏览文件
操作
浏览文件
下载
差异文件
Merge
上级
c447b091
ff3ecc17
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
177 addition
and
9 deletion
+177
-9
src/share/classes/com/sun/jmx/remote/internal/ServerNotifForwarder.java
...ses/com/sun/jmx/remote/internal/ServerNotifForwarder.java
+10
-6
test/ProblemList.txt
test/ProblemList.txt
+0
-3
test/javax/management/remote/mandatory/notif/ConcurrentModificationTest.java
...nt/remote/mandatory/notif/ConcurrentModificationTest.java
+167
-0
未找到文件。
src/share/classes/com/sun/jmx/remote/internal/ServerNotifForwarder.java
浏览文件 @
b595fd36
...
...
@@ -25,16 +25,15 @@
package
com.sun.jmx.remote.internal
;
import
com.sun.jmx.mbeanserver.Util
;
import
com.sun.jmx.remote.security.NotificationAccessController
;
import
com.sun.jmx.remote.util.ClassLogger
;
import
com.sun.jmx.remote.util.EnvHelp
;
import
java.io.IOException
;
import
java.security.AccessControlContext
;
import
java.security.AccessController
;
import
java.security.PrivilegedAction
;
import
java.security.PrivilegedActionException
;
import
java.security.PrivilegedExceptionAction
;
import
java.util.ArrayList
;
import
java.util.Collections
;
import
java.util.HashMap
;
import
java.util.HashSet
;
...
...
@@ -291,13 +290,18 @@ public class ServerNotifForwarder {
// so that we can know too, and remove the corresponding entry from the listenerMap.
// See 6957378.
private
void
snoopOnUnregister
(
NotificationResult
nr
)
{
Set
<
IdAndFilter
>
delegateSet
=
listenerMap
.
get
(
MBeanServerDelegate
.
DELEGATE_NAME
);
if
(
delegateSet
==
null
||
delegateSet
.
isEmpty
())
{
return
;
List
<
IdAndFilter
>
copy
=
null
;
synchronized
(
listenerMap
)
{
Set
<
IdAndFilter
>
delegateSet
=
listenerMap
.
get
(
MBeanServerDelegate
.
DELEGATE_NAME
);
if
(
delegateSet
==
null
||
delegateSet
.
isEmpty
())
{
return
;
}
copy
=
new
ArrayList
<>(
delegateSet
);
}
for
(
TargetedNotification
tn
:
nr
.
getTargetedNotifications
())
{
Integer
id
=
tn
.
getListenerID
();
for
(
IdAndFilter
idaf
:
delegateSet
)
{
for
(
IdAndFilter
idaf
:
copy
)
{
if
(
idaf
.
id
==
id
)
{
// This is a notification from the MBeanServerDelegate.
Notification
n
=
tn
.
getNotification
();
...
...
test/ProblemList.txt
浏览文件 @
b595fd36
...
...
@@ -148,9 +148,6 @@ java/lang/management/MemoryMXBean/LowMemoryTest2.sh generic-all
# 6959636
javax/management/loading/LibraryLoader/LibraryLoaderTest.java windows-all
# 7120365
javax/management/remote/mandatory/notif/DiffHBTest.java generic-all
############################################################################
# jdk_math
...
...
test/javax/management/remote/mandatory/notif/ConcurrentModificationTest.java
0 → 100644
浏览文件 @
b595fd36
/*
* Copyright (c) 2012, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
*
* This code is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License version 2 only, as
* published by the Free Software Foundation.
*
* This code 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
* version 2 for more details (a copy is included in the LICENSE file that
* accompanied this code).
*
* You should have received a copy of the GNU General Public License version
* 2 along with this work; if not, write to the Free Software Foundation,
* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
*
* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
* or visit www.oracle.com if you need additional information or have any
* questions.
*/
/*
* @test
* @bug 7120365
* @summary test on Concurrent Modification
* @author Shanliang JIANG
* @run main ConcurrentModificationTest
*/
import
java.net.MalformedURLException
;
import
java.util.ConcurrentModificationException
;
import
javax.management.MBeanServer
;
import
javax.management.MBeanServerConnection
;
import
javax.management.MBeanServerFactory
;
import
javax.management.Notification
;
import
javax.management.NotificationListener
;
import
javax.management.ObjectName
;
import
javax.management.remote.JMXConnector
;
import
javax.management.remote.JMXConnectorFactory
;
import
javax.management.remote.JMXConnectorServer
;
import
javax.management.remote.JMXConnectorServerFactory
;
import
javax.management.remote.JMXServiceURL
;
/**
*
*/
public
class
ConcurrentModificationTest
{
private
static
final
String
[]
protocols
=
{
"rmi"
,
"iiop"
,
"jmxmp"
};
private
static
int
number
=
100
;
private
static
final
MBeanServer
mbs
=
MBeanServerFactory
.
createMBeanServer
();
private
static
ObjectName
delegateName
;
private
static
ObjectName
[]
timerNames
=
new
ObjectName
[
number
];
private
static
NotificationListener
[]
listeners
=
new
NotificationListener
[
number
];
private
static
Throwable
uncaughtException
=
null
;
public
static
void
main
(
String
[]
args
)
throws
Exception
{
System
.
out
.
println
(
">>> test on Concurrent Modification."
);
Thread
.
setDefaultUncaughtExceptionHandler
(
new
Thread
.
UncaughtExceptionHandler
()
{
@Override
public
void
uncaughtException
(
Thread
t
,
Throwable
e
)
{
e
.
printStackTrace
();
if
(
e
instanceof
ConcurrentModificationException
)
{
uncaughtException
=
e
;
}
}
});
delegateName
=
new
ObjectName
(
"JMImplementation:type=MBeanServerDelegate"
);
for
(
int
i
=
0
;
i
<
number
;
i
++)
{
timerNames
[
i
]
=
new
ObjectName
(
"MBean:name=Timer"
+
i
);
listeners
[
i
]
=
new
NotificationListener
()
{
@Override
public
void
handleNotification
(
Notification
notification
,
Object
handback
)
{
// nothing
}
};
}
String
errors
=
""
;
for
(
int
i
=
0
;
i
<
protocols
.
length
;
i
++)
{
uncaughtException
=
null
;
System
.
out
.
println
(
">>> Test for protocol "
+
protocols
[
i
]);
test
(
protocols
[
i
]);
if
(
uncaughtException
!=
null
)
{
if
(
""
.
equals
(
errors
))
{
errors
=
"Failed to "
+
protocols
[
i
]
+
": "
+
uncaughtException
;
}
else
{
errors
=
errors
+
", failed to "
+
protocols
[
i
]
+
": "
+
uncaughtException
;
}
System
.
out
.
println
(
">>> FAILED for protocol "
+
protocols
[
i
]);
}
else
{
System
.
out
.
println
(
">>> PASSED for protocol "
+
protocols
[
i
]);
}
}
if
(
""
.
equals
(
errors
))
{
System
.
out
.
println
(
"All Passed!"
);
}
else
{
System
.
out
.
println
(
"!!!!!! Failed."
);
throw
new
RuntimeException
(
errors
);
}
}
private
static
void
test
(
String
proto
)
throws
Exception
{
JMXServiceURL
u
=
new
JMXServiceURL
(
proto
,
null
,
0
);
JMXConnectorServer
server
;
JMXConnector
client
;
try
{
server
=
JMXConnectorServerFactory
.
newJMXConnectorServer
(
u
,
null
,
mbs
);
server
.
start
();
JMXServiceURL
addr
=
server
.
getAddress
();
client
=
JMXConnectorFactory
.
connect
(
addr
,
null
);
}
catch
(
MalformedURLException
e
)
{
System
.
out
.
println
(
">>> not support: "
+
proto
);
return
;
}
final
MBeanServerConnection
mserver
=
client
.
getMBeanServerConnection
();
int
count
=
0
;
boolean
adding
=
true
;
while
(
uncaughtException
==
null
&&
count
++
<
10
)
{
for
(
int
i
=
0
;
i
<
number
;
i
++)
{
listenerOp
(
mserver
,
listeners
[
i
],
adding
);
mbeanOp
(
mserver
,
timerNames
[
i
],
adding
);
}
adding
=
!
adding
;
}
if
(
uncaughtException
!=
null
)
{
// clean
for
(
int
i
=
0
;
i
<
number
;
i
++)
{
try
{
mbeanOp
(
mserver
,
timerNames
[
i
],
false
);
}
catch
(
Exception
e
)
{
}
}
}
client
.
close
();
server
.
stop
();
}
private
static
void
mbeanOp
(
MBeanServerConnection
mserver
,
ObjectName
name
,
boolean
adding
)
throws
Exception
{
if
(
adding
)
{
mserver
.
createMBean
(
"javax.management.timer.Timer"
,
name
);
}
else
{
mserver
.
unregisterMBean
(
name
);
}
}
private
static
void
listenerOp
(
MBeanServerConnection
mserver
,
NotificationListener
listener
,
boolean
adding
)
throws
Exception
{
if
(
adding
)
{
mserver
.
addNotificationListener
(
delegateName
,
listener
,
null
,
null
);
}
else
{
mserver
.
removeNotificationListener
(
delegateName
,
listener
);
}
}
}
\ No newline at end of file
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录