PerfMonMetricGetterTest.java

package kg.apc.perfmon;

import junit.framework.TestCase;
import kg.apc.emulators.DatagramChannelEmul;
import org.hyperic.sigar.Sigar;
import org.hyperic.sigar.SigarProxyCache;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.channels.DatagramChannel;

/**
 * @author undera
 */
public class PerfMonMetricGetterTest extends TestCase {

    public PerfMonMetricGetterTest() {
    }

    public void testProcessCommand() throws IOException {
        System.out.println("processCommand");
        String toString = "test\ntest\nerr\n";
        final DatagramChannel channel = DatagramChannelEmul.open();
        channel.configureBlocking(false);
        final InetSocketAddress inetSocketAddress = new InetSocketAddress(
                "localhost", 4444);
        channel.connect(inetSocketAddress);
        PerfMonMetricGetter instance = new PerfMonMetricGetter(
                SigarProxyCache.newInstance(new Sigar(), 500),
                new PerfMonWorker(), channel, inetSocketAddress);
        instance.addCommandString(toString);
        instance.processNextCommand();
        instance.processNextCommand();
        try {
            instance.processNextCommand();
            fail();
        } catch (UnsupportedOperationException e) {
        }
    }

    public void testAddCommandString() throws IOException {
        System.out.println("addCommandString");
        String byteBufferToString = "";
        PerfMonMetricGetter instance = new PerfMonMetricGetter(
                SigarProxyCache.newInstance(new Sigar(), 500),
                new PerfMonWorker(), DatagramChannel.open());
        instance.addCommandString(byteBufferToString);
    }

    public void testProcessNextCommand() throws Exception {
        System.out.println("processNextCommand");
        PerfMonMetricGetter instance = new PerfMonMetricGetter(
                SigarProxyCache.newInstance(new Sigar(), 500),
                new PerfMonWorker(), DatagramChannel.open());
        boolean expResult = false;
        boolean result = instance.processNextCommand();
        assertEquals(expResult, result);
    }

    public void testSendMetrics() throws IOException {
        System.out.println("sendMetrics");
        PerfMonMetricGetter instance = new PerfMonMetricGetter(
                SigarProxyCache.newInstance(new Sigar(), 500),
                new PerfMonWorker(), DatagramChannel.open());
        instance.getMetricsLine();
    }

    public void testProcessCommand_single_metrics() throws IOException {
        System.out.println("processCommand");
        String toString = "metrics-single:cpu\tmemory\ttcp\n";
        final DatagramChannel channel = DatagramChannelEmul.open();
        channel.configureBlocking(false);
        final InetSocketAddress inetSocketAddress = new InetSocketAddress(
                "localhost", 4444);
        channel.connect(inetSocketAddress);
        PerfMonMetricGetter instance = new PerfMonMetricGetter(
                SigarProxyCache.newInstance(new Sigar(), 500),
                new PerfMonWorker(), channel, inetSocketAddress);
        instance.addCommandString(toString);
        instance.processNextCommand();
    }

    public void testProcessCommand_udp_transmitter() throws IOException {
        System.out.println("UDP transmitter");
        String cmd = "udp-transmitter:localhost:3333:cpu\tmemory\ttcp\n";
        final DatagramChannel channel = DatagramChannelEmul.open();
        channel.configureBlocking(false);
        final InetSocketAddress inetSocketAddress = new InetSocketAddress(
                "localhost", 4444);
        channel.connect(inetSocketAddress);
        PerfMonMetricGetter instance = new PerfMonMetricGetter(
                SigarProxyCache.newInstance(new Sigar(), 500),
                new PerfMonWorker(), channel, inetSocketAddress);
        instance.addCommandString(cmd);
        instance.processNextCommand();
    }
}