blob: b5e2381c1a3853f68e93707aba61d76671388e66 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
package com.example.test;
import java.io.IOException;
import java.net.UnknownHostException;
import java.util.Timer;
import java.util.TimerTask;
import android.annotation.SuppressLint;
import android.os.Handler;
import android.os.Message;
public class Transam implements Runnable {
public Timer timer;
public boolean flag = true;
public boolean reqlog = false;
public int cnt = 4;
public int port;
public String ip;
Thread thread;
Myrequest req;
Myrespond res;
Controller core;
Login log;
Transam(String i,int p,Myrequest r,Login l){
port = p;
ip = i;
req = r;
log = l;
reqlog = true;
}
Transam(String i,int p,Myrequest r,Controller c){
port = p;
ip = i;
req = r;
core = c;
}
public void run() {
final thd t = new thd();
flag = false;
thread = new Thread(t);
cnt = 4;
thread.start();
timer = new Timer();
TimerTask task = new Timertk();
timer.schedule(task,2000,2000);
}
class thd implements Runnable {
@Override
public void run() {
try{
SocketClient client = new SocketClient(ip,port);
res = client.sendMsg(req);
if(!reqlog){
core.recieveInfo(res);
}
else{
if((Integer) res.contain.get(2)==0){
int t = (Integer) res.contain.get(1);
log.success(t);
}
else{
log.failed();
}
}
Message msg = new Message();
msg.what = 1;
handler.sendMessage(msg);
client.closeSocket();
}catch (UnknownHostException e){
}catch (IOException e){
}
}
}
@SuppressLint("HandlerLeak")
Handler handler = new Handler(){
public void handleMessage(Message msg) {
switch (msg.what) {
case 1:
flag = true;
break;
case 2:
if(!reqlog){
res = new Myrespond();
res.wrong = msg.obj.toString();
core.recieveInfo(res);
}
else{
log.failed();
}
break;
case 3:
final thd t = new thd();
thread = new Thread(t);
thread.start();
break;
}
super.handleMessage(msg);
}
};
class Timertk extends TimerTask {
public void run() {
if(flag==false&&cnt>0){
cnt--;
}
else if(cnt==0) {
Message msg = new Message();
msg.obj = "connecting failed";
msg.what = 2;
handler.sendMessage(msg);
timer.cancel();
}
else if(flag==true){
timer.cancel();
}
}
};
}
|