|
1 /* |
|
2 * Copyright (c) 2006 Nokia Corporation and/or its subsidiary(-ies). |
|
3 * All rights reserved. |
|
4 * This component and the accompanying materials are made available |
|
5 * under the terms of the License "Eclipse Public License v1.0" |
|
6 * which accompanies this distribution, and is available |
|
7 * at the URL "http://www.eclipse.org/legal/epl-v10.html". |
|
8 * |
|
9 * Initial Contributors: |
|
10 * Nokia Corporation - initial contribution. |
|
11 * |
|
12 * Contributors: |
|
13 * |
|
14 * Description: Timer for the notifier* |
|
15 */ |
|
16 |
|
17 |
|
18 |
|
19 |
|
20 #include "CCseSchedulerLandLord.h" |
|
21 #include "CCseSchedulerPluginStarter.h" |
|
22 #include <ipvideo/CCseScheduledProgram.h> |
|
23 #include "CCseSchedulerThreadPacket.h" |
|
24 #include <ipvideo/MCseScheduleObserver.h> // Observer for informing engine |
|
25 #include <e32std.h> |
|
26 #include "CseDebug.h" // Debug macros |
|
27 #include "CCseSemaphoreController.h" |
|
28 |
|
29 _LIT( KCseUniThreadName, "CseThread" ); |
|
30 _LIT( KCseLine, "-" ); |
|
31 |
|
32 // ============================ MEMBER FUNCTIONS =============================== |
|
33 |
|
34 // --------------------------------------------------------------------------- |
|
35 // CCseSchedulerTimer::CCseSchedulerTimer() |
|
36 // |
|
37 // --------------------------------------------------------------------------- |
|
38 CCseSchedulerLandLord::CCseSchedulerLandLord( MCseScheduleObserver* aObserver ) : |
|
39 CActive( CActive::EPriorityStandard ), |
|
40 iThreadRunning( EFalse ), |
|
41 iTakedownRequested( EFalse ) |
|
42 |
|
43 { |
|
44 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::CCseSchedulerLandLord"); |
|
45 |
|
46 // C++ default constructor |
|
47 iObserver = aObserver; |
|
48 |
|
49 CSELOGSTRING_HIGH_LEVEL("<<<CCseSchedulerLandLord::CCseSchedulerLandLord"); |
|
50 } |
|
51 |
|
52 // --------------------------------------------------------------------------- |
|
53 // CCseSchedulerLandLord::~CCseSchedulerLandLord() |
|
54 // |
|
55 // --------------------------------------------------------------------------- |
|
56 CCseSchedulerLandLord::~CCseSchedulerLandLord() |
|
57 { |
|
58 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::~CCseSchedulerLandLord"); |
|
59 |
|
60 Cancel(); |
|
61 |
|
62 delete iShutdownCompleteMonitor; |
|
63 iShutdownCompleteMonitor = NULL; |
|
64 delete iActiveSchedulerWait; |
|
65 iActiveSchedulerWait = NULL; |
|
66 iObserver = NULL; |
|
67 delete iThreadPacket; |
|
68 iThreadPacket = NULL; |
|
69 delete iThreadName; |
|
70 |
|
71 CSELOGSTRING_HIGH_LEVEL("<<<CCseSchedulerLandLord::~CCseSchedulerLandLord"); |
|
72 } |
|
73 |
|
74 // --------------------------------------------------------------------------- |
|
75 // CCseSchedulerLandLord::NewL() |
|
76 // |
|
77 // --------------------------------------------------------------------------- |
|
78 CCseSchedulerLandLord* CCseSchedulerLandLord::NewL( |
|
79 MCseScheduleObserver* aObserver ) |
|
80 { |
|
81 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::NewL"); |
|
82 |
|
83 // Symbian C++ constructor |
|
84 CCseSchedulerLandLord* self = new ( ELeave ) CCseSchedulerLandLord( aObserver ); |
|
85 CleanupStack::PushL( self ); |
|
86 self->ConstructL(); |
|
87 CleanupStack::Pop( ); |
|
88 |
|
89 CSELOGSTRING_HIGH_LEVEL("<<<CCseSchedulerLandLord::NewL"); |
|
90 return self; |
|
91 } |
|
92 |
|
93 // --------------------------------------------------------------------------- |
|
94 // CCseSchedulerLandLord::ConstructL() |
|
95 // |
|
96 // --------------------------------------------------------------------------- |
|
97 void CCseSchedulerLandLord::ConstructL() |
|
98 { |
|
99 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::ConstructL"); |
|
100 |
|
101 iActiveSchedulerWait = new (ELeave) CActiveSchedulerWait; |
|
102 CActiveScheduler::Add( this ); |
|
103 |
|
104 CSELOGSTRING_HIGH_LEVEL("<<<CCseSchedulerLandLord::ConstructL"); |
|
105 } |
|
106 |
|
107 // --------------------------------------------------------------------------- |
|
108 // CCseSchedulerLandLord::DoCancel() |
|
109 // |
|
110 // --------------------------------------------------------------------------- |
|
111 void CCseSchedulerLandLord::DoCancel() |
|
112 { |
|
113 CSELOGSTRING_HIGH_LEVEL( ">>>CCseSchedulerLandLord::DoCancel" ); |
|
114 |
|
115 if ( iThreadRunning ) |
|
116 { |
|
117 CSELOGSTRING_HIGH_LEVEL( |
|
118 "CCseSchedulerLandLord::DoCancel Canceling thread" ); |
|
119 |
|
120 // Signal thread to die away! |
|
121 iPluginShutdownSemaphore.Signal(); |
|
122 |
|
123 iThreadRunning = EFalse; |
|
124 |
|
125 // Complete schedule with KErrAbort |
|
126 TRAP_IGNORE( iObserver->ScheduleCompletedL( |
|
127 iThreadPacket->Schedule( )->DbIdentifier(), KErrAbort ) ); |
|
128 } |
|
129 |
|
130 CSELOGSTRING_HIGH_LEVEL( "<<<CCseSchedulerLandLord::DoCancel" ); |
|
131 } |
|
132 |
|
133 // --------------------------------------------------------------------------- |
|
134 // CCseSchedulerTimer::RunL() |
|
135 // |
|
136 // --------------------------------------------------------------------------- |
|
137 void CCseSchedulerLandLord::RunL() |
|
138 { |
|
139 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::RunL"); |
|
140 |
|
141 iThreadRunning = EFalse; |
|
142 |
|
143 // In case we have not cancelled operation, complete schedule with result code. |
|
144 // If we have cancelled it, we're not interested about the result as the |
|
145 // schedule has already been removed from the DB |
|
146 if( !iTakedownRequested ) |
|
147 { |
|
148 iObserver->ScheduleCompletedL( iThreadPacket->Schedule( )->DbIdentifier(), |
|
149 iThreadPacket->ResultCode( ) ); |
|
150 } |
|
151 CSELOGSTRING_HIGH_LEVEL("<<<CCseSchedulerLandLord::RunL"); |
|
152 } |
|
153 |
|
154 // --------------------------------------------------------------------------- |
|
155 // CCseSchedulerTimer::SetScheduleL() |
|
156 // |
|
157 // --------------------------------------------------------------------------- |
|
158 void CCseSchedulerLandLord::SetScheduleL( CCseScheduledProgram& aData ) |
|
159 { |
|
160 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::SetSchedule"); |
|
161 |
|
162 delete iThreadPacket; |
|
163 iThreadPacket = NULL; |
|
164 iThreadPacket = CCseSchedulerThreadPacket::NewL(); |
|
165 iThreadPacket->SetScheduleL( aData ); |
|
166 |
|
167 CSELOGSTRING_HIGH_LEVEL("<<<CCseSchedulerLandLord::SetSchedule"); |
|
168 } |
|
169 |
|
170 // --------------------------------------------------------------------------- |
|
171 // CCseSchedulerTimer::ThreadPacket() |
|
172 // |
|
173 // --------------------------------------------------------------------------- |
|
174 CCseSchedulerThreadPacket* CCseSchedulerLandLord::ThreadPacket( ) |
|
175 { |
|
176 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::Schedule"); |
|
177 CSELOGSTRING_HIGH_LEVEL("<<<CCseSchedulerLandLord::Schedule"); |
|
178 |
|
179 return iThreadPacket; |
|
180 } |
|
181 |
|
182 // ----------------------------------------------------------------------------- |
|
183 // CCseSchedulerLandLord::RunError |
|
184 // From CActive, called when RunL leaves. |
|
185 // ----------------------------------------------------------------------------- |
|
186 // |
|
187 TInt CCseSchedulerLandLord::RunError( TInt /*aError*/ ) |
|
188 { |
|
189 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::RunError"); |
|
190 // ATM there isn't leaving code in RunL so we just cancel timer if it is active. |
|
191 Cancel(); |
|
192 // Return KErrNone to avoid crash. |
|
193 return KErrNone; |
|
194 } |
|
195 |
|
196 // ----------------------------------------------------------------------------- |
|
197 // CCseSchedulerLandLord::GenerateThreadName |
|
198 // Generates "unique" name for thread |
|
199 // ----------------------------------------------------------------------------- |
|
200 // |
|
201 void CCseSchedulerLandLord::GenerateThreadNameL( ) |
|
202 { |
|
203 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::GenerateThreadName"); |
|
204 |
|
205 delete iThreadName; |
|
206 iThreadName = NULL; |
|
207 iThreadName = KCseUniThreadName().AllocL(); |
|
208 iThreadName = iThreadName->ReAllocL( |
|
209 iThreadName->Size() + // Length of original name. |
|
210 sizeof( TUint32 ) * 2 + // Space for Plugin Uid and DbIdentifier |
|
211 2 ); // Two "-" as a separator between |
|
212 // Uid and identifier |
|
213 |
|
214 // Separator |
|
215 iThreadName->Des( ).Append( KCseLine ); |
|
216 |
|
217 // Plugin uid |
|
218 iThreadName->Des( ).AppendNum( iThreadPacket->Schedule()->PluginUid() ); |
|
219 |
|
220 // Separator |
|
221 iThreadName->Des( ).Append( KCseLine ); |
|
222 |
|
223 // Finally schedule identifier to make thread name unique |
|
224 iThreadName->Des( ).AppendNum( iThreadPacket->Schedule()->DbIdentifier() ); |
|
225 |
|
226 CSELOGSTRING_HIGH_LEVEL("<<<CCseSchedulerLandLord::GenerateThreadName"); |
|
227 } |
|
228 |
|
229 // ----------------------------------------------------------------------------- |
|
230 // CCseSchedulerLandLord::GenerateSemahoresL |
|
231 // Generates semaphores for shutdown signalling |
|
232 // ----------------------------------------------------------------------------- |
|
233 // |
|
234 void CCseSchedulerLandLord::GenerateSemaphoresL( ) |
|
235 { |
|
236 iPluginShutdownSemaphore.CreateLocal( 0 ); |
|
237 iThreadPacket->SetShutdownSemaphore( iPluginShutdownSemaphore ); |
|
238 |
|
239 iPluginShutdownCompleteSemaphore.CreateLocal( 0 ); |
|
240 iThreadPacket->SetShutdownCompleteSemaphore( iPluginShutdownCompleteSemaphore ); |
|
241 } |
|
242 |
|
243 // ----------------------------------------------------------------------------- |
|
244 // CCseSchedulerLandLord::RunPluginL |
|
245 // From CActive, called when RunL leaves. |
|
246 // ----------------------------------------------------------------------------- |
|
247 // |
|
248 void CCseSchedulerLandLord::RunPluginL( ) |
|
249 { |
|
250 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::RunPluginL"); |
|
251 TInt error( KErrNone ); |
|
252 |
|
253 // Create semaphores for shutdown signalling |
|
254 GenerateSemaphoresL(); |
|
255 |
|
256 // First we create unique thread name |
|
257 GenerateThreadNameL( ); |
|
258 |
|
259 // Create thread where to run schedule |
|
260 error = iThread.Create( *iThreadName, |
|
261 CCseSchedulerPluginStarter::StartThread, |
|
262 KDefaultStackSize, |
|
263 NULL, // uses caller thread's heap |
|
264 iThreadPacket, // Schedule |
|
265 EOwnerThread ); |
|
266 |
|
267 if( error == KErrNone ) |
|
268 { |
|
269 // Creation succesfull, start running it and logon on it. |
|
270 CSELOGSTRING_HIGH_LEVEL( |
|
271 "CCseSchedulerLandLord::RunPluginL - Thread creation succesfull"); |
|
272 iThread.Resume(); |
|
273 iThread.Logon( iStatus ); |
|
274 SetActive(); |
|
275 iThreadRunning = ETrue; |
|
276 } |
|
277 else |
|
278 { |
|
279 CSELOGSTRING2_HIGH_LEVEL( |
|
280 "CCseSchedulerLandLord::RunPluginL - Thread creation FAILED: %d", |
|
281 error); |
|
282 } |
|
283 |
|
284 CSELOGSTRING_HIGH_LEVEL("<<<CCseSchedulerLandLord::RunPluginL"); |
|
285 } |
|
286 |
|
287 // ----------------------------------------------------------------------------- |
|
288 // CCseSchedulerLandLord::ActiveWait |
|
289 // |
|
290 // ----------------------------------------------------------------------------- |
|
291 // |
|
292 void CCseSchedulerLandLord::ActiveWait( TBool aStart ) |
|
293 { |
|
294 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::ActiveWait()"); |
|
295 if (aStart) |
|
296 { |
|
297 if(!iActiveSchedulerWait->IsStarted()) |
|
298 { |
|
299 CSELOGSTRING_HIGH_LEVEL("CCseSchedulerLandLord::ActiveWait - Wait start"); |
|
300 iActiveSchedulerWait->Start(); |
|
301 } |
|
302 } |
|
303 else |
|
304 { |
|
305 if(iActiveSchedulerWait->IsStarted()) |
|
306 { |
|
307 CSELOGSTRING_HIGH_LEVEL("CCseSchedulerLandLord::ActiveWait - Wait stop"); |
|
308 iActiveSchedulerWait->AsyncStop(); |
|
309 } |
|
310 } |
|
311 CSELOGSTRING_HIGH_LEVEL("<<<CCseSchedulerLandLord::ActiveWait()"); |
|
312 } |
|
313 |
|
314 // ----------------------------------------------------------------------------- |
|
315 // CCseSchedulerLandLord::ActiveWait |
|
316 // |
|
317 // ----------------------------------------------------------------------------- |
|
318 // |
|
319 void CCseSchedulerLandLord::SemaphoreSignalled() |
|
320 { |
|
321 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::ShutdownPlugin()"); |
|
322 |
|
323 ActiveWait( EFalse ); |
|
324 |
|
325 CSELOGSTRING_HIGH_LEVEL("<<<CCseSchedulerLandLord::ShutdownPlugin()"); |
|
326 } |
|
327 |
|
328 // --------------------------------------------------------------------------- |
|
329 // CCseSchedulerLandLord::ClearL() |
|
330 // |
|
331 // --------------------------------------------------------------------------- |
|
332 void CCseSchedulerLandLord::ClearL() |
|
333 { |
|
334 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::ClearL"); |
|
335 |
|
336 if( iThreadRunning ) |
|
337 { |
|
338 // Flag the takedown. We're cancelling the operation, so we have |
|
339 // no interest about result code as the schedule has already |
|
340 // been removed from the DB. |
|
341 iTakedownRequested = ETrue; |
|
342 |
|
343 // Signal thread to die away! |
|
344 iPluginShutdownSemaphore.Signal(); |
|
345 |
|
346 if( !iShutdownCompleteMonitor ) |
|
347 { |
|
348 CSELOGSTRING_HIGH_LEVEL("CCseSchedulerLandLord::ClearL - New semaphore monitor" ); |
|
349 iShutdownCompleteMonitor = CCseSemaphoreController::NewL( iPluginShutdownCompleteSemaphore, *this ); |
|
350 } |
|
351 |
|
352 CSELOGSTRING_HIGH_LEVEL("CCseSchedulerLandLord::ClearL - StartMonitor" ); |
|
353 iShutdownCompleteMonitor->Start(); |
|
354 |
|
355 ActiveWait( ETrue ); |
|
356 |
|
357 iThreadRunning = EFalse; |
|
358 } |
|
359 |
|
360 CSELOGSTRING_HIGH_LEVEL("<<<CCseSchedulerLandLord::ClearL"); |
|
361 } |
|
362 |
|
363 // ----------------------------------------------------------------------------- |
|
364 // CCseSchedulerLandLord::ActiveWait |
|
365 // |
|
366 // ----------------------------------------------------------------------------- |
|
367 // |
|
368 TBool CCseSchedulerLandLord::IsWorking() |
|
369 { |
|
370 CSELOGSTRING_HIGH_LEVEL(">>>CCseSchedulerLandLord::IsWorking()"); |
|
371 |
|
372 CSELOGSTRING2_HIGH_LEVEL("<<<CCseSchedulerLandLord::IsWorking(): %d", iThreadRunning); |
|
373 |
|
374 return iThreadRunning; |
|
375 } |
|
376 |
|
377 // End of file |