OPENDJ-3037 inlined DirectoryServer methods that delegate to the schema
| | |
| | | if (attribute.getAttributeDescription().getAttributeType().isObjectClass()) { |
| | | for (ByteString attrName : attribute) { |
| | | try { |
| | | entry.addObjectClass(DirectoryServer.getObjectClass(attrName.toString())); |
| | | entry.addObjectClass(DirectoryServer.getSchema().getObjectClass(attrName.toString())); |
| | | } catch (DirectoryException e) { |
| | | throw new IllegalStateException(e.getMessage(), e); |
| | | } |
| | |
| | | for (Object value : getAttributeValues(attrType.getNameOrOID())) |
| | | { |
| | | String ocName = value.toString().trim(); |
| | | objectClasses.put(DirectoryServer.getObjectClass(ocName), ocName); |
| | | objectClasses.put(DirectoryServer.getSchema().getObjectClass(ocName), ocName); |
| | | } |
| | | } |
| | | else |
| | |
| | | for (Object value : csr.getAttributeValues(attrType.getNameOrOID())) |
| | | { |
| | | String ocName = value.toString().trim(); |
| | | objectClasses.put(DirectoryServer.getObjectClass(ocName), ocName); |
| | | objectClasses.put(DirectoryServer.getSchema().getObjectClass(ocName), ocName); |
| | | } |
| | | } |
| | | else |
| | |
| | | final LinkedHashMap<ObjectClass, String> ocMap = new LinkedHashMap<>(objectClassNames.size()); |
| | | for (final String name : objectClassNames) |
| | | { |
| | | ocMap.put(DirectoryServer.getObjectClass(name), name); |
| | | ocMap.put(DirectoryServer.getSchema().getObjectClass(name), name); |
| | | } |
| | | if (sync) |
| | | { |
| | |
| | | |
| | | private void add(String attrName, Syntax syntax, Object attrValue) |
| | | { |
| | | AttributeType attrType = getAttributeType(attrName, syntax); |
| | | AttributeType attrType = getSchema().getAttributeType(attrName, syntax); |
| | | attrs.add(Attributes.create(attrType, String.valueOf(attrValue))); |
| | | } |
| | | |
| | |
| | | // Construct the backup base entry. |
| | | LinkedHashMap<ObjectClass,String> objectClasses = new LinkedHashMap<>(2); |
| | | objectClasses.put(CoreSchema.getTopObjectClass(), OC_TOP); |
| | | objectClasses.put(DirectoryServer.getObjectClass(OC_UNTYPED_OBJECT_LC), OC_UNTYPED_OBJECT); |
| | | objectClasses.put(DirectoryServer.getSchema().getObjectClass(OC_UNTYPED_OBJECT_LC), OC_UNTYPED_OBJECT); |
| | | |
| | | LinkedHashMap<AttributeType,List<Attribute>> opAttrs = new LinkedHashMap<>(0); |
| | | LinkedHashMap<AttributeType,List<Attribute>> userAttrs = new LinkedHashMap<>(1); |
| | |
| | | // Construct the backup directory entry to return. |
| | | LinkedHashMap<ObjectClass,String> ocMap = new LinkedHashMap<>(2); |
| | | ocMap.put(CoreSchema.getTopObjectClass(), OC_TOP); |
| | | ocMap.put(DirectoryServer.getObjectClass(OC_BACKUP_DIRECTORY), OC_BACKUP_DIRECTORY); |
| | | ocMap.put(DirectoryServer.getSchema().getObjectClass(OC_BACKUP_DIRECTORY), OC_BACKUP_DIRECTORY); |
| | | |
| | | LinkedHashMap<AttributeType,List<Attribute>> opAttrs = new LinkedHashMap<>(0); |
| | | LinkedHashMap<AttributeType,List<Attribute>> userAttrs = new LinkedHashMap<>(3); |
| | |
| | | // Construct the backup entry to return. |
| | | LinkedHashMap<ObjectClass, String> ocMap = new LinkedHashMap<>(3); |
| | | ocMap.put(CoreSchema.getTopObjectClass(), OC_TOP); |
| | | ocMap.put(DirectoryServer.getObjectClass(OC_BACKUP_INFO), OC_BACKUP_INFO); |
| | | ocMap.put(DirectoryServer.getSchema().getObjectClass(OC_BACKUP_INFO), OC_BACKUP_INFO); |
| | | ocMap.put(CoreSchema.getExtensibleObjectObjectClass(), OC_EXTENSIBLE_OBJECT); |
| | | |
| | | LinkedHashMap<AttributeType, List<Attribute>> opAttrs = new LinkedHashMap<>(0); |
| | |
| | | static |
| | | { |
| | | CHANGELOG_ROOT_OBJECT_CLASSES.put(CoreSchema.getTopObjectClass(), OC_TOP); |
| | | CHANGELOG_ROOT_OBJECT_CLASSES.put(DirectoryServer.getObjectClass("container"), "container"); |
| | | CHANGELOG_ROOT_OBJECT_CLASSES.put(DirectoryServer.getSchema().getObjectClass("container"), "container"); |
| | | } |
| | | |
| | | /** The set of objectclasses that will be used in ECL entries. */ |
| | |
| | | static |
| | | { |
| | | CHANGELOG_ENTRY_OBJECT_CLASSES.put(CoreSchema.getTopObjectClass(), OC_TOP); |
| | | CHANGELOG_ENTRY_OBJECT_CLASSES.put(DirectoryServer.getObjectClass(OC_CHANGELOG_ENTRY), OC_CHANGELOG_ENTRY); |
| | | CHANGELOG_ENTRY_OBJECT_CLASSES.put(getSchema().getObjectClass(OC_CHANGELOG_ENTRY), OC_CHANGELOG_ENTRY); |
| | | } |
| | | |
| | | /** The attribute type for the "creatorsName" attribute. */ |
| | |
| | | |
| | | // Construct the set of objectclasses to include in the base monitor entry. |
| | | monitorObjectClasses.put(CoreSchema.getTopObjectClass(), OC_TOP); |
| | | monitorObjectClasses.put(DirectoryServer.getObjectClass(OC_MONITOR_ENTRY), OC_MONITOR_ENTRY); |
| | | monitorObjectClasses.put(DirectoryServer.getSchema().getObjectClass(OC_MONITOR_ENTRY), OC_MONITOR_ENTRY); |
| | | |
| | | // Create the set of base DNs that we will handle. In this case, it's just |
| | | // the DN of the base monitor entry. |
| | |
| | | */ |
| | | private Entry getBranchMonitorEntry(final DN dn) |
| | | { |
| | | final ObjectClass monitorOC = DirectoryServer.getObjectClass(OC_MONITOR_BRANCH); |
| | | final ObjectClass monitorOC = DirectoryServer.getSchema().getObjectClass(OC_MONITOR_BRANCH); |
| | | final HashMap<ObjectClass, String> monitorClasses = newObjectClasses(monitorOC, OC_MONITOR_BRANCH); |
| | | |
| | | final HashMap<AttributeType, List<Attribute>> monitorUserAttrs = new LinkedHashMap<>(); |
| | |
| | | */ |
| | | package org.opends.server.backends; |
| | | |
| | | import static org.forgerock.opendj.ldap.schema.CoreSchema.*; |
| | | import static org.opends.messages.BackendMessages.*; |
| | | import static org.opends.server.util.ServerConstants.*; |
| | | import static org.opends.server.util.StaticUtils.*; |
| | |
| | | import org.forgerock.opendj.ldap.ResultCode; |
| | | import org.forgerock.opendj.ldap.SearchScope; |
| | | import org.forgerock.opendj.ldap.schema.AttributeType; |
| | | import org.forgerock.opendj.ldap.schema.CoreSchema; |
| | | import org.forgerock.opendj.ldap.schema.ObjectClass; |
| | | import org.forgerock.opendj.server.config.server.BackendCfg; |
| | | import org.opends.server.api.Backend; |
| | |
| | | |
| | | // Initialize null entry object classes. |
| | | objectClasses = new HashMap<>(); |
| | | objectClasses.put(CoreSchema.getTopObjectClass(), OC_TOP); |
| | | objectClasses.put(getTopObjectClass(), OC_TOP); |
| | | objectClasses.put(getExtensibleObjectObjectClass(), "extensibleobject"); |
| | | |
| | | String nulOCName = "nullbackendobject"; |
| | | ObjectClass nulOC = DirectoryServer.getObjectClass(nulOCName); |
| | | ObjectClass nulOC = DirectoryServer.getSchema().getObjectClass(nulOCName); |
| | | try { |
| | | DirectoryServer.getSchema().registerObjectClass(nulOC, new ServerSchemaElement(nulOC).getSchemaFile(), false); |
| | | } catch (DirectoryException de) { |
| | |
| | | throw new InitializationException(de.getMessageObject()); |
| | | } |
| | | objectClasses.put(nulOC, nulOCName); |
| | | |
| | | String extOCName = "extensibleobject"; |
| | | ObjectClass extOC = DirectoryServer.getObjectClass(extOCName); |
| | | if (extOC.isPlaceHolder()) { |
| | | throw new InitializationException(LocalizableMessage.raw("Unable to locate " + extOCName + |
| | | " objectclass in the current server schema")); |
| | | } |
| | | objectClasses.put(extOC, extOCName); |
| | | } |
| | | |
| | | @Override |
| | |
| | | // Construct the set of objectclasses to include in the root DSE entry. |
| | | dseObjectClasses = new HashMap<>(2); |
| | | dseObjectClasses.put(getTopObjectClass(), OC_TOP); |
| | | dseObjectClasses.put(DirectoryServer.getObjectClass(OC_ROOT_DSE), OC_ROOT_DSE); |
| | | dseObjectClasses.put(DirectoryServer.getSchema().getObjectClass(OC_ROOT_DSE), OC_ROOT_DSE); |
| | | |
| | | // Set the backend ID for this backend. The identifier needs to be |
| | | // specific enough to avoid conflict with user backend identifiers. |
| | |
| | | // Construct the set of objectclasses to include in the schema entry. |
| | | schemaObjectClasses = new LinkedHashMap<>(3); |
| | | schemaObjectClasses.put(CoreSchema.getTopObjectClass(), OC_TOP); |
| | | schemaObjectClasses.put(DirectoryServer.getObjectClass(OC_LDAP_SUBENTRY_LC), OC_LDAP_SUBENTRY); |
| | | schemaObjectClasses.put(DirectoryServer.getObjectClass(OC_SUBSCHEMA), OC_SUBSCHEMA); |
| | | schemaObjectClasses.put(DirectoryServer.getSchema().getObjectClass(OC_LDAP_SUBENTRY_LC), OC_LDAP_SUBENTRY); |
| | | schemaObjectClasses.put(DirectoryServer.getSchema().getObjectClass(OC_SUBSCHEMA), OC_SUBSCHEMA); |
| | | |
| | | configEntryDN = configEntry.getName(); |
| | | baseDNs = cfg.getBaseDN(); |
| | |
| | | { |
| | | Map<ObjectClass,String> objectClasses = new LinkedHashMap<>(); |
| | | objectClasses.put(CoreSchema.getTopObjectClass(), OC_TOP); |
| | | objectClasses.put(DirectoryServer.getObjectClass(OC_LDAP_SUBENTRY_LC), OC_LDAP_SUBENTRY); |
| | | objectClasses.put(DirectoryServer.getObjectClass(OC_SUBSCHEMA), OC_SUBSCHEMA); |
| | | objectClasses.put(DirectoryServer.getSchema().getObjectClass(OC_LDAP_SUBENTRY_LC), OC_LDAP_SUBENTRY); |
| | | objectClasses.put(DirectoryServer.getSchema().getObjectClass(OC_SUBSCHEMA), OC_SUBSCHEMA); |
| | | |
| | | Map<AttributeType,List<Attribute>> userAttributes = new LinkedHashMap<>(); |
| | | Map<AttributeType,List<Attribute>> operationalAttributes = new LinkedHashMap<>(); |
| | |
| | | // Construct the trust store base entry. |
| | | LinkedHashMap<ObjectClass,String> objectClasses = new LinkedHashMap<>(2); |
| | | objectClasses.put(CoreSchema.getTopObjectClass(), OC_TOP); |
| | | objectClasses.put(DirectoryServer.getObjectClass("ds-cfg-branch"), "ds-cfg-branch"); |
| | | objectClasses.put(DirectoryServer.getSchema().getObjectClass("ds-cfg-branch"), "ds-cfg-branch"); |
| | | |
| | | LinkedHashMap<AttributeType,List<Attribute>> userAttrs = new LinkedHashMap<>(1); |
| | | for (AVA ava : getBaseDN().rdn()) |
| | |
| | | // Construct the certificate entry to return. |
| | | LinkedHashMap<ObjectClass,String> ocMap = new LinkedHashMap<>(2); |
| | | ocMap.put(CoreSchema.getTopObjectClass(), OC_TOP); |
| | | ocMap.put(DirectoryServer.getObjectClass(OC_CRYPTO_INSTANCE_KEY), OC_CRYPTO_INSTANCE_KEY); |
| | | ocMap.put(DirectoryServer.getSchema().getObjectClass(OC_CRYPTO_INSTANCE_KEY), OC_CRYPTO_INSTANCE_KEY); |
| | | |
| | | LinkedHashMap<AttributeType,List<Attribute>> opAttrs = new LinkedHashMap<>(0); |
| | | LinkedHashMap<AttributeType,List<Attribute>> userAttrs = new LinkedHashMap<>(3); |
| | |
| | | throw new DirectoryException(ResultCode.ENTRY_ALREADY_EXISTS, message); |
| | | } |
| | | |
| | | if (entry.hasObjectClass(DirectoryServer.getObjectClass(OC_SELF_SIGNED_CERT_REQUEST))) |
| | | if (entry.hasObjectClass(DirectoryServer.getSchema().getObjectClass(OC_SELF_SIGNED_CERT_REQUEST))) |
| | | { |
| | | try |
| | | { |
| | |
| | | for (ByteString os : a.getValues()) |
| | | { |
| | | String ocName = os.toString(); |
| | | objectClasses.put(getObjectClass(ocName), ocName); |
| | | objectClasses.put(getSchema().getObjectClass(ocName), ocName); |
| | | } |
| | | } |
| | | else if (attrType.isOperational()) |
| | |
| | | import org.forgerock.opendj.ldap.DN; |
| | | import org.forgerock.opendj.ldap.ResultCode; |
| | | import org.forgerock.opendj.ldap.schema.AttributeType; |
| | | import org.forgerock.opendj.ldap.schema.ObjectClass; |
| | | import org.forgerock.opendj.ldap.schema.Syntax; |
| | | import org.forgerock.opendj.server.config.server.AlertHandlerCfg; |
| | | import org.forgerock.opendj.server.config.server.ConnectionHandlerCfg; |
| | | import org.forgerock.opendj.server.config.server.CryptoManagerCfg; |
| | |
| | | } |
| | | |
| | | /** |
| | | * Retrieves the objectclass for the provided name or OID. It can optionally return a generated |
| | | * "default" version if the requested objectclass is not defined in the schema. |
| | | * |
| | | * @param nameOrOid |
| | | * The name or OID for the objectclass to retrieve. |
| | | * @return The objectclass type, or {@code null} if there is no objectclass with the specified |
| | | * name or OID defined in the server schema and a default class should not be returned. |
| | | */ |
| | | public static ObjectClass getObjectClass(String nameOrOid) |
| | | { |
| | | return directoryServer.schema.getObjectClass(nameOrOid); |
| | | } |
| | | |
| | | /** |
| | | * Retrieves the attribute type for the provided name or OID. It can optionally return a generated |
| | | * placeholder version if the requested attribute type is not defined in the schema. |
| | | * |
| | |
| | | */ |
| | | public static AttributeType getAttributeType(String nameOrOid) |
| | | { |
| | | return getAttributeType(nameOrOid, getSchema().getDefaultSyntax()); |
| | | } |
| | | |
| | | /** |
| | | * Retrieves the attribute type for the provided name or OID. It will return a generated |
| | | * placeholder version with the name or OID if the requested attribute type is not defined in the |
| | | * schema. |
| | | * |
| | | * @param nameOrOid |
| | | * The name or OID for the attribute type to look for. |
| | | * @param syntax |
| | | * The syntax for the attribute type to generate. |
| | | * @return The requested attribute type, or a generated placeholder version if there is no |
| | | * attribute with the specified type defined in the server schema |
| | | */ |
| | | public static AttributeType getAttributeType(String nameOrOid, Syntax syntax) |
| | | { |
| | | return directoryServer.schema.getAttributeType(nameOrOid, syntax); |
| | | return getSchema().getAttributeType(nameOrOid, getSchema().getDefaultSyntax()); |
| | | } |
| | | |
| | | /** |
| | |
| | | public SubentryPasswordPolicy(SubEntry subentry) throws DirectoryException |
| | | { |
| | | // Determine if this is a password policy subentry. |
| | | ObjectClass pwdPolicyOC = DirectoryServer.getObjectClass(PWD_OC_POLICY); |
| | | ObjectClass pwdPolicyOC = DirectoryServer.getSchema().getObjectClass(PWD_OC_POLICY); |
| | | Entry entry = subentry.getEntry(); |
| | | Map<ObjectClass, String> objectClasses = entry.getObjectClasses(); |
| | | if (pwdPolicyOC.isPlaceHolder()) |
| | |
| | | |
| | | // Now check for the pwdValidatorPolicy OC and its attribute. |
| | | // Determine if this is a password validator policy object class. |
| | | ObjectClass pwdValidatorPolicyOC = DirectoryServer.getObjectClass(PWD_OC_VALIDATORPOLICY); |
| | | ObjectClass pwdValidatorPolicyOC = DirectoryServer.getSchema().getObjectClass(PWD_OC_VALIDATORPOLICY); |
| | | if (!pwdValidatorPolicyOC.isPlaceHolder() && |
| | | objectClasses.containsKey(pwdValidatorPolicyOC)) |
| | | { |
| | |
| | | import javax.net.ssl.SSLContext; |
| | | import javax.net.ssl.TrustManager; |
| | | |
| | | import net.jcip.annotations.GuardedBy; |
| | | |
| | | import org.forgerock.i18n.LocalizableMessage; |
| | | import org.forgerock.i18n.slf4j.LocalizedLogger; |
| | | import org.forgerock.opendj.config.server.ConfigChangeResult; |
| | | import org.forgerock.opendj.config.server.ConfigException; |
| | | import org.forgerock.opendj.config.server.ConfigurationChangeListener; |
| | | import org.forgerock.opendj.ldap.ByteString; |
| | | import org.forgerock.opendj.ldap.DN; |
| | | import org.forgerock.opendj.ldap.ModificationType; |
| | |
| | | import org.forgerock.opendj.ldap.SearchScope; |
| | | import org.forgerock.opendj.ldap.schema.AttributeType; |
| | | import org.forgerock.opendj.ldap.schema.CoreSchema; |
| | | import org.forgerock.opendj.ldap.schema.ObjectClass; |
| | | import org.forgerock.opendj.server.config.server.CryptoManagerCfg; |
| | | import org.forgerock.util.Reject; |
| | | import org.opends.admin.ads.ADSContext; |
| | | import org.forgerock.opendj.config.server.ConfigurationChangeListener; |
| | | import org.forgerock.opendj.server.config.server.CryptoManagerCfg; |
| | | import org.opends.server.api.Backend; |
| | | import org.opends.server.backends.TrustStoreBackend; |
| | | import org.opends.server.core.AddOperation; |
| | |
| | | import org.opends.server.types.IdentifiedException; |
| | | import org.opends.server.types.InitializationException; |
| | | import org.opends.server.types.Modification; |
| | | import org.forgerock.opendj.ldap.schema.ObjectClass; |
| | | import org.opends.server.types.SearchResultEntry; |
| | | import org.opends.server.util.Base64; |
| | | import org.opends.server.util.SelectableCertificateKeyManager; |
| | | import org.opends.server.util.ServerConstants; |
| | | import org.opends.server.util.StaticUtils; |
| | | |
| | | import net.jcip.annotations.GuardedBy; |
| | | |
| | | import static org.opends.messages.CoreMessages.*; |
| | | import static org.opends.server.config.ConfigConstants.*; |
| | | import static org.opends.server.protocols.internal.InternalClientConnection.*; |
| | |
| | | attrInitVectorLength = DirectoryServer.getAttributeType(ATTR_CRYPTO_INIT_VECTOR_LENGTH_BITS); |
| | | attrKeyLength = DirectoryServer.getAttributeType(ATTR_CRYPTO_KEY_LENGTH_BITS); |
| | | attrCompromisedTime = DirectoryServer.getAttributeType(ATTR_CRYPTO_KEY_COMPROMISED_TIME); |
| | | ocCertRequest = DirectoryServer.getObjectClass("ds-cfg-self-signed-cert-request"); // TODO: ConfigConstants |
| | | ocInstanceKey = DirectoryServer.getObjectClass(OC_CRYPTO_INSTANCE_KEY); |
| | | ocCipherKey = DirectoryServer.getObjectClass(OC_CRYPTO_CIPHER_KEY); |
| | | ocMacKey = DirectoryServer.getObjectClass(OC_CRYPTO_MAC_KEY); |
| | | // TODO: ConfigConstants |
| | | ocCertRequest = DirectoryServer.getSchema().getObjectClass("ds-cfg-self-signed-cert-request"); |
| | | ocInstanceKey = DirectoryServer.getSchema().getObjectClass(OC_CRYPTO_INSTANCE_KEY); |
| | | ocCipherKey = DirectoryServer.getSchema().getObjectClass(OC_CRYPTO_CIPHER_KEY); |
| | | ocMacKey = DirectoryServer.getSchema().getObjectClass(OC_CRYPTO_MAC_KEY); |
| | | |
| | | localTruststoreDN = DN.valueOf(DN_TRUST_STORE_ROOT); |
| | | DN adminSuffixDN = DN.valueOf(ADSContext.getAdministrationSuffixDN()); |
| | |
| | | { |
| | | } |
| | | |
| | | ocInstanceKey = DirectoryServer.getObjectClass(OC_CRYPTO_INSTANCE_KEY); |
| | | ocCipherKey = DirectoryServer.getObjectClass(OC_CRYPTO_CIPHER_KEY); |
| | | ocMacKey = DirectoryServer.getObjectClass(OC_CRYPTO_MAC_KEY); |
| | | ocInstanceKey = DirectoryServer.getSchema().getObjectClass(OC_CRYPTO_INSTANCE_KEY); |
| | | ocCipherKey = DirectoryServer.getSchema().getObjectClass(OC_CRYPTO_CIPHER_KEY); |
| | | ocMacKey = DirectoryServer.getSchema().getObjectClass(OC_CRYPTO_MAC_KEY); |
| | | |
| | | attrCert = getAttributeType(ATTR_CRYPTO_PUBLIC_KEY_CERTIFICATE); |
| | | attrAlias = getAttributeType(ATTR_CRYPTO_KEY_ID); |
| | |
| | | ifNull(entry); |
| | | |
| | | // FIXME -- This needs to exclude enhanced groups once we have support for them. |
| | | return entry.hasObjectClass(DirectoryServer.getObjectClass(OC_GROUP_OF_URLS_LC)); |
| | | return entry.hasObjectClass(DirectoryServer.getSchema().getObjectClass(OC_GROUP_OF_URLS_LC)); |
| | | } |
| | | |
| | | @Override |
| | |
| | | |
| | | private boolean hasObjectClass(Entry entry, String ocName) |
| | | { |
| | | return entry.hasObjectClass(DirectoryServer.getObjectClass(ocName)); |
| | | return entry.hasObjectClass(DirectoryServer.getSchema().getObjectClass(ocName)); |
| | | } |
| | | |
| | | @Override |
| | |
| | | ifNull(entry); |
| | | |
| | | // FIXME -- This needs to exclude enhanced groups once we have support for them. |
| | | return entry.hasObjectClass(DirectoryServer.getObjectClass(OC_VIRTUAL_STATIC_GROUP)); |
| | | return entry.hasObjectClass(DirectoryServer.getSchema().getObjectClass(OC_VIRTUAL_STATIC_GROUP)); |
| | | } |
| | | |
| | | @Override |
| | |
| | | @Override |
| | | public ObjectClass getMonitorObjectClass() |
| | | { |
| | | return DirectoryServer.getObjectClass(OC_MONITOR_BACKEND); |
| | | return DirectoryServer.getSchema().getObjectClass(OC_MONITOR_BACKEND); |
| | | } |
| | | |
| | | @Override |
| | |
| | | @Override |
| | | public ObjectClass getMonitorObjectClass() |
| | | { |
| | | return DirectoryServer.getObjectClass(OC_MONITOR_CONNHANDLER); |
| | | return DirectoryServer.getSchema().getObjectClass(OC_MONITOR_CONNHANDLER); |
| | | } |
| | | |
| | | |
| | |
| | | if (attrName.startsWith("@")) |
| | | { |
| | | final String ocName = attrName.substring(1); |
| | | final ObjectClass oc = getObjectClass(ocName); |
| | | final ObjectClass oc = getSchema().getObjectClass(ocName); |
| | | if (oc.isPlaceHolder()) |
| | | { |
| | | logger.trace("Cannot replace unknown objectclass %s", ocName); |
| | |
| | | |
| | | import static org.forgerock.opendj.adapter.server3x.Converters.*; |
| | | import static org.forgerock.opendj.ldap.ByteString.*; |
| | | import static org.forgerock.opendj.ldap.schema.CoreSchema.*; |
| | | import static org.opends.messages.ProtocolMessages.*; |
| | | import static org.opends.server.config.ConfigConstants.*; |
| | | import static org.opends.server.util.CollectionUtils.*; |
| | |
| | | import org.forgerock.opendj.ldap.requests.ModifyDNRequest; |
| | | import org.forgerock.opendj.ldap.requests.ModifyRequest; |
| | | import org.forgerock.opendj.ldap.schema.AttributeType; |
| | | import org.forgerock.opendj.ldap.schema.CoreSchema; |
| | | import org.forgerock.opendj.ldap.schema.ObjectClass; |
| | | import org.opends.server.api.ClientConnection; |
| | | import org.opends.server.api.ConnectionHandler; |
| | | import org.opends.server.core.AddOperation; |
| | |
| | | import org.opends.server.types.Entry; |
| | | import org.opends.server.types.IntermediateResponse; |
| | | import org.opends.server.types.Modification; |
| | | import org.forgerock.opendj.ldap.schema.ObjectClass; |
| | | import org.opends.server.types.Operation; |
| | | import org.opends.server.types.Privilege; |
| | | import org.opends.server.types.RawAttribute; |
| | |
| | | try |
| | | { |
| | | LinkedHashMap<ObjectClass,String> objectClasses = new LinkedHashMap<>(); |
| | | put(objectClasses, CoreSchema.getTopObjectClass()); |
| | | put(objectClasses, DirectoryServer.getObjectClass(OC_PERSON)); |
| | | put(objectClasses, DirectoryServer.getObjectClass(OC_ROOT_DN)); |
| | | put(objectClasses, getTopObjectClass()); |
| | | put(objectClasses, getPersonObjectClass()); |
| | | put(objectClasses, DirectoryServer.getSchema().getObjectClass(OC_ROOT_DN)); |
| | | |
| | | LinkedHashMap<AttributeType,List<Attribute>> userAttrs = new LinkedHashMap<>(); |
| | | put(userAttrs, ATTR_COMMON_NAME, commonName); |
| | |
| | | for (ByteString v : a) |
| | | { |
| | | String ocName = v.toString(); |
| | | objectClasses.put(DirectoryServer.getObjectClass(ocName), ocName); |
| | | objectClasses.put(DirectoryServer.getSchema().getObjectClass(ocName), ocName); |
| | | } |
| | | } |
| | | else |
| | |
| | | @Override |
| | | public ObjectClass getMonitorObjectClass() |
| | | { |
| | | return DirectoryServer.getObjectClass(OC_MONITOR_CONNHANDLERSTATS); |
| | | return DirectoryServer.getSchema().getObjectClass(OC_MONITOR_CONNHANDLERSTATS); |
| | | } |
| | | |
| | | @Override |
| | |
| | | for (ByteString os : a.getValues()) |
| | | { |
| | | String ocName = os.toString(); |
| | | ObjectClass oc = DirectoryServer.getObjectClass(ocName); |
| | | ObjectClass oc = DirectoryServer.getSchema().getObjectClass(ocName); |
| | | objectClasses.put(oc, ocName); |
| | | } |
| | | } |
| | |
| | | if (name.startsWith("@")) |
| | | { |
| | | String ocName = name.substring(1); |
| | | ObjectClass objectClass = DirectoryServer.getObjectClass(ocName); |
| | | ObjectClass objectClass = DirectoryServer.getSchema().getObjectClass(ocName); |
| | | if (!objectClass.isPlaceHolder()) |
| | | { |
| | | for (AttributeType at : objectClass.getRequiredAttributes()) |
| | |
| | | org.forgerock.opendj.ldap.Entry configEntry, String attrName, Syntax syntax, Object...values) |
| | | { |
| | | org.forgerock.opendj.ldap.Entry newEntry = LinkedHashMapEntry.deepCopyOfEntry(configEntry); |
| | | AttributeType attrType = DirectoryServer.getAttributeType(attrName, syntax); |
| | | AttributeType attrType = DirectoryServer.getSchema().getAttributeType(attrName, syntax); |
| | | newEntry.replaceAttribute(new LinkedAttribute(AttributeDescription.create(attrType), values)); |
| | | return newEntry; |
| | | } |
| | |
| | | for (ByteString v : a) |
| | | { |
| | | String ocName = v.toString(); |
| | | objectClasses.put(DirectoryServer.getObjectClass(ocName), ocName); |
| | | objectClasses.put(DirectoryServer.getSchema().getObjectClass(ocName), ocName); |
| | | } |
| | | } |
| | | else if (t.isOperational()) |
| | |
| | | |
| | | for (String objectClassName : objectClassNames) |
| | | { |
| | | ObjectClass c = DirectoryServer.getObjectClass(objectClassName); |
| | | ObjectClass c = DirectoryServer.getSchema().getObjectClass(objectClassName); |
| | | for (AttributeType t : c.getRequiredAttributes()) |
| | | { |
| | | if (t.isOperational()) |
| | |
| | | for (TemplateValue v : valueList) |
| | | { |
| | | String ocName = v.getValue().toString(); |
| | | objectClasses.put(DirectoryServer.getObjectClass(ocName), ocName); |
| | | objectClasses.put(DirectoryServer.getSchema().getObjectClass(ocName), ocName); |
| | | } |
| | | } |
| | | else if (t.isOperational()) |
| | |
| | | for (ByteString v : a) |
| | | { |
| | | String ocName = v.toString(); |
| | | ocs.put(DirectoryServer.getObjectClass(ocName), ocName); |
| | | ocs.put(DirectoryServer.getSchema().getObjectClass(ocName), ocName); |
| | | } |
| | | |
| | | AttributeDescription attrDesc = a.getAttributeDescription(); |
| | |
| | | // all attributes required by the object classes are present. |
| | | for (ObjectClass o : objectClasses.keySet()) |
| | | { |
| | | if (DirectoryServer.getObjectClass(o.getOID()).isPlaceHolder()) |
| | | if (DirectoryServer.getSchema().getObjectClass(o.getOID()).isPlaceHolder()) |
| | | { |
| | | invalidReason.append(ERR_ENTRY_SCHEMA_UNKNOWN_OC.get(dn, o.getNameOrOID())); |
| | | return false; |
| | |
| | | */ |
| | | private boolean hasObjectClassOrAttribute(String objectClassName, String attrTypeName) |
| | | { |
| | | ObjectClass oc = DirectoryServer.getObjectClass(objectClassName); |
| | | ObjectClass oc = DirectoryServer.getSchema().getObjectClass(objectClassName); |
| | | if (oc.isPlaceHolder()) |
| | | { |
| | | // This should not happen |
| | |
| | | */ |
| | | private boolean hasObjectClass(String objectClassLowerCase) |
| | | { |
| | | ObjectClass oc = DirectoryServer.getObjectClass(objectClassLowerCase); |
| | | ObjectClass oc = DirectoryServer.getSchema().getObjectClass(objectClassLowerCase); |
| | | if (oc.isPlaceHolder()) |
| | | { |
| | | // This should not happen |
| | |
| | | { |
| | | entryBuffer.position(startPos); |
| | | final String ocName = entryBuffer.readStringUtf8(endPos - startPos); |
| | | objectClasses.put(DirectoryServer.getObjectClass(ocName), ocName); |
| | | objectClasses.put(DirectoryServer.getSchema().getObjectClass(ocName), ocName); |
| | | } |
| | | |
| | | /** |
| | |
| | | String lowerName = toLowerName(rule, v); |
| | | |
| | | // Create a default object class if necessary. |
| | | ObjectClass oc = DirectoryServer.getObjectClass(lowerName); |
| | | ObjectClass oc = DirectoryServer.getSchema().getObjectClass(lowerName); |
| | | |
| | | if (replace) |
| | | { |
| | |
| | | @Override |
| | | public boolean matches(final Entry entry) |
| | | { |
| | | final ObjectClass oc = DirectoryServer.getObjectClass(normalizedObjectClass); |
| | | final ObjectClass oc = DirectoryServer.getSchema().getObjectClass(normalizedObjectClass); |
| | | return !oc.isPlaceHolder() && entry.hasObjectClass(oc); |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | String ocName = value.toString().trim(); |
| | | ObjectClass objectClass = DirectoryServer.getObjectClass(ocName); |
| | | ObjectClass objectClass = DirectoryServer.getSchema().getObjectClass(ocName); |
| | | if (objectClasses.containsKey(objectClass)) |
| | | { |
| | | logger.warn(WARN_LDIF_DUPLICATE_OBJECTCLASS, entryDN, lastEntryLineNumber, ocName); |
| | |
| | | RDN rdn = dn.rdn(); |
| | | |
| | | // If there is only one RDN attribute, then see which objectclass we should use. |
| | | ObjectClass structuralClass = DirectoryServer.getObjectClass(getObjectClassName(rdn)); |
| | | ObjectClass structuralClass = DirectoryServer.getSchema().getObjectClass(getObjectClassName(rdn)); |
| | | |
| | | // Get the top and untypedObject classes to include in the entry. |
| | | LinkedHashMap<ObjectClass,String> objectClasses = new LinkedHashMap<>(3); |
| | |
| | | assertThat(result.getName().toString()).isEqualTo(entry.getName().toString()); |
| | | List<ObjectClass> ocs = new ArrayList<>(result.getObjectClasses().keySet()); |
| | | assertThat(ocs).hasSize(2); |
| | | assertThat(ocs.get(0).getOID()).isEqualTo(DirectoryServer.getObjectClass("ds-cfg-backend").getOID()); |
| | | assertThat(ocs.get(0).getOID()).isEqualTo(DirectoryServer.getSchema().getObjectClass("ds-cfg-backend").getOID()); |
| | | assertThat(ocs.get(1).getOID()).as("This should be a placeholder").endsWith("-oid"); |
| | | } |
| | | |
| | |
| | | " MAY ( street $ c) X-ORIGIN 'user defined' )"); |
| | | assertEquals(resultCode, 0); |
| | | |
| | | assertFalse(getObjectClass("testaddanddeletedefinitionwithextraspaces").isPlaceHolder()); |
| | | assertFalse(getObjectClass("testaddanddeletedefinitionwithextraspaces-oid").isPlaceHolder()); |
| | | assertFalse(getSchema().getObjectClass("testaddanddeletedefinitionwithextraspaces").isPlaceHolder()); |
| | | assertFalse(getSchema().getObjectClass("testaddanddeletedefinitionwithextraspaces-oid").isPlaceHolder()); |
| | | |
| | | resultCode = TestCaseUtils.applyModifications(false, |
| | | "dn: cn=schema", |
| | |
| | | " MAY ( street $ c) X-ORIGIN 'user defined' )"); |
| | | assertEquals(resultCode, 0); |
| | | |
| | | assertTrue(getObjectClass("testaddanddeletedefinitionwithextraspaces").isPlaceHolder()); |
| | | assertTrue(getObjectClass("testaddanddeletedefinitionwithextraspaces-oid").isPlaceHolder()); |
| | | assertTrue(getSchema().getObjectClass("testaddanddeletedefinitionwithextraspaces").isPlaceHolder()); |
| | | assertTrue(getSchema().getObjectClass("testaddanddeletedefinitionwithextraspaces-oid").isPlaceHolder()); |
| | | } |
| | | |
| | | /** |
| | |
| | | |
| | | // check the object classes were not changed |
| | | for (String ocBefore : entryBefore.getObjectClasses().values()) { |
| | | ObjectClass objectClass = DirectoryServer.getObjectClass(ocBefore); |
| | | ObjectClass objectClass = DirectoryServer.getSchema().getObjectClass(ocBefore); |
| | | String ocAfter = entryAfter.getObjectClasses().get(objectClass); |
| | | assertEquals(ocBefore, ocAfter); |
| | | } |
| | |
| | | |
| | | import static org.assertj.core.api.Assertions.*; |
| | | import static org.forgerock.opendj.ldap.requests.Requests.*; |
| | | import static org.forgerock.opendj.ldap.schema.CoreSchema.*; |
| | | import static org.opends.server.TestCaseUtils.*; |
| | | import static org.opends.server.protocols.internal.InternalClientConnection.*; |
| | | import static org.opends.server.protocols.ldap.LDAPConstants.*; |
| | |
| | | import org.forgerock.opendj.ldap.ResultCode; |
| | | import org.forgerock.opendj.ldap.requests.AddRequest; |
| | | import org.forgerock.opendj.ldap.schema.AttributeType; |
| | | import org.forgerock.opendj.ldap.schema.CoreSchema; |
| | | import org.forgerock.opendj.ldap.schema.ObjectClass; |
| | | import org.opends.server.TestCaseUtils; |
| | | import org.opends.server.api.Backend; |
| | |
| | | |
| | | UpdatePreOpPlugin.reset(); |
| | | |
| | | ObjectClass oc = DirectoryServer.getObjectClass("extensibleobject"); |
| | | ObjectClass oc = getExtensibleObjectObjectClass(); |
| | | UpdatePreOpPlugin.addObjectClassToAdd(oc); |
| | | |
| | | AddOperation addOperation = getRootConnection().processAdd(entry); |
| | |
| | | |
| | | UpdatePreOpPlugin.reset(); |
| | | |
| | | ObjectClass oc = DirectoryServer.getObjectClass("extensibleobject"); |
| | | ObjectClass oc = getExtensibleObjectObjectClass(); |
| | | UpdatePreOpPlugin.addObjectClassToRemove(oc); |
| | | |
| | | AddOperation addOperation = getRootConnection().processAdd(entry); |
| | |
| | | retrieveCompletedOperationElements(addOperation); |
| | | |
| | | Entry e = DirectoryServer.getEntry(DN.valueOf("uid=test.user,o=test")); |
| | | List<Attribute> attrList = e.getAttribute(CoreSchema.getObjectClassAttributeType()); |
| | | List<Attribute> attrList = e.getAttribute(getObjectClassAttributeType()); |
| | | assertTrue(findAttributeValueIgnoreCase(attrList, "top")); |
| | | } |
| | | |
| | |
| | | retrieveSuccessfulOperationElements(modifyOperation); |
| | | |
| | | Entry e = DirectoryServer.getEntry(DN.valueOf("uid=test.user," + baseDN)); |
| | | assertFalse(e.hasObjectClass(DirectoryServer.getObjectClass("extensibleobject"))); |
| | | assertFalse(e.hasObjectClass(getExtensibleObjectObjectClass())); |
| | | } |
| | | |
| | | |
| | |
| | | |
| | | Entry e = DirectoryServer.getEntry(DN.valueOf("uid=test.user," + baseDN)); |
| | | assertTrue(e.hasObjectClass(getExtensibleObjectObjectClass())); |
| | | assertTrue(e.hasObjectClass(DirectoryServer.getObjectClass("inetOrgPerson"))); |
| | | assertTrue(e.hasObjectClass(DirectoryServer.getSchema().getObjectClass("inetOrgPerson"))); |
| | | assertTrue(e.hasObjectClass(getOrganizationalPersonObjectClass())); |
| | | assertTrue(e.hasObjectClass(getPersonObjectClass())); |
| | | assertTrue(e.hasObjectClass(getTopObjectClass())); |
| | |
| | | */ |
| | | package org.opends.server.replication.plugin; |
| | | |
| | | import static org.assertj.core.api.Assertions.*; |
| | | import static org.opends.server.TestCaseUtils.*; |
| | | import static org.opends.server.util.CollectionUtils.*; |
| | | import static org.testng.Assert.fail; |
| | | import static org.testng.Assert.*; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.Iterator; |
| | | import java.util.List; |
| | |
| | | import org.testng.annotations.DataProvider; |
| | | import org.testng.annotations.Test; |
| | | |
| | | import static org.testng.Assert.fail; |
| | | import static org.assertj.core.api.Assertions.*; |
| | | import static org.opends.server.TestCaseUtils.*; |
| | | import static org.opends.server.util.CollectionUtils.*; |
| | | import static org.testng.Assert.*; |
| | | |
| | | /** Various tests around fractional replication */ |
| | | @SuppressWarnings("javadoc") |
| | | public class FractionalReplicationTest extends ReplicationTestCase { |
| | |
| | | String objectClassStr = fractionalConf[0]; |
| | | if (!objectClassStr.equals("*")) |
| | | { |
| | | ObjectClass objectClass = DirectoryServer.getObjectClass(objectClassStr); |
| | | ObjectClass objectClass = DirectoryServer.getSchema().getObjectClass(objectClassStr); |
| | | assertTrue(newEntry.hasObjectClass(objectClass)); |
| | | } |
| | | |
| | |
| | | String objectClassStr = fractionalConf[0]; |
| | | if (!objectClassStr.equals("*")) |
| | | { |
| | | ObjectClass objectClass = DirectoryServer.getObjectClass(objectClassStr); |
| | | ObjectClass objectClass = DirectoryServer.getSchema().getObjectClass(objectClassStr); |
| | | assertTrue(entry.hasObjectClass(objectClass)); |
| | | } |
| | | |
| | |
| | | Entry newEntry = getEntry(entry.getName(), TIMEOUT, true); |
| | | assertNotNull(newEntry); |
| | | assertEquals(entry.getName(), newEntry.getName()); |
| | | ObjectClass objectClass = DirectoryServer.getObjectClass("inetOrgPerson"); |
| | | assertTrue(newEntry.hasObjectClass(objectClass)); |
| | | assertTrue(newEntry.hasObjectClass(getInetOrgPersonObjectClass())); |
| | | checkEntryAttributeValue(newEntry, "displayName", "ValueToBeKept"); |
| | | |
| | | /** |
| | |
| | | newEntry = getEntry(entry.getName(), TIMEOUT, true); |
| | | assertNotNull(newEntry); |
| | | assertEquals(entry.getName(), newEntry.getName()); |
| | | objectClass = DirectoryServer.getObjectClass("inetOrgPerson"); |
| | | assertTrue(newEntry.hasObjectClass(objectClass)); |
| | | assertTrue(newEntry.hasObjectClass(getInetOrgPersonObjectClass())); |
| | | checkEntryAttributeValue(newEntry, "displayName", "ValueToBeKept"); |
| | | checkEntryAttributeValue(newEntry, "givenName", "ValueToBeKeptToo"); |
| | | } |
| | |
| | | Entry newEntry = getEntry(entry.getName(), TIMEOUT, true); |
| | | assertNotNull(newEntry); |
| | | assertEquals(entry.getName(), newEntry.getName()); |
| | | ObjectClass objectClass = DirectoryServer.getObjectClass("inetOrgPerson"); |
| | | assertTrue(newEntry.hasObjectClass(objectClass)); |
| | | assertTrue(newEntry.hasObjectClass(getInetOrgPersonObjectClass())); |
| | | checkEntryAttributeValue(newEntry, "displayName", "ValueToBeKept"); |
| | | checkEntryAttributeValue(newEntry, "carLicense", "cirLicenseValue"); |
| | | |
| | |
| | | newEntry = getEntry(entry.getName(), TIMEOUT, true); |
| | | assertNotNull(newEntry); |
| | | assertEquals(entry.getName(), newEntry.getName()); |
| | | objectClass = DirectoryServer.getObjectClass("inetOrgPerson"); |
| | | assertTrue(newEntry.hasObjectClass(objectClass)); |
| | | assertTrue(newEntry.hasObjectClass(getInetOrgPersonObjectClass())); |
| | | checkEntryAttributeValue(newEntry, "displayName", "ValueToBeKept"); |
| | | checkEntryAttributeValue(newEntry, "description", "ValueToBeKeptToo"); |
| | | checkEntryAttributeValue(newEntry, "carLicense", "cirLicenseValue"); |
| | |
| | | Entry newEntry = getEntry(entry.getName(), TIMEOUT, true); |
| | | assertNotNull(newEntry); |
| | | assertEquals(entry.getName(), newEntry.getName()); |
| | | ObjectClass objectClass = DirectoryServer.getObjectClass("inetOrgPerson"); |
| | | assertTrue(newEntry.hasObjectClass(objectClass)); |
| | | assertTrue(newEntry.hasObjectClass(getInetOrgPersonObjectClass())); |
| | | checkEntryAttributeValue(newEntry, "displayName", "ValueToBeKept"); |
| | | checkEntryAttributeValue(newEntry, "givenName", "ValueToBeRemoved"); |
| | | |
| | |
| | | newEntry = getEntry(newEntryDn, TIMEOUT, true); |
| | | assertNotNull(newEntry); |
| | | assertEquals(newEntryDn, newEntry.getName()); |
| | | objectClass = DirectoryServer.getObjectClass("inetOrgPerson"); |
| | | assertTrue(newEntry.hasObjectClass(objectClass)); |
| | | assertTrue(newEntry.hasObjectClass(getInetOrgPersonObjectClass())); |
| | | checkEntryAttributeValue(newEntry, "displayName", "ValueToBeKept"); |
| | | assertThat(newEntry.getAttribute("givenName")).isEmpty(); |
| | | } |
| | |
| | | Entry newEntry = getEntry(entry.getName(), TIMEOUT, true); |
| | | assertNotNull(newEntry); |
| | | assertEquals(entry.getName(), newEntry.getName()); |
| | | ObjectClass objectClass = DirectoryServer.getObjectClass("inetOrgPerson"); |
| | | assertTrue(newEntry.hasObjectClass(objectClass)); |
| | | assertTrue(newEntry.hasObjectClass(getInetOrgPersonObjectClass())); |
| | | checkEntryAttributeValue(newEntry, "displayName", "ValueToBeKept"); |
| | | checkEntryAttributeValue(newEntry, "description", "ValueToBeRemoved"); |
| | | |
| | |
| | | newEntry = getEntry(newEntryDn, TIMEOUT, true); |
| | | assertNotNull(newEntry); |
| | | assertEquals(newEntryDn, newEntry.getName()); |
| | | objectClass = DirectoryServer.getObjectClass("inetOrgPerson"); |
| | | assertTrue(newEntry.hasObjectClass(objectClass)); |
| | | assertTrue(newEntry.hasObjectClass(getInetOrgPersonObjectClass())); |
| | | checkEntryAttributeValue(newEntry, "displayName", "ValueToBeKept"); |
| | | assertThat(newEntry.getAttribute("description")).isEmpty(); |
| | | } |
| | |
| | | endTest(); |
| | | } |
| | | } |
| | | |
| | | private ObjectClass getInetOrgPersonObjectClass() |
| | | { |
| | | return DirectoryServer.getSchema().getObjectClass("inetOrgPerson"); |
| | | } |
| | | } |
| | |
| | | import org.forgerock.opendj.ldap.DN; |
| | | import org.forgerock.opendj.ldap.ModificationType; |
| | | import org.forgerock.opendj.ldap.schema.AttributeType; |
| | | import org.forgerock.opendj.ldap.schema.CoreSchema; |
| | | import org.forgerock.opendj.ldap.schema.ObjectClass; |
| | | import org.opends.server.core.ModifyOperationBasis; |
| | | import org.opends.server.replication.ReplicationTestCase; |
| | |
| | | */ |
| | | DN dn = DN.valueOf(TEST_ROOT_DN_STRING); |
| | | Map<ObjectClass, String> objectClasses = new HashMap<>(); |
| | | objectClasses.put(getObjectClass(ORGANIZATION), ORGANIZATION); |
| | | objectClasses.put(CoreSchema.getOrganizationObjectClass(), ORGANIZATION); |
| | | |
| | | // start with a new entry with an empty attribute |
| | | Entry entry = new Entry(dn, objectClasses, null, null); |
| | |
| | | byte safeDataLevel, List<Attribute> entryAttrList) throws Exception |
| | | { |
| | | Map<ObjectClass, String> objectClassList = new HashMap<>(); |
| | | objectClassList.put(DirectoryServer.getObjectClass("organization"), "organization"); |
| | | objectClassList.put(getOrganizationObjectClass(), "organization"); |
| | | |
| | | Attribute attr = Attributes.create("o", "com"); |
| | | Map<AttributeType, List<Attribute>> userAttList = new HashMap<>(); |
| | |
| | | final int restoreBeginCountStart = restoreBeginCount.get(); |
| | | final int restoreEndCountStart = restoreEndCount.get(); |
| | | |
| | | ObjectClass backupClass = DirectoryServer.getObjectClass("ds-task-backup"); |
| | | ObjectClass backupClass = DirectoryServer.getSchema().getObjectClass("ds-task-backup"); |
| | | |
| | | testTask(taskEntry, expectedState, 30); |
| | | if (expectedState == TaskState.COMPLETED_SUCCESSFULLY || |
| | |
| | | int importBeginCount = TestTaskListener.importBeginCount.get(); |
| | | int importEndCount = TestTaskListener.importEndCount.get(); |
| | | |
| | | ObjectClass exportClass = |
| | | DirectoryServer.getObjectClass("ds-task-export"); |
| | | ObjectClass exportClass = DirectoryServer.getSchema().getObjectClass("ds-task-export"); |
| | | |
| | | // Use a big timeout since this test is sensitive to host environment (e.g. |
| | | // low memory, etc). See issue OPENDJ-256. |
| | |
| | | String avalue = toLowerCase(s[i+1]); |
| | | |
| | | if (atype.equals("objectclass")) { |
| | | entry.addObjectClass(DirectoryServer.getObjectClass(avalue)); |
| | | entry.addObjectClass(DirectoryServer.getSchema().getObjectClass(avalue)); |
| | | } else { |
| | | Attribute attr = Attributes.create(atype, avalue); |
| | | |