Package org.jacoco.core.runtime

Examples of org.jacoco.core.runtime.RemoteControlWriter


  @Test
  public void testRemoteReset() throws Exception {
    runtime.fillProbes();

    final RemoteControlWriter remoteWriter = new RemoteControlWriter(
        mockConnection.getSocketB().getOutputStream());

    final TcpConnection con = new TcpConnection(
        mockConnection.getSocketA(), runtime);
    con.init();

    final Future<Void> f = executor.submit(new Callable<Void>() {
      public Void call() throws Exception {
        con.run();
        return null;
      }
    });

    assertBlocks(f);

    remoteWriter.visitDumpCommand(false, true);

    final RemoteControlReader remoteReader = new RemoteControlReader(
        mockConnection.getSocketB().getInputStream());

    final ExecutionDataStore execStore = new ExecutionDataStore();
View Full Code Here


  @Before
  public void setup() throws Exception {
    logger = new ExceptionRecorder();
    final MockSocketConnection con = new MockSocketConnection();
    remoteSocket = con.getSocketB();
    remoteWriter = new RemoteControlWriter(remoteSocket.getOutputStream());
    controller = new TcpClientController(logger) {
      @Override
      protected Socket createSocket(AgentOptions options)
          throws IOException {
        return con.getSocketA();
View Full Code Here

   * @param args
   * @throws IOException
   */
  public static void main(final String[] args) throws IOException {
    final FileOutputStream localFile = new FileOutputStream(DESTFILE);
    final RemoteControlWriter localWriter = new RemoteControlWriter(
        localFile);

    // Open a socket to the coverage agent:
    final Socket socket = new Socket(InetAddress.getByName(ADDRESS), PORT);
    final RemoteControlWriter writer = new RemoteControlWriter(
        socket.getOutputStream());
    final RemoteControlReader reader = new RemoteControlReader(
        socket.getInputStream());
    reader.setSessionInfoVisitor(localWriter);
    reader.setExecutionDataVisitor(localWriter);

    // Send a dump command and read the response:
    writer.visitDumpCommand(true, false);
    reader.read();

    socket.close();
    localFile.close();
  }
View Full Code Here

  }

  @Test
  public void testWriteExecutionData() throws Exception {
    final Socket socket = serverSocket.connect();
    final RemoteControlWriter remoteWriter = new RemoteControlWriter(
        socket.getOutputStream());
    final RemoteControlReader remoteReader = new RemoteControlReader(
        socket.getInputStream());

    // First process a NOP command to ensure the connection is initialized:
    remoteWriter.visitDumpCommand(false, false);
    remoteReader.read();

    // Now the actual test starts:
    controller.writeExecutionData();
View Full Code Here

      // 1. Open socket connection
      final Socket socket = new Socket(InetAddress.getByName(address),
          port);
      log(format("Connecting to %s", socket.getRemoteSocketAddress()));
      final RemoteControlWriter remoteWriter = new RemoteControlWriter(
          socket.getOutputStream());
      final RemoteControlReader remoteReader = new RemoteControlReader(
          socket.getInputStream());

      // 2. Open file output
      output = openOutputStream();
      final ExecutionDataWriter outputWriter = new ExecutionDataWriter(
          output);
      remoteReader.setSessionInfoVisitor(outputWriter);
      remoteReader.setExecutionDataVisitor(outputWriter);

      // 3. Request dump
      remoteWriter.visitDumpCommand(dump, reset);
      remoteReader.read();

      socket.close();

    } catch (final IOException e) {
View Full Code Here

  }

  @Test
  public void testWriteExecutionData() throws Exception {
    final Socket socket = serverSocket.connect();
    final RemoteControlWriter remoteWriter = new RemoteControlWriter(
        socket.getOutputStream());
    final RemoteControlReader remoteReader = new RemoteControlReader(
        socket.getInputStream());

    // First process a NOP command to ensure the connection is initialized:
    remoteWriter.visitDumpCommand(false, false);
    remoteReader.read();

    // Now the actual test starts:
    controller.writeExecutionData();
View Full Code Here

    f.get();
  }

  @Test
  public void testRemoteDump() throws Exception {
    final RemoteControlWriter remoteWriter = new RemoteControlWriter(
        mockConnection.getSocketB().getOutputStream());

    final TcpConnection con = new TcpConnection(
        mockConnection.getSocketA(), runtime);
    con.init();

    final Future<Void> f = executor.submit(new Callable<Void>() {
      public Void call() throws Exception {
        con.run();
        return null;
      }
    });

    assertBlocks(f);

    remoteWriter.visitDumpCommand(true, false);
    readAndAssertData();

    con.close();
    f.get();
  }
View Full Code Here

    f.get();
  }

  @Test
  public void testLocalDump() throws Exception {
    new RemoteControlWriter(mockConnection.getSocketB().getOutputStream());

    final TcpConnection con = new TcpConnection(
        mockConnection.getSocketA(), runtime);
    con.init();
View Full Code Here

  @Test
  public void testRemoteReset() throws Exception {
    runtime.fillProbes();

    final RemoteControlWriter remoteWriter = new RemoteControlWriter(
        mockConnection.getSocketB().getOutputStream());

    final TcpConnection con = new TcpConnection(
        mockConnection.getSocketA(), runtime);
    con.init();

    final Future<Void> f = executor.submit(new Callable<Void>() {
      public Void call() throws Exception {
        con.run();
        return null;
      }
    });

    assertBlocks(f);

    remoteWriter.visitDumpCommand(false, true);

    final RemoteControlReader remoteReader = new RemoteControlReader(
        mockConnection.getSocketB().getInputStream());

    final ExecutionDataStore execStore = new ExecutionDataStore();
View Full Code Here

    f.get();
  }

  @Test
  public void testRemoteDump() throws Exception {
    final RemoteControlWriter remoteWriter = new RemoteControlWriter(
        mockConnection.getSocketB().getOutputStream());

    final TcpConnection con = new TcpConnection(
        mockConnection.getSocketA(), runtime);
    con.init();

    final Future<Void> f = executor.submit(new Callable<Void>() {
      public Void call() throws Exception {
        con.run();
        return null;
      }
    });

    assertBlocks(f);

    remoteWriter.visitDumpCommand(true, false);
    readAndAssertData();

    con.close();
    f.get();
  }
View Full Code Here

TOP

Related Classes of org.jacoco.core.runtime.RemoteControlWriter

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.