TB10.1 Example Applications: examples/Base/IPC/condvar/condvarlocal/src/producer.cpp Source File

00001 // Copyright (c) 2008-2009 Nokia Corporation and/or its subsidiary(-ies).
-00002 // All rights reserved.
-00003 // This component and the accompanying materials are made available
-00004 // under the terms of "Eclipse Public License v1.0"
-00005 // which accompanies this distribution, and is available
-00006 // at the URL "http://www.eclipse.org/legal/epl-v10.html".
-00007 //
-00008 // Initial Contributors:
-00009 // Nokia Corporation - initial contribution.
-00010 //
-00011 // Contributors:
-00012 //
-00013 // Description:
-00014 // Contains the definition of member functions of the CProducer class.
-00015 //
-00016 
-00017 
-00018 
-00023 #include "producer.h"
-00024 
-00031 CProducer* CProducer::NewL(CConsoleBase* aConsole,CQueue* aTokens)
-00032         {
-00033         CProducer* self = new (ELeave)CProducer;
-00034         CleanupStack::PushL(self);
-00035         self->ConstructL(aConsole,aTokens);
-00036         CleanupStack::Pop(self);
-00037         return self;
-00038         }
-00039 
-00051 void CProducer::ConstructL(CConsoleBase* aConsole,CQueue* aTokens)
-00052         {
-00053         iConsole = aConsole;
-00054         iQueue = aTokens;
-00055 
-00056         // Create an object of the CPeriodic class.
-00057         iPeriodicProd = CPeriodic::NewL(CActive::EPriorityUserInput);
-00058 
-00059         // Create the producer thread.
-00060         _LIT(KProducer,"ProducerThread");
-00061         User::LeaveIfError(iProdThread.Create(KProducer,ProdThreadFunc,KDefaultStackSize,KMinHeapSize,256*KMinHeapSize,iQueue,EOwnerThread));
-00062         iProdThread.SetPriority(EPriorityMore);
-00063 
-00064         // The producer thread invokes the InsertFunction() function every two seconds.
-00065         // Associate InsertFunction() as the call back function for the iPeriodicCons object.
-00066         iPeriodicProd->Start(0,3000000,TCallBack(InsertFunction,this));
-00067         }
-00068 
-00072 CProducer::CProducer()
-00073         {
-00074         }
-00075 
-00079 void CProducer::Display()
-00080         {
-00081         RArray<TInt> array;
-00082         // Initialize the array.
-00083         // The array reflects the contents of the CQueue queue.
-00084         iQueue->GetTokens(array);
-00085         // Print the array.
-00086         iConsole->Printf(KNewLine);
-00087         _LIT(KTextQueue,"Queue Contents:\n[  ");
-00088         iConsole->Printf(KTextQueue);
-00089 
-00090         _LIT(KTextIntFormat,"%d  ");
-00091 
-00092         for(TInt ix = 0 ; ix < array.Count() ; ix++)
-00093                 {
-00094                 iConsole->Printf(KTextIntFormat,array[ix]);
-00095                 }
-00096 
-00097         _LIT(KTextQueueEnd,"]");
-00098         iConsole->Printf(KTextQueueEnd);
-00099         iConsole->Printf(KNewLine);
-00100         iConsole->Printf(KNewLine);
-00101         array.Close();
-00102         }
-00103 
-00109 TInt CProducer::ProdThreadFunc(TAny* aPtr)
-00110         {
-00111         // The while loop mechanism ensures that the thread performs the CQueue::Insert() operation each time RThread::Resume() is invoked on the thread handle.
-00112         while(true)
-00113                 {
-00114                 CQueue* ptr = (CQueue*)aPtr;
-00115                 __ASSERT_ALWAYS(ptr,User::Panic(KTxtPanic,-1));
-00116                 // Insert a token into the queue.
-00117                 ptr->Insert();
-00118                 // Suspend the thread.
-00119                 RThread().Suspend();
-00120                 }
-00121         return KErrNone;
-00122         }
-00123 
-00127 void CProducer::ResumeProd()
-00128         {
-00129         // Call the RThread::Resume() function on the producer thread.
-00130         // Control goes to the CProducer::ProdThreadFunc() function after this statement.
-00131         iProdThread.Resume();
-00132         }
-00133 
-00137 void CProducer::Produce()
-00138         {
-00139         // Call the CQueue::Insert() function.
-00140         iQueue->Insert();
-00141         }
-00142 
-00146 CProducer::~CProducer()
-00147         {
-00148         iProdThread.Kill(KErrCancel);
-00149         delete iPeriodicProd;
-00150         }
-00151 
-00152 
-00158 TInt CProducer::InsertFunction(TAny* aPtr)
-00159         {
-00160         CProducer* ptr = static_cast<CProducer*> (aPtr);
-00161         __ASSERT_ALWAYS(ptr,User::Panic(KTxtPanic,-1));
-00162         // Invoke the RThread::Resume() function on the producer thread repeatedly.
-00163         ptr->ResumeProd();
-00164         return KErrNone;
-00165         }
-