WISE Thread Interface
(→S60 Platform) |
(→S60 Platform) |
||
| Line 8: | Line 8: | ||
== S60 Platform == | == S60 Platform == | ||
| + | <code> | ||
| + | TInt ThreadEntry(TAny* aPtr); | ||
| + | |||
| + | void CWISE_TESTAppView::RunEngineL(TInt aSyncType) | ||
| + | { | ||
| + | if ( iThread.ExitType()!=EExitPending ) iThread.Close(); | ||
| + | |||
| + | iLogger->SetState(aSyncType); | ||
| + | User::LeaveIfError(iThread.Create(_L("WISEThread"),ThreadEntry,0x5000, | ||
| + | 0x1000,0x1000000,iLogger)); | ||
| + | |||
| + | iThread.Resume(); | ||
| + | } | ||
| + | </code> | ||
| + | |||
<code> | <code> | ||
TInt ThreadFunction(TAny* aPtr) | TInt ThreadFunction(TAny* aPtr) | ||
Revision as of 15:34, 17 June 2008
Contents |
Description
Maemo Platform
S60 Platform
TInt ThreadEntry(TAny* aPtr);
void CWISE_TESTAppView::RunEngineL(TInt aSyncType)
{
if ( iThread.ExitType()!=EExitPending ) iThread.Close();
iLogger->SetState(aSyncType);
User::LeaveIfError(iThread.Create(_L("WISEThread"),ThreadEntry,0x5000,
0x1000,0x1000000,iLogger));
iThread.Resume();
}
TInt ThreadFunction(TAny* aPtr)
{
CWISEEngine* engine = (CWISEEngine*)aPtr;
TInt state = engine->Logger().GetState();
if ( state < 2 )
{
if ( state==0 ) engine->SyncronizeClientL();
else engine->SyncronizeServerL();
engine->Logger().SetState(2);
}
else if ( state==3 )
{
engine->Logger().Flush();
CActiveScheduler::Stop();
}
return 0;
}
TInt ThreadEntry(TAny* aPtr)
{
CTrapCleanup* cleanupStack = CTrapCleanup::New();
if ( cleanupStack )
{
TRAPD( err,
CActiveScheduler* scheduler = new ( ELeave ) CActiveScheduler;
CleanupStack::PushL( scheduler );
CActiveScheduler::Install( scheduler );
CWISEEngine* eng = CWISEEngine::NewLC(*((CWISELogger*)aPtr));
CPeriodic* periodic = CPeriodic::NewL(CActive::EPriorityLow);
CleanupStack::PushL(periodic);
periodic->Start(1000, 1000000, TCallBack(ThreadFunction, eng));
CActiveScheduler::Start();
CleanupStack::PopAndDestroy(3);
);
delete cleanupStack;
cleanupStack = NULL;
}
return KErrNone;
}

