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

dumper: code style modification

Browse source
This commit is contained in:
Manuel Pitz 2021-06-25 15:42:47 +02:00
parent a89a7be290
commit b8ca1dffbe
1 changed files with 10 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
lib/dumper.cpp
View file

@ -81,19 +81,22 @@ void Dumper::writeDataBinary(unsigned len, double *yData, double *xData){
unsigned dataLen = len * sizeof(yData[0]);
long unsigned int bytesWritten = write(socketFd, &dataLen, sizeof(dataLen));
if(bytesWritten != sizeof(len)) {
if (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 )) {
if (bytesWritten != dataLen && (!supressRepeatedWarning || warningCounter <1 ))
{
logger->warn("Could not send all content to socket {}", socketName);
warningCounter++;
}
@ -101,7 +104,8 @@ 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];
@ -113,7 +117,8 @@ void Dumper::writeDataCSV(unsigned len, double *yData, double *xData)
auto str = ss.str();
auto bytesWritten = write(socketFd, str.c_str(), str.length());
if ((long unsigned int) bytesWritten != str.length() && (!supressRepeatedWarning || warningCounter <1 )) {
if ((long unsigned int) bytesWritten != str.length() && (!supressRepeatedWarning || warningCounter <1 ))
{
logger->warn("Could not send all content to socket {}", socketName);
warningCounter++;
}