blob: 18c19da3e849c586ca246b57f53fff4d101c3985 (
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
|
package com.macaroon.piztor;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Vector;
import android.os.Handler;
import android.os.Message;
public class SocketClient {
static Socket client;
public SocketClient(String site, int port) throws UnknownHostException,
IOException {
try {
client = new Socket(site, port);
} catch (UnknownHostException e) {
throw e;
} catch (IOException e) {
throw e;
}
}
public void sendMsg(Req req,Handler recall) throws IOException {
try {
DataOutputStream out = new DataOutputStream(
client.getOutputStream());
int tmp = req.type;
out.writeByte(tmp);
switch (tmp) {
case 0:
ReqLogin rau = (ReqLogin) req;
String id = rau.user;
String pa = rau.pass;
out.writeBytes(id + "\0" + pa);
break;
case 2:
ReqUpdate rup = (ReqUpdate) req;
int tk2 = rup.token;
double slat = rup.lat;
double slot = rup.lot;
out.writeInt(tk2);
out.writeDouble(slat);
out.writeDouble(slot);
break;
case 3:
ReqLocation ras = (ReqLocation) req;
int tk3 = ras.token;
int gid = ras.gid;
out.writeInt(tk3);
out.writeInt(gid);
break;
}
out.flush();
client.shutdownOutput();
DataInputStream in = new DataInputStream(client.getInputStream());
Message msg = new Message();
int type = in.readUnsignedByte();
switch (type) {
case 0:
int id = in.readInt();
int status = in.readUnsignedByte();
ResLogin rchklogin = new ResLogin(id,status);
msg.obj = rchklogin;
msg.what = 0;
recall.sendMessage(msg);
break;
case 2:
int status1 = in.readUnsignedByte();
ResUpdate rchkupd = new ResUpdate(status1);
msg.obj = rchkupd;
msg.what = 1;
recall.sendMessage(msg);
break;
case 3:
int n = in.readInt();
Vector<Rlocation> tmpv = new Vector<Rlocation>();
for (int i = 1; i <= n; i++) {
int tid = in.readInt();
double lat = in.readDouble();
double lot = in.readDouble();
tmpv.add(new Rlocation(tid,lat,lot));
}
ResLocation rlocin = new ResLocation(n,tmpv);
msg.obj = rlocin;
msg.what = 3;
recall.sendMessage(msg);
break;
}
} catch (IOException e) {
throw e;
}
}
public void closeSocket() {
try {
client.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
|