Skip to content

Commit 243cbd6

Browse files
committed
(WIP) fix
1 parent a1c6c6b commit 243cbd6

2 files changed

Lines changed: 4 additions & 2 deletions

File tree

org.eclipse.eclemma.core/src/org/eclipse/eclemma/core/AgentExecutionDataSource.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
******************************************************************************/
1313
package org.eclipse.eclemma.core;
1414

15+
import java.io.BufferedInputStream;
1516
import java.io.IOException;
1617
import java.net.Socket;
1718

@@ -45,7 +46,7 @@ public void accept(IExecutionDataVisitor executionDataVisitor,
4546
final RemoteControlWriter writer = new RemoteControlWriter(
4647
socket.getOutputStream());
4748
final RemoteControlReader reader = new RemoteControlReader(
48-
socket.getInputStream());
49+
new BufferedInputStream(socket.getInputStream()));
4950
reader.setExecutionDataVisitor(executionDataVisitor);
5051
reader.setSessionInfoVisitor(sessionInfoVisitor);
5152
writer.visitDumpCommand(true, reset);

org.eclipse.eclemma.core/src/org/eclipse/eclemma/internal/core/launching/AgentServer.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
******************************************************************************/
1313
package org.eclipse.eclemma.internal.core.launching;
1414

15+
import java.io.BufferedInputStream;
1516
import java.io.IOException;
1617
import java.net.InetAddress;
1718
import java.net.ServerSocket;
@@ -109,7 +110,7 @@ protected IStatus run(IProgressMonitor monitor) {
109110
final Socket socket = serverSocket.accept();
110111
writer = new RemoteControlWriter(socket.getOutputStream());
111112
final RemoteControlReader reader = new RemoteControlReader(
112-
socket.getInputStream());
113+
new BufferedInputStream(socket.getInputStream()));
113114
while (true) {
114115
final MemoryExecutionDataSource memory = new MemoryExecutionDataSource();
115116
memory.readFrom(reader);

0 commit comments

Comments
 (0)