hydrar/mistserver
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

BootMSOffset propagation in MistProcMKVExec

Browse source
This commit is contained in:
Thulinma 2021-05-04 15:27:15 +02:00
parent 5aa459f2c8
commit 3ba7723b10
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/process/process_exec.cpp
View file

@ -20,6 +20,7 @@ JSON::Value & pData = pStat["proc_status_update"]["status"];
tthread::mutex statsMutex; tthread::mutex statsMutex;
uint64_t statSinkMs = 0; uint64_t statSinkMs = 0;
uint64_t statSourceMs = 0; uint64_t statSourceMs = 0;
uint64_t bootMsOffset = 0;
namespace Mist{ namespace Mist{
@ -54,6 +55,7 @@ namespace Mist{
char *data = thisPacket.getData(); char *data = thisPacket.getData();
Bit::htobll(data + 12, pTime); Bit::htobll(data + 12, pTime);
if (pTime >= statSinkMs){statSinkMs = pTime;} if (pTime >= statSinkMs){statSinkMs = pTime;}
if (meta && meta.getBootMsOffset() != bootMsOffset){meta.setBootMsOffset(bootMsOffset);}
} }
} }
void setInFile(int stdin_val){ void setInFile(int stdin_val){
@ -125,6 +127,7 @@ namespace Mist{
maxSkipAhead = 0; maxSkipAhead = 0;
if (!sendFirst){ if (!sendFirst){
sendPacketTime = thisPacket.getTime(); sendPacketTime = thisPacket.getTime();
bootMsOffset = M.getBootMsOffset();
sendFirst = true; sendFirst = true;
/* /*
uint64_t maxJitter = 1; uint64_t maxJitter = 1;