equal
deleted
inserted
replaced
332 gint TMSStreamBodyImpl::GetStreamId() |
332 gint TMSStreamBodyImpl::GetStreamId() |
333 { |
333 { |
334 return iContext.StreamId; |
334 return iContext.StreamId; |
335 } |
335 } |
336 |
336 |
337 gint TMSStreamBodyImpl::Init() |
337 gint TMSStreamBodyImpl::Init(gint retrytime) |
338 { |
338 { |
339 gint ret(TMS_RESULT_SUCCESS); |
339 gint ret(TMS_RESULT_SUCCESS); |
340 |
340 |
341 ret = ValidateStream(); |
341 ret = ValidateStream(); |
342 |
342 |
353 } |
353 } |
354 |
354 |
355 if (iContext.CallProxy) |
355 if (iContext.CallProxy) |
356 { |
356 { |
357 ret = (iContext.CallProxy)->InitStream(iContext.CallType, |
357 ret = (iContext.CallProxy)->InitStream(iContext.CallType, |
358 iContext.StreamType, iContext.StreamId, fmttype, &iMsgQueue); |
358 iContext.StreamType, iContext.StreamId, fmttype, &iMsgQueue, |
|
359 retrytime); |
359 } |
360 } |
360 else |
361 else |
361 { |
362 { |
362 ret = TMS_RESULT_UNINITIALIZED_OBJECT; |
363 ret = TMS_RESULT_UNINITIALIZED_OBJECT; |
363 } |
364 } |
488 ret = TMS_RESULT_UNINITIALIZED_OBJECT; |
489 ret = TMS_RESULT_UNINITIALIZED_OBJECT; |
489 } |
490 } |
490 return ret; |
491 return ret; |
491 } |
492 } |
492 |
493 |
493 gint TMSStreamBodyImpl::Start() |
494 gint TMSStreamBodyImpl::Start(gint retrytime) |
494 { |
495 { |
495 gint ret(TMS_RESULT_SUCCESS); |
496 gint ret(TMS_RESULT_SUCCESS); |
496 if (iContext.CallProxy) |
497 if (iContext.CallProxy) |
497 { |
498 { |
498 ret = (iContext.CallProxy)->StartStream(iContext.CallType, |
499 ret = (iContext.CallProxy)->StartStream(iContext.CallType, |
499 iContext.StreamType, iContext.StreamId); |
500 iContext.StreamType, iContext.StreamId, retrytime); |
500 } |
501 } |
501 else |
502 else |
502 { |
503 { |
503 ret = TMS_RESULT_UNINITIALIZED_OBJECT; |
504 ret = TMS_RESULT_UNINITIALIZED_OBJECT; |
504 } |
505 } |
732 { |
733 { |
733 event.curr_state = aEventType; |
734 event.curr_state = aEventType; |
734 event.prev_state = iPrevState; |
735 event.prev_state = iPrevState; |
735 if (iObserver) |
736 if (iObserver) |
736 { |
737 { |
737 event.type = TMS_EVENT_STREAM_STATE_CHANGED; |
738 if (aError != TMS_RESULT_SUCCESS) |
|
739 { |
|
740 //event.type = TMS_EVENT_STREAM_STATE_CHANGE_ERROR; |
|
741 event.type = TMS_EVENT_STREAM_STATE_CHANGED; |
|
742 } |
|
743 else |
|
744 { |
|
745 event.type = TMS_EVENT_STREAM_STATE_CHANGED; |
|
746 } |
738 iObserver->TMSStreamEvent(*iParent, event); |
747 iObserver->TMSStreamEvent(*iParent, event); |
739 } |
748 } |
740 break; |
749 break; |
741 } |
750 } |
742 default: |
751 default: |