moonlight-stream/moonlight-android
1
0
Fork 0
mirror of https://github.com/moonlight-stream/moonlight-android.git synced 2026-06-17 22:31:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

Supply the max packet size to EnetConnection.readPacket()

Browse Source
This commit is contained in:
Cameron Gutman
2016-03-05 18:32:50 -06:00
parent 5fd105c9a9
commit b3042312f6
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
moonlight-common/src/com/limelight/nvstream/control/ControlStream.java
+1 -1
View File
@@ -200,7 +200,7 @@ public class ControlStream implements ConnectionStatusListener, InputPacketSende
synchronized (this) { synchronized (this) {
sendPacket(packet); sendPacket(packet);
if (context.serverGeneration >= ConnectionContext.SERVER_GENERATION_5) { if (context.serverGeneration >= ConnectionContext.SERVER_GENERATION_5) {
enetConnection.readPacket(CONTROL_TIMEOUT); enetConnection.readPacket(128, CONTROL_TIMEOUT);
} }
else { else {
new NvCtlResponse(in); new NvCtlResponse(in);
moonlight-common/src/com/limelight/nvstream/enet/EnetConnection.java
+2 -2
View File
@@ -37,8 +37,8 @@ public class EnetConnection implements Closeable {
return conn; return conn;
} }
public ByteBuffer readPacket(int timeout) throws IOException { public ByteBuffer readPacket(int maxSize, int timeout) throws IOException {
ByteBuffer buffer = ByteBuffer.allocate(128); ByteBuffer buffer = ByteBuffer.allocate(maxSize);
int readLength = readPacket(enetClient, buffer.array(), buffer.limit(), timeout); int readLength = readPacket(enetClient, buffer.array(), buffer.limit(), timeout);
if (readLength <= 0) { if (readLength <= 0) {