Revize 313ff1dc
Přidáno uživatelem Oto Šťáva před téměř 4 roky(ů)
deltarobot/curvedataserver.cpp | ||
---|---|---|
131 | 131 |
|
132 | 132 |
CurveDataServer::~CurveDataServer() |
133 | 133 |
{ |
134 |
_threadIsRunning = false; |
|
135 |
_pingThread.join(); |
|
136 |
|
|
134 | 137 |
std::lock_guard<decltype (_socketsLock)> l(_socketsLock); |
135 | 138 |
for (auto& client : _sockets) |
136 | 139 |
{ |
137 | 140 |
terminateConnection(client, "Server is stopping"); |
138 | 141 |
} |
139 | 142 |
_sockets.clear(); |
140 |
|
|
141 |
_threadIsRunning = false; |
|
142 | 143 |
} |
143 | 144 |
|
144 | 145 |
void CurveDataServer::onNewConnection() |
... | ... | |
437 | 438 |
|
438 | 439 |
void CurveDataServer::threadFunction() |
439 | 440 |
{ |
441 |
/* |
|
440 | 442 |
while (_threadIsRunning) |
441 | 443 |
{ |
442 | 444 |
//processPings(); |
... | ... | |
445 | 447 |
|
446 | 448 |
std::this_thread::sleep_for(std::chrono::milliseconds(100)); |
447 | 449 |
} |
450 |
*/ |
|
448 | 451 |
} |
449 | 452 |
|
450 | 453 |
void CurveDataServer::processPings() |
Také k dispozici: Unified diff
Re #8906 - Server doc comments; cleanup