diff --git a/aqhome/ipc2/msgreader.c b/aqhome/ipc2/msgreader.c index 9fe903c..b8f8f84 100644 --- a/aqhome/ipc2/msgreader.c +++ b/aqhome/ipc2/msgreader.c @@ -248,11 +248,19 @@ void AQH_MsgReader_StartSkipping(AQH_OBJECT *o) xo=GWEN_INHERIT_GETDATA(AQH_OBJECT, AQH_MSG_READER, o); if (xo) { + int rv; + DBG_ERROR(AQH_LOGDOMAIN, "Enter skip mode"); GWEN_RingBuffer_Reset(xo->ringBuffer); _resetBuffers(xo); - xo->flags|=AQH_MSGREADER_FLAGS_SKIP; - xo->timestamp=_getTimeInMilliSeconds(); + + rv=AQH_FdObject_FlushInput(xo->fdObject); + if (rv<0) { + AQH_Object_EmitSignal(o, AQH_MSG_READER_SIGNAL_ERROR, rv, NULL); + } + + //xo->flags|=AQH_MSGREADER_FLAGS_SKIP; + //xo->timestamp=_getTimeInMilliSeconds(); } }