22 using namespace QTMS; |
22 using namespace QTMS; |
23 using namespace TMS; |
23 using namespace TMS; |
24 |
24 |
25 QTMSClientSource::QTMSClientSource() : |
25 QTMSClientSource::QTMSClientSource() : |
26 iSource(NULL) |
26 iSource(NULL) |
27 { |
27 { |
28 } |
28 } |
29 |
29 |
30 QTMSClientSource::~QTMSClientSource() |
30 QTMSClientSource::~QTMSClientSource() |
31 { |
31 { |
32 delete iSource; |
32 delete iSource; |
33 } |
33 } |
34 |
34 |
35 gint QTMSClientSource::SetEnqueueMode(const gboolean enable) |
35 gint QTMSClientSource::SetEnqueueMode(const gboolean enable) |
36 { |
36 { |
37 gint status(QTMS_RESULT_UNINITIALIZED_OBJECT); |
37 gint status(QTMS_RESULT_UNINITIALIZED_OBJECT); |
38 if (iSource) |
38 if (iSource) { |
39 { |
39 status = static_cast<TMSClientSource*> (iSource)->SetEnqueueMode(enable); |
40 status = static_cast<TMSClientSource*> (iSource)->SetEnqueueMode( |
40 } |
41 enable); |
|
42 } |
|
43 return status; |
41 return status; |
44 } |
42 } |
45 |
43 |
46 gint QTMSClientSource::GetEnqueueMode(gboolean& enable) |
44 gint QTMSClientSource::GetEnqueueMode(gboolean& enable) |
47 { |
45 { |
48 gint status(QTMS_RESULT_UNINITIALIZED_OBJECT); |
46 gint status(QTMS_RESULT_UNINITIALIZED_OBJECT); |
49 if (iSource) |
47 if (iSource) { |
50 { |
48 status = static_cast<TMSClientSource*> (iSource)->GetEnqueueMode(enable); |
51 status = static_cast<TMSClientSource*> (iSource)->GetEnqueueMode( |
49 } |
52 enable); |
|
53 } |
|
54 return status; |
50 return status; |
55 } |
51 } |
56 |
52 |
57 gint QTMSClientSource::Flush() |
53 gint QTMSClientSource::Flush() |
58 { |
54 { |
59 gint status(QTMS_RESULT_UNINITIALIZED_OBJECT); |
55 gint status(QTMS_RESULT_UNINITIALIZED_OBJECT); |
60 if (iSource) |
56 if (iSource) { |
61 { |
|
62 status = static_cast<TMSClientSource*> (iSource)->Flush(); |
57 status = static_cast<TMSClientSource*> (iSource)->Flush(); |
63 } |
58 } |
64 return status; |
59 return status; |
65 } |
60 } |
66 |
61 |
67 gint QTMSClientSource::GetType(QTMSSourceType& sourcetype) |
62 gint QTMSClientSource::GetType(QTMSSourceType& sourcetype) |
68 { |
63 { |
69 gint status(QTMS_RESULT_UNINITIALIZED_OBJECT); |
64 gint status(QTMS_RESULT_UNINITIALIZED_OBJECT); |
70 if (iSource) |
65 if (iSource) { |
71 { |
|
72 status = static_cast<TMSClientSource*> (iSource)->GetType(sourcetype); |
66 status = static_cast<TMSClientSource*> (iSource)->GetType(sourcetype); |
73 } |
67 } |
74 return status; |
68 return status; |
75 } |
69 } |
76 |
70 |
77 gint QTMSClientSource::BufferFilled(QTMSBuffer& buffer) |
71 gint QTMSClientSource::BufferFilled(QTMSBuffer& buffer) |
78 { |
72 { |
79 gint status(QTMS_RESULT_UNINITIALIZED_OBJECT); |
73 gint status(QTMS_RESULT_UNINITIALIZED_OBJECT); |
80 if (iSource) |
74 if (iSource) { |
81 { |
75 TMSBuffer& buf(reinterpret_cast<TMSBuffer&> (buffer)); |
82 TMSBuffer& buf(reinterpret_cast<TMSBuffer&>(buffer)); |
|
83 status = static_cast<TMSClientSource*> (iSource)->BufferFilled(buf); |
76 status = static_cast<TMSClientSource*> (iSource)->BufferFilled(buf); |
84 } |
77 } |
85 return status; |
78 return status; |
86 } |
79 } |
87 |
80 |
88 // Push mode |
81 // Push mode |
89 gint QTMSClientSource::ProcessBuffer(QTMSBuffer* buffer) |
82 gint QTMSClientSource::ProcessBuffer(QTMSBuffer* buffer) |
90 { |
83 { |
91 gint status(QTMS_RESULT_UNINITIALIZED_OBJECT); |
84 gint status(QTMS_RESULT_UNINITIALIZED_OBJECT); |
92 if (iSource) |
85 if (iSource) { |
93 { |
86 TMSBuffer* buf(reinterpret_cast<TMSBuffer*> (buffer)); |
94 TMSBuffer* buf(reinterpret_cast<TMSBuffer*>(buffer)); |
|
95 status = static_cast<TMSClientSource*> (iSource)->ProcessBuffer(buf); |
87 status = static_cast<TMSClientSource*> (iSource)->ProcessBuffer(buf); |
96 } |
88 } |
97 return status; |
89 return status; |
98 } |
90 } |
99 |
91 |
100 // End of file |
92 // End of file |