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

xfs_file_buffered_aio_write(
       struct kiocb            *iocb,
       struct iov_iter         *from)
{
...
       int                     iolock = XFS_IOLOCK_EXCL;
...
       xfs_rw_ilock(ip, iolock);
...
       ret = generic_perform_write(file, from, pos);

epickrram

xfs_file_read_iter(
       struct kiocb            *iocb,
       struct iov_iter         *to)
{
...
       xfs_rw_ilock(ip, XFS_IOLOCK_SHARED);
...
       ret = generic_file_read_iter(iocb, to);
...
       xfs_rw_iunlock(ip, XFS_IOLOCK_SHARED);