47         EMsgComQueue

    47         EMsgComQueue

    48         };

    48         };

    49 

    49 

    50 public:

    50 public:

    51     static gint Create(TMSCallType callType, TMSStreamType stype,

    51     static gint Create(TMSCallType callType, TMSStreamType stype,

    54     virtual ~TMSStreamBodyImpl();

    53     virtual ~TMSStreamBodyImpl();

    55 

    54 

    56     // From TMSStreamBody

    55     // From TMSStreamBody

    57     virtual gint AddObserver(TMSStreamObserver& obsrvr, gpointer user_data);

    56     virtual gint AddObserver(TMSStreamObserver& obsrvr, gpointer user_data);

    58     virtual gint RemoveObserver(TMSStreamObserver& obsrvr);

    57     virtual gint RemoveObserver(TMSStreamObserver& obsrvr);

    81     gint PostConstruct(TMSCallType callType, TMSStreamType stype,

    80     gint PostConstruct(TMSCallType callType, TMSStreamType stype,

    82             TMSCallProxy* proxy, TMSStream& parent);

    81             TMSCallProxy* proxy, TMSStream& parent);

    83 

    82 

    84     gint CreateQueue(const gint aNumSlots);

    83     gint CreateQueue(const gint aNumSlots);

    85     void ReceiveMsgQHandlerEventsL();

    84     void ReceiveMsgQHandlerEventsL();

    87     gint ValidateStream();

    86     gint ValidateStream();

    88     gint ValidateSource(TMSSource* source);

    87     gint ValidateSource(TMSSource* source);

    89     gint ValidateSink(TMSSink* sink);

    88     gint ValidateSink(TMSSink* sink);

    90     gint ValidateFormat(TMSFormat* format);

    89     gint ValidateFormat(TMSFormat* format);

    91 

    90 

   100     TMSSource* iSource;

    99     TMSSource* iSource;

   101     TMSSink* iSink;

   100     TMSSink* iSink;

   102 

   101 

   103     // Message queue and the handler

   102     // Message queue and the handler

   104     RMsgQueue<TmsMsgBuf> iMsgQueue;

   103     RMsgQueue<TmsMsgBuf> iMsgQueue;

   106 

   105 

   107     // Need to make this a list

   106     // Need to make this a list

   108     TMSStreamObserver* iObserver;

   107     TMSStreamObserver* iObserver;

   109 

   108 

   110     gpointer iUserData;

   109     gpointer iUserData;