public DistributedJDBCConfigurationImpl(ConfigurationProvider cp) 
{
                 
        super(true, false);
        Map p = cp.getProperties();
        String pUnit = getPersistenceUnitName(p);
        setDiagnosticContext(pUnit);
        brokerPlugin.setString(DistributedBrokerImpl.class.getName());
        distributionPolicyPlugin = addPlugin("DistributionPolicy", true);
        distributionPolicyPlugin.setDynamic(true);
        lenientPlugin = addBoolean("Lenient");
        masterPlugin = addString("Master");
        namesPlugin = addStringList("Names");
        executorServicePlugin = new ExecutorServiceValue();
        addValue(executorServicePlugin);
        setSlices(p);
}

Configure itself as well as underlying slices.

 Map createSliceProperties(Map original,
    String slice) 
{
        Map result = new Properties();
        String prefix = PREFIX_SLICE + slice + DOT;
        for (Object o : original.keySet()) {
            String key = o.toString();
            if (key.startsWith(prefix)) {
                String newKey = PREFIX_OPENJPA + key.substring(prefix.length());
                result.put(newKey, original.get(o));
            } else if (key.startsWith(PREFIX_SLICE)) {
                // ignore keys that are in 'slice.' namespace but not this slice
            } else if (key.startsWith(PREFIX_OPENJPA)) {
                String newKey = prefix + key.substring(PREFIX_OPENJPA.length());
                if (!original.containsKey(newKey))
                    result.put(key, original.get(o));
            } else { // keys that are neither "openjpa" nor "slice" namespace
                result.put(key, original.get(o));
            }
        }
        return result;
}

Creates given slice specific configuration properties from given original key-value map. The rules are
• if key begins with "slice.XXX." where XXX is the given slice name, then replace "slice.XXX. with openjpa..
• if key begins with "slice." but not with "slice.XXX.", the ignore i.e. any property of other slices or global slice property e.g. slice.DistributionPolicy if key starts with "openjpa." and a corresponding "slice.XXX." property does not exist, then use this as default property property with any other prefix is simply copied

 public List getActiveSliceNames() 
{
        if (_activeSliceNames.isEmpty()) {
            for (Slice slice:_slices)
                if (slice.isActive())
                    _activeSliceNames.add(slice.getName());
        }
        return _activeSliceNames;
}

Gets the name of the active slices.

 public List getAvailableSliceNames() 
{
        List< String > result = new ArrayList< String >();
        for (Slice slice:_slices)
            result.add(slice.getName());
        return result;
}

Gets the name of the available slices.

 public Object getConnectionFactory() 
{
        if (virtualDataSource == null) {
            DistributedDataSource ds = createDistributedDataStore();
            virtualDataSource =
                    DataSourceFactory.installDBDictionary(
                            getDBDictionaryInstance(), ds, this, false);
        }
        return virtualDataSource;
}

 String getConnectionInfo(OpenJPAConfiguration conf) 
{
        String result = conf.getConnectionURL();
        if (result == null) {
            result = conf.getConnectionDriverName();
            String props = conf.getConnectionProperties();
            if (props != null)
                result += "(" + props + ")";
        }
        return result;
}

 public DistributionPolicy getDistributionPolicyInstance() 
{
        if (distributionPolicyPlugin.get() == null) {
            distributionPolicyPlugin.instantiate(DistributionPolicy.class,
                    this, true);
        }
        return (DistributionPolicy) distributionPolicyPlugin.get();
}

 public String getExecutorService() 
{
        return executorServicePlugin.getString();
}

 public ExecutorService getExecutorServiceInstance() 
{
        if (executorServicePlugin.get() == null) {
            executorServicePlugin.instantiate(ExecutorService.class, this);
        }
        return (ExecutorService) executorServicePlugin.get();
}

 public Slice getMaster() 
{
        return _master;
}

Gets the master slice.

 public Slice getSlice(String name) 
{
        for (Slice slice:_slices)
            if (slice.getName().equals(name))
                return slice;
        throw new UserException(_loc.get("slice-not-found", name,
                    getActiveSliceNames()));
}

Get the configuration for given slice.

 public List getSlices(Slice.Status statuses) 
{
        if (statuses == null)
            return Collections.unmodifiableList(_slices);
        List< Slice > result = new ArrayList< Slice >();
        for (Slice slice:_slices) {
            for (Slice.Status status:statuses)
                if (slice.getStatus().equals(status))
                    result.add(slice);
        }
        return result;
}

Gets the slices of given status. Null returns all irrespective of status.

 boolean isXACompliant(DataSource ds) 
{
        if (ds instanceof DelegatingDataSource)
            return ((DelegatingDataSource) ds).getInnermostDelegate() 
               instanceof XADataSource;
        return ds instanceof XADataSource;
}

 public  void setDistributionPolicyInstance(String val) 
{
        distributionPolicyPlugin.set(val);
}

 public  void setExecutorService(ExecutorService txnManager) 
{
        executorServicePlugin.set(txnManager);
}

  void setSlices(Map original) 
{
        List< String > sliceNames = findSlices(original);
        Log log = getConfigurationLog();
        if (sliceNames.isEmpty()) {
            throw new UserException(_loc.get("slice-none-configured"));
        } 
        String unit = getPersistenceUnitName(original);
        for (String key : sliceNames) {
            JDBCConfiguration child = new JDBCConfigurationImpl();
            child.fromProperties(createSliceProperties(original, key));
            child.setId(unit+DOT+key);
            Slice slice = new Slice(key, child);
            _slices.add(slice);
            if (log.isTraceEnabled())
                log.trace(_loc.get("slice-configuration", key, child
                        .toProperties(false)));
        }
        setMaster(original);
}

Create individual slices with configurations from the given properties.