diff --git a/src/input/input_dtsc.cpp b/src/input/input_dtsc.cpp index 8a9fa65d..180f0e36 100644 --- a/src/input/input_dtsc.cpp +++ b/src/input/input_dtsc.cpp @@ -100,6 +100,7 @@ namespace Mist { std::string toRec = srcConn.Received().copy(8); unsigned long rSize = Bit::btohl(toRec.c_str() + 4); if (!srcConn.Received().available(8 + rSize)) { + nProxy.userClient.keepAlive(); Util::sleep(100); continue; //abort - not enough data yet } @@ -121,6 +122,7 @@ namespace Mist { } }else{ Util::sleep(100); + nProxy.userClient.keepAlive(); } } } @@ -218,6 +220,7 @@ namespace Mist { if (!needsLock()){ thisPacket.reInit(srcConn); if (thisPacket.getVersion() == DTSC::DTCM){ + nProxy.userClient.keepAlive(); std::string cmd; thisPacket.getString("cmd", cmd); if (cmd == "reset"){ diff --git a/src/output/output.h b/src/output/output.h index b19df26d..eb0f5222 100644 --- a/src/output/output.h +++ b/src/output/output.h @@ -42,7 +42,7 @@ namespace Mist { static JSON::Value capa; //non-virtual generic functions int run(); - void stats(bool force = false); + virtual void stats(bool force = false); void seek(unsigned long long pos); bool seek(unsigned int tid, unsigned long long pos, bool getNextKey = false); void stop();