--- a/mmserv/tms/inc/tmsqueuehandler.h Mon Jun 21 16:15:34 2010 +0300
+++ b/mmserv/tms/inc/tmsqueuehandler.h Thu Jul 15 19:13:36 2010 +0300
@@ -27,7 +27,7 @@
namespace TMS {
// FORWARD DECLARATIONS
-class TMSBuffer; //TMSDataBuffer
+class TMSBuffer;
class TMSGlobalContext;
/**
@@ -73,24 +73,28 @@
*/
TRequestStatus* Status();
+ /*
+ * Add and remove observer to buffer events
+ */
gint AddObserver(MQueueHandlerObserver& obsvr, gint aClientId);
gint RemoveObserver(MQueueHandlerObserver& obsvr);
private:
/**
- * constructor
+ * Constructors
*/
TMSQueueHandler(RMsgQueue<TmsMsgBuf>* aMsgQueue,
TMSGlobalContext* glblCtx);
void ConstructL();
- // from CActive
+ // From CActive
void DoCancel();
void RunL();
TInt RunError(TInt aError);
+ // For buffer processing upon handler events
void DoFillBuffer(gint aBufLen, gint aStatus, gboolean flag, guint32 key);
void DoEmptyBuffer(gint aBufLen, gint aStatus, gboolean flag, guint32 key);
gint FindStreamInList();
@@ -99,7 +103,6 @@
TMSStreamState ConvertToStreamState(gint request);
private:
- // data
RPointerArray<MQueueHandlerObserver> iObserversList; // (not owned)
MQueueHandlerObserver* iObserver; //not owned
@@ -109,7 +112,7 @@
RChunk iChunk;
TPtr8 iChunkDataPtr;
TMSBuffer* iBuffer;
- TMSGlobalContext *iTMSGlobalContext;
+ TMSGlobalContext* iTMSGlobalContext;
};
} //namespace TMS