Skip to content

Ignite 7935 anal #29

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
xtern wants to merge 43 commits into
base: master
Choose a base branch
from
Open

Ignite 7935 anal #29

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
43 commits
Select commit Hold shift + click to select a range
bfb4faa
IGNITE-7935 wip draft split.
xtern Jan 17, 2019
3846ab9
wip draft split 2.
xtern Jan 18, 2019
5657b27
wip2
xtern Jan 18, 2019
6bcb300
wip
xtern Jan 21, 2019
5d3e3d6
wip
xtern Jan 21, 2019
a902efe
wip (refactoring)
xtern Jan 22, 2019
464a84a
IGNITE-7935 freelist batch insert.
xtern Jan 22, 2019
1e1cab2
IGNITE-7935 Draft preview.
xtern Jan 22, 2019
b02face
WIP - not working
xtern Jan 22, 2019
5e2e884
wip-workable
xtern Jan 23, 2019
7154664
debugging + bug fixing.
xtern Jan 23, 2019
0c34947
IGNITE-7935 fixed large object tails size 12 bytes.
xtern Jan 24, 2019
84f5f48
IGNITE-7935 Minor fixes.
xtern Jan 24, 2019
9068bf3
testing
xtern Jan 24, 2019
fceb512
IGNITE-7933 deeper - get lock only once.
xtern Jan 25, 2019
2b70b5a
IGNITE-7935 (wip) minor code cleanup.
xtern Jan 25, 2019
b4fa23a
IGNITE-7935 Optimize data page storing (wip).
xtern Jan 29, 2019
b268b16
IGNITE-7935 Create something like benchmark.
xtern Jan 29, 2019
322aaa3
IGNITE-7935 Pds check (wip).
xtern Jan 30, 2019
281f9e3
IGNITE-7935 MVCC support should be implemented in separate ticket.
xtern Jan 31, 2019
26fe2c6
IGNITE-7935 Support partial rebalance.
xtern Feb 1, 2019
04ee069
IGNITE-7935 Experimental isolated streamer.
xtern Feb 6, 2019
9fa5103
IGNITE-7935 Refactoring (wip).
xtern Feb 7, 2019
be7ad84
IGNITE-7935 Bench bug.
xtern Feb 8, 2019
2bd0d78
minor
xtern Feb 8, 2019
7dde461
IGNITE-7935 added mem stat.
xtern Feb 11, 2019
ccd0b27
wip
xtern Feb 11, 2019
a3b6fbd
system property (wip).
xtern Feb 11, 2019
db3279a
diagnostic
xtern Feb 14, 2019
ba5cb3e
diag fix
xtern Feb 14, 2019
3db04d7
deep external anal
xtern Feb 20, 2019
e848d81
experiments
xtern Feb 21, 2019
51307cc
Remove binary packing.
xtern Feb 21, 2019
19b3a5a
restore test, minor gc help.
xtern Feb 21, 2019
ce47eb1
wip
xtern Feb 22, 2019
6e589cd
wip minor code improvement
xtern Feb 23, 2019
bfacc40
invokeall wip
xtern Mar 4, 2019
3207dab
invokeAll - wip
xtern Mar 7, 2019
f1758a9
draft wip
xtern Mar 10, 2019
c85ac84
wip
xtern Mar 11, 2019
6b8fcef
wip ref
xtern Mar 11, 2019
f2b1d84
unworkable
xtern Mar 12, 2019
5a4c552
fixed
xtern Mar 12, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1081,6 +1081,9 @@ public final class IgniteSystemProperties {
*/
public static final String IGNITE_DISCOVERY_DISABLE_CACHE_METRICS_UPDATE = "IGNITE_DISCOVERY_DISABLE_CACHE_METRICS_UPDATE";

/** */
public static final String IGNITE_DATA_STORAGE_BATCH_PAGE_WRITE = "IGNITE_DATA_STORAGE_BATCH_PAGE_WRITE";

/**
* Enforces singleton.
*/
Expand Down
4 changes: 4 additions & 0 deletions modules/core/src/main/java/org/apache/ignite/internal/GridKernalContext.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,7 @@
import org.apache.ignite.internal.managers.indexing.GridIndexingManager;
import org.apache.ignite.internal.managers.loadbalancer.GridLoadBalancerManager;
import org.apache.ignite.internal.processors.cache.mvcc.MvccProcessor;
import org.apache.ignite.internal.processors.diag.DiagnosticProcessor;
import org.apache.ignite.internal.stat.IoStatisticsManager;
import org.apache.ignite.internal.processors.compress.CompressionProcessor;
import org.apache.ignite.internal.processors.service.ServiceProcessorAdapter;
Expand Down Expand Up @@ -467,6 +468,9 @@ public interface GridKernalContext extends Iterable<GridComponent> {
*/
public FailureProcessor failure();

/** */
public DiagnosticProcessor diagnostic();

/**
* Print grid kernal memory stats (sizes of internal structures, etc.).
*
Expand Down
12 changes: 11 additions & 1 deletion modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -48,6 +48,7 @@
import org.apache.ignite.internal.managers.failover.GridFailoverManager;
import org.apache.ignite.internal.managers.indexing.GridIndexingManager;
import org.apache.ignite.internal.managers.loadbalancer.GridLoadBalancerManager;
import org.apache.ignite.internal.processors.diag.DiagnosticProcessor;
import org.apache.ignite.internal.processors.service.ServiceProcessorAdapter;
import org.apache.ignite.internal.processors.affinity.GridAffinityProcessor;
import org.apache.ignite.internal.processors.authentication.IgniteAuthenticationProcessor;
Expand Down Expand Up @@ -423,6 +424,9 @@ public class GridKernalContextImpl implements GridKernalContext, Externalizable
/** Failure processor. */
private FailureProcessor failureProc;

/** */
private DiagnosticProcessor diagProc;

/** Recovery mode flag. Flag is set to {@code false} when discovery manager started. */
private boolean recoveryMode = true;

Expand Down Expand Up @@ -585,9 +589,10 @@ else if (comp instanceof GridEncryptionManager)
* Processors.
* ==========
*/

else if (comp instanceof FailureProcessor)
failureProc = (FailureProcessor)comp;
else if (comp instanceof DiagnosticProcessor)
diagProc = (DiagnosticProcessor)comp;
else if (comp instanceof GridTaskProcessor)
taskProc = (GridTaskProcessor)comp;
else if (comp instanceof GridJobProcessor)
Expand Down Expand Up @@ -1196,6 +1201,11 @@ void disconnected(boolean disconnected) {
return failureProc;
}

/** {@inheritDoc} */
@Override public DiagnosticProcessor diagnostic() {
return diagProc;
}

/** {@inheritDoc} */
@Override public Thread.UncaughtExceptionHandler uncaughtExceptionHandler() {
return hnd;
Expand Down
3 changes: 3 additions & 0 deletions modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -141,6 +141,7 @@
import org.apache.ignite.internal.processors.continuous.GridContinuousProcessor;
import org.apache.ignite.internal.processors.datastreamer.DataStreamProcessor;
import org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor;
import org.apache.ignite.internal.processors.diag.DiagnosticProcessor;
import org.apache.ignite.internal.processors.failure.FailureProcessor;
import org.apache.ignite.internal.processors.hadoop.Hadoop;
import org.apache.ignite.internal.processors.hadoop.HadoopProcessorAdapter;
Expand Down Expand Up @@ -967,6 +968,8 @@ public void start(

startProcessor(new FailureProcessor(ctx));

startProcessor(new DiagnosticProcessor(ctx));

startProcessor(new PoolProcessor(ctx));

// Closure processor should be started before all others
Expand Down
Loading