detectors/slsDetectorPackage
25
0
Fork 0
mirror of https://github.com/slsdetectorgroup/slsDetectorPackage.git synced 2025-04-25 07:40:03 +02:00
Code Issues Actions Packages Releases Activity

fix sending

Browse Source
This commit is contained in:
Erik Frojdh 2019-06-05 15:51:21 +02:00
parent b5e4d7d8fb
commit 3d6404952a
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
slsSupportLib/src/DataSocket.cpp
View File

@ -41,7 +41,8 @@ DataSocket &DataSocket::operator=(DataSocket &&move) noexcept {
}
int DataSocket::receiveData(void *buffer, size_t size) {
size_t dataRead = 0;
//TODO!(Erik) Add sleep? how many reties?
int dataRead = 0;
while (dataRead < size) {
auto thisRead =
::read(getSocketId(), reinterpret_cast<char *>(buffer) + dataRead,
@ -71,11 +72,14 @@ int DataSocket::setReceiveTimeout(int us) {
int DataSocket::sendData(const void *buffer, size_t size) {
// int dataSent = 0;
// while (dataSent < (int)size) {
return ::write(getSocketId(), buffer, size);
// }
// return dataSent;
int dataSent = 0;
while (dataSent < (int)size) {
auto thisSend = ::write(getSocketId(), buffer, size);
if (thisSend <= 0)
break;
dataSent += thisSend;
}
return dataSent;
}
int DataSocket::setTimeOut(int t_seconds) {