Node Director
|
Classes | |
class | LDAPAccessor |
Public Member Functions | |
LDAPndk () | |
LDAPndk (String url) | |
void | setCredentials (Credentials cred) |
synchronized void | setURL (String url) throws DirectorException |
DN | completeDN (DN dn) |
Enumeration | search (String expr, final Options searchopt) throws DirectorException |
DBAccessor | get (DN dn) throws DirectorException |
void | replace (DBObject dbo) throws DirectorException |
void | remove (DBObject dbo) throws DirectorException |
void | modify (DBObject dbo, Vector attrs) throws DirectorException |
void | append (DBObject dbo) throws DirectorException |
void | truncate () throws DirectorException |
DN | forceRelative (String name, DN base) |
Public Member Functions inherited from sfi.director.repository.DBConnection | |
String | getURL () |
void | setContext (RemoteJob context) |
void | setOption (String option) |
void | setOption (String option, String val) |
void | setOption (Options opt) |
void | setOption (SURL url) |
String | getOption (String option) |
void | setError (Exception e) |
Exception | getError () |
Enumeration | search (String expr) throws DirectorException |
abstract Enumeration | search (String expr, Options searchopt) throws DirectorException |
void | close () throws DirectorException |
Static Public Member Functions | |
static LDAPAttributeSet | toAttributes (DBObject dbo) |
Static Public Member Functions inherited from sfi.director.repository.DBConnection | |
static Enumeration | unwrap (final Enumeration wrapped) |
Given an Enumeration of DBAccessor objects as returned by the search() method, returns an Enumeration of DBObject objects. | |
static String | escapeSearchval (String val) |
Static Public Attributes | |
static final int | retryLoopDelay = 5000 |
static final int | retryMaxCount = 24 |
Static Public Attributes inherited from sfi.director.repository.DBConnection | |
static final String | SEARCH_BASEDN = "BaseDN" |
used in conjunction with the search() method to set the base DN of the subtree we are about to search (option) | |
static final String | SEARCH_NOSUB = "Sub" |
static final String | SEARCH_WITHSTRUCT = "WithStruct" |
static final String | SEARCH_SORT = "Sort" |
static final String | SEARCH_SCHEMA = "Schema" |
Protected Member Functions | |
LDAPConnection | getLDAPConnection (String host, DN rootDN) |
String | makeName (DN dn) throws DirectorException |
Static Protected Member Functions | |
static boolean | isCommException (LDAPException e) |
static boolean | isCredentialsException (LDAPException e) |
static String | mangleFilter (String filter) |
Protected Attributes | |
LDAPConnection | rootContext |
String | host |
DN | rootDN |
Credentials | accessCreds |
String | orgUrl |
boolean | wasConnectedBefore = false |
boolean | flakyServer = false |
Is our LDAP server not standard-compliant? If set to true the LDAP module will try to emulate some functions. | |
Protected Attributes inherited from sfi.director.repository.DBConnection | |
String | url |
RemoteJob | context |
Options | options = new Options() |
Exception | error = null |
Static Protected Attributes | |
static int | reconnectRetries |
track number of maximum unsuccessful re-connection retries the LDAP is willing to do. | |
static boolean | saslProviderAdded = false |
sfi.director.repository.LDAPndk.LDAPndk | ( | ) |
sfi.director.repository.LDAPndk.LDAPndk | ( | String | url | ) |
|
virtual |
*
DirectorException |
dbo |
Implements sfi.director.repository.DBConnection.
References sfi.director.repository.LDAPndk.isCommException(), sfi.director.repository.LDAPndk.makeName(), sfi.director.repository.LDAPndk.orgUrl, sfi.director.repository.LDAPndk.rootContext, sfi.director.repository.LDAPndk.setURL(), and sfi.director.repository.LDAPndk.toAttributes().
Referenced by sfi.director.repository.LDAPndk.replace().
Reimplemented from sfi.director.repository.DBConnection.
References sfi.director.repository.LDAPndk.rootDN.
DBAccessor sfi.director.repository.LDAPndk.get | ( | DN | dn | ) | throws DirectorException |
|
protected |
Reimplemented in sfi.director.repository.LDAPI.
Referenced by sfi.director.repository.LDAPndk.setURL().
|
staticprotected |
|
staticprotected |
Referenced by sfi.director.repository.LDAPndk.setURL().
|
protected |
References sfi.director.repository.DN.getRaw(), and sfi.director.repository.LDAPndk.rootDN.
Referenced by sfi.director.repository.LDAPndk.append(), sfi.director.repository.LDAPndk.get(), sfi.director.repository.LDAPndk.modify(), sfi.director.repository.LDAPndk.remove(), sfi.director.repository.LDAPndk.replace(), and sfi.director.repository.LDAPndk.search().
|
staticprotected |
void sfi.director.repository.LDAPndk.modify | ( | DBObject | dbo, |
Vector | attrs | ||
) | throws DirectorException |
Reimplemented from sfi.director.repository.DBConnection.
References sfi.director.repository.LDAPndk.isCommException(), sfi.director.repository.LDAPndk.makeName(), sfi.director.repository.LDAPndk.orgUrl, sfi.director.repository.LDAPndk.rootContext, and sfi.director.repository.LDAPndk.setURL().
Referenced by sfi.director.repository.LDAPndk.replace().
void sfi.director.repository.LDAPndk.remove | ( | DBObject | dbo | ) | throws DirectorException |
void sfi.director.repository.LDAPndk.replace | ( | DBObject | dbo | ) | throws DirectorException |
Reimplemented from sfi.director.repository.DBConnection.
References sfi.director.repository.LDAPndk.append(), sfi.director.repository.DBObject.diffAttributes(), sfi.director.repository.DBObject.getAttributes(), sfi.director.repository.DBAccessor.getDBObject(), sfi.director.repository.DBObject.getDN(), sfi.director.repository.DBObject.getValue(), sfi.director.repository.LDAPndk.makeName(), sfi.director.repository.LDAPndk.modify(), sfi.director.repository.DN.parent(), sfi.director.repository.DN.RDNattrs(), and sfi.director.repository.LDAPndk.rootContext.
Enumeration sfi.director.repository.LDAPndk.search | ( | String | expr, |
final Options | searchopt | ||
) | throws DirectorException |
References sfi.director.repository.LDAPndk.forceRelative(), sfi.director.repository.SchemaEnforcer.getAttributesStr(), sfi.director.repository.SchemaEnforcer.getSchemaEnforcer(), sfi.director.repository.LDAPndk.isCommException(), sfi.director.repository.LDAPndk.makeName(), sfi.director.repository.LDAPndk.orgUrl, sfi.director.repository.LDAPndk.rootContext, sfi.director.repository.LDAPndk.rootDN, sfi.director.repository.DBConnection.SEARCH_BASEDN, sfi.director.repository.DBConnection.SEARCH_NOSUB, sfi.director.repository.DBConnection.SEARCH_SCHEMA, sfi.director.repository.DBConnection.SEARCH_SORT, sfi.director.repository.DN.setRaw(), sfi.director.repository.LDAPndk.setURL(), and sfi.director.util.Tools.split().
void sfi.director.repository.LDAPndk.setCredentials | ( | Credentials | cred | ) |
Reimplemented from sfi.director.repository.DBConnection.
References sfi.director.repository.LDAPndk.accessCreds.
synchronized void sfi.director.repository.LDAPndk.setURL | ( | String | url | ) | throws DirectorException |
Reimplemented from sfi.director.repository.DBConnection.
References sfi.director.repository.LDAPndk.accessCreds, sfi.director.util.Tools.debug(), sfi.director.util.Credentials.getCredentials(), sfi.director.repository.LDAPndk.getLDAPConnection(), sfi.director.util.Credentials.getPassword(), sfi.director.util.Credentials.getPrincipal(), sfi.director.repository.LDAPndk.host, sfi.director.util.Credentials.invalidate(), sfi.director.util.Credentials.isCancelled(), sfi.director.repository.LDAPndk.isCredentialsException(), sfi.director.util.Tools.log(), sfi.director.repository.LDAPndk.orgUrl, sfi.director.repository.LDAPndk.reconnectRetries, sfi.director.repository.LDAPndk.retryLoopDelay, sfi.director.repository.LDAPndk.retryMaxCount, sfi.director.repository.LDAPndk.rootContext, sfi.director.repository.LDAPndk.rootDN, sfi.director.repository.LDAPndk.saslProviderAdded, sfi.director.repository.DBConnection.url, sfi.director.util.Logger.WARNING, and sfi.director.repository.LDAPndk.wasConnectedBefore.
Referenced by sfi.director.repository.LDAPndk.append(), sfi.director.repository.LDAPndk.get(), sfi.director.repository.LDAPndk.LDAPndk(), sfi.director.repository.LDAPndk.modify(), sfi.director.repository.LDAPndk.remove(), and sfi.director.repository.LDAPndk.search().
|
static |
References sfi.director.repository.DBObject.getAttribute(), and sfi.director.repository.DBObject.getAttributes().
Referenced by sfi.director.repository.LDAPndk.append().
|
virtual |
Implements sfi.director.repository.DBConnection.
|
protected |
|
protected |
Is our LDAP server not standard-compliant? If set to true the LDAP module will try to emulate some functions.
Currently this does only effect the way how attributes are deleted. LDAP lets you remove attributes by replacing it by replacing them with an empty attribute. At least OpenLDAP 1.x rejects doing so. This is set by the LDAPndk() constructor from Setup.properties (setup property "FlakyLDAPServer" in director.conf).
Referenced by sfi.director.repository.LDAPndk.LDAPndk().
|
protected |
Referenced by sfi.director.repository.LDAPndk.setURL().
|
protected |
|
staticprotected |
track number of maximum unsuccessful re-connection retries the LDAP is willing to do.
This is 'static' since we want to avoid the number of retries increase with the number of open connections.
Referenced by sfi.director.repository.LDAPndk.setURL().
|
static |
Referenced by sfi.director.repository.LDAPndk.setURL().
|
static |
Referenced by sfi.director.repository.LDAPndk.setURL().
|
protected |
Referenced by sfi.director.repository.LDAPndk.append(), sfi.director.repository.LDAPndk.get(), sfi.director.repository.LDAPndk.LDAPndk(), sfi.director.repository.LDAPndk.modify(), sfi.director.repository.LDAPndk.remove(), sfi.director.repository.LDAPndk.replace(), sfi.director.repository.LDAPndk.search(), and sfi.director.repository.LDAPndk.setURL().
|
protected |
|
staticprotected |
Referenced by sfi.director.repository.LDAPndk.setURL().
|
protected |
Referenced by sfi.director.repository.LDAPndk.setURL().