http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c323a8e7/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java b/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java deleted file mode 100644 index 8ffafac..0000000 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridKernal.java +++ /dev/null @@ -1,3322 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.ignite.internal; - -import org.apache.ignite.*; -import org.apache.ignite.cache.*; -import org.apache.ignite.cache.affinity.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.processors.*; -import org.apache.ignite.internal.processors.cache.*; -import org.apache.ignite.internal.processors.portable.*; -import org.apache.ignite.internal.util.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.lifecycle.*; -import org.apache.ignite.marshaller.*; -import org.apache.ignite.marshaller.optimized.*; -import org.apache.ignite.mxbean.*; -import org.apache.ignite.plugin.*; -import org.apache.ignite.internal.product.*; -import org.apache.ignite.spi.*; -import org.apache.ignite.spi.authentication.*; -import org.apache.ignite.spi.authentication.noop.*; -import org.apache.ignite.hadoop.*; -import org.apache.ignite.internal.managers.*; -import org.apache.ignite.internal.managers.checkpoint.*; -import org.apache.ignite.internal.managers.collision.*; -import org.apache.ignite.internal.managers.communication.*; -import org.apache.ignite.internal.managers.deployment.*; -import org.apache.ignite.internal.managers.discovery.*; -import org.apache.ignite.internal.managers.eventstorage.*; -import org.apache.ignite.internal.managers.failover.*; -import org.apache.ignite.internal.managers.indexing.*; -import org.apache.ignite.internal.managers.loadbalancer.*; -import org.apache.ignite.internal.managers.securesession.*; -import org.apache.ignite.internal.managers.security.*; -import org.apache.ignite.internal.managers.swapspace.*; -import org.apache.ignite.internal.processors.affinity.*; -import org.apache.ignite.internal.processors.clock.*; -import org.apache.ignite.internal.processors.closure.*; -import org.apache.ignite.internal.processors.continuous.*; -import org.apache.ignite.internal.processors.dataload.*; -import org.apache.ignite.internal.processors.email.*; -import org.apache.ignite.internal.processors.interop.*; -import org.apache.ignite.internal.processors.job.*; -import org.apache.ignite.internal.processors.jobmetrics.*; -import org.apache.ignite.internal.processors.license.*; -import org.apache.ignite.internal.processors.offheap.*; -import org.apache.ignite.internal.processors.plugin.*; -import org.apache.ignite.internal.processors.port.*; -import org.apache.ignite.internal.processors.query.*; -import org.apache.ignite.internal.processors.resource.*; -import org.apache.ignite.internal.processors.rest.*; -import org.apache.ignite.internal.processors.segmentation.*; -import org.apache.ignite.internal.processors.service.*; -import org.apache.ignite.internal.processors.session.*; -import org.apache.ignite.internal.processors.streamer.*; -import org.apache.ignite.internal.processors.task.*; -import org.apache.ignite.internal.processors.timeout.*; -import org.apache.ignite.plugin.security.*; -import org.apache.ignite.spi.securesession.noop.*; -import org.apache.ignite.internal.util.future.*; -import org.apache.ignite.internal.util.lang.*; -import org.apache.ignite.internal.util.nodestart.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -import javax.management.*; -import java.io.*; -import java.lang.management.*; -import java.lang.reflect.*; -import java.net.*; -import java.text.*; -import java.util.*; -import java.util.concurrent.*; -import java.util.concurrent.atomic.*; - -import static org.apache.ignite.internal.GridKernalState.*; -import static org.apache.ignite.lifecycle.LifecycleEventType.*; -import static org.apache.ignite.IgniteSystemProperties.*; -import static org.apache.ignite.internal.IgniteComponentType.*; -import static org.apache.ignite.internal.GridNodeAttributes.*; -import static org.apache.ignite.internal.GridProductImpl.*; -import static org.apache.ignite.internal.processors.license.GridLicenseSubsystem.*; -import static org.apache.ignite.internal.util.nodestart.GridNodeStartUtils.*; - -/** - * GridGain kernal. - * <p/> - * See <a href="http://en.wikipedia.org/wiki/Kernal";>http://en.wikipedia.org/wiki/Kernal</a> for information on the - * misspelling. - */ -public class GridKernal extends ClusterGroupAdapter implements GridEx, IgniteMXBean { - /** */ - private static final long serialVersionUID = 0L; - - /** Compatible versions. */ - private static final String COMPATIBLE_VERS = GridProperties.get("gridgain.compatible.vers"); - - /** GridGain site that is shown in log messages. */ - static final String SITE = "www.gridgain.com"; - - /** System line separator. */ - private static final String NL = U.nl(); - - /** Periodic version check delay. */ - private static final long PERIODIC_VER_CHECK_DELAY = 1000 * 60 * 60; // Every hour. - - /** Periodic version check delay. */ - private static final long PERIODIC_VER_CHECK_CONN_TIMEOUT = 10 * 1000; // 10 seconds. - - /** Periodic version check delay. */ - private static final long PERIODIC_LIC_CHECK_DELAY = 1000 * 60; // Every minute. - - /** Periodic starvation check interval. */ - private static final long PERIODIC_STARVATION_CHECK_FREQ = 1000 * 30; - - /** Shutdown delay in msec. when license violation detected. */ - private static final int SHUTDOWN_DELAY = 60 * 1000; - - /** */ - private IgniteConfiguration cfg; - - /** */ - @SuppressWarnings({"FieldAccessedSynchronizedAndUnsynchronized"}) - @GridToStringExclude - private GridLoggerProxy log; - - /** */ - private String gridName; - - /** */ - @GridToStringExclude - private ObjectName kernalMBean; - - /** */ - @GridToStringExclude - private ObjectName locNodeMBean; - - /** */ - @GridToStringExclude - private ObjectName pubExecSvcMBean; - - /** */ - @GridToStringExclude - private ObjectName sysExecSvcMBean; - - /** */ - @GridToStringExclude - private ObjectName mgmtExecSvcMBean; - - /** */ - @GridToStringExclude - private ObjectName p2PExecSvcMBean; - - /** */ - @GridToStringExclude - private ObjectName restExecSvcMBean; - - /** Kernal start timestamp. */ - private long startTime = U.currentTimeMillis(); - - /** Spring context, potentially {@code null}. */ - private GridSpringResourceContext rsrcCtx; - - /** */ - @GridToStringExclude - private Timer updateNtfTimer; - - /** */ - @GridToStringExclude - private Timer starveTimer; - - /** */ - @GridToStringExclude - private Timer licTimer; - - /** */ - @GridToStringExclude - private Timer metricsLogTimer; - - /** Indicate error on grid stop. */ - @GridToStringExclude - private boolean errOnStop; - - /** Node local store. */ - @GridToStringExclude - private ClusterNodeLocalMap nodeLoc; - - /** Scheduler. */ - @GridToStringExclude - private IgniteScheduler scheduler; - - /** Grid security instance. */ - @GridToStringExclude - private GridSecurity security; - - /** Portables instance. */ - @GridToStringExclude - private IgnitePortables portables; - - /** Kernal gateway. */ - @GridToStringExclude - private final AtomicReference<GridKernalGateway> gw = new AtomicReference<>(); - - /** Data Grid edition usage registered flag. */ - @GridToStringExclude - private volatile boolean dbUsageRegistered; - - /** */ - @GridToStringExclude - private final Collection<String> compatibleVers; - - /** Stop guard. */ - @GridToStringExclude - private final AtomicBoolean stopGuard = new AtomicBoolean(); - - /** - * No-arg constructor is required by externalization. - */ - public GridKernal() { - this(null); - } - - /** - * @param rsrcCtx Optional Spring application context. - */ - public GridKernal(@Nullable GridSpringResourceContext rsrcCtx) { - super(null, null, null, (IgnitePredicate<ClusterNode>)null); - - this.rsrcCtx = rsrcCtx; - - String[] compatibleVers = COMPATIBLE_VERS.split(","); - - for (int i = 0; i < compatibleVers.length; i++) - compatibleVers[i] = compatibleVers[i].trim(); - - this.compatibleVers = Collections.unmodifiableList(Arrays.asList(compatibleVers)); - } - - /** {@inheritDoc} */ - @Override public IgniteCluster cluster() { - return this; - } - - /** {@inheritDoc} */ - @Override public final IgniteCompute compute(ClusterGroup prj) { - return ((ClusterGroupAdapter)prj).compute(); - } - - /** {@inheritDoc} */ - @Override public final IgniteMessaging message(ClusterGroup prj) { - return ((ClusterGroupAdapter)prj).message(); - } - - /** {@inheritDoc} */ - @Override public final IgniteEvents events(ClusterGroup prj) { - return ((ClusterGroupAdapter)prj).events(); - } - - /** {@inheritDoc} */ - @Override public IgniteManaged managed(ClusterGroup prj) { - return ((ClusterGroupAdapter)prj).managed(); - } - - /** {@inheritDoc} */ - @Override public ExecutorService executorService(ClusterGroup prj) { - return ((ClusterGroupAdapter)prj).executorService(); - } - - /** {@inheritDoc} */ - @Override public String name() { - return gridName; - } - - /** {@inheritDoc} */ - @Override public String getCopyright() { - return ctx.product().copyright(); - } - - /** {@inheritDoc} */ - @Override public String getLicenseFilePath() { - assert cfg != null; - - return cfg.getLicenseUrl(); - } - - /** {@inheritDoc} */ - @Override public long getStartTimestamp() { - return startTime; - } - - /** {@inheritDoc} */ - @Override public String getStartTimestampFormatted() { - return DateFormat.getDateTimeInstance().format(new Date(startTime)); - } - - /** {@inheritDoc} */ - @Override public long getUpTime() { - return U.currentTimeMillis() - startTime; - } - - /** {@inheritDoc} */ - @Override public String getUpTimeFormatted() { - return X.timeSpan2HMSM(U.currentTimeMillis() - startTime); - } - - /** {@inheritDoc} */ - @Override public String getFullVersion() { - return COMPOUND_VER + '-' + BUILD_TSTAMP_STR; - } - - /** {@inheritDoc} */ - @Override public String getCheckpointSpiFormatted() { - assert cfg != null; - - return Arrays.toString(cfg.getCheckpointSpi()); - } - - /** {@inheritDoc} */ - @Override public String getSwapSpaceSpiFormatted() { - assert cfg != null; - - return cfg.getSwapSpaceSpi().toString(); - } - - /** {@inheritDoc} */ - @Override public String getCommunicationSpiFormatted() { - assert cfg != null; - - return cfg.getCommunicationSpi().toString(); - } - - /** {@inheritDoc} */ - @Override public String getDeploymentSpiFormatted() { - assert cfg != null; - - return cfg.getDeploymentSpi().toString(); - } - - /** {@inheritDoc} */ - @Override public String getDiscoverySpiFormatted() { - assert cfg != null; - - return cfg.getDiscoverySpi().toString(); - } - - /** {@inheritDoc} */ - @Override public String getEventStorageSpiFormatted() { - assert cfg != null; - - return cfg.getEventStorageSpi().toString(); - } - - /** {@inheritDoc} */ - @Override public String getCollisionSpiFormatted() { - assert cfg != null; - - return cfg.getCollisionSpi().toString(); - } - - /** {@inheritDoc} */ - @Override public String getFailoverSpiFormatted() { - assert cfg != null; - - return Arrays.toString(cfg.getFailoverSpi()); - } - - /** {@inheritDoc} */ - @Override public String getLoadBalancingSpiFormatted() { - assert cfg != null; - - return Arrays.toString(cfg.getLoadBalancingSpi()); - } - - /** {@inheritDoc} */ - @Override public String getAuthenticationSpiFormatted() { - assert cfg != null; - - return cfg.getAuthenticationSpi().toString(); - } - - /** {@inheritDoc} */ - @Override public String getSecureSessionSpiFormatted() { - assert cfg != null; - - return cfg.getSecureSessionSpi().toString(); - } - - /** {@inheritDoc} */ - @Override public String getOsInformation() { - return U.osString(); - } - - /** {@inheritDoc} */ - @Override public String getJdkInformation() { - return U.jdkString(); - } - - /** {@inheritDoc} */ - @Override public String getOsUser() { - return System.getProperty("user.name"); - } - - /** {@inheritDoc} */ - @Override public String getVmName() { - return ManagementFactory.getRuntimeMXBean().getName(); - } - - /** {@inheritDoc} */ - @Override public String getInstanceName() { - return gridName; - } - - /** {@inheritDoc} */ - @Override public String getExecutorServiceFormatted() { - assert cfg != null; - - return cfg.getExecutorService().toString(); - } - - /** {@inheritDoc} */ - @Override public String getGridGainHome() { - assert cfg != null; - - return cfg.getGridGainHome(); - } - - /** {@inheritDoc} */ - @Override public String getGridLoggerFormatted() { - assert cfg != null; - - return cfg.getGridLogger().toString(); - } - - /** {@inheritDoc} */ - @Override public String getMBeanServerFormatted() { - assert cfg != null; - - return cfg.getMBeanServer().toString(); - } - - /** {@inheritDoc} */ - @Override public UUID getLocalNodeId() { - assert cfg != null; - - return cfg.getNodeId(); - } - - /** {@inheritDoc} */ - @SuppressWarnings("unchecked") - @Override public Collection<String> getUserAttributesFormatted() { - assert cfg != null; - - return F.transform(cfg.getUserAttributes().entrySet(), new C1<Map.Entry<String, ?>, String>() { - @Override public String apply(Map.Entry<String, ?> e) { - return e.getKey() + ", " + e.getValue().toString(); - } - }); - } - - /** {@inheritDoc} */ - @Override public boolean isPeerClassLoadingEnabled() { - assert cfg != null; - - return cfg.isPeerClassLoadingEnabled(); - } - - /** {@inheritDoc} */ - @Override public Collection<String> getLifecycleBeansFormatted() { - LifecycleBean[] beans = cfg.getLifecycleBeans(); - - return F.isEmpty(beans) ? Collections.<String>emptyList() : F.transform(beans, F.<LifecycleBean>string()); - } - - /** - * @param attrs Current attributes. - * @param name New attribute name. - * @param val New attribute value. - * @throws IgniteCheckedException If duplicated SPI name found. - */ - private void add(Map<String, Object> attrs, String name, @Nullable Serializable val) throws IgniteCheckedException { - assert attrs != null; - assert name != null; - - if (attrs.put(name, val) != null) { - if (name.endsWith(ATTR_SPI_CLASS)) - // User defined duplicated names for the different SPIs. - throw new IgniteCheckedException("Failed to set SPI attribute. Duplicated SPI name found: " + - name.substring(0, name.length() - ATTR_SPI_CLASS.length())); - - // Otherwise it's a mistake of setting up duplicated attribute. - assert false : "Duplicate attribute: " + name; - } - } - - /** - * Notifies life-cycle beans of grid event. - * - * @param evt Grid event. - * @throws IgniteCheckedException If user threw exception during start. - */ - @SuppressWarnings({"CatchGenericClass"}) - private void notifyLifecycleBeans(LifecycleEventType evt) throws IgniteCheckedException { - if (!cfg.isDaemon() && cfg.getLifecycleBeans() != null) - for (LifecycleBean bean : cfg.getLifecycleBeans()) - if (bean != null) - bean.onLifecycleEvent(evt); - } - - /** - * Notifies life-cycle beans of grid event. - * - * @param evt Grid event. - */ - @SuppressWarnings({"CatchGenericClass"}) - private void notifyLifecycleBeansEx(LifecycleEventType evt) { - try { - notifyLifecycleBeans(evt); - } - // Catch generic throwable to secure against user assertions. - catch (Throwable e) { - U.error(log, "Failed to notify lifecycle bean (safely ignored) [evt=" + evt + - ", gridName=" + gridName + ']', e); - } - } - - /** - * @param cfg Grid configuration to use. - * @param utilityCachePool Utility cache pool. - * @param errHnd Error handler to use for notification about startup problems. - * @throws IgniteCheckedException Thrown in case of any errors. - */ - @SuppressWarnings({"CatchGenericClass", "unchecked"}) - public void start(final IgniteConfiguration cfg, ExecutorService utilityCachePool, GridAbsClosure errHnd) - throws IgniteCheckedException { - gw.compareAndSet(null, new GridKernalGatewayImpl(cfg.getGridName())); - - GridKernalGateway gw = this.gw.get(); - - gw.writeLock(); - - try { - switch (gw.getState()) { - case STARTED: { - U.warn(log, "Grid has already been started (ignored)."); - - return; - } - - case STARTING: { - U.warn(log, "Grid is already in process of being started (ignored)."); - - return; - } - - case STOPPING: { - throw new IgniteCheckedException("Grid is in process of being stopped"); - } - - case STOPPED: { - break; - } - } - - gw.setState(STARTING); - } - finally { - gw.writeUnlock(); - } - - assert cfg != null; - - // Make sure we got proper configuration. - validateCommon(cfg); - - gridName = cfg.getGridName(); - - this.cfg = cfg; - - log = (GridLoggerProxy)cfg.getGridLogger().getLogger(getClass().getName() + - (gridName != null ? '%' + gridName : "")); - - RuntimeMXBean rtBean = ManagementFactory.getRuntimeMXBean(); - - // Ack various information. - ackAsciiLogo(); - ackConfigUrl(); - ackDaemon(); - ackOsInfo(); - ackLanguageRuntime(); - ackRemoteManagement(); - ackVmArguments(rtBean); - ackClassPaths(rtBean); - ackSystemProperties(); - ackEnvironmentVariables(); - ackSmtpConfiguration(); - ackCacheConfiguration(); - ackP2pConfiguration(); - - // Run background network diagnostics. - GridDiagnostic.runBackgroundCheck(gridName, cfg.getExecutorService(), log); - - boolean notifyEnabled = IgniteSystemProperties.getBoolean(GG_UPDATE_NOTIFIER, true); - - GridUpdateNotifier verChecker0 = null; - - if (notifyEnabled) { - try { - verChecker0 = new GridUpdateNotifier(gridName, VER, SITE, gw, false); - - verChecker0.checkForNewVersion(cfg.getExecutorService(), log); - } - catch (IgniteCheckedException e) { - if (log.isDebugEnabled()) - log.debug("Failed to create GridUpdateNotifier: " + e); - } - } - - final GridUpdateNotifier verChecker = verChecker0; - - // Ack 3-rd party licenses location. - if (log.isInfoEnabled() && cfg.getGridGainHome() != null) - log.info("3-rd party licenses can be found at: " + cfg.getGridGainHome() + File.separatorChar + "libs" + - File.separatorChar + "licenses"); - - // Check that user attributes are not conflicting - // with internally reserved names. - for (String name : cfg.getUserAttributes().keySet()) - if (name.startsWith(ATTR_PREFIX)) - throw new IgniteCheckedException("User attribute has illegal name: '" + name + "'. Note that all names " + - "starting with '" + ATTR_PREFIX + "' are reserved for internal use."); - - // Ack local node user attributes. - logNodeUserAttributes(); - - // Ack configuration. - ackSpis(); - - Map<String, Object> attrs = createNodeAttributes(cfg, BUILD_TSTAMP_STR); - - // Spin out SPIs & managers. - try { - GridKernalContextImpl ctx = - new GridKernalContextImpl(log, this, cfg, gw, utilityCachePool, ENT); - - nodeLoc = new ClusterNodeLocalMapImpl(ctx); - - U.onGridStart(); - - // Set context into rich adapter. - setKernalContext(ctx); - - // Start and configure resource processor first as it contains resources used - // by all other managers and processors. - GridResourceProcessor rsrcProc = new GridResourceProcessor(ctx); - - rsrcProc.setSpringContext(rsrcCtx); - - ctx.product(new GridProductImpl(ctx, verChecker)); - - scheduler = new IgniteSchedulerImpl(ctx); - - startProcessor(ctx, rsrcProc, attrs); - - // Inject resources into lifecycle beans. - if (!cfg.isDaemon() && cfg.getLifecycleBeans() != null) - for (LifecycleBean bean : cfg.getLifecycleBeans()) - if (bean != null) - rsrcProc.inject(bean); - - // Lifecycle notification. - notifyLifecycleBeans(BEFORE_GRID_START); - - // Starts lifecycle aware components. - U.startLifecycleAware(lifecycleAwares(cfg)); - - addHelper(ctx, GGFS_HELPER.create(F.isEmpty(cfg.getGgfsConfiguration()))); - - startProcessor(ctx, new IgnitePluginProcessor(ctx, cfg), attrs); - - // Off-heap processor has no dependencies. - startProcessor(ctx, new GridOffHeapProcessor(ctx), attrs); - - // Closure processor should be started before all others - // (except for resource processor), as many components can depend on it. - startProcessor(ctx, new GridClosureProcessor(ctx), attrs); - - // Start some other processors (order & place is important). - startProcessor(ctx, (GridProcessor)EMAIL.create(ctx, cfg.getSmtpHost() == null), attrs); - startProcessor(ctx, new GridPortProcessor(ctx), attrs); - startProcessor(ctx, new GridJobMetricsProcessor(ctx), attrs); - - // Timeout processor needs to be started before managers, - // as managers may depend on it. - startProcessor(ctx, new GridTimeoutProcessor(ctx), attrs); - - // Start SPI managers. - // NOTE: that order matters as there are dependencies between managers. - startManager(ctx, createComponent(GridSecurityManager.class, ctx), attrs); - startManager(ctx, createComponent(GridSecureSessionManager.class, ctx), attrs); - startManager(ctx, new GridIoManager(ctx), attrs); - startManager(ctx, new GridCheckpointManager(ctx), attrs); - - startManager(ctx, new GridEventStorageManager(ctx), attrs); - startManager(ctx, new GridDeploymentManager(ctx), attrs); - startManager(ctx, new GridLoadBalancerManager(ctx), attrs); - startManager(ctx, new GridFailoverManager(ctx), attrs); - startManager(ctx, new GridCollisionManager(ctx), attrs); - startManager(ctx, new GridSwapSpaceManager(ctx), attrs); - startManager(ctx, new GridIndexingManager(ctx), attrs); - - ackSecurity(ctx); - - // Start processors before discovery manager, so they will - // be able to start receiving messages once discovery completes. - startProcessor(ctx, new GridClockSyncProcessor(ctx), attrs); - startProcessor(ctx, createComponent(GridLicenseProcessor.class, ctx), attrs); - startProcessor(ctx, new GridAffinityProcessor(ctx), attrs); - startProcessor(ctx, createComponent(GridSegmentationProcessor.class, ctx), attrs); - startProcessor(ctx, new GridQueryProcessor(ctx), attrs); - startProcessor(ctx, new GridCacheProcessor(ctx), attrs); - startProcessor(ctx, new GridTaskSessionProcessor(ctx), attrs); - startProcessor(ctx, new GridJobProcessor(ctx), attrs); - startProcessor(ctx, new GridTaskProcessor(ctx), attrs); - startProcessor(ctx, (GridProcessor)SCHEDULE.createOptional(ctx), attrs); - startProcessor(ctx, createComponent(GridPortableProcessor.class, ctx), attrs); - startProcessor(ctx, createComponent(GridInteropProcessor.class, ctx), attrs); - startProcessor(ctx, new GridRestProcessor(ctx), attrs); - startProcessor(ctx, new GridDataLoaderProcessor(ctx), attrs); - startProcessor(ctx, new GridStreamProcessor(ctx), attrs); - startProcessor(ctx, (GridProcessor)GGFS.create(ctx, F.isEmpty(cfg.getGgfsConfiguration())), attrs); - startProcessor(ctx, new GridContinuousProcessor(ctx), attrs); - startProcessor(ctx, (GridProcessor)(cfg.isPeerClassLoadingEnabled() ? - IgniteComponentType.HADOOP.create(ctx, true): // No-op when peer class loading is enabled. - IgniteComponentType.HADOOP.createIfInClassPath(ctx, cfg.getHadoopConfiguration() != null)), attrs); - startProcessor(ctx, new GridServiceProcessor(ctx), attrs); - - // Start plugins. - for (PluginProvider provider : ctx.plugins().allProviders()) { - ctx.add(new GridPluginComponent(provider)); - - provider.start(ctx.plugins().pluginContextForProvider(provider), attrs); - } - - ctx.createMessageFactory(); - - if (ctx.isEnterprise()) { - security = new GridSecurityImpl(ctx); - portables = new GridPortablesImpl(ctx); - } - - gw.writeLock(); - - try { - gw.setState(STARTED); - - // Start discovery manager last to make sure that grid is fully initialized. - startManager(ctx, new GridDiscoveryManager(ctx), attrs); - } - finally { - gw.writeUnlock(); - } - - // Check whether physical RAM is not exceeded. - checkPhysicalRam(); - - // Suggest configuration optimizations. - suggestOptimizations(ctx, cfg); - - if (!ctx.isEnterprise()) - warnNotSupportedFeaturesForOs(cfg); - - // Notify discovery manager the first to make sure that topology is discovered. - ctx.discovery().onKernalStart(); - - // Notify IO manager the second so further components can send and receive messages. - ctx.io().onKernalStart(); - - // Callbacks. - for (GridComponent comp : ctx) { - // Skip discovery manager. - if (comp instanceof GridDiscoveryManager) - continue; - - // Skip IO manager. - if (comp instanceof GridIoManager) - continue; - - comp.onKernalStart(); - } - - // Ack the license. - ctx.license().ackLicense(); - - // Register MBeans. - registerKernalMBean(); - registerLocalNodeMBean(); - registerExecutorMBeans(); - - // Lifecycle bean notifications. - notifyLifecycleBeans(AFTER_GRID_START); - } - catch (Throwable e) { - IgniteSpiVersionCheckException verCheckErr = X.cause(e, IgniteSpiVersionCheckException.class); - - if (verCheckErr != null) - U.error(log, verCheckErr.getMessage()); - else if (X.hasCause(e, InterruptedException.class, IgniteInterruptedException.class)) - U.warn(log, "Grid startup routine has been interrupted (will rollback)."); - else - U.error(log, "Got exception while starting (will rollback startup routine).", e); - - errHnd.apply(); - - stop(true); - - if (e instanceof IgniteCheckedException) - throw (IgniteCheckedException)e; - else - throw new IgniteCheckedException(e); - } - - // Mark start timestamp. - startTime = U.currentTimeMillis(); - - // Ack latest version information. - if (verChecker != null) - verChecker.reportStatus(log); - - if (notifyEnabled) { - assert verChecker != null; - - verChecker.reportOnlyNew(true); - verChecker.licenseProcessor(ctx.license()); - - updateNtfTimer = new Timer("gridgain-update-notifier-timer"); - - // Setup periodic version check. - updateNtfTimer.scheduleAtFixedRate(new GridTimerTask() { - @Override public void safeRun() throws InterruptedException { - verChecker.topologySize(nodes().size()); - - verChecker.checkForNewVersion(cfg.getExecutorService(), log); - - // Just wait for 10 secs. - Thread.sleep(PERIODIC_VER_CHECK_CONN_TIMEOUT); - - // Report status if one is available. - // No-op if status is NOT available. - verChecker.reportStatus(log); - } - }, PERIODIC_VER_CHECK_DELAY, PERIODIC_VER_CHECK_DELAY); - } - - String intervalStr = IgniteSystemProperties.getString(GG_STARVATION_CHECK_INTERVAL); - - // Start starvation checker if enabled. - boolean starveCheck = !isDaemon() && !"0".equals(intervalStr); - - if (starveCheck) { - final long interval = F.isEmpty(intervalStr) ? PERIODIC_STARVATION_CHECK_FREQ : Long.parseLong(intervalStr); - - starveTimer = new Timer("gridgain-starvation-checker"); - - starveTimer.scheduleAtFixedRate(new GridTimerTask() { - /** Last completed task count. */ - private long lastCompletedCnt; - - @Override protected void safeRun() { - ExecutorService e = cfg.getExecutorService(); - - if (!(e instanceof ThreadPoolExecutor)) - return; - - ThreadPoolExecutor exec = (ThreadPoolExecutor)e; - - long completedCnt = exec.getCompletedTaskCount(); - - // If all threads are active and no task has completed since last time and there is - // at least one waiting request, then it is possible starvation. - if (exec.getPoolSize() == exec.getActiveCount() && completedCnt == lastCompletedCnt && - !exec.getQueue().isEmpty()) - LT.warn(log, null, "Possible thread pool starvation detected (no task completed in last " + - interval + "ms, is executorService pool size large enough?)"); - - lastCompletedCnt = completedCnt; - } - }, interval, interval); - } - - if (!isDaemon()) { - licTimer = new Timer("gridgain-license-checker"); - - // Setup periodic license check. - licTimer.scheduleAtFixedRate(new GridTimerTask() { - @Override public void safeRun() throws InterruptedException { - try { - ctx.license().checkLicense(); - } - // This exception only happens when license processor was unable - // to resolve license violation on its own and this grid instance - // now needs to be shutdown. - // - // Note that in most production configurations the license will - // have certain grace period and license processor will attempt - // to reload the license during the grace period. - // - // This exception thrown here means that grace period, if any, - // has expired and license violation is still unresolved. - catch (IgniteProductLicenseException ignored) { - U.error(log, "License violation is unresolved. GridGain node will shutdown in " + - (SHUTDOWN_DELAY / 1000) + " sec."); - U.error(log, " ^-- Contact your support for immediate assistance (!)"); - - // Allow interruption to break from here since - // node is stopping anyways. - Thread.sleep(SHUTDOWN_DELAY); - - G.stop(gridName, true); - } - // Safety net. - catch (Throwable e) { - U.error(log, "Unable to check the license due to system error.", e); - U.error(log, "Grid instance will be stopped..."); - - // Stop the grid if we get unknown license-related error. - // Should never happen. Practically an assertion... - G.stop(gridName, true); - } - } - }, PERIODIC_LIC_CHECK_DELAY, PERIODIC_LIC_CHECK_DELAY); - } - - long metricsLogFreq = cfg.getMetricsLogFrequency(); - - if (metricsLogFreq > 0) { - metricsLogTimer = new Timer("gridgain-metrics-logger"); - - metricsLogTimer.scheduleAtFixedRate(new GridTimerTask() { - /** */ - private final DecimalFormat dblFmt = new DecimalFormat("#.##"); - - @Override protected void safeRun() { - if (log.isInfoEnabled()) { - ClusterMetrics m = localNode().metrics(); - - double cpuLoadPct = m.getCurrentCpuLoad() * 100; - double avgCpuLoadPct = m.getAverageCpuLoad() * 100; - double gcPct = m.getCurrentGcCpuLoad() * 100; - - long heapUsed = m.getHeapMemoryUsed(); - long heapMax = m.getHeapMemoryMaximum(); - - long heapUsedInMBytes = heapUsed / 1024 / 1024; - long heapCommInMBytes = m.getHeapMemoryCommitted() / 1024 / 1024; - - double freeHeapPct = heapMax > 0 ? ((double)((heapMax - heapUsed) * 100)) / heapMax : -1; - - int hosts = 0; - int nodes = 0; - int cpus = 0; - - try { - ClusterMetrics metrics = metrics(); - - Collection<ClusterNode> nodes0 = nodes(); - - hosts = U.neighborhood(nodes0).size(); - nodes = nodes0.size(); - cpus = metrics.getTotalCpus(); - } - catch (IgniteCheckedException ignore) { - // No-op. - } - - int pubPoolActiveThreads = 0; - int pubPoolIdleThreads = 0; - int pubPoolQSize = 0; - - ExecutorService pubExec = cfg.getExecutorService(); - - if (pubExec instanceof ThreadPoolExecutor) { - ThreadPoolExecutor exec = (ThreadPoolExecutor)pubExec; - - int poolSize = exec.getPoolSize(); - - pubPoolActiveThreads = Math.min(poolSize, exec.getActiveCount()); - pubPoolIdleThreads = poolSize - pubPoolActiveThreads; - pubPoolQSize = exec.getQueue().size(); - } - - int sysPoolActiveThreads = 0; - int sysPoolIdleThreads = 0; - int sysPoolQSize = 0; - - ExecutorService sysExec = cfg.getSystemExecutorService(); - - if (sysExec instanceof ThreadPoolExecutor) { - ThreadPoolExecutor exec = (ThreadPoolExecutor)sysExec; - - int poolSize = exec.getPoolSize(); - - sysPoolActiveThreads = Math.min(poolSize, exec.getActiveCount()); - sysPoolIdleThreads = poolSize - sysPoolActiveThreads; - sysPoolQSize = exec.getQueue().size(); - } - - String msg = NL + - "Metrics for local node (to disable set 'metricsLogFrequency' to 0)" + NL + - " ^-- H/N/C [hosts=" + hosts + ", nodes=" + nodes + ", CPUs=" + cpus + "]" + NL + - " ^-- CPU [cur=" + dblFmt.format(cpuLoadPct) + "%, avg=" + - dblFmt.format(avgCpuLoadPct) + "%, GC=" + dblFmt.format(gcPct) + "%]" + NL + - " ^-- Heap [used=" + dblFmt.format(heapUsedInMBytes) + "MB, free=" + - dblFmt.format(freeHeapPct) + "%, comm=" + dblFmt.format(heapCommInMBytes) + "MB]" + NL + - " ^-- Public thread pool [active=" + pubPoolActiveThreads + ", idle=" + - pubPoolIdleThreads + ", qSize=" + pubPoolQSize + "]" + NL + - " ^-- System thread pool [active=" + sysPoolActiveThreads + ", idle=" + - sysPoolIdleThreads + ", qSize=" + sysPoolQSize + "]" + NL + - " ^-- Outbound messages queue [size=" + m.getOutboundMessagesQueueSize() + "]"; - - log.info(msg); - } - } - }, metricsLogFreq, metricsLogFreq); - } - - ctx.performance().logSuggestions(log, gridName); - - ackBenchmarks(); - ackVisor(); - - ackStart(rtBean); - - if (!isDaemon()) - ctx.discovery().ackTopology(); - - // Send node start email notification, if enabled. - if (isSmtpEnabled() && isAdminEmailsSet() && cfg.isLifeCycleEmailNotification()) { - SB sb = new SB(); - - for (GridPortRecord rec : ctx.ports().records()) - sb.a(rec.protocol()).a(":").a(rec.port()).a(" "); - - String nid = localNode().id().toString().toUpperCase(); - String nid8 = U.id8(localNode().id()).toUpperCase(); - - IgniteProductLicense lic = ctx.license().license(); - - String body = - "GridGain node started with the following parameters:" + NL + - NL + - "----" + NL + - "GridGain ver. " + COMPOUND_VER + '#' + BUILD_TSTAMP_STR + "-sha1:" + REV_HASH + NL + - "Grid name: " + gridName + NL + - "Node ID: " + nid + NL + - "Node order: " + localNode().order() + NL + - "Node addresses: " + U.addressesAsString(localNode()) + NL + - "Local ports: " + sb + NL + - "OS name: " + U.osString() + NL + - "OS user: " + System.getProperty("user.name") + NL + - "CPU(s): " + localNode().metrics().getTotalCpus() + NL + - "Heap: " + U.heapSize(localNode(), 2) + "GB" + NL + - "JVM name: " + U.jvmName() + NL + - "JVM vendor: " + U.jvmVendor() + NL + - "JVM version: " + U.jvmVersion() + NL + - "VM name: " + rtBean.getName() + NL; - - if (lic != null) { - body += - "License ID: " + lic.id().toString().toUpperCase() + NL + - "Licensed to: " + lic.userOrganization() + NL; - } - else - assert !ENT; - - body += - "----" + NL + - NL + - "NOTE:" + NL + - "This message is sent automatically to all configured admin emails." + NL + - "To change this behavior use 'lifeCycleEmailNotify' grid configuration property." + - NL + NL + - "| " + SITE + NL + - "| supp...@gridgain.com" + NL; - - sendAdminEmailAsync("GridGain node started: " + nid8, body, false); - } - } - - /** - * Validates common configuration parameters. - * - * @param cfg Configuration. - */ - private void validateCommon(IgniteConfiguration cfg) { - A.notNull(cfg.getNodeId(), "cfg.getNodeId()"); - - A.notNull(cfg.getMBeanServer(), "cfg.getMBeanServer()"); - A.notNull(cfg.getGridLogger(), "cfg.getGridLogger()"); - A.notNull(cfg.getMarshaller(), "cfg.getMarshaller()"); - A.notNull(cfg.getExecutorService(), "cfg.getExecutorService()"); - A.notNull(cfg.getUserAttributes(), "cfg.getUserAttributes()"); - - // All SPIs should be non-null. - A.notNull(cfg.getSwapSpaceSpi(), "cfg.getSwapSpaceSpi()"); - A.notNull(cfg.getCheckpointSpi(), "cfg.getCheckpointSpi()"); - A.notNull(cfg.getCommunicationSpi(), "cfg.getCommunicationSpi()"); - A.notNull(cfg.getDeploymentSpi(), "cfg.getDeploymentSpi()"); - A.notNull(cfg.getDiscoverySpi(), "cfg.getDiscoverySpi()"); - A.notNull(cfg.getEventStorageSpi(), "cfg.getEventStorageSpi()"); - A.notNull(cfg.getAuthenticationSpi(), "cfg.getAuthenticationSpi()"); - A.notNull(cfg.getSecureSessionSpi(), "cfg.getSecureSessionSpi()"); - A.notNull(cfg.getCollisionSpi(), "cfg.getCollisionSpi()"); - A.notNull(cfg.getFailoverSpi(), "cfg.getFailoverSpi()"); - A.notNull(cfg.getLoadBalancingSpi(), "cfg.getLoadBalancingSpi()"); - A.notNull(cfg.getIndexingSpi(), "cfg.getIndexingSpi()"); - - A.ensure(cfg.getNetworkTimeout() > 0, "cfg.getNetworkTimeout() > 0"); - A.ensure(cfg.getNetworkSendRetryDelay() > 0, "cfg.getNetworkSendRetryDelay() > 0"); - A.ensure(cfg.getNetworkSendRetryCount() > 0, "cfg.getNetworkSendRetryCount() > 0"); - - if (!F.isEmpty(cfg.getPluginConfigurations())) { - for (PluginConfiguration pluginCfg : cfg.getPluginConfigurations()) - A.notNull(pluginCfg.providerClass(), "PluginConfiguration.providerClass()"); - } - } - - /** - * Checks whether physical RAM is not exceeded. - */ - @SuppressWarnings("ConstantConditions") - private void checkPhysicalRam() { - long ram = ctx.discovery().localNode().attribute(ATTR_PHY_RAM); - - if (ram != -1) { - String macs = ctx.discovery().localNode().attribute(ATTR_MACS); - - long totalHeap = 0; - - for (ClusterNode node : ctx.discovery().allNodes()) { - if (macs.equals(node.attribute(ATTR_MACS))) { - long heap = node.metrics().getHeapMemoryMaximum(); - - if (heap != -1) - totalHeap += heap; - } - } - - if (totalHeap > ram) { - U.quietAndWarn(log, "Attempting to start more nodes than physical RAM " + - "available on current host (this can cause significant slowdown)"); - } - } - } - - /** - * @param ctx Context. - * @param cfg Configuration to check for possible performance issues. - */ - private void suggestOptimizations(GridKernalContext ctx, IgniteConfiguration cfg) { - GridPerformanceSuggestions perf = ctx.performance(); - - if (ctx.collision().enabled()) - perf.add("Disable collision resolution (remove 'collisionSpi' from configuration)"); - - if (ctx.checkpoint().enabled()) - perf.add("Disable checkpoints (remove 'checkpointSpi' from configuration)"); - - if (cfg.isPeerClassLoadingEnabled()) - perf.add("Disable peer class loading (set 'peerClassLoadingEnabled' to false)"); - - if (cfg.isMarshalLocalJobs()) - perf.add("Disable local jobs marshalling (set 'marshalLocalJobs' to false)"); - - if (cfg.getIncludeEventTypes() != null && cfg.getIncludeEventTypes().length != 0) - perf.add("Disable grid events (remove 'includeEventTypes' from configuration)"); - - if (IgniteOptimizedMarshaller.available() && !(cfg.getMarshaller() instanceof IgniteOptimizedMarshaller)) - perf.add("Enable optimized marshaller (set 'marshaller' to " + - IgniteOptimizedMarshaller.class.getSimpleName() + ')'); - } - - /** - * Warns user about unsupported features which was configured in OS edition. - * - * @param cfg Grid configuration. - */ - private void warnNotSupportedFeaturesForOs(IgniteConfiguration cfg) { - Collection<String> msgs = new ArrayList<>(); - - if (!F.isEmpty(cfg.getSegmentationResolvers())) - msgs.add("Network segmentation detection."); - - if (cfg.getSecureSessionSpi() != null && !(cfg.getSecureSessionSpi() instanceof NoopSecureSessionSpi)) - msgs.add("Secure session SPI."); - - if (cfg.getAuthenticationSpi() != null && !(cfg.getAuthenticationSpi() instanceof NoopAuthenticationSpi)) - msgs.add("Authentication SPI."); - - if (!F.isEmpty(msgs)) { - U.quietAndInfo(log, "The following features are not supported in open source edition, " + - "related configuration settings will be ignored " + - "(consider downloading enterprise edition from http://www.gridgain.com):"); - - for (String s : msgs) - U.quietAndInfo(log, " ^-- " + s); - - U.quietAndInfo(log, ""); - } - } - - /** - * Creates attributes map and fills it in. - * - * @param cfg Grid configuration. - * @param build Build string. - * @return Map of all node attributes. - * @throws IgniteCheckedException thrown if was unable to set up attribute. - */ - @SuppressWarnings({"SuspiciousMethodCalls", "unchecked", "TypeMayBeWeakened"}) - private Map<String, Object> createNodeAttributes(IgniteConfiguration cfg, String build) throws IgniteCheckedException { - Map<String, Object> attrs = new HashMap<>(); - - final String[] incProps = cfg.getIncludeProperties(); - - try { - // Stick all environment settings into node attributes. - attrs.putAll(F.view(System.getenv(), new P1<String>() { - @Override public boolean apply(String name) { - return incProps == null || U.containsStringArray(incProps, name, true) || - U.isVisorNodeStartProperty(name) || U.isVisorRequiredProperty(name); - } - })); - - if (log.isDebugEnabled()) - log.debug("Added environment properties to node attributes."); - } - catch (SecurityException e) { - throw new IgniteCheckedException("Failed to add environment properties to node attributes due to " + - "security violation: " + e.getMessage()); - } - - try { - // Stick all system properties into node's attributes overwriting any - // identical names from environment properties. - for (Map.Entry<Object, Object> e : F.view(System.getProperties(), new P1<Object>() { - @Override public boolean apply(Object o) { - String name = (String)o; - - return incProps == null || U.containsStringArray(incProps, name, true) || - U.isVisorRequiredProperty(name); - } - }).entrySet()) { - Object val = attrs.get(e.getKey()); - - if (val != null && !val.equals(e.getValue())) - U.warn(log, "System property will override environment variable with the same name: " - + e.getKey()); - - attrs.put((String)e.getKey(), e.getValue()); - } - - if (log.isDebugEnabled()) - log.debug("Added system properties to node attributes."); - } - catch (SecurityException e) { - throw new IgniteCheckedException("Failed to add system properties to node attributes due to security " + - "violation: " + e.getMessage()); - } - - // Add local network IPs and MACs. - String ips = F.concat(U.allLocalIps(), ", "); // Exclude loopbacks. - String macs = F.concat(U.allLocalMACs(), ", "); // Only enabled network interfaces. - - // Ack network context. - if (log.isInfoEnabled()) { - log.info("Non-loopback local IPs: " + (F.isEmpty(ips) ? "N/A" : ips)); - log.info("Enabled local MACs: " + (F.isEmpty(macs) ? "N/A" : macs)); - } - - // Warn about loopback. - if (ips.isEmpty() && macs.isEmpty()) - U.warn(log, "GridGain is starting on loopback address... Only nodes on the same physical " + - "computer can participate in topology.", - "GridGain is starting on loopback address..."); - - // Stick in network context into attributes. - add(attrs, ATTR_IPS, (ips.isEmpty() ? "" : ips)); - add(attrs, ATTR_MACS, (macs.isEmpty() ? "" : macs)); - - // Stick in some system level attributes - add(attrs, ATTR_JIT_NAME, U.getCompilerMx() == null ? "" : U.getCompilerMx().getName()); - add(attrs, ATTR_BUILD_VER, COMPOUND_VER); - add(attrs, ATTR_BUILD_DATE, build); - add(attrs, ATTR_COMPATIBLE_VERS, (Serializable)compatibleVersions()); - add(attrs, ATTR_MARSHALLER, cfg.getMarshaller().getClass().getName()); - add(attrs, ATTR_USER_NAME, System.getProperty("user.name")); - add(attrs, ATTR_GRID_NAME, gridName); - - add(attrs, ATTR_PEER_CLASSLOADING, cfg.isPeerClassLoadingEnabled()); - add(attrs, ATTR_DEPLOYMENT_MODE, cfg.getDeploymentMode()); - add(attrs, ATTR_LANG_RUNTIME, getLanguage()); - - add(attrs, ATTR_JVM_PID, U.jvmPid()); - - // Build a string from JVM arguments, because parameters with spaces are split. - SB jvmArgs = new SB(512); - - for (String arg : U.jvmArgs()) { - if (arg.startsWith("-")) - jvmArgs.a("@@@"); - else - jvmArgs.a(' '); - - jvmArgs.a(arg); - } - // Add it to attributes. - add(attrs, ATTR_JVM_ARGS, jvmArgs.toString()); - - // Check daemon system property and override configuration if it's set. - if (isDaemon()) - add(attrs, ATTR_DAEMON, "true"); - - // In case of the parsing error, JMX remote disabled or port not being set - // node attribute won't be set. - if (isJmxRemoteEnabled()) { - String portStr = System.getProperty("com.sun.management.jmxremote.port"); - - if (portStr != null) - try { - add(attrs, ATTR_JMX_PORT, Integer.parseInt(portStr)); - } - catch (NumberFormatException ignore) { - // No-op. - } - } - - // Whether restart is enabled and stick the attribute. - add(attrs, ATTR_RESTART_ENABLED, Boolean.toString(isRestartEnabled())); - - // Save port range, port numbers will be stored by rest processor at runtime. - if (cfg.getClientConnectionConfiguration() != null) - add(attrs, ATTR_REST_PORT_RANGE, cfg.getClientConnectionConfiguration().getRestPortRange()); - - try { - AuthenticationSpi authSpi = cfg.getAuthenticationSpi(); - - boolean securityEnabled = authSpi != null && !U.hasAnnotation(authSpi.getClass(), IgniteSpiNoop.class); - - GridSecurityCredentialsProvider provider = cfg.getSecurityCredentialsProvider(); - - if (provider != null) { - GridSecurityCredentials cred = provider.credentials(); - - if (cred != null) - add(attrs, ATTR_SECURITY_CREDENTIALS, cred); - else if (securityEnabled) - throw new IgniteCheckedException("Failed to start node (authentication SPI is configured, " + - "by security credentials provider returned null)."); - } - else if (securityEnabled) - throw new IgniteCheckedException("Failed to start node (authentication SPI is configured, " + - "but security credentials provider is not set. Fix the configuration and restart the node)."); - } - catch (IgniteCheckedException e) { - throw new IgniteCheckedException("Failed to create node security credentials", e); - } - - // Stick in SPI versions and classes attributes. - addAttributes(attrs, cfg.getCollisionSpi()); - addAttributes(attrs, cfg.getSwapSpaceSpi()); - addAttributes(attrs, cfg.getDiscoverySpi()); - addAttributes(attrs, cfg.getFailoverSpi()); - addAttributes(attrs, cfg.getCommunicationSpi()); - addAttributes(attrs, cfg.getEventStorageSpi()); - addAttributes(attrs, cfg.getCheckpointSpi()); - addAttributes(attrs, cfg.getLoadBalancingSpi()); - addAttributes(attrs, cfg.getAuthenticationSpi()); - addAttributes(attrs, cfg.getSecureSessionSpi()); - addAttributes(attrs, cfg.getDeploymentSpi()); - - // Set user attributes for this node. - if (cfg.getUserAttributes() != null) { - for (Map.Entry<String, ?> e : cfg.getUserAttributes().entrySet()) { - if (attrs.containsKey(e.getKey())) - U.warn(log, "User or internal attribute has the same name as environment or system " + - "property and will take precedence: " + e.getKey()); - - attrs.put(e.getKey(), e.getValue()); - } - } - - return attrs; - } - - /** - * Add SPI version and class attributes into node attributes. - * - * @param attrs Node attributes map to add SPI attributes to. - * @param spiList Collection of SPIs to get attributes from. - * @throws IgniteCheckedException Thrown if was unable to set up attribute. - */ - private void addAttributes(Map<String, Object> attrs, IgniteSpi... spiList) throws IgniteCheckedException { - for (IgniteSpi spi : spiList) { - Class<? extends IgniteSpi> spiCls = spi.getClass(); - - add(attrs, U.spiAttribute(spi, ATTR_SPI_CLASS), spiCls.getName()); - } - } - - /** @throws IgniteCheckedException If registration failed. */ - private void registerKernalMBean() throws IgniteCheckedException { - try { - kernalMBean = U.registerMBean( - cfg.getMBeanServer(), - cfg.getGridName(), - "Kernal", - getClass().getSimpleName(), - this, - IgniteMXBean.class); - - if (log.isDebugEnabled()) - log.debug("Registered kernal MBean: " + kernalMBean); - } - catch (JMException e) { - kernalMBean = null; - - throw new IgniteCheckedException("Failed to register kernal MBean.", e); - } - } - - /** @throws IgniteCheckedException If registration failed. */ - private void registerLocalNodeMBean() throws IgniteCheckedException { - ClusterLocalNodeMetricsMXBean mbean = new ClusterLocalNodeMetricsMXBeanImpl(ctx.discovery().localNode()); - - try { - locNodeMBean = U.registerMBean( - cfg.getMBeanServer(), - cfg.getGridName(), - "Kernal", - mbean.getClass().getSimpleName(), - mbean, - ClusterLocalNodeMetricsMXBean.class); - - if (log.isDebugEnabled()) - log.debug("Registered local node MBean: " + locNodeMBean); - } - catch (JMException e) { - locNodeMBean = null; - - throw new IgniteCheckedException("Failed to register local node MBean.", e); - } - } - - /** @throws IgniteCheckedException If registration failed. */ - private void registerExecutorMBeans() throws IgniteCheckedException { - pubExecSvcMBean = registerExecutorMBean(cfg.getExecutorService(), "GridExecutionExecutor"); - sysExecSvcMBean = registerExecutorMBean(cfg.getSystemExecutorService(), "GridSystemExecutor"); - mgmtExecSvcMBean = registerExecutorMBean(cfg.getManagementExecutorService(), "GridManagementExecutor"); - p2PExecSvcMBean = registerExecutorMBean(cfg.getPeerClassLoadingExecutorService(), "GridClassLoadingExecutor"); - - ClientConnectionConfiguration clientCfg = cfg.getClientConnectionConfiguration(); - - if (clientCfg != null) { - restExecSvcMBean = clientCfg.getRestExecutorService() != null ? - registerExecutorMBean(clientCfg.getRestExecutorService(), "GridRestExecutor") : null; - } - } - - /** - * @param exec Executor service to register. - * @param name Property name for executor. - * @return Name for created MBean. - * @throws IgniteCheckedException If registration failed. - */ - private ObjectName registerExecutorMBean(ExecutorService exec, String name) throws IgniteCheckedException { - assert exec != null; - - try { - ObjectName res = U.registerMBean( - cfg.getMBeanServer(), - cfg.getGridName(), - "Thread Pools", - name, - new IgniteThreadPoolMXBeanAdapter(exec), - IgniteThreadPoolMXBean.class); - - if (log.isDebugEnabled()) - log.debug("Registered executor service MBean: " + res); - - return res; - } - catch (JMException e) { - throw new IgniteCheckedException("Failed to register executor service MBean [name=" + name + ", exec=" + exec + ']', - e); - } - } - - /** - * Unregisters given mbean. - * - * @param mbean MBean to unregister. - * @return {@code True} if successfully unregistered, {@code false} otherwise. - */ - private boolean unregisterMBean(@Nullable ObjectName mbean) { - if (mbean != null) - try { - cfg.getMBeanServer().unregisterMBean(mbean); - - if (log.isDebugEnabled()) - log.debug("Unregistered MBean: " + mbean); - - return true; - } - catch (JMException e) { - U.error(log, "Failed to unregister MBean.", e); - - return false; - } - - return true; - } - - /** - * @param ctx Kernal context. - * @param mgr Manager to start. - * @param attrs SPI attributes to set. - * @throws IgniteCheckedException Throw in case of any errors. - */ - private void startManager(GridKernalContextImpl ctx, GridManager mgr, Map<String, Object> attrs) - throws IgniteCheckedException { - mgr.addSpiAttributes(attrs); - - // Set all node attributes into discovery manager, - // so they can be distributed to all nodes. - if (mgr instanceof GridDiscoveryManager) - ((GridDiscoveryManager)mgr).setNodeAttributes(attrs, ctx.product().version()); - - // Add manager to registry before it starts to avoid - // cases when manager is started but registry does not - // have it yet. - ctx.add(mgr); - - try { - mgr.start(); - } - catch (IgniteCheckedException e) { - throw new IgniteCheckedException("Failed to start manager: " + mgr, e); - } - } - - /** - * @param ctx Kernal context. - * @param proc Processor to start. - * @param attrs Attributes. - * @throws IgniteCheckedException Thrown in case of any error. - */ - private void startProcessor(GridKernalContextImpl ctx, GridProcessor proc, Map<String, Object> attrs) - throws IgniteCheckedException { - ctx.add(proc); - - try { - proc.start(); - - proc.addAttributes(attrs); - } - catch (IgniteCheckedException e) { - throw new IgniteCheckedException("Failed to start processor: " + proc, e); - } - } - - /** - * Add helper. - * - * @param ctx Context. - * @param helper Helper. - */ - private void addHelper(GridKernalContextImpl ctx, Object helper) { - ctx.addHelper(helper); - } - - /** - * Gets "on" or "off" string for given boolean value. - * - * @param b Boolean value to convert. - * @return Result string. - */ - private String onOff(boolean b) { - return b ? "on" : "off"; - } - - /** - * - * @return Whether or not REST is enabled. - */ - private boolean isRestEnabled() { - assert cfg != null; - - return cfg.getClientConnectionConfiguration() != null; - } - - /** - * Acks remote management. - */ - private void ackRemoteManagement() { - assert log != null; - - if (!log.isInfoEnabled()) - return; - - SB sb = new SB(); - - sb.a("Remote Management ["); - - boolean on = isJmxRemoteEnabled(); - - sb.a("restart: ").a(onOff(isRestartEnabled())).a(", "); - sb.a("REST: ").a(onOff(isRestEnabled())).a(", "); - sb.a("JMX ("); - sb.a("remote: ").a(onOff(on)); - - if (on) { - sb.a(", "); - - sb.a("port: ").a(System.getProperty("com.sun.management.jmxremote.port", "<n/a>")).a(", "); - sb.a("auth: ").a(onOff(Boolean.getBoolean("com.sun.management.jmxremote.authenticate"))).a(", "); - - // By default SSL is enabled, that's why additional check for null is needed. - // See http://docs.oracle.com/javase/6/docs/technotes/guides/management/agent.html - sb.a("ssl: ").a(onOff(Boolean.getBoolean("com.sun.management.jmxremote.ssl") || - System.getProperty("com.sun.management.jmxremote.ssl") == null)); - } - - sb.a(")"); - - sb.a(']'); - - log.info(sb.toString()); - } - - /** - * Acks configuration URL. - */ - private void ackConfigUrl() { - assert log != null; - - if (log.isInfoEnabled()) - log.info("Config URL: " + System.getProperty(GG_CONFIG_URL, "n/a")); - } - - /** - * Acks Visor instructions. - */ - private void ackVisor() { - assert log != null; - - if (isDaemon()) - return; - - if (ctx.isEnterprise()) - U.quietAndInfo(log, "To start GUI Management & Monitoring run ggvisorui.{sh|bat}"); - else - U.quietAndInfo(log, "To start Console Management & Monitoring run ggvisorcmd.{sh|bat}"); - } - - /** - * Acks benchmarking instructions. - */ - private void ackBenchmarks() { - if (!isDaemon()) - U.quietAndInfo(log, "If running benchmarks, see http://bit.ly/GridGain-Benchmarking";); - } - - /** - * Acks ASCII-logo. Thanks to http://patorjk.com/software/taag - */ - private void ackAsciiLogo() { - assert log != null; - - String fileName = log.fileName(); - - if (System.getProperty(GG_NO_ASCII) == null) { - String ver = "ver. " + ACK_VER; - - // Big thanks to: http://patorjk.com/software/taag - // Font name "Small Slant" - if (log.isQuiet()) { - U.quiet(false, - " __________ ________________ ", - " / _/ ___/ |/ / _/_ __/ __/ ", - " _/ // (_ / // / / / / _/ ", - "/___/\\___/_/|_/___/ /_/ /___/ ", - " ", - ver, - COPYRIGHT, - "", - "Quiet mode."); - - if (fileName != null) - U.quiet(false, " ^-- Logging to file '" + fileName + '\''); - - U.quiet(false, - " ^-- To see **FULL** console log here add -DGRIDGAIN_QUIET=false or \"-v\" to ggstart.{sh|bat}", - ""); - } - - if (log.isInfoEnabled()) { - log.info(NL + NL + - ">>> __________ ________________ " + NL + - ">>> / _/ ___/ |/ / _/_ __/ __/ " + NL + - ">>> _/ // (_ / // / / / / _/ " + NL + - ">>> /___/\\___/_/|_/___/ /_/ /___/ " + NL + - ">>> " + NL + - ">>> " + ver + NL + - ">>> " + COPYRIGHT + NL - ); - } - } - } - - /** - * Prints start info. - * - * @param rtBean Java runtime bean. - */ - private void ackStart(RuntimeMXBean rtBean) { - if (log.isQuiet()) { - U.quiet(false, ""); - U.quiet(false, "GridGain node started OK (id=" + U.id8(localNode().id()) + - (F.isEmpty(gridName) ? "" : ", grid=" + gridName) + ')'); - } - - if (log.isInfoEnabled()) { - log.info(""); - - String ack = "GridGain ver. " + COMPOUND_VER + '#' + BUILD_TSTAMP_STR + "-sha1:" + REV_HASH; - - String dash = U.dash(ack.length()); - - SB sb = new SB(); - - for (GridPortRecord rec : ctx.ports().records()) - sb.a(rec.protocol()).a(":").a(rec.port()).a(" "); - - String str = - NL + NL + - ">>> " + dash + NL + - ">>> " + ack + NL + - ">>> " + dash + NL + - ">>> OS name: " + U.osString() + NL + - ">>> CPU(s): " + localNode().metrics().getTotalCpus() + NL + - ">>> Heap: " + U.heapSize(localNode(), 2) + "GB" + NL + - ">>> VM name: " + rtBean.getName() + NL + - ">>> Grid name: " + gridName + NL + - ">>> Local node [" + - "ID=" + localNode().id().toString().toUpperCase() + - ", order=" + localNode().order() + - "]" + NL + - ">>> Local node addresses: " + U.addressesAsString(localNode()) + NL + - ">>> Local ports: " + sb + NL; - - str += ">>> GridGain documentation: http://"; + SITE + "/documentation" + NL; - - log.info(str); - } - } - - /** - * Logs out OS information. - */ - private void ackOsInfo() { - assert log != null; - - if (log.isInfoEnabled()) { - log.info("OS: " + U.osString()); - log.info("OS user: " + System.getProperty("user.name")); - } - } - - /** - * Logs out language runtime. - */ - private void ackLanguageRuntime() { - assert log != null; - - if (log.isInfoEnabled()) { - log.info("Language runtime: " + getLanguage()); - log.info("VM information: " + U.jdkString()); - log.info("VM total memory: " + U.heapSize(2) + "GB"); - } - } - - /** - * @return Language runtime. - */ - @SuppressWarnings("ThrowableInstanceNeverThrown") - private String getLanguage() { - boolean scala = false; - boolean groovy = false; - boolean clojure = false; - - for (StackTraceElement elem : Thread.currentThread().getStackTrace()) { - String s = elem.getClassName().toLowerCase(); - - if (s.contains("scala")) { - scala = true; - - break; - } - else if (s.contains("groovy")) { - groovy = true; - - break; - } - else if (s.contains("clojure")) { - clojure = true; - - break; - } - } - - if (scala) { - try (InputStream in = getClass().getResourceAsStream("/library.properties")) { - Properties props = new Properties(); - - if (in != null) - props.load(in); - - return "Scala ver. " + props.getProperty("version.number", "<unknown>"); - } - catch (Throwable ignore) { - return "Scala ver. <unknown>"; - } - } - - // How to get Groovy and Clojure version at runtime?!? - return groovy ? "Groovy" : clojure ? "Clojure" : U.jdkName() + " ver. " + U.jdkVersion(); - } - - /** - * Stops grid instance. - * - * @param cancel Whether or not to cancel running jobs. - */ - public void stop(boolean cancel) { - // Make sure that thread stopping grid is not interrupted. - boolean interrupted = Thread.interrupted(); - - try { - stop0(cancel); - } - finally { - if (interrupted) - Thread.currentThread().interrupt(); - } - } - - /** - * @param cancel Whether or not to cancel running jobs. - */ - private void stop0(boolean cancel) { - String nid = getLocalNodeId().toString().toUpperCase(); - String nid8 = U.id8(getLocalNodeId()).toUpperCase(); - - gw.compareAndSet(null, new GridKernalGatewayImpl(gridName)); - - GridKernalGateway gw = this.gw.get(); - - if (stopGuard.compareAndSet(false, true)) { - // Only one thread is allowed to perform stop sequence. - boolean firstStop = false; - - GridKernalState state = gw.getState(); - - if (state == STARTED) - firstStop = true; - else if (state == STARTING) - U.warn(log, "Attempt to stop starting grid. This operation " + - "cannot be guaranteed to be successful."); - - if (firstStop) { - // Notify lifecycle beans. - if (log.isDebugEnabled()) - log.debug("Notifying lifecycle beans."); - - notifyLifecycleBeansEx(LifecycleEventType.BEFORE_GRID_STOP); - } - - IgniteEmailProcessorAdapter email = ctx.email(); - - List<GridComponent> comps = ctx.components(); - - // Callback component in reverse order while kernal is still functional - // if called in the same thread, at least. - for (ListIterator<GridComponent> it = comps.listIterator(comps.size()); it.hasPrevious();) { - GridComponent comp = it.previous(); - - try { - comp.onKernalStop(cancel); - } - catch (Throwable e) { - errOnStop = true; - - U.error(log, "Failed to pre-stop processor: " + comp, e); - } - } - - // Cancel update notification timer. - if (updateNtfTimer != null) - updateNtfTimer.cancel(); - - if (starveTimer != null) - starveTimer.cancel(); - - // Cancel license timer. - if (licTimer != null) - licTimer.cancel(); - - // Cancel metrics log timer. - if (metricsLogTimer != null) - metricsLogTimer.cancel(); - - gw.writeLock(); - - try { - assert gw.getState() == STARTED || gw.getState() == STARTING; - - // No more kernal calls from this point on. - gw.setState(STOPPING); - - // Clear node local store. - nodeLoc.clear(); - - if (log.isDebugEnabled()) - log.debug("Grid " + (gridName == null ? "" : '\'' + gridName + "' ") + "is stopping."); - } - finally { - gw.writeUnlock(); - } - - // Unregister MBeans. - if (!( - unregisterMBean(pubExecSvcMBean) & - unregisterMBean(sysExecSvcMBean) & - unregisterMBean(mgmtExecSvcMBean) & - unregisterMBean(p2PExecSvcMBean) & - unregisterMBean(kernalMBean) & - unregisterMBean(locNodeMBean) & - unregisterMBean(restExecSvcMBean) - )) - errOnStop = false; - - // Stop components in reverse order. - for (ListIterator<GridComponent> it = comps.listIterator(comps.size()); it.hasPrevious();) { - GridComponent comp = it.previous(); - - try { - comp.stop(cancel); - - if (log.isDebugEnabled()) - log.debug("Component stopped: " + comp); - } - catch (Throwable e) { - errOnStop = true; - - U.error(log, "Failed to stop component (ignoring): " + comp, e); - } - } - - // Stops lifecycle aware components. - U.stopLifecycleAware(log, lifecycleAwares(cfg)); - - // Lifecycle notification. - notifyLifecycleBeansEx(LifecycleEventType.AFTER_GRID_STOP); - - // Clean internal class/classloader caches to avoid stopped contexts held in memory. - IgniteOptimizedMarshaller.clearCache(); - IgniteMarshallerExclusions.clearCache(); - GridEnumCache.clear(); - - gw.writeLock(); - - try { - gw.setState(STOPPED); - } - finally { - gw.writeUnlock(); - } - - // Ack stop. - if (log.isQuiet()) { - if (!errOnStop) - U.quiet(false, "GridGain node stopped OK [uptime=" + - X.timeSpan2HMSM(U.currentTimeMillis() - startTime) + ']'); - else - U.quiet(true, "GridGain node stopped wih ERRORS [uptime=" + - X.timeSpan2HMSM(U.currentTimeMillis() - startTime) + ']'); - } - - if (log.isInfoEnabled()) - if (!errOnStop) { - String ack = "GridGain ver. " + COMPOUND_VER + '#' + BUILD_TSTAMP_STR + "-sha1:" + REV_HASH + - " stopped OK"; - - String dash = U.dash(ack.length()); - - log.info(NL + NL + - ">>> " + dash + NL + - ">>> " + ack + NL + - ">>> " + dash + NL + - ">>> Grid name: " + gridName + NL + - ">>> Grid uptime: " + X.timeSpan2HMSM(U.currentTimeMillis() - startTime) + - NL + - NL); - } - else { - String ack = "GridGain ver. " + COMPOUND_VER + '#' + BUILD_TSTAMP_STR + "-sha1:" + REV_HASH + - " stopped with ERRORS"; - - String dash = U.dash(ack.length()); - - log.info(NL + NL + - ">>> " + ack + NL + - ">>> " + dash + NL + - ">>> Grid name: " + gridName + NL + - ">>> Grid uptime: " + X.timeSpan2HMSM(U.currentTimeMillis() - startTime) + - NL + - ">>> See log above for detailed error message." + NL + - ">>> Note that some errors during stop can prevent grid from" + NL + - ">>> maintaining correct topology since this node may have" + NL + - ">>> not exited grid properly." + NL + - NL); - } - - // Send node start email notification, if enabled. - if (isSmtpEnabled() && isAdminEmailsSet() && cfg.isLifeCycleEmailNotification()) { - String errOk = errOnStop ? "with ERRORS" : "OK"; - - String headline = "GridGain ver. " + COMPOUND_VER + '#' + BUILD_TSTAMP_STR + - " stopped " + errOk + ":"; - String subj = "GridGain node stopped " + errOk + ": " + nid8; - - IgniteProductLicense lic = ctx.license() != null ? ctx.license().license() : null; - - String body = - headline + NL + NL + - "----" + NL + - "GridGain ver. " + COMPOUND_VER + '#' + BUILD_TSTAMP_STR + "-sha1:" + REV_HASH + NL + - "Grid name: " + gridName + NL + - "Node ID: " + nid + NL + - "Node uptime: " + X.timeSpan2HMSM(U.currentTimeMillis() - startTime) + NL; - - if (lic != null) { - body += - "License ID: " + lic.id().toString().toUpperCase() + NL + - "Licensed to: " + lic.userOrganization() + NL; - } - else - assert !ENT; - - body += - "----" + NL + - NL + - "NOTE:" + NL + - "This message is sent automatically to all configured admin emails." + NL + - "To change this behavior use 'lifeCycleEmailNotify' grid configuration property."; - - if (errOnStop) - body += - NL + NL + - "NOTE:" + NL + - "See node's log for detailed error message." + NL + - "Some errors during stop can prevent grid from" + NL + - "maintaining correct topology since this node may " + NL + - "have not exited grid properly."; - - body += - NL + NL + - "| " + SITE + NL + - "| supp...@gridgain.com" + NL; - - if (email != null) { - try { - email.sendNow(subj, - body, - false, - Arrays.asList(cfg.getAdminEmails())); - } - catch (IgniteCheckedException e) { - U.error(log, "Failed to send lifecycle email notification.", e); - } - } - } - - U.onGridStop(); - } - else { - // Proper notification. - if (log.isDebugEnabled()) { - if (gw.getState() == STOPPED) - log.debug("Grid is already stopped. Nothing to do."); - else - log.debug("Grid is being stopped by another thread. Aborting this stop sequence " + - "allowing other thread to finish."); - } - } - } - - /** - * USED ONLY FOR TESTING. - * - * @param <K> Key type. - * @param <V> Value type. - * @return Internal cache instance. - */ - /*@java.test.only*/ - public <K, V> GridCacheAdapter<K, V> internalCache() { - return internalCache(null); - } - - /** - * USED ONLY FOR TESTING. - * - * @param name Cache name. - * @param <K> Key type. - * @param <V> Value type. - * @return Internal cache instance. - */ - /*@java.test.only*/ - public <K, V> GridCacheAdapter<K, V> internalCache(@Nullable String name) { - return ctx.cache().internalCache(name); - } - - /** - * It's intended for use by internal marshalling implementation only. - * - * @return Kernal context. - */ - public GridKernalContext context() { - return ctx; - } - - /** - * Prints all system properties in debug mode. - */ - private void ackSystemProperties() { - assert log != null; - - if (log.isDebugEnabled()) - for (Object key : U.asIterable(System.getProperties().keys())) - log.debug("System property [" + key + '=' + System.getProperty((String) key) + ']'); - } - - /** - * Prints all user attributes in info mode. - */ - private void logNodeUserAttributes() { - assert log != null; - - if (log.isInfoEnabled()) - for (Map.Entry<?, ?> attr : cfg.getUserAttributes().entrySet()) - log.info("Local node user attribute [" + attr.getKey() + '=' + attr.getValue() + ']'); - } - - /** - * Prints all environment variables in debug mode. - */ - private void ackEnvironmentVariables() { - assert log != null; - - if (log.isDebugEnabled()) - for (Map.Entry<?, ?> envVar : System.getenv().entrySet()) - log.debug("Environment variable [" + envVar.getKey() + '=' + envVar.getValue() + ']'); - } - - /** - * Acks daemon mode status. - */ - private void ackDaemon() { - assert log != null; - - if (log.isInfoEnabled()) - log.info("Daemon mode: " + (isDaemon() ? "on" : "off")); - } - - /** - * - * @return {@code True} is this node is daemon. - */ - private boolean isDaemon() { - assert cfg != null; - - return cfg.isDaemon() || "true".equalsIgnoreCase(System.getProperty(GG_DAEMON)); - } - - /** - * Whether or not remote JMX management is enabled for this node. Remote JMX management is - * enabled when the following system property is set: - * <ul> - * <li>{@code com.sun.management.jmxremote}</li> - * </ul> - * - * @return {@code True} if remote JMX management is enabled - {@code false} otherwise. - */ - @Override public boolean isJmxRemoteEnabled() { - return System.getProperty("com.sun.management.jmxremote") != null; - } - - /** - * Whether or not node restart is enabled. Node restart us supported when this node was started - * with {@code bin/ggstart.{sh|bat}} script using {@code -r} argument. Node can be - * programmatically restarted using {@link org.apache.ignite.Ignition#restart(boolean)}} method. - * - * @return {@code True} if restart mode is enabled, {@code false} otherwise. - * @see org.apache.ignite.Ignition#restart(boolean) - */ - @Override public boolean isRestartEnabled() { - return System.getProperty(GG_SUCCESS_FILE) != null; - } - - /** - * Whether or not SMTP is configured. Note that SMTP is considered configured if - * SMTP host is provided in configuration (see {@link org.apache.ignite.configuration.IgniteConfiguration#getSmtpHost()}. - * <p> - * If SMTP is not configured all emails notifications will be disabled. - * - * @return {@code True} if SMTP is configured - {@code false} otherwise. - * @see org.apache.ignite.configuration.IgniteConfiguration#getSmtpFromEmail() - * @see org.apache.ignite.configuration.IgniteConfiguration#getSmtpHost() - * @see org.apache.ignite.configuration.IgniteConfiguration#getSmtpPassword() - * @see org.apache.ignite.configuration.IgniteConfiguration#getSmtpPort() - * @see org.apache.ignite.configuration.IgniteConfiguration#getSmtpUsername() - * @see org.apache.ignite.configuration.IgniteConfiguration#isSmtpSsl() - * @see org.apache.ignite.configuration.IgniteConfiguration#isSmtpStartTls() - * @see #sendAdminEmailAsync(String, String, boolean) - */ - @Override public boolean isSmtpEnabled() { - assert cfg != null; - - return cfg.getSmtpHost() != null; - } - - /** - * Prints all configuration properties in info mode and SPIs in debug mode. - */ - private void ackSpis() { - assert log != null; - - if (log.isDebugEnabled()) { - log.debug("+-------------+"); - log.debug("START SPI LIST:"); - log.debug("+-------------+"); - log.debug("Grid checkpoint SPI : " + Arrays.toString(cfg.getCheckpointSpi())); - log.debug("Grid collision SPI : " + cfg.getCollisionSpi()); - log.debug("Grid communication SPI : " + cfg.getCommunicationSpi()); - log.debug("Grid deployment SPI : " + cfg.getDeploymentSpi()); - log.debug("Grid discovery SPI : " + cfg.getDiscoverySpi()); - log.debug("Grid event storage SPI : " + cfg.getEventStorageSpi()); - log.debug("Grid failover SPI : " + Arrays.toString(cfg.getFailoverSpi())); - log.debug("Grid load balancing SPI : " + Arrays.toString(cfg.getLoadBalancingSpi())); - log.debug("Grid authentication SPI : " + cfg.getAuthenticationSpi()); - log.debug("Grid secure session SPI : " + cfg.getSecureSessionSpi()); - log.debug("Grid swap space SPI : " + cfg.getSwapSpaceSpi()); - } - } - - /** - * - */ - private void ackCacheConfiguration() { - CacheConfiguration[] cacheCfgs = cfg.getCacheConfiguration(); - - if (cacheCfgs == null || cacheCfgs.length == 0) - U.warn(log, "Cache is not configured - in-memory data grid is off."); - else { - SB sb = new SB(); - - for (CacheConfiguration c : cacheCfgs) { - String name = c.getName(); - - if (name == null) - name = "<default>"; - - sb.a("'").a(name).a("', "); - } - - String names = sb.toString(); - - U.log(log, "Configured caches [" + names.substring(0, names.length() - 2) + ']'); - } - } - - /** - * - */ - private void ackP2pConfiguration() { - assert cfg != null; - - if (cfg.isPeerClassLoadingEnabled()) - U.warn( - log, - "Peer class loading is enabled (disable it in production for performance and " + - "deployment consistency reasons)", - "Peer class loading is enabled (disable it for better performance)" - ); - } - - /** - * Prints security status. - * - * @param ctx Kernal context. - */ - private void ackSecurity(GridKernalContext ctx) { - assert log != null; - - if (log.isInfoEnabled()) - log.info("Security status [authentication=" + onOff(ctx.security().enabled()) + ", " + - "secure-session=" + onOff(ctx.secureSession().enabled()) + ']'); - } - - /** - * Prints out SMTP configuration. - */ - private void ackSmtpConfiguration() { - assert log != null; - - String host = cfg.getSmtpHost(); - - boolean ssl = cfg.isSmtpSsl(); - int port = cfg.getSmtpPort(); - - if (host == null) { - U.warn(log, "SMTP is not configured - email notifications are off."); - - return; - } - - String from = cfg.getSmtpFromEmail(); - - if (log.isQuiet()) - U.quiet(false, "SMTP enabled [host=" + host + ":" + port + ", ssl=" + (ssl ? "on" : "off") + ", from=" + - from + ']'); - - if (log.isInfoEnabled()) { - String[] adminEmails = cfg.getAdminEmails(); - - log.info("SMTP enabled [host=" + host + ", port=" + port + ", ssl=" + ssl + ", from=" + from + ']'); - log.info("Admin emails: " + (!isAdminEmailsSet() ? "N/A" : Arrays.toString(adminEmails))); - } - - if (!isAdminEmailsSet
<TRUNCATED>
