pavlukhin

private final ConcurrentMap<Integer, ConcurrentMap<Integer, AtomicLong>> sizeDeltas = new ConcurrentHashMap<>();

// Good old approach
@Override public void accumulateSizeDelta(int cacheId, int part, long delta) {
    ConcurrentMap<Integer, AtomicLong> partDeltas = sizeDeltas.get(cacheId);
    if (partDeltas == null) {
        ConcurrentMap<Integer, AtomicLong> partDeltas0 =
            sizeDeltas.putIfAbsent(cacheId, partDeltas = new ConcurrentHashMap<>());
        if (partDeltas0 != null)
            partDeltas = partDeltas0;

pavlukhin

#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 262144 bytes for committing reserved memory.
# Possible reasons:
#   The system is out of physical RAM or swap space
#   In 32 bit mode, the process size limit was hit
# Possible solutions:
#   Reduce memory load on the system
#   Increase physical memory or swap space
#   Check if swap backing store is full

pavlukhin

package org.apache.ignite.internal.processors.cache.ivan;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.TimeUnit;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.cache.CacheAtomicityMode;
import org.apache.ignite.cache.CacheMode;

pavlukhin

pavlukhin

package org.apache.ignite.internal.processors.cache.ivan;

import java.io.Serializable;
import java.util.Collections;
import org.apache.ignite.Ignite;
import org.apache.ignite.Ignition;
import org.apache.ignite.cache.CacheInterceptorAdapter;
import org.apache.ignite.client.IgniteClient;
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.configuration.ClientConfiguration;

pavlukhin

pavlukhin

import java.util.Collections;
import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.IgniteDataStreamer;
import org.apache.ignite.Ignition;
import org.apache.ignite.cache.QueryEntity;
import org.apache.ignite.cache.query.SqlFieldsQuery;
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;

pavlukhin

package org.ivan.experiments.agent;

import java.lang.instrument.Instrumentation;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;

public class WeakeningAgent {

pavlukhin

package _Self.buildTypes

import jetbrains.buildServer.configs.kotlin.v2018_2.*
import jetbrains.buildServer.configs.kotlin.v2018_2.buildSteps.script

object RunAll : BuildType({
    name = "--> Run :: All"
    description = "Dummy build for run all build in project by one click"

    artifactRules = "report.html"

pavlukhin

class User {
    String userName;
    Address address;

    public User(String userName, Address address) {
        this.userName = userName;
        this.address = address;
    }
}