code style

This commit is contained in:
John
2023-05-18 13:00:12 +02:00
parent 5b53fa313b
commit e606772e9d
8 changed files with 21 additions and 22 deletions
+1 -2
View File
@@ -875,8 +875,7 @@ int main(int argc, char* argv[], char* envp[]) {
s_configPath += "/"; s_configPath += "/";
} }
const string lang = MappedFileReader::normalizeLanguage( const string lang = MappedFileReader::normalizeLanguage(
s_opt.preferLanguage == nullptr || !s_opt.preferLanguage[0] ? "" : s_opt.preferLanguage s_opt.preferLanguage == nullptr || !s_opt.preferLanguage[0] ? "" : s_opt.preferLanguage);
);
string configLocalPrefix, configUriPrefix; string configLocalPrefix, configUriPrefix;
HttpClient* configHttpClient = nullptr; HttpClient* configHttpClient = nullptr;
if (s_configPath.find("://") == string::npos) { if (s_configPath.find("://") == string::npos) {
+7 -7
View File
@@ -21,11 +21,11 @@
#endif #endif
#include "ebusd/mainloop.h" #include "ebusd/mainloop.h"
#include "ebusd/scan.h"
#include <iomanip> #include <iomanip>
#include <deque> #include <deque>
#include <algorithm> #include <algorithm>
#include "ebusd/main.h" #include "ebusd/main.h"
#include "ebusd/scan.h"
#include "lib/utils/log.h" #include "lib/utils/log.h"
#include "lib/ebus/data.h" #include "lib/ebus/data.h"
@@ -106,10 +106,10 @@ result_t UserList::addFromFile(const string& filename, unsigned int lineNo, map<
MainLoop::MainLoop(const struct options& opt, Device *device, MessageMap* messages, ScanHelper* scanHelper) MainLoop::MainLoop(const struct options& opt, Device *device, MessageMap* messages, ScanHelper* scanHelper)
: Thread(), m_device(device), m_reconnectCount(0), m_userList(opt.accessLevel), m_messages(messages), m_scanHelper(scanHelper), : Thread(), m_device(device), m_reconnectCount(0), m_userList(opt.accessLevel), m_messages(messages),
m_address(opt.address), m_scanConfig(opt.scanConfig), m_initialScan(opt.readOnly ? ESC : opt.initialScan), m_scanHelper(scanHelper), m_address(opt.address), m_scanConfig(opt.scanConfig),
m_polling(opt.pollInterval > 0), m_enableHex(opt.enableHex), m_shutdown(false), m_runUpdateCheck(opt.updateCheck), m_initialScan(opt.readOnly ? ESC : opt.initialScan), m_polling(opt.pollInterval > 0), m_enableHex(opt.enableHex),
m_httpClient(opt.caFile, opt.caPath) { m_shutdown(false), m_runUpdateCheck(opt.updateCheck), m_httpClient(opt.caFile, opt.caPath) {
m_device->setListener(this); m_device->setListener(this);
// open Device // open Device
result_t result = m_device->open(); result_t result = m_device->open();
@@ -170,9 +170,9 @@ MainLoop::MainLoop(const struct options& opt, Device *device, MessageMap* messag
if (opt.enableDefine) { if (opt.enableDefine) {
m_newlyDefinedMessages = new MessageMap(true, "", false); m_newlyDefinedMessages = new MessageMap(true, "", false);
m_newlyDefinedMessages->setResolver(scanHelper); m_newlyDefinedMessages->setResolver(scanHelper);
} else { } else {
m_newlyDefinedMessages = nullptr; m_newlyDefinedMessages = nullptr;
} }
} }
MainLoop::~MainLoop() { MainLoop::~MainLoop() {
+4 -3
View File
@@ -21,7 +21,6 @@
#endif #endif
#include "ebusd/scan.h" #include "ebusd/scan.h"
#include "ebusd/bushandler.h"
#include <dirent.h> #include <dirent.h>
#include <sys/stat.h> #include <sys/stat.h>
#include <iostream> #include <iostream>
@@ -30,6 +29,7 @@
#include <map> #include <map>
#include <vector> #include <vector>
#include <functional> #include <functional>
#include "ebusd/bushandler.h"
#include "lib/utils/log.h" #include "lib/utils/log.h"
@@ -133,7 +133,7 @@ result_t ScanHelper::collectConfigFiles(const string& relPath, const string& pre
DataFieldTemplates* ScanHelper::getTemplates(const string& filename) { DataFieldTemplates* ScanHelper::getTemplates(const string& filename) {
if (filename == "*") { if (filename == "*") {
unsigned long maxLength = 0; size_t maxLength = 0;
DataFieldTemplates* best = nullptr; DataFieldTemplates* best = nullptr;
for (auto it : m_templatesByPath) { for (auto it : m_templatesByPath) {
if (it.first.size() > maxLength) { if (it.first.size() > maxLength) {
@@ -478,7 +478,8 @@ result_t ScanHelper::loadScanConfigFile(symbol_t address, string* relativeFile)
return RESULT_OK; return RESULT_OK;
} }
bool ScanHelper::parseMessage(const string& arg, bool onlyMasterSlave, MasterSymbolString* master, SlaveSymbolString* slave) { bool ScanHelper::parseMessage(const string& arg, bool onlyMasterSlave, MasterSymbolString* master,
SlaveSymbolString* slave) {
size_t pos = arg.find_first_of('/'); size_t pos = arg.find_first_of('/');
if (pos == string::npos) { if (pos == string::npos) {
logError(lf_main, "invalid message %s: missing \"/\"", arg.c_str()); logError(lf_main, "invalid message %s: missing \"/\"", arg.c_str());
+1 -1
View File
@@ -21,6 +21,7 @@
#include <stdint.h> #include <stdint.h>
#include <string> #include <string>
#include <vector>
#include <map> #include <map>
#include "lib/ebus/data.h" #include "lib/ebus/data.h"
#include "lib/ebus/message.h" #include "lib/ebus/message.h"
@@ -40,7 +41,6 @@ class BusHandler;
* Helper class for handling device scanning and config loading. * Helper class for handling device scanning and config loading.
*/ */
class ScanHelper : public Resolver { class ScanHelper : public Resolver {
public: public:
/** /**
* Constructor. * Constructor.
+5 -5
View File
@@ -245,7 +245,7 @@ string Device::getEnhancedInfos() {
res = requestEnhancedInfo(2); res = requestEnhancedInfo(2);
if (res != RESULT_OK) { if (res != RESULT_OK) {
fails += ", cannot request config"; fails += ", cannot request config";
requestEnhancedInfo(0xff); // wait for completion requestEnhancedInfo(0xff); // wait for completion
m_infoPos = 0; m_infoPos = 0;
m_infoId = 0xff; m_infoId = 0xff;
} }
@@ -266,7 +266,7 @@ string Device::getEnhancedInfos() {
if (res != RESULT_OK) { if (res != RESULT_OK) {
fails += ", cannot request bus voltage"; fails += ", cannot request bus voltage";
} }
res = requestEnhancedInfo(0xff); // wait for completion res = requestEnhancedInfo(0xff); // wait for completion
if (res != RESULT_OK) { if (res != RESULT_OK) {
m_enhInfoBusVoltage = "bus voltage unknown"; m_enhInfoBusVoltage = "bus voltage unknown";
m_infoPos = 0; m_infoPos = 0;
@@ -509,7 +509,7 @@ bool Device::available() {
// drop first byte of invalid sequence // drop first byte of invalid sequence
m_bufPos = (m_bufPos + 1) % m_bufSize; m_bufPos = (m_bufPos + 1) % m_bufSize;
m_bufLen--; m_bufLen--;
pos--; // check same pos again pos--; // check same pos again
continue; continue;
} }
if (cmd == ENH_RES_RECEIVED || cmd == ENH_RES_STARTED || cmd == ENH_RES_FAILED) { if (cmd == ENH_RES_RECEIVED || cmd == ENH_RES_STARTED || cmd == ENH_RES_FAILED) {
@@ -524,7 +524,7 @@ bool Device::available() {
fprintf(stdout, "raw avail enhanced skip cmd %d @%d+%d %2.2x\n", cmd, m_bufPos, pos, ch); fprintf(stdout, "raw avail enhanced skip cmd %d @%d+%d %2.2x\n", cmd, m_bufPos, pos, ch);
fflush(stdout); fflush(stdout);
#endif #endif
pos++; // skip enhanced sequence of 2 bytes pos++; // skip enhanced sequence of 2 bytes
continue; continue;
} }
#ifdef DEBUG_RAW_TRAFFIC #ifdef DEBUG_RAW_TRAFFIC
@@ -537,7 +537,7 @@ bool Device::available() {
// skip byte from erroneous protocol // skip byte from erroneous protocol
m_bufPos = (m_bufPos+1)%m_bufSize; m_bufPos = (m_bufPos+1)%m_bufSize;
m_bufLen--; m_bufLen--;
pos--; // check byte 2 again from scratch and allow as byte 1 pos--; // check byte 2 again from scratch and allow as byte 1
} }
return false; return false;
} }
+1 -1
View File
@@ -460,7 +460,7 @@ result_t Message::create(const string& filename, const DataFieldTemplates* templ
return result; return result;
} }
} }
if (id.size() + data->getLength(pt_masterData, maxLength==MAX_POS ? MAX_POS-id.size() : maxLength) > 2 + maxLength if (id.size() + data->getLength(pt_masterData, maxLength == MAX_POS ? MAX_POS-id.size() : maxLength) > 2 + maxLength
|| data->getLength(pt_slaveData, maxLength) > maxLength) { || data->getLength(pt_slaveData, maxLength) > maxLength) {
// max NN exceeded // max NN exceeded
delete data; delete data;
+1 -1
View File
@@ -152,7 +152,7 @@ SSLSocket* SSLSocket::connect(const string& host, const uint16_t& port, bool htt
time_t until = time(nullptr) + (timeout <= 3 ? 3 : timeout); // at least 3 seconds time_t until = time(nullptr) + (timeout <= 3 ? 3 : timeout); // at least 3 seconds
if (!https) { if (!https) {
do { do {
bio = BIO_new_connect((char*)hostPort.c_str()); bio = BIO_new_connect(static_cast<const char*>(hostPort.c_str()));
if (isError("connect", bio)) { if (isError("connect", bio)) {
break; break;
} }
+1 -2
View File
@@ -132,8 +132,7 @@ class HttpClient {
m_caFile(caFile), m_caFile(caFile),
m_caPath(caPath), m_caPath(caPath),
#endif #endif
m_socket(nullptr), m_port(0), m_timeout(0), m_bufferSize(0), m_buffer(nullptr) m_socket(nullptr), m_port(0), m_timeout(0), m_bufferSize(0), m_buffer(nullptr) {
{
if (init) { if (init) {
initialize(); initialize();
} }