epickrram

epickrram

import java.lang.management.ManagementFactory;
import java.lang.management.ThreadInfo;
import java.lang.management.ThreadMXBean;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.LockSupport;
import java.util.concurrent.locks.ReentrantLock;

public final class SynchronisationThroughputTest

epickrram

import net.bytebuddy.agent.ByteBuddyAgent;
import net.bytebuddy.agent.builder.AgentBuilder;
import net.bytebuddy.description.method.MethodDescription;
import net.bytebuddy.description.method.MethodList;
import net.bytebuddy.description.type.TypeDescription;
import net.bytebuddy.dynamic.DynamicType;
import net.bytebuddy.dynamic.scaffold.InstrumentedType;
import net.bytebuddy.implementation.Implementation;
import net.bytebuddy.implementation.MethodDelegation;
import net.bytebuddy.implementation.bind.annotation.Origin;

epickrram

/**
 * Callback for UDP-specific statistics in /proc/net/snmp.
 */
@FunctionalInterface
public interface SnmpUdpStatisticsHandler
{
    /**
     * Callback method.
     * @param inErrors InErrors count
     * @param receiveBufferErrors RecvbufErrors count

epickrram

/**
 * Callback for statistics from /proc/net/softnet_stat.
 */
@FunctionalInterface
public interface SoftnetStatsHandler
{
    /**
     * Callback method.
     * @param cpuId zero-based CPU that these statistics refer to
     * @param processed softIRQ events processed

epickrram

udpSocketMonitor.beginMonitoringOf(InetAddress.getByName("239.193.50.102"));

epickrram

/**
 * Handler for socket statistics from /proc/net/udp.
 */
@FunctionalInterface
public interface UdpSocketStatisticsHandler
{
    /**
     * Callback method.
     * @param inetAddress the ip address
     * @param port the socket port

epickrram

public void performMatching(final Order order) {
  transactionReporter.startOfTransaction()

  order.executeAggressively(orderBook);

  tradeReporter.reportTrades(order.getTrades());

  engine.updateAggregateOrderStatistics();

  transactionReporter.endOfTransaction();

epickrram

public class BigDecimalBenchmark extends SimpleBenchmark
{
    private static final BigDecimal QUANTITY_DIVISOR = new BigDecimal(100);
    private static final BigDecimal PRICE_DIVISOR = new BigDecimal(1000000);
    private static final BigDecimal QUANTITY_INCREMENT = new BigDecimal("0.001");
    private static final BigDecimal PRICE_INCREMENT = new BigDecimal("0.00001");

    @Override
    protected void setUp() throws Exception
    {

epickrram

static final class Unicorn
    {
        private static int mainMethodLineOfLastPatInvocation = 0;

        private static boolean pat()
        {
            boolean result = false;
            final StackTraceElement[] stackTrace = Thread.currentThread().getStackTrace();
            final StackTraceElement mainMethodInvocationPoint = stackTrace[3];
            if(mainMethodInvocationPoint.getLineNumber() != mainMethodLineOfLastPatInvocation)