Package org.jacoco.core.runtime

Examples of org.jacoco.core.runtime.RemoteControlReader

212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
    assertEquals(0, mockConnection.getSocketB().getInputStream()
        .available());
  }

  private void readAndAssertData() throws IOException {
    final RemoteControlReader remoteReader = new RemoteControlReader(
        mockConnection.getSocketB().getInputStream());

    final ExecutionDataStore execStore = new ExecutionDataStore();
    remoteReader.setExecutionDataVisitor(execStore);
    final SessionInfoStore infoStore = new SessionInfoStore();
    remoteReader.setSessionInfoVisitor(infoStore);

    assertTrue(remoteReader.read());

    final List<SessionInfo> infos = infoStore.getInfos();
    assertEquals(1, infos.size());
    assertEquals("stubid", infos.get(0).getId());
View Full Code Here
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
    assertBlocks(f);

    remoteWriter.visitDumpCommand(false, true);

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

    final ExecutionDataStore execStore = new ExecutionDataStore();
    remoteReader.setExecutionDataVisitor(execStore);
    final SessionInfoStore infoStore = new SessionInfoStore();
    remoteReader.setSessionInfoVisitor(infoStore);

    assertTrue(remoteReader.read());
    assertTrue(infoStore.getInfos().isEmpty());
    assertTrue(execStore.getContents().isEmpty());
    runtime.assertNoProbes();

    con.close();
View Full Code Here
64
65
66
67
68
69
70
        return con.getSocketA();
      }
    };
    runtime = new StubRuntime();
    controller.startup(new AgentOptions(), runtime);
    remoteReader = new RemoteControlReader(remoteSocket.getInputStream());
  }
View Full Code Here
44
45
46
47
48
49
50
51
52
    this.initialized = false;
  }

  public void init() throws IOException {
    this.writer = new RemoteControlWriter(socket.getOutputStream());
    this.reader = new RemoteControlReader(socket.getInputStream());
    this.reader.setRemoteCommandVisitor(this);
    this.initialized = true;
  }
View Full Code Here
41
42
43
44
45
46
47
48
49
    this.initialized = false;
  }

  public void init() throws IOException {
    this.writer = new RemoteControlWriter(socket.getOutputStream());
    this.reader = new RemoteControlReader(socket.getInputStream());
    this.reader.setRemoteCommandVisitor(this);
    this.initialized = true;
  }
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
    final ExecFileLoader loader = new ExecFileLoader();
    final Socket socket = tryConnect(address, port);
    try {
      final RemoteControlWriter remoteWriter = new RemoteControlWriter(
          socket.getOutputStream());
      final RemoteControlReader remoteReader = new RemoteControlReader(
          socket.getInputStream());
      remoteReader.setSessionInfoVisitor(loader.getSessionInfoStore());
      remoteReader
          .setExecutionDataVisitor(loader.getExecutionDataStore());

      remoteWriter.visitDumpCommand(dump, reset);
      remoteReader.read();

    } finally {
      socket.close();
    }
    return loader;
View Full Code Here
41
42
43
44
45
46
47
48
49
    this.initialized = false;
  }

  public void init() throws IOException {
    this.writer = new RemoteControlWriter(socket.getOutputStream());
    this.reader = new RemoteControlReader(socket.getInputStream());
    this.reader.setRemoteCommandVisitor(this);
    this.initialized = true;
  }
View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
  }

  private void handleConnection(Socket socket) throws IOException {
    final RemoteControlWriter writer = new RemoteControlWriter(
        socket.getOutputStream());
    final RemoteControlReader reader = new RemoteControlReader(
        socket.getInputStream());
    reader.setRemoteCommandVisitor(new IRemoteCommandVisitor() {
      public void visitDumpCommand(boolean dump, boolean reset)
          throws IOException {
        dumpRequested = dump;
        resetRequested = reset;
        if (dump) {
          writer.visitSessionInfo(new SessionInfo("TestId", 100, 200));
        }
        writer.sendCmdOk();
      }
    });
    reader.read();
  }
View Full Code Here
70
71
72
73
74
75
76
77
78
      this.fileWriter = fileWriter;

      // Just send a valid header:
      new RemoteControlWriter(socket.getOutputStream());

      reader = new RemoteControlReader(socket.getInputStream());
      reader.setSessionInfoVisitor(this);
      reader.setExecutionDataVisitor(this);
    }
View Full Code Here
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
    assertEquals(0, mockConnection.getSocketB().getInputStream()
        .available());
  }

  private void readAndAssertData() throws IOException {
    final RemoteControlReader remoteReader = new RemoteControlReader(
        mockConnection.getSocketB().getInputStream());

    final ExecutionDataStore execStore = new ExecutionDataStore();
    remoteReader.setExecutionDataVisitor(execStore);
    final SessionInfoStore infoStore = new SessionInfoStore();
    remoteReader.setSessionInfoVisitor(infoStore);

    assertTrue(remoteReader.read());

    final List<SessionInfo> infos = infoStore.getInfos();
    assertEquals(1, infos.size());
    assertEquals("stubid", infos.get(0).getId());
View Full Code Here
TOP

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

  • com.mountainminds.eclemma.core.AgentExecutionDataSource
  • com.mountainminds.eclemma.internal.core.ExecutionDataDumperTest
  • com.mountainminds.eclemma.internal.core.launching.AgentServer
  • org.jacoco.agent.rt.controller.TcpClientControllerTest
  • org.jacoco.agent.rt.controller.TcpConnection
  • org.jacoco.agent.rt.controller.TcpConnectionTest
  • org.jacoco.agent.rt.controller.TcpServerControllerTest
  • org.jacoco.agent.rt.internal.output.TcpClientOutputTest
  • org.jacoco.agent.rt.internal.output.TcpConnection
  • org.jacoco.agent.rt.internal.output.TcpConnectionTest
    • 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.