GFAuthConfigFactorypublic class GFAuthConfigFactory extends javax.security.auth.message.config.AuthConfigFactory | This class implements methods in the abstract class AuthConfigFactory. |
| Fields Summary |
|---|
| private static Logger | logger | | private static ReadWriteLock | rwLock | | private static Lock | rLock | | private static Lock | wLock | | private static Map | id2ProviderMap | | private static Map | id2RegisContextMap | | private static Map | id2RegisListenersMap | | private static Map | provider2IdsMap | | private static final String | CONF_FILE_NAME | | private static final RegStoreFileParser | regStore |
| Constructors Summary |
|---|
public GFAuthConfigFactory()
rwLock = new ReentrantReadWriteLock(true);
rLock = rwLock.readLock();
wLock = rwLock.writeLock();
/* Within the GF process, the user.dir location is
* set to be glassfish/domains/domain-in-use/config.
*/
regStore = new RegStoreFileParser(System.getProperty("user.dir"),
CONF_FILE_NAME, false);
GFAuthConfigFactory slave = new GFAuthConfigFactory();
slave._loadFactory();
|
| Methods Summary |
|---|
| private static javax.security.auth.message.config.AuthConfigProvider | _constructProvider(java.lang.String className, java.util.Map properties, javax.security.auth.message.config.AuthConfigFactory factory)
//XXX do we need doPrivilege here
AuthConfigProvider provider = null;
if (className != null) {
try {
ClassLoader loader =
Thread.currentThread().getContextClassLoader();
Class c = Class.forName(className, true, loader);
Constructor<AuthConfigProvider> constr =
c.getConstructor(Map.class, AuthConfigFactory.class);
provider = constr.newInstance
(new Object[] {properties, factory} );
} catch(Exception ex) {
if (logger.isLoggable(Level.FINE)) {
logger.log(Level.FINE,
"Cannot load AuthConfigProvider: " + className, ex);
} else if (logger.isLoggable(Level.WARNING)) {
logger.log(Level.WARNING,
"jmac.factory_unable_to_load_provider",
new String [] { className, ex.toString() });
}
}
}
return provider;
| | private static void | _deleteStoredRegistration(java.lang.String regId, RegistrationContext ctx)
if (ctx.isPersistent()) {
regStore.delete(ctx);
}
| | private void | _loadFactory()
try {
wLock.lock();
id2ProviderMap = new HashMap<String, AuthConfigProvider>();
id2RegisContextMap = new HashMap<String, RegistrationContext>();
id2RegisListenersMap =
new HashMap<String, List<RegistrationListener>>();
provider2IdsMap = new HashMap<AuthConfigProvider, List<String>>();
} finally {
wLock.unlock();
}
try {
for (EntryInfo info : regStore.getPersistedEntries()) {
if (info.isConstructorEntry()) {
_constructProvider(info.getClassName(),
info.getProperties(), this);
} else {
for (RegistrationContext ctx : info.getRegContexts()) {
registerConfigProvider(info.getClassName(),
info.getProperties(), ctx.getMessageLayer(),
ctx.getAppContext(), ctx.getDescription());
}
}
}
} catch (Exception e) {
if (logger.isLoggable(Level.WARNING)) {
logger.log(Level.WARNING,
"jmac.factory_auth_config_loader_failure");
}
}
| | private static java.lang.String | _register(javax.security.auth.message.config.AuthConfigProvider provider, java.util.Map properties, java.lang.String layer, java.lang.String appContext, java.lang.String description, boolean persist)
String regisID = getRegistrationID(layer, appContext);
RegistrationContext rc =
new RegistrationContextImpl(layer,appContext,description,persist);
RegistrationContext prevRegisContext = null;
List<RegistrationListener> listeners = null;
try {
wLock.lock();
prevRegisContext = id2RegisContextMap.get(regisID);
AuthConfigProvider prevProvider = id2ProviderMap.get(regisID);
id2ProviderMap.put(regisID, provider);
id2RegisContextMap.put(regisID, rc);
if (prevProvider != null) {
List<String> prevRegisIDs = provider2IdsMap.get(prevProvider);
prevRegisIDs.remove(regisID);
if ((!prevProvider.equals(provider)) &&
prevRegisIDs.size() == 0) { // cleanup
provider2IdsMap.remove(prevProvider);
}
}
List<String> regisIDs = provider2IdsMap.get(provider);
if (regisIDs == null) {
regisIDs = new ArrayList<String>();
provider2IdsMap.put(provider, regisIDs);
}
regisIDs.add(regisID);
if ((provider != null && (!provider.equals(prevProvider))) ||
(provider == null && prevProvider != null)) {
listeners = id2RegisListenersMap.get(regisID);
}
} finally {
wLock.unlock();
if (persist) {
_storeRegistration(regisID, rc, provider,properties);
} else if (prevRegisContext != null && prevRegisContext.isPersistent()) {
_deleteStoredRegistration(regisID, prevRegisContext);
}
}
// outside wLock to prevent dead lock
if (listeners != null && listeners.size() > 0) {
for (RegistrationListener listener : listeners) {
listener.notify(layer, appContext);
}
}
return regisID;
| | private static void | _storeRegistration(java.lang.String regId, RegistrationContext ctx, javax.security.auth.message.config.AuthConfigProvider p, java.util.Map properties)
String className = null;
if (p != null) {
className = p.getClass().getName();
}
if (ctx.isPersistent()) {
regStore.store(className, ctx, properties);
}
| | private static boolean | _unRegister(java.lang.String regisID)
boolean rvalue = false;
RegistrationContext rc = null;;
List<RegistrationListener> listeners = null;
String[] dIds = decomposeRegisID(regisID);
try {
wLock.lock();
rc = id2RegisContextMap.remove(regisID);
AuthConfigProvider provider = id2ProviderMap.remove(regisID);
List<String> regisIDs = provider2IdsMap.get(provider);
if (regisIDs != null) {
regisIDs.remove(regisID);
}
if (regisIDs == null || regisIDs.size() == 0) {
provider2IdsMap.remove(provider);
}
listeners = id2RegisListenersMap.remove(regisID);
rvalue = (provider != null);
} finally {
wLock.unlock();
if (rc != null && rc.isPersistent()) {
_deleteStoredRegistration(regisID, rc);
}
}
// outside wLock to prevent dead lock
if (listeners != null && listeners.size() > 0) {
for (RegistrationListener listener : listeners) {
listener.notify(dIds[0], dIds[1]);
}
}
return rvalue;
| | private static java.lang.String[] | decomposeRegisID(java.lang.String regisID)This API decomposes the given regisID into layer and appContext.
String layer = null;
String appContext = null;
if (regisID.equals("__0")) {
// null, null
} else if (regisID.startsWith("__1")) {
appContext = (regisID.length() == 3)?
"" : regisID.substring(3);
} else if (regisID.startsWith("__2")) {
layer = (regisID.length() == 3)?
"" : regisID.substring(3);
} else if (regisID.startsWith("__3")) {
int ind = regisID.indexOf('_", 3);
if (regisID.length() > 3 && ind > 0) {
String numberString = regisID.substring(3, ind);
int n;
try {
n = Integer.parseInt(numberString);
} catch(Exception ex) {
throw new IllegalArgumentException();
}
layer = regisID.substring(ind + 1, ind + 1 + n);
appContext = regisID.substring(ind + 1 + n);
} else {
throw new IllegalArgumentException();
}
} else {
throw new IllegalArgumentException();
}
return new String[] { layer, appContext };
| | public java.lang.String[] | detachListener(javax.security.auth.message.config.RegistrationListener listener, java.lang.String layer, java.lang.String appContext)Disassociate the listener from all the provider
registrations whose layer and appContext values are matched
by the corresponding arguments to this method.
String regisID = getRegistrationID(layer, appContext);
try {
wLock.lock();
RegistrationListener ler = null;
List<RegistrationListener> listeners =
id2RegisListenersMap.get(regisID);
if (listeners != null && listeners.remove(listener)) {
ler = listener;
}
return (ler != null)? new String[]{ regisID } : new String[0];
} finally {
wLock.unlock();
}
| | public javax.security.auth.message.config.AuthConfigProvider | getConfigProvider(java.lang.String layer, java.lang.String appContext, javax.security.auth.message.config.RegistrationListener listener)Get a registered AuthConfigProvider from the factory.
Get the provider of ServerAuthConfig and/or
ClientAuthConfig objects registered for the identified message
layer and application context.
AuthConfigProvider provider = null;
String regisID = getRegistrationID(layer, appContext);
try {
rLock.lock();
provider = id2ProviderMap.get(regisID);
if (provider == null) {
provider = id2ProviderMap.get(getRegistrationID(null, appContext));
}
if (provider == null) {
provider = id2ProviderMap.get(getRegistrationID(layer, null));
}
if (provider == null) {
provider = id2ProviderMap.get(getRegistrationID(null, null));
}
} finally {
rLock.unlock();
}
if (listener != null) {
// do this check first to try to optimize the multiple thread env
boolean lregister = false;
try {
rLock.lock();
List<RegistrationListener> listeners =
id2RegisListenersMap.get(regisID);
if (listeners != null) {
lregister = listeners.contains(listener);
}
} finally {
rLock.unlock();
}
if (!lregister) {
try {
wLock.lock();
List<RegistrationListener> listeners =
id2RegisListenersMap.get(regisID);
if (listeners == null) {
listeners = new ArrayList<RegistrationListener>();
id2RegisListenersMap.put(regisID, listeners);
}
if (!listeners.contains(listener)) {
listeners.add(listener);
}
} finally {
wLock.unlock();
}
}
}
return provider;
| | static java.util.List | getDefaultProviders()
List<EntryInfo> entries = new ArrayList<EntryInfo>(2);
entries.add(new EntryInfo(
"com.sun.xml.wss.provider.wsit.WSITAuthConfigProvider", null));
entries.add(new EntryInfo(
GFServerConfigProvider.class.getName(), null));
return entries;
| | public RegistrationContext | getRegistrationContext(java.lang.String registrationID)Get the the registration context for the identified registration.
try {
rLock.lock();
return id2RegisContextMap.get(registrationID);
} finally {
rLock.unlock();
}
| | private static java.lang.String | getRegistrationID(java.lang.String layer, java.lang.String appContext)
String regisID = null;
// __0 (null, null)
// __1<appContext> (null, appContext)
// __2<layer> (layer, null)
// __3<nn>_<layer><appContext> (layer, appContext)
if (layer != null) {
regisID = (appContext != null) ?
"__3" + layer.length() + "_" + layer + appContext :
"__2" + layer;
} else {
regisID = (appContext != null) ?
"__1" + appContext :
"__0";
}
return regisID;
| | public java.lang.String[] | getRegistrationIDs(javax.security.auth.message.config.AuthConfigProvider provider)Get the registration identifiers for all registrations of the
provider instance at the factory.
try {
rLock.lock();
Collection<String> regisIDs = null;
if (provider != null) {
regisIDs = provider2IdsMap.get(provider);
} else {
Collection<List<String>> collList = provider2IdsMap.values();
if (collList != null) {
regisIDs = new HashSet<String>();
for (List<String> listIds : collList) {
if (listIds != null) {
regisIDs.addAll(listIds);
}
}
}
}
return ((regisIDs != null)?
regisIDs.toArray(new String[regisIDs.size()]) :
new String[0]);
} finally {
rLock.unlock();
}
| | public void | refresh()Cause the factory to reprocess its persisent declarative
representation of provider registrations.
A factory should only replace an existing registration when
a change of provider implementation class or initialization
properties has occured. re
_loadFactory();
| | public java.lang.String | registerConfigProvider(java.lang.String className, java.util.Map properties, java.lang.String layer, java.lang.String appContext, java.lang.String description)Registers within the factory, a provider
of ServerAuthConfig and/or ClientAuthConfig objects for a
message layer and application context identifier.
At most one registration may exist within the factory for a
given combination of message layer
and appContext. Any pre-existing
registration with identical values for layer and appContext is replaced
by a subsequent registration. When replacement occurs, the registration
identifier, layer, and appContext identifier remain unchanged,
and the AuthConfigProvider (with initialization properties) and
description are replaced.
Within the lifetime of its Java process, a factory must assign unique
registration identifiers to registrations, and must never
assign a previously used registration identifier to a registration
whose message layer and or appContext identifier differ from
the previous use.
Programmatic registrations performed via this method must update
(according to the replacement rules described above), the persistent
declarative representation of provider registrations employed by the
factory constructor.
//XXX do we need doPrivilege here
AuthConfigProvider provider =
_constructProvider(className, properties, null);
return _register(provider,properties,
layer,appContext,description,true);
| | public java.lang.String | registerConfigProvider(javax.security.auth.message.config.AuthConfigProvider provider, java.lang.String layer, java.lang.String appContext, java.lang.String description)
return _register(provider,null,layer,appContext,description,false);
| | public boolean | removeRegistration(java.lang.String registrationID)Remove the identified provider registration from the factory
and invoke any listeners associated with the removed registration.
return _unRegister(registrationID);
|
|
