ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [31/53] [abbrv] incubator-ignite git commit: Merge branch 'sprint-1' into ignite-49
Date Tue, 27 Jan 2015 16:40:51 GMT
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/401b24fb/modules/core/src/main/java/org/apache/ignite/mxbean/CacheMetricsMXBean.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/mxbean/CacheMetricsMXBean.java
index 0000000,0000000..77c5849
new file mode 100644
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/mxbean/CacheMetricsMXBean.java
@@@ -1,0 -1,0 +1,222 @@@
++/*
++ * 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.mxbean;
++
++import org.apache.ignite.cache.*;
++import org.apache.ignite.*;
++
++/**
++ * This interface defines JMX view on {@link IgniteCache}.
++ */
++import org.apache.ignite.*;
++
++import javax.cache.management.*;
++
++/**
++ * This interface defines JMX view on {@link IgniteCache}.
++ */
++@IgniteMBeanDescription("MBean that provides access to cache descriptor.")
++public interface CacheMetricsMXBean extends CacheStatisticsMXBean, CacheMetrics {
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Clear statistics.")
++    public void clear();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of hits.")
++    public long getCacheHits();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Percentage of successful hits.")
++    public float getCacheHitPercentage();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of misses.")
++    public long getCacheMisses();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Percentage of accesses that failed to find anything.")
++    public float getCacheMissPercentage();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of gets.")
++    public long getCacheGets();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of puts.")
++    public long getCachePuts();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of removals.")
++    public long getCacheRemovals();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of eviction entries.")
++    public long getCacheEvictions();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Average time to execute get.")
++    public float getAverageGetTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Average time to execute put.")
++    public float getAveragePutTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Average time to execute remove.")
++    public float getAverageRemoveTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Average time to commit transaction.")
++    public float getAverageTxCommitTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Average time to rollback transaction.")
++    public float getAverageTxRollbackTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of transaction commits.")
++    public long getCacheTxCommits();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of transaction rollback.")
++    public long getCacheTxRollbacks();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Cache name.")
++    public String name();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of entries that was swapped to disk.")
++    public long getOverflowSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of entries stored in off-heap memory.")
++    public long getOffHeapEntriesCount();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Memory size allocated in off-heap.")
++    public long getOffHeapAllocatedSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of non-null values in the cache.")
++    public int getSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of keys in the cache (possibly with null values).")
++    public int getKeySize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("True if cache is empty.")
++    public boolean isEmpty();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Current size of evict queue.")
++    public int getDhtEvictQueueCurrentSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction per-thread map size.")
++    public int getTxThreadMapSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction per-Xid map size.")
++    public int getTxXidMapSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction committed queue size.")
++    public int getTxCommitQueueSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction prepared queue size.")
++    public int getTxPrepareQueueSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction start version counts map size.")
++    public int getTxStartVersionCountsSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction committed ID map size.")
++    public int getTxCommittedVersionsSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction rolled back ID map size.")
++    public int getTxRolledbackVersionsSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction DHT per-thread map size.")
++    public int getTxDhtThreadMapSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction DHT per-Xid map size.")
++    public int getTxDhtXidMapSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction DHT committed queue size.")
++    public int getTxDhtCommitQueueSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction DHT prepared queue size.")
++    public int getTxDhtPrepareQueueSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction DHT start version counts map size.")
++    public int getTxDhtStartVersionCountsSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction DHT committed ID map size.")
++    public int getTxDhtCommittedVersionsSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Transaction DHT rolled back ID map size.")
++    public int getTxDhtRolledbackVersionsSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("True if write-behind is enabled for this cache.")
++    public boolean isWriteBehindEnabled();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Size of internal buffer that triggers flush procedure.")
++    public int getWriteBehindFlushSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Count of flush threads.")
++    public int getWriteBehindFlushThreadCount();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Flush frequency interval in milliseconds.")
++    public long getWriteBehindFlushFrequency();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Maximum size of batch for similar operations.")
++    public int getWriteBehindStoreBatchSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Count of cache overflow events since write-behind cache has
started.")
++    public int getWriteBehindTotalCriticalOverflowCount();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Count of cache overflow events since write-behind cache has
started.")
++    public int getWriteBehindCriticalOverflowCount();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Count of cache cache entries that are currently in retry state.")
++    public int getWriteBehindErrorRetryCount();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Count of cache entries that are waiting to be flushed.")
++    public int getWriteBehindBufferSize();
++}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/401b24fb/modules/core/src/main/java/org/apache/ignite/mxbean/ClusterMetricsMXBean.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/mxbean/ClusterMetricsMXBean.java
index 0000000,0000000..6ddafd8
new file mode 100644
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/mxbean/ClusterMetricsMXBean.java
@@@ -1,0 -1,0 +1,240 @@@
++/*
++ * 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.mxbean;
++
++import org.apache.ignite.cluster.*;
++
++/**
++ * MBean for local node metrics.
++ */
++@IgniteMBeanDescription("MBean that provides access to all local node metrics.")
++public interface ClusterMetricsMXBean extends ClusterMetrics {
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Last update time of this node metrics.")
++    public long getLastUpdateTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Maximum number of jobs that ever ran concurrently on this node.")
++    public int getMaximumActiveJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of currently active jobs concurrently executing on the
node.")
++    public int getCurrentActiveJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Average number of active jobs concurrently executing on the
node.")
++    public float getAverageActiveJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Maximum number of waiting jobs this node had.")
++    public int getMaximumWaitingJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of queued jobs currently waiting to be executed.")
++    public int getCurrentWaitingJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Average number of waiting jobs this node had queued.")
++    public float getAverageWaitingJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Maximum number of jobs rejected at once during a single collision
resolution operation.")
++    public int getMaximumRejectedJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of jobs rejected after more recent collision resolution
operation.")
++    public int getCurrentRejectedJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Average number of jobs this node rejects during collision resolution
operations.")
++    public float getAverageRejectedJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription(
++        "Total number of jobs this node rejects during collision resolution operations since
node startup.")
++    public int getTotalRejectedJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Maximum number of cancelled jobs this node ever had running
concurrently.")
++    public int getMaximumCancelledJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Number of cancelled jobs that are still running.")
++    public int getCurrentCancelledJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Average number of cancelled jobs this node ever had running
concurrently.")
++    public float getAverageCancelledJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Total number of cancelled jobs since node startup.")
++    public int getTotalCancelledJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Total number of jobs handled by the node.")
++    public int getTotalExecutedJobs();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Maximum time a job ever spent waiting in a queue to be executed.")
++    public long getMaximumJobWaitTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Current wait time of oldest job.")
++    public long getCurrentJobWaitTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Average time jobs spend waiting in the queue to be executed.")
++    public double getAverageJobWaitTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Time it took to execute the longest job on the node.")
++    public long getMaximumJobExecuteTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Longest time a current job has been executing for.")
++    public long getCurrentJobExecuteTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Average time a job takes to execute on the node.")
++    public double getAverageJobExecuteTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Total number of tasks handled by the node.")
++    public int getTotalExecutedTasks();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Total time this node spent executing jobs.")
++    public long getTotalBusyTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Total time this node spent idling (not executing any jobs).")
++    public long getTotalIdleTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Time this node spend idling since executing last job.")
++    public long getCurrentIdleTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Percentage of time this node is busy executing jobs vs. idling.")
++    public float getBusyTimePercentage();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Percentage of time this node is idling vs. executing jobs.")
++    public float getIdleTimePercentage();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("The number of CPUs available to the Java Virtual Machine.")
++    public int getTotalCpus();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("The system load average; or a negative value if not available.")
++    public double getCurrentCpuLoad();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Average of CPU load values over all metrics kept in the history.")
++    public double getAverageCpuLoad();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Average time spent in CG since the last update.")
++    public double getCurrentGcCpuLoad();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("The initial size of memory in bytes; -1 if undefined.")
++    public long getHeapMemoryInitialized();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Current heap size that is used for object allocation.")
++    public long getHeapMemoryUsed();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("The amount of committed memory in bytes.")
++    public long getHeapMemoryCommitted();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("The maximum amount of memory in bytes; -1 if undefined.")
++    public long getHeapMemoryMaximum();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("The initial size of memory in bytes; -1 if undefined.")
++    public long getNonHeapMemoryInitialized();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Current non-heap memory size that is used by Java VM.")
++    public long getNonHeapMemoryUsed();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Amount of non-heap memory in bytes that is committed for the
JVM to use.")
++    public long getNonHeapMemoryCommitted();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Maximum amount of non-heap memory in bytes that can " +
++        "be used for memory management. -1 if undefined.")
++    public long getNonHeapMemoryMaximum();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Uptime of the JVM in milliseconds.")
++    public long getUpTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Start time of the JVM in milliseconds.")
++    public long getStartTime();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Current number of live threads.")
++    public int getCurrentThreadCount();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("The peak live thread count.")
++    public int getMaximumThreadCount();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("The total number of threads started.")
++    public long getTotalStartedThreadCount();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Current number of live daemon threads.")
++    public int getCurrentDaemonThreadCount();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Last data version.")
++    public long getLastDataVersion();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Sent messages count.")
++    public int getSentMessagesCount();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Sent bytes count.")
++    public long getSentBytesCount();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Received messages count.")
++    public int getReceivedMessagesCount();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Received bytes count.")
++    public long getReceivedBytesCount();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Outbound messages queue size.")
++    public int getOutboundMessagesQueueSize();
++
++    /** {@inheritDoc} */
++    @IgniteMBeanDescription("Start time of the grid node in milliseconds.")
++    @Override long getNodeStartTime();
++}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/401b24fb/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/401b24fb/modules/core/src/test/java/org/apache/ignite/internal/GridDiscoverySelfTest.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/401b24fb/modules/core/src/test/java/org/apache/ignite/p2p/GridP2PClassLoadingSelfTest.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/401b24fb/modules/core/src/test/java/org/apache/ignite/testframework/GridTestNode.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/401b24fb/modules/core/src/test/java/org/apache/ignite/testframework/junits/spi/GridSpiAbstractTest.java
----------------------------------------------------------------------


Mime
View raw message