@@ -268,17 +268,17 @@ int InfoLoggerDispatchSQLImpl::customMessageProcess(std::shared_ptr<InfoLoggerMe
268268 // log bad message content (truncated)
269269 const int maxLen = 200 ;
270270 int msgLen = (int )strlen (message);
271- theLog->error (" Dropping message (%d bytes): %.*s%s" , msgLen, maxLen, message, (msgLen> maxLen) ? " ..." : " " );
271+ theLog->error (" Dropping message (%d bytes): %.*s%s" , msgLen, maxLen, message, (msgLen > maxLen) ? " ..." : " " );
272272 msgDroppedCount++;
273273 return 0 ; // remove message from queue
274274 };
275-
275+
276276 // procedure for delayed messages and keep count of them
277277 auto returnDelayedMessage = [&]() {
278278 msgDelayedCount++;
279279 return -1 ; // keep message in queue
280280 };
281-
281+
282282 if (!dbIsConnected) {
283283 return returnDelayedMessage ();
284284 }
@@ -320,7 +320,7 @@ int InfoLoggerDispatchSQLImpl::customMessageProcess(std::shared_ptr<InfoLoggerMe
320320 if (mysql_query (db, " START TRANSACTION" )) {
321321 theLog->error (" DB start transaction failed: %s" , mysql_error (db));
322322 commitEnabled = 0 ;
323- return returnDelayedMessage ();
323+ return returnDelayedMessage ();
324324 } else {
325325 if (commitDebug) {
326326 theLog->info (" DB transaction started" );
@@ -344,18 +344,18 @@ int InfoLoggerDispatchSQLImpl::customMessageProcess(std::shared_ptr<InfoLoggerMe
344344 // update bind variables
345345 if (mysql_stmt_bind_param (stmt, bind)) {
346346 theLog->error (" mysql_stmt_bind() failed: %s" , mysql_error (db));
347- theLog->error (" message: %s" , msg);
347+ theLog->error (" message: %s" , msg);
348348 // if can not bind, message malformed, drop it
349349 return returnDroppedMessage (msg);
350350 }
351351
352352 // Do the insertion
353353 if (mysql_stmt_execute (stmt)) {
354354 theLog->error (" mysql_stmt_exec() failed: (%d) %s" , mysql_errno (db), mysql_error (db));
355- // column too long
356- if (mysql_errno (db) == ER_DATA_TOO_LONG) {
357- return returnDroppedMessage (msg);
358- }
355+ // column too long
356+ if (mysql_errno (db) == ER_DATA_TOO_LONG) {
357+ return returnDroppedMessage (msg);
358+ }
359359 // retry with new connection - usually it means server was down
360360 disconnectDB ();
361361 return returnDelayedMessage ();
0 commit comments