Mirrors/VILLASnode
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
Code Issues Releases Wiki Activity

adjust code style

Browse source
This commit is contained in:
Steffen Vogel 2021-06-29 10:53:05 -04:00
parent b8ca1dffbe
commit 7900da31f4
1 changed files with 9 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
lib/dumper.cpp
View file

@ -79,24 +79,21 @@ void Dumper::writeDataBinary(unsigned len, double *yData, double *xData){
if (yData == nullptr)
return;
unsigned dataLen = len * sizeof(yData[0]);
long unsigned int bytesWritten = write(socketFd, &dataLen, sizeof(dataLen));
if (bytesWritten != sizeof(len))
{
size_t dataLen = len * sizeof(yData[0]);
ssize_t bytesWritten = write(socketFd, &dataLen, sizeof(dataLen));
if ((size_t) bytesWritten != sizeof(len)) {
logger->warn("Could not send all content to socket {}", socketName);
warningCounter++;
}
bytesWritten = write(socketFd, "d000", 4);
if (bytesWritten != 4)
{
if (bytesWritten != 4) {
logger->warn("Could not send all content to socket {}", socketName);
warningCounter++;
}
bytesWritten = write(socketFd, yData, dataLen );
if (bytesWritten != dataLen && (!supressRepeatedWarning || warningCounter <1 ))
{
bytesWritten = write(socketFd, yData, dataLen );
if (bytesWritten != (ssize_t) dataLen && (!supressRepeatedWarning || warningCounter <1 )) {
logger->warn("Could not send all content to socket {}", socketName);
warningCounter++;
}
@ -104,21 +101,19 @@ void Dumper::writeDataBinary(unsigned len, double *yData, double *xData){
void Dumper::writeDataCSV(unsigned len, double *yData, double *xData)
{
for (unsigned i = 0; i<len; i++)
{
for (unsigned i = 0; i < len; i++) {
std::stringstream ss;
ss << yData[i];
if(xData != nullptr)
if (xData != nullptr)
ss << ";" << xData[i];
ss << std::endl;
auto str = ss.str();
auto bytesWritten = write(socketFd, str.c_str(), str.length());
if ((long unsigned int) bytesWritten != str.length() && (!supressRepeatedWarning || warningCounter <1 ))
{
if ((size_t) bytesWritten != str.length() && (!supressRepeatedWarning || warningCounter < 1)) {
logger->warn("Could not send all content to socket {}", socketName);
warningCounter++;
}