ReVanced-Mirror/jadb
1
0
Fork 0
mirror of https://github.com/revanced/jadb.git synced 2025-02-11 09:36:48 +01:00
Code Issues Projects Releases Wiki Activity

Support for responding to multiple requests on the same connection

Browse Source
This commit is contained in:
Samuel Carlsson 2014-03-17 21:57:57 +01:00
parent 548acc6aa2
commit a872b5413e
1 changed files with 42 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
test/se/vidstige/jadb/test/fakes/AdbResponder.java
View File

@ -16,35 +16,49 @@ public class AdbResponder implements Runnable {
@Override
public void run()
{
{
System.out.println("Serving client");
try {
System.out.println("Serving client");
DataInput input = new DataInputStream(socket.getInputStream());
OutputStreamWriter output = new OutputStreamWriter(socket.getOutputStream());
byte[] buffer = new byte[4];
input.readFully(buffer);
String encodedLength = new String(buffer, Charset.forName("utf-8"));
int length = Integer.parseInt(encodedLength, 16);
buffer = new byte[length];
input.readFully(buffer);
String command = new String(buffer, Charset.forName("utf-8"));
System.out.println("Command: " + command);
if ("host:version".equals(command)) {
output.write("OKAY");
send(output, "001F");
}
else if ("host:devices".equals(command)) {
output.write("OKAY");
send(output, "X\tdevice\nY\tdevice");
}
else
{
output.write("FAIL");
}
output.flush();
while (true)
{
DataInput input = new DataInputStream(socket.getInputStream());
OutputStreamWriter output = new OutputStreamWriter(socket.getOutputStream());
byte[] buffer = new byte[4];
input.readFully(buffer);
String encodedLength = new String(buffer, Charset.forName("utf-8"));
System.out.println("DEBUG: " + encodedLength);
int length = Integer.parseInt(encodedLength, 16);
buffer = new byte[length];
input.readFully(buffer);
String command = new String(buffer, Charset.forName("utf-8"));
System.out.println("Command: " + command);
if ("host:version".equals(command)) {
output.write("OKAY");
send(output, "001F"); // version. required to be 31
System.out.println("OK");
}
else if ("host:transport-any".equals(command))
{
output.write("OKAY");
System.out.println("OK");
}
else if ("host:devices".equals(command)) {
output.write("OKAY");
send(output, "X\tdevice\nY\tdevice");
System.out.println("OK");
}
else
{
output.write("FAIL");
send(output, "Unknown command: " + command);
System.out.println("FAIL");
}
output.flush();
}
} catch (IOException e) {
System.out.println(e.getMessage());
}