atria-soft/zeus
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

[DEV] send close event

Browse Source
This commit is contained in:
Edouard DUPIN 2016-05-16 23:34:27 +02:00
parent 565ef54dfb
commit 11170b362e
2 changed files with 17 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
jus/TcpString.cpp
View File

@ -65,6 +65,8 @@ void jus::TcpString::connect(){
void jus::TcpString::disconnect(){
JUS_DEBUG("disconnect [START]");
uint32_t size = 0xFFFFFFFF;
m_connection.write(&size, 4);
if (m_thread != nullptr) {
m_threadRunning = false;
m_connection.unlink();
@ -86,21 +88,29 @@ int32_t jus::TcpString::write(const std::string& _data) {
std::string jus::TcpString::read() {
// TODO : Do it better with a correct way to check data size ...
JUS_WARNING("Read [START]");
std::string out;
uint32_t size = 0;
int32_t len = m_connection.read(&size, 4);
if (len != 4) {
JUS_ERROR("Protocol error occured ...");
} else {
out.resize(size);
len = m_connection.read(&out[0], size);
if (len == 0) {
JUS_WARNING("Read No data");
} else if (len != size) {
// TODO do it again ...
JUS_ERROR("Protocol error occured .2.");
if (size == -1) {
JUS_WARNING("Remote close connection");
m_threadRunning = false;
//m_connection.unlink();
} else {
out.resize(size);
len = m_connection.read(&out[0], size);
if (len == 0) {
JUS_WARNING("Read No data");
} else if (len != size) {
// TODO do it again ...
JUS_ERROR("Protocol error occured .2.");
}
}
}
JUS_WARNING("Read [STOP]");
return out;
}

BIN
tools/gateway/__pycache__/lutin_jus-gateway.cpython-35.pyc
View File

Binary file not shown.