equal
deleted
inserted
replaced
93 // TODO send stream attributes here |
93 // TODO send stream attributes here |
94 gint ret(TMS_RESULT_SUCCESS); |
94 gint ret(TMS_RESULT_SUCCESS); |
95 |
95 |
96 if (iProxy) |
96 if (iProxy) |
97 { |
97 { |
98 ret = iProxy->BufferEmptied(TMS_CALL_IP, |
98 //TODO: must use strm_id instead of 1 |
99 TMS_STREAM_UPLINK, |
99 ret = iProxy->BufferEmptied(TMS_CALL_IP, TMS_STREAM_UPLINK, 1, |
100 1, //TODO: must use strm_id |
100 *buffer); |
101 *buffer); |
|
102 } |
101 } |
103 else |
102 else |
104 { |
103 { |
105 ret = TMS_RESULT_UNINITIALIZED_OBJECT; |
104 ret = TMS_RESULT_UNINITIALIZED_OBJECT; |
106 } |
105 } |
118 gpointer queuehandler) |
117 gpointer queuehandler) |
119 { |
118 { |
120 iProxy = aProxy; |
119 iProxy = aProxy; |
121 if (queuehandler) |
120 if (queuehandler) |
122 { |
121 { |
123 ((TMSQueueHandler*) queuehandler)->AddObserver(*this, TMS_SINK_CLIENT); |
122 static_cast<TMSQueueHandler*>(queuehandler)->AddObserver(*this, |
|
123 TMS_SINK_CLIENT); |
124 } |
124 } |
125 } |
125 } |
126 |
126 |
127 void TMSClientSinkBodyImpl::QueueEvent(TInt aEventType, TInt /*aError*/, |
127 void TMSClientSinkBodyImpl::QueueEvent(TInt aEventType, TInt /*aError*/, |
128 void* user_data) |
128 void* user_data) |
130 if (iObserver) |
130 if (iObserver) |
131 { |
131 { |
132 switch (aEventType) |
132 switch (aEventType) |
133 { |
133 { |
134 case TMS_EVENT_SINK_PROCESS_BUFFER: |
134 case TMS_EVENT_SINK_PROCESS_BUFFER: |
135 iObserver->ProcessBuffer(((TMSBuffer*) user_data)); |
135 iObserver->ProcessBuffer(static_cast<TMSBuffer*>(user_data)); |
136 break; |
136 break; |
137 default: |
137 default: |
138 break; |
138 break; |
139 } |
139 } |
140 } |
140 } |