diff options
author | Teddy <ted.sybil@gmail.com> | 2013-08-27 08:48:13 +0800 |
---|---|---|
committer | Teddy <ted.sybil@gmail.com> | 2013-08-27 08:48:13 +0800 |
commit | 3849201b28bc38bb8b42574bdf847dd7a5ce8aa7 (patch) | |
tree | 922a19e548553fb500252e131c6b2745eeca7648 /client/Piztor/src/com/macaroon/piztor/SocketClient.java | |
parent | ae935e1c38c7ffe662fa3381b0a5bd8b91c72b49 (diff) | |
parent | 0cfa72f9f352a81ff40ce41d2a94aa4f63d3a815 (diff) |
Merge branch 'master' of github.com:Determinant/piztor
Diffstat (limited to 'client/Piztor/src/com/macaroon/piztor/SocketClient.java')
-rw-r--r-- | client/Piztor/src/com/macaroon/piztor/SocketClient.java | 14 |
1 files changed, 11 insertions, 3 deletions
diff --git a/client/Piztor/src/com/macaroon/piztor/SocketClient.java b/client/Piztor/src/com/macaroon/piztor/SocketClient.java index 812de05..f97e397 100644 --- a/client/Piztor/src/com/macaroon/piztor/SocketClient.java +++ b/client/Piztor/src/com/macaroon/piztor/SocketClient.java @@ -4,6 +4,7 @@ import java.io.DataInputStream; import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
+import java.net.SocketTimeoutException;
import java.net.UnknownHostException;
import java.util.Locale;
import java.util.Vector;
@@ -14,18 +15,21 @@ import android.os.Message; public class SocketClient {
static Socket client;
- public SocketClient(String site, int port) throws UnknownHostException,
+ public SocketClient(String site, int port, int retime) throws UnknownHostException,
IOException {
try {
client = new Socket(site, port);
+ client.setSoTimeout(retime);
} catch (UnknownHostException e) {
+ e.printStackTrace();
throw e;
} catch (IOException e) {
+ e.printStackTrace();
throw e;
}
}
- public void sendMsg(Req req,Handler recall) throws IOException {
+ public int sendMsg(Req req,Handler recall) throws IOException,SocketTimeoutException {
try {
DataOutputStream out = new DataOutputStream(
client.getOutputStream());
@@ -161,10 +165,14 @@ public class SocketClient { recall.sendMessage(msg);
break;
}
+ return 0;
+ } catch (SocketTimeoutException e){
+ System.out.println("Time out!");
+ return 1;
} catch (IOException e) {
throw e;
- }
+ }
}
public void closeSocket() throws IOException{
|