DB insert by timestamp

Author: sy-c

doc/releaseNotes.md

@@ -120,3 +120,6 @@ This file describes the main feature changes for each InfoLogger released versio
 
 ## v2.4.3 - 01/02/2022
 - infoBrowser configuration: added parameter "queryLimit" to change the maximum number of messages returned by a query. Default is 10000.
+
+## v2.4.4 - 09/05/2022
+- changed algorithm of DB threads message distribution, now based on timestamp to help keeping multi-line split messages in same order.

src/infoLoggerServer.cxx

@@ -17,6 +17,7 @@
 #include "infoLoggerMessageDecode.h"
 #include "InfoLoggerMessageList.h"
 #include "InfoLoggerDispatch.h"
+#include "InfoLoggerMessageHelper.h"
 
 #include "ConfigInfoLoggerServer.h"
 
@@ -214,6 +215,13 @@ Daemon::LoopStatus InfoLoggerServer::doLoop()
       unsigned int nThreads = dispatchEnginesDB.size();
       unsigned int nTry = 1;
       int pushOk = 0;
+
+      // distribute message based on timestamp
+      // to try keeping messages inserted in same order when parallel insert
+      InfoLoggerMessageHelper h;
+      unsigned char * tptr= (unsigned char *) &msgList->msg->values[h.ix_timestamp].value.vDouble;
+      dbRoundRobinIx = (tptr[0] + tptr[1] + tptr[2] + tptr[3] + tptr[4] + tptr[5] + tptr[6] + tptr[7]) % nThreads;
+
       for (; nTry <= nThreads * 3; nTry++) {
         int err = dispatchEnginesDB[dbRoundRobinIx]->pushMessage(msgList);
         dbRoundRobinIx++;