1 /*

     2 * Copyright (c) 2009 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 "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: 

    15 *

    16 */

    17 #include "c3gpmuxerwriterthreadobserver.h"

    18 

    19 _LIT(KMuxerWriterThreadPanic,"MUXER-THREAD-PANIC");

    20 

    21 C3GPMuxerWriterThreadObserver* C3GPMuxerWriterThreadObserver::NewL(C3GPMuxer* aC3GPMuxer)

    22     {

    23     C3GPMuxerWriterThreadObserver* self = new(ELeave)C3GPMuxerWriterThreadObserver(aC3GPMuxer);

    24     CleanupStack::PushL(self);

    25     self->ConstructL();

    26     CleanupStack::Pop(self);

    27     return self;

    28     }

    29 

    30 C3GPMuxerWriterThreadObserver::C3GPMuxerWriterThreadObserver(C3GPMuxer* aC3GPMuxer):

    31 CActive(EPriorityStandard)

    32     {

    33         iWriterThread = aC3GPMuxer;

    34     }

    35 

    36 void C3GPMuxerWriterThreadObserver::ConstructL()

    37     {

    38     CActiveScheduler::Add(this);

    39     }

    40 

    41 void C3GPMuxerWriterThreadObserver::IssueRequest()

    42     {

    43     __ASSERT_ALWAYS(!IsActive(), User::Panic(KMuxerWriterThreadPanic, 0));

    44     iWriterThread->iThread.Logon(iStatus);

    45     SetActive();

    46     }

    47 

    48 void C3GPMuxerWriterThreadObserver::RunL()

    49     {

    50     if(KErrDied==iStatus.Int())

    51         {  

    52             iWriterThread->HandleError(KErrDied);

    53         }

    54     }

    55 void C3GPMuxerWriterThreadObserver::DoCancel()

    56     {

    57     //Do Nothing

    58     }

    59 C3GPMuxerWriterThreadObserver::~C3GPMuxerWriterThreadObserver()

    60     {

    61     Cancel();

    62     }

    63 TInt C3GPMuxerWriterThreadObserver::RunError(TInt)

    64     {

    65        return KErrNone;

    66     }