ConnectorConnectionPoolMBeanpublic class ConnectorConnectionPoolMBean extends com.sun.enterprise.admin.config.BaseConfigMBean implements com.sun.enterprise.admin.mbeanapi.IConnectorConnectionPoolMBean
| Fields Summary |
|---|
| private static final String | USER_NAME | | private static final String | PASSWORD | | private static final String | NAME | | private static final String | PRINCIPAL | | private static final String | USER_GROUP | | private static final String | POOL_NAME | | private static final String | MAP_NAME | | private static final String | VERBOSE | | private static final String | ADD_PRINCIPALS | | private static final String | REMOVE_PRINCIPALS | | private static final String | ADD_USER_GROUPS | | private static final String | REMOVE_USER_GROUPS | | private static final String | CREATE_SECURITY_MAP | | private static final String | CREATE_BACKEND_PRINCIPAL | | private static final String | GET_SECURITY_MAP | | private static final String | GET_SECURITY_MAP_BY_NAME | | private static final String | GET_BACKEND_PRINCIPAL | | private static final String | GET_POOL_BY_NAME | | private static final String | DEFAULT_TARGET | | private static final String | GET_CONNECTOR_POOLS | | private static final String | CONFIG | | private static final String | POOL_TYPE | | private static final String | MAP_TYPE | | private static final String | RES_TYPE | | private static final String | POOL_DOES_NOT_EXISTS | | private static final String | MAP_DOES_NOT_EXISTS | | private static final String | MAP_NAME_EXISTS | | private static final String | PRINCIPAL_USERGPS_NULL | | private static final String | PRINCIPAL_EXISTS | | private static final String | USERGROUP_EXISTS | | private static final String | SAME_PRINCIPAL_VALUES | | private static final String | SAME_USERGROUP_VALUES | | private static final String | PRINCIPAL_DOES_NOT_EXISTS | | private static final String | USERGROUP_DOES_NOT_EXISTS | | private static final String | OPERATION_NOT_SUPPORTED | | private static final String | USER_NAME_NULL | | private static final String | PRINCIPALS_USERGROUPS_NULL | | private static com.sun.enterprise.util.i18n.StringManager | localStrings |
| Constructors Summary |
|---|
public ConnectorConnectionPoolMBean()
super();
|
| Methods Summary |
|---|
| private java.lang.String[] | createMapInfo(javax.management.ObjectName mapRef)
String[] existingPrincipals = null;
String[] existingUserGroups = null;
StringBuffer buf1= new StringBuffer();
StringBuffer buf2= new StringBuffer();
String mapname = null;
String username = null;
String password = null;
if(mapRef != null) {
mapname = (String)getMBeanServer().getAttribute(mapRef,NAME);
existingPrincipals =
(String[])getMBeanServer().getAttribute(mapRef,PRINCIPAL);
existingUserGroups =
(String[])getMBeanServer().getAttribute(mapRef,USER_GROUP);
if(existingPrincipals != null){
for(int j=0;j<existingPrincipals.length;j++){
buf1.append(existingPrincipals[j]);
buf1.append(",");
}
}
if(existingUserGroups != null){
for(int j=0;j<existingUserGroups.length;j++){
buf2.append(existingUserGroups[j]);
buf2.append(",");
}
}
ObjectName backEndPrincipal = (ObjectName)getMBeanServer().invoke(
mapRef,GET_BACKEND_PRINCIPAL,null,null);
if(backEndPrincipal != null){
username =
(String)getMBeanServer().getAttribute(backEndPrincipal,USER_NAME);
password =
(String)getMBeanServer().getAttribute(backEndPrincipal,PASSWORD);
}
}
return new String[]{mapname,buf1.toString(),buf2.toString(),username,password};
| | public void | createSecurityMap(javax.management.AttributeList attrList)
// Overriding the BaseConfigMBean operation so that this operation is
// not called by the user, as creation of security map requires
// backend-principal username and password also.
String msg = localStrings.getString(OPERATION_NOT_SUPPORTED);
throw new Exception(msg);
| | public javax.management.ObjectName | createSecurityMap(javax.management.AttributeList attrList, java.lang.String userName, java.lang.String password, java.lang.String tgtName)
ObjectName mbean = null;
String poolName = null;
String mapname = null;
try {
if (tgtName == null || tgtName.equals("")) tgtName = DEFAULT_TARGET;
MBeanServer server = getMBeanServer();
String principals[] = null;
String usergroups[] = null;
if(attrList != null){
int s = attrList.size();
for(int i=0;i<s;i++){
try {
Attribute attribute =(Attribute)attrList.get(i);
if(isAttrNameMatch(attribute, NAME)){
mapname =(String) attribute.getValue();
continue;
}
if (isAttrNameMatch(attribute, PRINCIPAL))
principals = (String[])attribute.getValue();
if (isAttrNameMatch(attribute, USER_GROUP))
usergroups =(String[]) attribute.getValue();
if (isAttrNameMatch(attribute, POOL_NAME))
poolName = (String)attribute.getValue();
} catch(Exception e){
throw new Exception("failed while getting attribute" +
"names and values");
}
}
}
if(!doesPoolNameExists(poolName)){
String msg = localStrings.getString(POOL_DOES_NOT_EXISTS,poolName);
throw new Exception(msg);
}
if(doesMapNameExists(poolName,mapname)){
String msg = localStrings.getString(MAP_NAME_EXISTS
,mapname,poolName);
throw new Exception(msg);
}
//check if backend-principal user name is null
if(userName == null){
String msg = localStrings.getString(USER_NAME_NULL);
throw new Exception(msg);
}
// check if both principals and usergroups are null .If yes throw
// exception since atleast one of these is required.
if(principals == null && usergroups == null){
String msg = localStrings.getString(PRINCIPAL_USERGPS_NULL);
throw new Exception(msg);
}
//get all the security maps for this pool.....
ObjectName[] maps = getAllSecurityMapsForPool(poolName);
if(principals != null){
for(int i=0;i<principals.length;i++){
if (isPrincipalExisting(principals[i],maps)){
String msg = localStrings.getString
(PRINCIPAL_EXISTS,principals[i],poolName);
throw new Exception(msg);
}
}
}
if(usergroups != null){
for(int i=0;i<usergroups.length;i++){
if (isUserGroupExisting(usergroups[i],maps)){
String msg = localStrings.getString
(USERGROUP_EXISTS,usergroups[i],poolName);
throw new Exception(msg);
}
}
}
//This is a temporary fix for 8.0 pe.Currently there is no way you
// can create a security map and its a backend principal in a atomic
// manner . This would need two invoke operations on two different MBeans
// and hence events would be fired as soon as the first invoke operation
// completes which causes a NPE being thrown in the backend while accessing
// the backend principal.
//The direct call to config beans would be used until we find a better solution
// to handle this problem.
ConfigContext serverContext = getConfigContext();
com.sun.enterprise.config.serverbeans.Resources resourcesBean =
(Resources)ConfigBeansFactory.getConfigBeanByXPath(serverContext,
ServerXPathHelper.XPATH_RESOURCES);
com.sun.enterprise.config.serverbeans.ConnectorConnectionPool connPool =
resourcesBean.getConnectorConnectionPoolByName(poolName);
com.sun.enterprise.config.serverbeans.BackendPrincipal backEndPrincipal
= new com.sun.enterprise.config.serverbeans.BackendPrincipal();
backEndPrincipal.setUserName(userName);
if(password != null)
backEndPrincipal.setPassword(password);
com.sun.enterprise.config.serverbeans.SecurityMap securityMap =
new com.sun.enterprise.config.serverbeans.SecurityMap();
if(backEndPrincipal != null)
securityMap.setBackendPrincipal(backEndPrincipal);
if(mapname !=null)
securityMap.setName(mapname);
if(principals != null)
securityMap.setPrincipal(principals);
if(usergroups != null)
securityMap.setUserGroup(usergroups);
connPool.addSecurityMap(securityMap);
}/*catch (MBeanException me){
throw me;
}*/catch (Exception e) {
e.printStackTrace();
throw new MBeanException(e);
}
return mbean;
| | private boolean | doesMapNameExists(java.lang.String poolName, java.lang.String mapname)
//check if the mapname exists for the given pool name..
ObjectName poolObj = getConnectorConnObjectName(poolName);
ObjectName[] maps =(ObjectName[])getMBeanServer().invoke(poolObj,
GET_SECURITY_MAP, null, null);
boolean doesMapNameExists = false;
if (maps!= null && maps.length > 0){
for (int i=0; i<maps.length; i++){
String mapName =
(String)getMBeanServer().getAttribute(maps[i],NAME);
if (mapName.equals(mapname))
doesMapNameExists = true;
}
}
return doesMapNameExists;
| | private boolean | doesPoolNameExists(java.lang.String poolName)
//check if the poolname exists.If it does not then throw an exception.
ObjectName resObj = m_registry.getMbeanObjectName(RES_TYPE,
new String[]{getDomainName(),CONFIG});
ObjectName[] pools =(ObjectName[])getMBeanServer().invoke(resObj,
GET_CONNECTOR_POOLS,null,null);
boolean doesPoolExists = false;
if (pools!= null && pools.length > 0){
for (int i=0; i<pools.length; i++){
String pool = (String)getMBeanServer().getAttribute(pools[i],NAME);
if (pool.equals(poolName))
doesPoolExists = true;
}
}
return doesPoolExists;
| | private javax.management.ObjectName[] | getAllSecurityMapsForPool(java.lang.String poolName)
ObjectName poolObj = getConnectorConnObjectName(poolName);
return (ObjectName[])getMBeanServer().invoke(poolObj,
GET_SECURITY_MAP, null, null);
| | public javax.management.AttributeList | getAttributes(java.lang.String mapName, java.lang.String poolName)
String mapname = null;
String[] existingPrincipals = null;
String[] existingUserGroups = null;
String username = null;
String password = null;
if(mapName != null){
if(!doesMapNameExists(poolName,mapName)){
String msg = localStrings.getString(MAP_DOES_NOT_EXISTS
,mapName,poolName);
throw new Exception(msg);
}
}
ObjectName mapRef =(ObjectName)super.invoke(
GET_SECURITY_MAP_BY_NAME, new Object[]{mapName},
new String[] {"java.lang.String"});
if(mapRef != null) {
mapname = (String)getMBeanServer().getAttribute(mapRef,NAME);
existingPrincipals =
(String[])getMBeanServer().getAttribute(mapRef,PRINCIPAL);
existingUserGroups =
(String[])getMBeanServer().getAttribute(mapRef,USER_GROUP);
}
ObjectName backEndPrincipal = (ObjectName)getMBeanServer().invoke(
mapRef,GET_BACKEND_PRINCIPAL,null,null);
if(backEndPrincipal != null){
username = (String)
getMBeanServer().getAttribute(backEndPrincipal,USER_NAME);
password = (String)
getMBeanServer().getAttribute(backEndPrincipal,PASSWORD);
}
//set the attributes......
AttributeList attributes = new AttributeList();
if(mapname != null)
attributes.add(new Attribute(NAME,mapname));
if(existingPrincipals != null)
attributes.add(new Attribute(PRINCIPAL,existingPrincipals));
if(existingUserGroups != null)
attributes.add(new Attribute(USER_GROUP,existingUserGroups));
if(username != null)
attributes.add(new Attribute(USER_NAME,username));
if(password != null)
attributes.add(new Attribute(PASSWORD,password));
return attributes;
| | protected javax.management.ObjectName | getConfigMBean(com.sun.enterprise.admin.target.Target target)
ConfigTarget ct = target.getConfigTarget();
return new ObjectName(
ct.getTargetObjectName(new String[] {getDomainName()}));
| | private javax.management.ObjectName | getConnectorConnObjectName(java.lang.String poolName)
return m_registry.getMbeanObjectName(POOL_TYPE,
new String[]{getDomainName(),poolName,CONFIG});
| | protected javax.management.MBeanServer | getMBeanServer()
return com.sun.enterprise.admin.common.MBeanServerFactory.getMBeanServer();
| | private java.lang.String[] | getOptionsList(java.lang.Object sOptions)
StringTokenizer optionTokenizer = new StringTokenizer((String)sOptions,",");
int size = optionTokenizer.countTokens();
String [] sOptionsList = new String[size];
for (int ii=0; ii<size; ii++){
sOptionsList[ii] = optionTokenizer.nextToken();
}
return sOptionsList;
| | private javax.management.ObjectName | getSecurityMapObjectName(java.lang.String mapName, java.lang.String poolName)
return m_registry.getMbeanObjectName(MAP_TYPE,
new String[]{getDomainName(),poolName,mapName,CONFIG});
| | private static boolean | isAttrNameMatch(javax.management.Attribute attr, java.lang.String name)
//FIXME: this code should be changed after FCS
// for now we supporting both "dashed" and "underscored" names
return attr.getName().replace('_",'-").equals(name.replace('_",'-"));
| | private boolean | isPrincipalExisting(java.lang.String principal, javax.management.ObjectName[] maps)
boolean exists =false;
String[] existingPrincipals = null;
if (maps!= null && maps.length > 0){
for (int k=0; k<maps.length && !exists ; k++){
existingPrincipals =
(String[])getMBeanServer().getAttribute(maps[k],PRINCIPAL);
if(existingPrincipals != null && principal != null){
for(int i=0; i < existingPrincipals.length ; i++) {
if(existingPrincipals[i].equals(principal)){
exists = true;
break;
}
}
}
}
}
return exists ;
| | private boolean | isUserGroupExisting(java.lang.String usergroup, javax.management.ObjectName[] maps)
boolean exists =false;
String[] existingUserGroups = null;
if (maps!= null && maps.length > 0){
for (int k=0; k<maps.length && !exists ; k++){
existingUserGroups =
(String[])getMBeanServer().getAttribute(maps[k],USER_GROUP);
if(existingUserGroups != null && usergroup != null){
for(int i=0; i < existingUserGroups.length ; i++) {
if(existingUserGroups[i].equals(usergroup)){
exists = true;
break;
}
}
}
}
}
return exists ;
| | public java.util.ArrayList | listSecurityMap(java.lang.String mapName, java.lang.Boolean verb, java.lang.String poolName, java.lang.String tgtName)
ObjectName mbean = null;
boolean verbose = false;
ArrayList list = new ArrayList();
try {
if (tgtName == null || tgtName.equals("")) tgtName = DEFAULT_TARGET;
if(!doesPoolNameExists(poolName)){
String msg = localStrings.getString(POOL_DOES_NOT_EXISTS,poolName);
throw new Exception(msg);
}
if(mapName != null){
if(!doesMapNameExists(poolName,mapName)){
String msg = localStrings.getString(MAP_DOES_NOT_EXISTS
,mapName,poolName);
throw new Exception(msg);
}
}
verbose = verb.booleanValue();
//get all the map object names...
ObjectName[] maps =(ObjectName[]) super.invoke(GET_SECURITY_MAP,null,null);
if(mapName == null && verbose){
if(maps != null && maps.length >0){
for(int i=0;i<maps.length;i++){
String map = (String)getMBeanServer().getAttribute(
maps[i],NAME);
ObjectName mapRef =(ObjectName)super.invoke(
GET_SECURITY_MAP_BY_NAME, new Object[]{map},
new String[] {"java.lang.String"});
list.add(createMapInfo(mapRef));
}
}
}else if( mapName == null && !verbose ){
if(maps != null && maps.length >0){
for(int i=0;i<maps.length;i++){
String map = (String)
getMBeanServer().getAttribute(maps[i],NAME);
AttributeList attr = new AttributeList();
if(map != null)
attr.add(new Attribute(NAME,map));
//print the map names .....
ObjectName mapRef =(ObjectName)
super.invoke(GET_SECURITY_MAP_BY_NAME,new Object[]{map},
new String[] {"java.lang.String"});
String mapname = (String)getMBeanServer().getAttribute(mapRef,NAME);
list.add(new String[]{mapname,null,null,null,null});
}
}
}else {
// map name is not null, print the map details if verbose is true...
ObjectName mapRef =(ObjectName)super.invoke(GET_SECURITY_MAP_BY_NAME,
new Object[]{mapName}, new String[] {"java.lang.String"});
if(mapRef != null) {
if (verbose) {
list.add(createMapInfo(mapRef));
} else {
list.add(new String[]{mapName,null,null,null,null});
}
}
}
}catch (Exception e) {
e.printStackTrace();
throw new MBeanException(e);
}
return list;
| | public boolean | updateSecurityMap(javax.management.AttributeList attrList, java.lang.String tgtName)
String mapname = null;
String poolname = null;
String username = null;
String password = null;
String[] addPrincipals = null;
String[] addUserGroups = null;
String[] removePrincipals = null;
String[] removeUserGroups = null;
boolean status = false;
//ConfigContext ctx = getConfigContext();
try {
if (tgtName == null || tgtName.equals("")) tgtName = DEFAULT_TARGET;
//get all the values from the attribute list ...
if(attrList != null){
int s = attrList.size();
for(int i=0;i<s;i++){
try{
Attribute attribute =(Attribute)attrList.get(i);
if((isAttrNameMatch(attribute, POOL_NAME)))
poolname = (String)attribute.getValue();
if((isAttrNameMatch(attribute, NAME)))
mapname = (String)attribute.getValue();
if((isAttrNameMatch(attribute, USER_NAME)))
username = (String)attribute.getValue();
if((isAttrNameMatch(attribute, PASSWORD)))
password = (String)attribute.getValue();
if((isAttrNameMatch(attribute, ADD_PRINCIPALS)))
addPrincipals =
getOptionsList((String)attribute.getValue());
if((isAttrNameMatch(attribute, ADD_USER_GROUPS)))
addUserGroups =
getOptionsList((String)attribute.getValue());
if((isAttrNameMatch(attribute, REMOVE_PRINCIPALS)))
removePrincipals =
getOptionsList((String)attribute.getValue());
if((isAttrNameMatch(attribute, REMOVE_USER_GROUPS)))
removeUserGroups =
getOptionsList((String)attribute.getValue());
}catch(Exception e){
e.printStackTrace();
}
}
}
if(!doesPoolNameExists(poolname)){
String msg = localStrings.getString(POOL_DOES_NOT_EXISTS,poolname);
throw new Exception(msg);
}
if(!doesMapNameExists(poolname,mapname)){
String msg = localStrings.getString(MAP_DOES_NOT_EXISTS
,mapname,poolname);
throw new Exception(msg);
}
//get all the security maps for this pool.....
ObjectName[] maps = getAllSecurityMapsForPool(poolname);
//check if addPrincipals and removePrincipals have the same value
if(addPrincipals != null && removePrincipals != null){
for(int i=0; i < addPrincipals.length ; i++) {
for (int j=0; j < removePrincipals.length; j++) {
if(removePrincipals[j].equals(addPrincipals[i])){
String msg = localStrings.getString(
SAME_PRINCIPAL_VALUES,addPrincipals[i]);
throw new Exception(msg);
}
}
}
}
//check if addUserGroups and removeUserGroups have the same value
if(addUserGroups != null && removeUserGroups != null){
for(int i=0; i < addUserGroups.length ; i++) {
for (int j=0; j < removeUserGroups.length; j++) {
if(removeUserGroups[j].equals(addUserGroups[i])){
String msg = localStrings.getString(
SAME_USERGROUP_VALUES,addUserGroups[i]);
throw new Exception(msg);
}
}
}
}
// make sure that the principals to be added are not existing in any map ...
if(addPrincipals != null){
for(int i=0;i<addPrincipals.length;i++){
if (isPrincipalExisting(addPrincipals[i],maps)){
String msg = localStrings.getString(PRINCIPAL_EXISTS,
addPrincipals[i],poolname);
throw new Exception(msg);
}
}
}
// make sure that the user groups to be added are not existing in any map ...
if(addUserGroups != null){
for(int i=0;i<addUserGroups.length;i++){
if (isUserGroupExisting(addUserGroups[i],maps)){
String msg = localStrings.getString(USERGROUP_EXISTS
,addUserGroups[i],poolname);
throw new Exception(msg);
}
}
}
//get a reference to the MBean server ...
MBeanServer server = getMBeanServer();
ObjectName mbean = getSecurityMapObjectName(mapname,poolname);
String existingPrincipals[] = null;
String existingUserGroups[] = null;
existingPrincipals =(String[]) server.getAttribute(mbean,PRINCIPAL);
existingUserGroups =(String[]) server.getAttribute(mbean,USER_GROUP);
ArrayList source = null;
ArrayList source1 = null;
if(existingPrincipals != null){
source = new ArrayList(existingPrincipals.length);
for(int i=0; i<existingPrincipals.length ; i++)
source.add(existingPrincipals[i]);
}
if(existingUserGroups != null){
source1 = new ArrayList(existingUserGroups.length);
for(int i=0; i<existingUserGroups.length ; i++)
source1.add(existingUserGroups[i]);
}
//check if there is any invalid principal in removePrincipals.
if(removePrincipals != null){
for(int i=0;i<removePrincipals.length;i++){
String s = removePrincipals[i];
if (!source.contains(s)){
String msg =
localStrings.getString(PRINCIPAL_DOES_NOT_EXISTS,s,poolname);
throw new Exception(msg);
}
}
}
//check if there is any invalid usergroup in removeUserGroups.
if(removeUserGroups != null){
for(int i=0;i<removeUserGroups.length;i++){
String s = removeUserGroups[i];
if (!source1.contains(s)){
String msg =
localStrings.getString(USERGROUP_DOES_NOT_EXISTS,s,poolname);
throw new Exception(msg);
}
}
}
//FIX : Bug 4914883.
//The user should not delete all principals and usergroups in the map.
// Atleast one principal or usergroup must exists.
if(addPrincipals == null && addUserGroups == null ) {
boolean principalsEmpty = false;
boolean userGroupsEmpty = false;
if(removePrincipals == null && existingPrincipals.length==0)
principalsEmpty = true;
if(removeUserGroups == null && existingUserGroups.length==0)
userGroupsEmpty = true;
if (( removePrincipals != null )&&
(removePrincipals.length== existingPrincipals.length))
principalsEmpty = true;
if (( removeUserGroups != null ) &&
(removeUserGroups.length== existingUserGroups.length))
userGroupsEmpty = true;
if (userGroupsEmpty && principalsEmpty) {
String msg = localStrings.getString(PRINCIPALS_USERGROUPS_NULL);
throw new Exception(msg);
}
}
//add principals to the source arraylist.
if(addPrincipals != null){
for(int i=0; i < addPrincipals.length; i++) {
String s= addPrincipals[i];
if (!source.contains(s))
source.add(s);
else{
String msg = localStrings.getString(PRINCIPAL_EXISTS
,s,poolname);
throw new Exception(msg);
}
}
}
//removing principals from source arraylist.
if(removePrincipals != null){
for(int i=0; i <removePrincipals.length ;i++) {
String s = removePrincipals[i];
source.remove(s);
}
}
String newPrincipals[] = new String[source.size()];
for(int i=0; i< source.size(); i++)
newPrincipals[i]=(String) source.get(i);
//adding user-groups....
if(addUserGroups != null){
for(int i=0; i < addUserGroups.length; i++) {
String s= addUserGroups[i];
if (!source1.contains(s))
source1.add(s);
else{
String msg = localStrings.getString
(USERGROUP_EXISTS,s,poolname);
throw new Exception(msg);
}
}
}
//removing user-groups....
if(removeUserGroups != null){
for(int i=0; i <removeUserGroups.length ;i++) {
String s = removeUserGroups[i];
source1.remove(s);
}
}
String newUserGroups[] = new String[source1.size()];
for(int i=0; i< source1.size(); i++)
newUserGroups[i]=(String) source1.get(i);
//setting the updated principal user-group arrays....
Attribute princ =null;
Attribute ug = null;
if(newPrincipals != null){
princ = new Attribute(PRINCIPAL,newPrincipals);
server.setAttribute(mbean,princ);
}
if(newUserGroups != null){
ug = new Attribute(USER_GROUP,newUserGroups);
server.setAttribute(mbean,ug);
}
//updating the backend-principal.......
//get the backend principal for the given security map and pool...
ObjectName backendPrincipal =(ObjectName) getMBeanServer().invoke(
mbean, GET_BACKEND_PRINCIPAL,null,null);
if(username != null){
if(!((String)(server.getAttribute(backendPrincipal,
USER_NAME))).equals(username))
server.setAttribute(backendPrincipal,
new Attribute(USER_NAME,username));
}
if(password != null){
if(!((String)(server.getAttribute(backendPrincipal,
PASSWORD))).equals(password))
server.setAttribute(backendPrincipal,
new Attribute(PASSWORD,password));
}
status = true;
} catch (Exception e) {
status = false;
e.printStackTrace();
throw new MBeanException(e);
}
return status;
|
|
