moonlight-stream/moonlight-android
1
0
Fork 0
mirror of https://github.com/moonlight-stream/moonlight-android.git synced 2025-07-20 11:33:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Send control messages as a single TCP packet because the streamer on the PC can choke if it doesn't receive the header and body at the same time

Browse Source
This commit is contained in:
Cameron Gutman 2014-10-10 18:14:43 -07:00
parent d9c2d58519
commit ac6120adc4
1 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
moonlight-common/src/com/limelight/nvstream/control/ControlStream.java
View File

@ -80,8 +80,11 @@ public class ControlStream implements ConnectionStatusListener {
private void sendPacket(NvCtlPacket packet) throws IOException
{
packet.write(out);
out.flush();
// Prevent multiple clients from writing to the stream at the same time
synchronized (this) {
packet.write(out);
out.flush();
}
}
private ControlStream.NvCtlResponse sendAndGetReply(NvCtlPacket packet) throws IOException
@ -257,6 +260,7 @@ public class ControlStream implements ConnectionStatusListener {
public byte[] payload;
private static final ByteBuffer headerBuffer = ByteBuffer.allocate(4).order(ByteOrder.LITTLE_ENDIAN);
private static final ByteBuffer serializationBuffer = ByteBuffer.allocate(128).order(ByteOrder.LITTLE_ENDIAN);
public NvCtlPacket(InputStream in) throws IOException
{
@ -356,15 +360,15 @@ public class ControlStream implements ConnectionStatusListener {
public void write(OutputStream out) throws IOException
{
// Use the class's header buffer to construct the wireform to send
synchronized (headerBuffer) {
headerBuffer.rewind();
headerBuffer.putShort(type);
headerBuffer.putShort(paylen);
out.write(headerBuffer.array());
// Use the class's serialization buffer to construct the wireform to send
synchronized (serializationBuffer) {
serializationBuffer.rewind();
serializationBuffer.putShort(type);
serializationBuffer.putShort(paylen);
serializationBuffer.put(payload);
out.write(serializationBuffer.array(), 0, serializationBuffer.position());
}
out.write(payload);
}
}