-
Notifications
You must be signed in to change notification settings - Fork 1
Expand file tree
/
Copy pathnetwork.cpp
More file actions
106 lines (85 loc) · 1.8 KB
/
Copy pathnetwork.cpp
File metadata and controls
106 lines (85 loc) · 1.8 KB
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
#include "network.h"
#include "commander.h"
Network::Network()
{
enable = false;
socket = NULL;
commander = NULL;
}
Network::~Network()
{
}
void Network::init()
{
socket = new Socket();
socket->init();
commander = new Commander();
}
void Network::uninit()
{
socket->uninit();
delete socket;
socket = NULL;
delete commander;
enable = false;
}
bool Network::connect(int camnum)
{
enable = socket->connect();
Logger::log(CLIENT_LOG_INFO, "socket connect : %d :%s", camnum, enable ? "success" : "fail");
return enable;
}
void Network::update()
{
if( enable )
{
bool ret = socket->update();
if( ret == false)
{
Logger::log(CLIENT_LOG_ERR, "socket disconnected");
enable = false;
}
read();
}
}
// Parse recieved packet
bool Network::read()
{
// recieve and parse
if( enable )
{
SocketBuffer buffer;
bool ret = socket->recvpacket(&buffer);
if( ret == true )
{
// packet parse
parsepacket(&buffer);
}
}
else
return false;
return true;
}
// send packet to server
bool Network::write(char packet, char *data, int datasize)
{
if(enable)
{
char buff[SOCKET_BUFFER] = { 0, };
memcpy(buff, &datasize, sizeof(int)); // size header는 패킷 데이터 크기
buff[4] = packet;
memcpy(buff+sizeof(int)+sizeof(char), data, datasize);
return socket->sendpacket(buff, datasize + sizeof(int) + sizeof(char));
}
return false;
}
void Network::parsepacket(SocketBuffer *buffer)
{
int datasize = (int&)*(buffer->buffer);
char packet = (char&)*(buffer->buffer+sizeof(int));
commander->addcommand(packet, buffer->buffer + sizeof(int) + sizeof(char), datasize);
}
int Network::sendImmediate(char* data, int datasize)
{
return socket->sendImmediate(data, datasize);
}