18 #include "hsactivitydbclient_p.h" |
18 #include "hsactivitydbclient_p.h" |
19 #include "hsactivitydbasyncrequest_p.h" |
19 #include "hsactivitydbasyncrequest_p.h" |
20 #include "hsactivityglobals.h" |
20 #include "hsactivityglobals.h" |
21 #include "hsserializer.h" |
21 #include "hsserializer.h" |
22 #include <qvariant.h> |
22 #include <qvariant.h> |
23 #include <xqconversions> |
23 #include <XQConversions> |
24 |
24 |
25 |
25 |
26 // ----------------------------------------------------------------------------- |
26 // ----------------------------------------------------------------------------- |
27 // |
27 // |
28 // ----------------------------------------------------------------------------- |
28 // ----------------------------------------------------------------------------- |
29 // |
29 // |
30 HsActivityDbClientPrivate::HsActivityDbClientPrivate(HsActivityDbAsyncRequestObserver &observer): |
30 HsActivityDbClientPrivate::HsActivityDbClientPrivate(HsActivityDbAsyncRequestObserver &observer): |
31 mObserver(observer) |
31 mObserver(observer) |
32 { |
32 { |
33 mAsyncDataHandler = HsActivityDbAsyncRequestPrivate::newWaitActivityL( |
33 |
34 observer, *this); |
|
35 } |
34 } |
36 |
35 |
37 // ----------------------------------------------------------------------------- |
36 // ----------------------------------------------------------------------------- |
38 // |
37 // |
39 // ----------------------------------------------------------------------------- |
38 // ----------------------------------------------------------------------------- |
40 // |
39 // |
41 HsActivityDbClientPrivate::~HsActivityDbClientPrivate() |
40 HsActivityDbClientPrivate::~HsActivityDbClientPrivate() |
42 { |
41 { |
43 mAsyncTasks.ResetAndDestroy(); |
42 mAsyncTasks.ResetAndDestroy(); |
44 delete mAsyncDataHandler; |
|
45 Close(); |
43 Close(); |
46 } |
44 } |
47 |
45 |
48 // ----------------------------------------------------------------------------- |
46 // ----------------------------------------------------------------------------- |
49 // |
47 // |
154 |
152 |
155 // ----------------------------------------------------------------------------- |
153 // ----------------------------------------------------------------------------- |
156 // |
154 // |
157 // ----------------------------------------------------------------------------- |
155 // ----------------------------------------------------------------------------- |
158 // |
156 // |
|
157 int HsActivityDbClientPrivate::notifyDataChange() |
|
158 { |
|
159 TRAPD(errNo,HsActivityDbAsyncRequestPrivate::notifyDataChangeLD(mObserver, *this);) |
|
160 return errNo; |
|
161 } |
|
162 |
|
163 // ----------------------------------------------------------------------------- |
|
164 // |
|
165 // ----------------------------------------------------------------------------- |
|
166 // |
159 int HsActivityDbClientPrivate::launchActivity(const QVariantHash &activity) |
167 int HsActivityDbClientPrivate::launchActivity(const QVariantHash &activity) |
160 { |
168 { |
161 TRAPD(errNo, execSimpleRequestL(LaunchActivity, activity);) |
169 TRAPD(errNo, execSimpleRequestL(LaunchActivity, activity);) |
162 return errNo; |
170 return errNo; |
163 } |
171 } |
167 // ----------------------------------------------------------------------------- |
175 // ----------------------------------------------------------------------------- |
168 // |
176 // |
169 int HsActivityDbClientPrivate::cancelWaitActivity() |
177 int HsActivityDbClientPrivate::cancelWaitActivity() |
170 { |
178 { |
171 return SendReceive(CancelWait, TIpcArgs()); |
179 return SendReceive(CancelWait, TIpcArgs()); |
|
180 } |
|
181 |
|
182 // ----------------------------------------------------------------------------- |
|
183 // |
|
184 // ----------------------------------------------------------------------------- |
|
185 // |
|
186 int HsActivityDbClientPrivate::cancelNotifyDataChange() |
|
187 { |
|
188 return SendReceive(CancelNotify, TIpcArgs()); |
172 } |
189 } |
173 |
190 |
174 // ----------------------------------------------------------------------------- |
191 // ----------------------------------------------------------------------------- |
175 // |
192 // |
176 // ----------------------------------------------------------------------------- |
193 // ----------------------------------------------------------------------------- |
293 // |
310 // |
294 // ----------------------------------------------------------------------------- |
311 // ----------------------------------------------------------------------------- |
295 // |
312 // |
296 void HsActivityDbClientPrivate::waitActivityL(const QVariantHash &activity) |
313 void HsActivityDbClientPrivate::waitActivityL(const QVariantHash &activity) |
297 { |
314 { |
298 if (mAsyncDataHandler->IsActive()) { |
315 HsActivityDbAsyncRequestPrivate::waitActivityLD(mObserver,*this, activity); |
299 User::Leave(KErrServerBusy); |
|
300 } else { |
|
301 mAsyncDataHandler->waitActivity(activity); |
|
302 } |
|
303 } |
316 } |
304 |
317 |
305 // ----------------------------------------------------------------------------- |
318 // ----------------------------------------------------------------------------- |
306 // |
319 // |
307 // ----------------------------------------------------------------------------- |
320 // ----------------------------------------------------------------------------- |