Skip to content

Commit

Permalink
#ignite-239: remove some IgniteConfiguration set methods from Ignitio…
Browse files Browse the repository at this point in the history
…nEx.start().
  • Loading branch information
ivasilinets committed Feb 26, 2015
1 parent e13b3b1 commit 7aec19e
Show file tree
Hide file tree
Showing 2 changed files with 160 additions and 192 deletions.
Expand Up @@ -26,7 +26,19 @@
import org.apache.ignite.lifecycle.*; import org.apache.ignite.lifecycle.*;
import org.apache.ignite.marshaller.*; import org.apache.ignite.marshaller.*;
import org.apache.ignite.plugin.*; import org.apache.ignite.plugin.*;
import org.apache.ignite.spi.checkpoint.noop.*;
import org.apache.ignite.spi.collision.noop.*;
import org.apache.ignite.spi.communication.tcp.*;
import org.apache.ignite.spi.deployment.local.*;
import org.apache.ignite.spi.discovery.tcp.*;
import org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.*;
import org.apache.ignite.spi.eventstorage.memory.*;
import org.apache.ignite.spi.failover.always.*;
import org.apache.ignite.spi.indexing.*; import org.apache.ignite.spi.indexing.*;
import org.apache.ignite.spi.indexing.noop.*;
import org.apache.ignite.spi.loadbalancing.roundrobin.*;
import org.apache.ignite.spi.swapspace.file.*;
import org.apache.ignite.spi.swapspace.noop.*;
import org.apache.ignite.streamer.*; import org.apache.ignite.streamer.*;
import org.apache.ignite.plugin.segmentation.*; import org.apache.ignite.plugin.segmentation.*;
import org.apache.ignite.services.*; import org.apache.ignite.services.*;
Expand Down Expand Up @@ -371,6 +383,9 @@ public class IgniteConfiguration {
/** User's class loader. */ /** User's class loader. */
private ClassLoader classLdr; private ClassLoader classLdr;


/** */
private static final String[] EMPTY_STR_ARR = new String[0];

/** /**
* Creates valid grid configuration with all default values. * Creates valid grid configuration with all default values.
*/ */
Expand All @@ -388,76 +403,189 @@ public IgniteConfiguration(IgniteConfiguration cfg) {
assert cfg != null; assert cfg != null;


// SPIs. // SPIs.
discoSpi = cfg.getDiscoverySpi(); discoSpi = cfg.getDiscoverySpi() != null ? cfg.getDiscoverySpi() : new TcpDiscoverySpi();
commSpi = cfg.getCommunicationSpi();
deploySpi = cfg.getDeploymentSpi(); if (discoSpi instanceof TcpDiscoverySpi) {
evtSpi = cfg.getEventStorageSpi(); TcpDiscoverySpi tcpDisco = (TcpDiscoverySpi)discoSpi;
cpSpi = cfg.getCheckpointSpi();
colSpi = cfg.getCollisionSpi(); if (tcpDisco.getIpFinder() == null)
failSpi = cfg.getFailoverSpi(); tcpDisco.setIpFinder(new TcpDiscoveryMulticastIpFinder());
loadBalancingSpi = cfg.getLoadBalancingSpi(); }

commSpi = cfg.getCommunicationSpi() != null ? cfg.getCommunicationSpi() : new TcpCommunicationSpi();

deploySpi = cfg.getDeploymentSpi() != null ? cfg.getDeploymentSpi() : new LocalDeploymentSpi();

evtSpi = cfg.getEventStorageSpi() != null ? cfg.getEventStorageSpi() : new MemoryEventStorageSpi();

cpSpi = cfg.getCheckpointSpi() != null ? cfg.getCheckpointSpi() : new CheckpointSpi[] {new NoopCheckpointSpi()};

colSpi = cfg.getCollisionSpi() != null ? cfg.getCollisionSpi() : new NoopCollisionSpi();

failSpi = cfg.getFailoverSpi() != null ? cfg.getFailoverSpi() : new FailoverSpi[] {new AlwaysFailoverSpi()};

loadBalancingSpi = cfg.getLoadBalancingSpi() != null ? cfg.getLoadBalancingSpi() :
new LoadBalancingSpi[] {new RoundRobinLoadBalancingSpi()};

indexingSpi = cfg.getIndexingSpi() != null ? cfg.getIndexingSpi() : new NoopIndexingSpi();

swapSpaceSpi = cfg.getSwapSpaceSpi(); swapSpaceSpi = cfg.getSwapSpaceSpi();
indexingSpi = cfg.getIndexingSpi();
if (swapSpaceSpi == null) {
boolean needSwap = false;

CacheConfiguration[] caches = cfg.getCacheConfiguration();

if (caches != null) {
for (CacheConfiguration c : caches) {
if (c.isSwapEnabled()) {
needSwap = true;

break;
}
}
}

swapSpaceSpi = needSwap ? new FileSwapSpaceSpi() : new NoopSwapSpaceSpi();
}


/* /*
* Order alphabetically for maintenance purposes. * Order alphabetically for maintenance purposes.
*/ */
addrRslvr = cfg.getAddressResolver(); addrRslvr = cfg.getAddressResolver();

allResolversPassReq = cfg.isAllSegmentationResolversPassRequired(); allResolversPassReq = cfg.isAllSegmentationResolversPassRequired();

atomicCfg = cfg.getAtomicConfiguration(); atomicCfg = cfg.getAtomicConfiguration();

daemon = cfg.isDaemon(); daemon = cfg.isDaemon();

cacheCfg = cfg.getCacheConfiguration(); cacheCfg = cfg.getCacheConfiguration();

cacheSanityCheckEnabled = cfg.isCacheSanityCheckEnabled(); cacheSanityCheckEnabled = cfg.isCacheSanityCheckEnabled();
connectorCfg = cfg.getConnectorConfiguration();
connectorCfg = cfg.getConnectorConfiguration() != null ?
new ConnectorConfiguration(cfg.getConnectorConfiguration()) : null;

classLdr = cfg.getClassLoader(); classLdr = cfg.getClassLoader();

clockSyncFreq = cfg.getClockSyncFrequency(); clockSyncFreq = cfg.getClockSyncFrequency();

clockSyncSamples = cfg.getClockSyncSamples(); clockSyncSamples = cfg.getClockSyncSamples();

deployMode = cfg.getDeploymentMode(); deployMode = cfg.getDeploymentMode();

discoStartupDelay = cfg.getDiscoveryStartupDelay(); discoStartupDelay = cfg.getDiscoveryStartupDelay();

pubPoolSize = cfg.getPublicThreadPoolSize(); pubPoolSize = cfg.getPublicThreadPoolSize();

ggHome = cfg.getIgniteHome(); ggHome = cfg.getIgniteHome();

ggWork = cfg.getWorkDirectory(); ggWork = cfg.getWorkDirectory();

gridName = cfg.getGridName(); gridName = cfg.getGridName();
igfsCfg = cfg.getIgfsConfiguration();
IgfsConfiguration[] igfsCfgs = cfg.getIgfsConfiguration();

if (igfsCfgs != null) {
IgfsConfiguration[] clone = igfsCfgs.clone();

for (int i = 0; i < igfsCfgs.length; i++)
clone[i] = new IgfsConfiguration(igfsCfgs[i]);

igfsCfg = clone;
}

igfsPoolSize = cfg.getIgfsThreadPoolSize(); igfsPoolSize = cfg.getIgfsThreadPoolSize();

hadoopCfg = cfg.getHadoopConfiguration(); hadoopCfg = cfg.getHadoopConfiguration();

inclEvtTypes = cfg.getIncludeEventTypes(); inclEvtTypes = cfg.getIncludeEventTypes();

includeProps = cfg.getIncludeProperties(); includeProps = cfg.getIncludeProperties();

lifecycleBeans = cfg.getLifecycleBeans(); lifecycleBeans = cfg.getLifecycleBeans();

locHost = cfg.getLocalHost(); locHost = cfg.getLocalHost();

log = cfg.getGridLogger(); log = cfg.getGridLogger();

lsnrs = cfg.getLocalEventListeners(); lsnrs = cfg.getLocalEventListeners();

marsh = cfg.getMarshaller(); marsh = cfg.getMarshaller();

marshLocJobs = cfg.isMarshalLocalJobs(); marshLocJobs = cfg.isMarshalLocalJobs();
mbeanSrv = cfg.getMBeanServer();
mbeanSrv = cfg.getMBeanServer() != null ? cfg.getMBeanServer() : ManagementFactory.getPlatformMBeanServer();

metricsHistSize = cfg.getMetricsHistorySize(); metricsHistSize = cfg.getMetricsHistorySize();

metricsExpTime = cfg.getMetricsExpireTime(); metricsExpTime = cfg.getMetricsExpireTime();

metricsLogFreq = cfg.getMetricsLogFrequency(); metricsLogFreq = cfg.getMetricsLogFrequency();

metricsUpdateFreq = cfg.getMetricsUpdateFrequency(); metricsUpdateFreq = cfg.getMetricsUpdateFrequency();

mgmtPoolSize = cfg.getManagementThreadPoolSize(); mgmtPoolSize = cfg.getManagementThreadPoolSize();

netTimeout = cfg.getNetworkTimeout(); netTimeout = cfg.getNetworkTimeout();
nodeId = cfg.getNodeId();
nodeId = cfg.getNodeId() != null ? cfg.getNodeId() : UUID.randomUUID();

p2pEnabled = cfg.isPeerClassLoadingEnabled(); p2pEnabled = cfg.isPeerClassLoadingEnabled();
p2pLocClsPathExcl = cfg.getPeerClassLoadingLocalClassPathExclude();
p2pLocClsPathExcl = cfg.getPeerClassLoadingLocalClassPathExclude() != null ?
cfg.getPeerClassLoadingLocalClassPathExclude() : EMPTY_STR_ARR;

p2pMissedCacheSize = cfg.getPeerClassLoadingMissedResourcesCacheSize(); p2pMissedCacheSize = cfg.getPeerClassLoadingMissedResourcesCacheSize();

p2pPoolSize = cfg.getPeerClassLoadingThreadPoolSize(); p2pPoolSize = cfg.getPeerClassLoadingThreadPoolSize();

pluginCfgs = cfg.getPluginConfigurations(); pluginCfgs = cfg.getPluginConfigurations();

qryCfg = cfg.getQueryConfiguration(); qryCfg = cfg.getQueryConfiguration();

segChkFreq = cfg.getSegmentCheckFrequency(); segChkFreq = cfg.getSegmentCheckFrequency();

segPlc = cfg.getSegmentationPolicy(); segPlc = cfg.getSegmentationPolicy();

segResolveAttempts = cfg.getSegmentationResolveAttempts(); segResolveAttempts = cfg.getSegmentationResolveAttempts();

segResolvers = cfg.getSegmentationResolvers(); segResolvers = cfg.getSegmentationResolvers();

sndRetryCnt = cfg.getNetworkSendRetryCount(); sndRetryCnt = cfg.getNetworkSendRetryCount();

sndRetryDelay = cfg.getNetworkSendRetryDelay(); sndRetryDelay = cfg.getNetworkSendRetryDelay();
streamerCfg = cfg.getStreamerConfiguration();
StreamerConfiguration[] streamerCfgs = cfg.getStreamerConfiguration();

if (streamerCfgs != null) {
StreamerConfiguration[] clone = streamerCfgs.clone();

for (int i = 0; i < streamerCfgs.length; i++)
clone[i] = new StreamerConfiguration(streamerCfgs[i]);

streamerCfg = clone;
}

svcCfgs = cfg.getServiceConfiguration(); svcCfgs = cfg.getServiceConfiguration();

sysPoolSize = cfg.getSystemThreadPoolSize(); sysPoolSize = cfg.getSystemThreadPoolSize();

timeSrvPortBase = cfg.getTimeServerPortBase(); timeSrvPortBase = cfg.getTimeServerPortBase();

timeSrvPortRange = cfg.getTimeServerPortRange(); timeSrvPortRange = cfg.getTimeServerPortRange();

txCfg = cfg.getTransactionConfiguration() != null ? txCfg = cfg.getTransactionConfiguration() != null ?
new TransactionConfiguration(cfg.getTransactionConfiguration()) : null; new TransactionConfiguration(cfg.getTransactionConfiguration()) : null;
userAttrs = cfg.getUserAttributes();
if (cfg.getUserAttributes() == null)
userAttrs = Collections.emptyMap();
else
userAttrs = cfg.getUserAttributes();

waitForSegOnStart = cfg.isWaitForSegmentOnStart(); waitForSegOnStart = cfg.isWaitForSegmentOnStart();

warmupClos = cfg.getWarmupClosure(); warmupClos = cfg.getWarmupClosure();
} }


Expand Down

0 comments on commit 7aec19e

Please sign in to comment.