Commit 69544c2a authored by Daniel Wolf's avatar Daniel Wolf
Browse files

Don't continue with the iteration if the proxy should stop

parent bfd36f59
...@@ -127,7 +127,7 @@ public class DNSUDPProxy extends DNSProxy{ ...@@ -127,7 +127,7 @@ public class DNSUDPProxy extends DNSProxy{
FileInputStream inputStream = new FileInputStream(parcelFileDescriptor.getFileDescriptor()); FileInputStream inputStream = new FileInputStream(parcelFileDescriptor.getFileDescriptor());
FileOutputStream outputStream = new FileOutputStream(parcelFileDescriptor.getFileDescriptor()); FileOutputStream outputStream = new FileOutputStream(parcelFileDescriptor.getFileDescriptor());
byte[] packet = new byte[32767]; byte[] packet = new byte[32767];
while(shouldRun){ outer: while(shouldRun){
StructPollfd structFd = new StructPollfd(); StructPollfd structFd = new StructPollfd();
structFd.fd = inputStream.getFD(); structFd.fd = inputStream.getFD();
structFd.events = (short) OsConstants.POLLIN; structFd.events = (short) OsConstants.POLLIN;
...@@ -143,6 +143,7 @@ public class DNSUDPProxy extends DNSProxy{ ...@@ -143,6 +143,7 @@ public class DNSUDPProxy extends DNSProxy{
int index = 0; int index = 0;
if(shouldRun){ if(shouldRun){
for(DatagramSocket socket: futureSocketAnswers.keySet()){ for(DatagramSocket socket: futureSocketAnswers.keySet()){
if(!shouldRun)break outer;
StructPollfd pollingFd = polls[2 + index++] = new StructPollfd(); StructPollfd pollingFd = polls[2 + index++] = new StructPollfd();
pollingFd.fd = ParcelFileDescriptor.fromDatagramSocket(socket).getFileDescriptor(); pollingFd.fd = ParcelFileDescriptor.fromDatagramSocket(socket).getFileDescriptor();
pollingFd.events = (short)OsConstants.POLLIN; pollingFd.events = (short)OsConstants.POLLIN;
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment