-
Notifications
You must be signed in to change notification settings - Fork 0
/
Connserver.cpp
93 lines (89 loc) · 1.63 KB
/
Connserver.cpp
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
#include "Connserver.h"
Connserver::Connserver():connflag(false), addr("0.0.0.0", 0)
{
}
Connserver::~Connserver()
{
}
Connserver::Connserver(const char* ip, unsigned short port) :connflag(false)
{
addr.SetIp(ip);
addr.SetPortW(port);
}
bool Connserver::Connnect()
{
wsocket = new OS_TcpSocket;
wsocket->SetOpt_RecvTimeout(5000);
wsocket->SetOpt_SendTimeout(5000);
wsocket->Open(true);
if (wsocket->Connect(addr) < 0)
{
return false;
}
connflag = true;
return true;
}
bool Connserver::isconnected()
{
mutex.Lock();
return connflag;
mutex.Unlock();
}
bool Connserver::Disconnect()
{
mutex.Lock();
wsocket->Send("exit",128);
wsocket->Close();
delete wsocket;
connflag = false;
mutex.Unlock();
return true;
}
bool Connserver::Checkconn()
{
char req[128], rep[128];
strcpy(req, "checkconn");
Sendrequest(req, rep);
if (memcmp(rep, "checkright",10) == 0)
{
return true;
}
connflag = false;
return false;
}
bool Connserver::Sendrequest(const char* req)
{
char respon[128];
mutex.Lock();
if (connflag)
{
wsocket->Send(req, 128);
mutex.Unlock();
return true;
}
mutex.Unlock();
return false;
}
bool Connserver::Sendrequest(const char* req,char* rep)
{
char respon[128] = { 0 };
mutex.Lock();
//ͳһ·¢ËͽÓÊÕ×Ö½ÚÊý
if (connflag)
{
wsocket->Send(req,128);
wsocket->Recv(respon, 128);
mutex.Unlock();
strcpy(rep, respon);
return true;
}
mutex.Unlock();
return false;
}
void Connserver::SetTcpAddr(const char* ip, unsigned short port)
{
mutex.Lock();
addr.SetIp(ip);
addr.SetPortW(port);
mutex.Unlock();
}