Mirrors/megabasterd
1
0
Fork 0
mirror of https://github.com/tonikelope/megabasterd.git synced 2025-05-23 18:16:18 +02:00
Code Issues Packages Projects Releases Wiki Activity

2.53

Browse Source
This commit is contained in:
tonikelope 2017-12-07 20:00:16 +01:00
parent 66e5ac8251
commit c9329ba591
2 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/megabasterd/MainPanel.java
View File

@ -45,7 +45,7 @@ import org.apache.http.auth.UsernamePasswordCredentials;
*/
public final class MainPanel {
public static final String VERSION = "2.52";
public static final String VERSION = "2.53";
public static final int THROTTLE_SLICE_SIZE = 16 * 1024;
public static final int DEFAULT_BYTE_BUFFER_SIZE = 16 * 1024;
public static final int STREAMER_PORT = 1337;

19
src/megabasterd/SmartMegaProxyManager.java
View File

@ -8,11 +8,11 @@ import java.net.MalformedURLException;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Random;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.logging.Level;
import java.util.logging.Logger;
import static megabasterd.MainPanel.THREAD_POOL;
import static megabasterd.MiscTools.getApacheKissHttpClient;
import static megabasterd.MiscTools.swingReflectionInvoke;
import org.apache.http.client.methods.CloseableHttpResponse;
@ -71,6 +71,17 @@ public class SmartMegaProxyManager implements Runnable {
public void setProxy_list_url(String proxy_list_url) {
_proxy_list_url = proxy_list_url;
THREAD_POOL.execute(new Runnable() {
@Override
public void run() {
synchronized (_refresh_lock) {
_refreshProxyList();
}
}
});
}
public Object getRefresh_lock() {
@ -172,8 +183,12 @@ public class SmartMegaProxyManager implements Runnable {
_proxy_list.clear();
this._proxy_list.addAll(Arrays.asList(proxy_list));
for (String proxy : proxy_list) {
if (proxy.trim().matches(".+?:[0-9]{1,5}")) {
this._proxy_list.add(proxy);
}
}
}
Logger.getLogger(SmartMegaProxyManager.class.getName()).log(Level.INFO, "{0} Smart Proxy Manager: proxy list refreshed ({1})", new Object[]{Thread.currentThread().getName(), _proxy_list.size()});