blob: 3410502eaa0797c8ef10462fec9e888955f8ea6d (
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
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
package com.macaroon.piztor;
import java.io.IOException;
import java.net.UnknownHostException;
import java.util.LinkedList;
import java.util.Queue;
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 Timer mtimer;
public boolean running = false;
public boolean flag = true;
public int cnt = 4;
Res res;
Req req;
public int p; // port
public String i; // ip
Thread thread;
Handler core;
Handler recall; // recall
Queue<Req> reqtask; // request task
Transam(String ip, int port, Handler Recall) {
p = port;
i = ip;
recall = Recall;
reqtask = new LinkedList<Req>();
}
public void send(Req r) {
reqtask.offer(r);
}
public void setHandler(Handler Recall) {
recall = Recall;
reqtask.clear();
}
public void run() { // start the main timer
// TimerTask tmain = new Timertk();
// mtimer = new Timer();
// mtimer.schedule(tmain, 100, 100); //check the queue for every 100
// msec
while (true) {
if (running == false) {
if (!reqtask.isEmpty()) { // poll the head request
req = reqtask.poll();
if (req.time + req.alive < System.currentTimeMillis()) { // time
// out!
Message ret = new Message();
ret.obj = "Time out!";
ret.what = 100;
recall.sendMessage(ret);
} else { // run the request
final thd t = new thd();
flag = false;
thread = new Thread(t);
cnt = 4;
running = true;
thread.start();
timer = new Timer();
TimerTask task = new Timertk();
timer.schedule(task, 2000, 2000);
}
}
}
}
}
class tmain extends TimerTask {
public void run() {
}
};
class thd implements Runnable {
public void run() {
try {
SocketClient client = new SocketClient(i, p);
client.sendMsg(req, recall);
Message msg = new Message();
msg.what = 1;
handler.sendMessage(msg);
client.closeSocket();
} catch (UnknownHostException e) {
e.printStackTrace();
System.out.println("UnknownHostException");
} catch (IOException e) {
e.printStackTrace();
System.out.println("IOException");
}
}
}
@SuppressLint("HandlerLeak")
Handler handler = new Handler() {
public void handleMessage(Message msg) {
switch (msg.what) {
case 1:
flag = true;
break;
case 2:
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 = 101;
recall.sendMessage(msg);
timer.cancel();
} else if (flag == true) {
timer.cancel();
running = false;
}
}
};
}
|