Mercurial Hosting > luan
changeset 733:ffbbe25dab09
add http option time_out
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Tue, 14 Jun 2016 00:04:08 -0600 |
parents | d7371dc8c2e7 |
children | e44e98fe9de8 |
files | core/src/luan/modules/url/LuanUrl.java |
diffstat | 1 files changed, 19 insertions(+), 0 deletions(-) [+] |
line wrap: on
line diff
diff -r d7371dc8c2e7 -r ffbbe25dab09 core/src/luan/modules/url/LuanUrl.java --- a/core/src/luan/modules/url/LuanUrl.java Sun Jun 12 23:05:31 2016 -0600 +++ b/core/src/luan/modules/url/LuanUrl.java Tue Jun 14 00:04:08 2016 -0600 @@ -14,6 +14,7 @@ import java.util.HashMap; import java.util.List; import java.util.Base64; +import luan.Luan; import luan.LuanState; import luan.LuanTable; import luan.LuanJavaFunction; @@ -31,6 +32,7 @@ private Map headers; private String content = null; private MultipartClient multipart = null; + private int timeout = 0; public LuanUrl(LuanState luan,URL url,LuanTable options) throws LuanException { this.url = url; @@ -140,6 +142,9 @@ } } } + Integer timeout = getInt(map,"time_out"); + if( timeout != null ) + this.timeout = timeout; if( !map.isEmpty() ) throw new LuanException( "unrecognized options: "+map ); } @@ -183,6 +188,16 @@ return (String)val; } + private static Integer getInt(Map map,String key) throws LuanException { + Object val = map.remove(key); + if( val==null ) + return null; + Integer i = Luan.asInteger(val); + if( i==null ) + throw new LuanException( "parameter '"+key+"' must be an integer" ); + return i; + } + private static LuanTable getTable(Map map,String key) throws LuanException { Object val = map.remove(key); if( val!=null && !(val instanceof LuanTable) ) @@ -197,6 +212,10 @@ @Override public InputStream inputStream() throws IOException, LuanException { URLConnection con = url.openConnection(); + if( timeout != 0 ) { + con.setConnectTimeout(timeout); + con.setReadTimeout(timeout); + } if( headers != null ) { for( Object hack : headers.entrySet() ) { Map.Entry entry = (Map.Entry)hack;